BeamZetaSqlCalcRel$CalcFn.processElement Unsupported Beam fieldType: LOGICAL_TYPE

[damccorm]

eight failures in shard 6, eight failures in shard 7, eight failures in shard 8, ten failures in shard 9, five failures in shard 10, four failures in shard 11, six failures in shard 12, two failures in shard 16, six failures in shard 31, three failures in shard 42, two failures in shard 43, eight failures in shard 44, two failures in shard 50

org.apache.beam.sdk.Pipeline$PipelineExecutionException: java.lang.UnsupportedOperationException: Unsupported
Beam fieldType: LOGICAL_TYPE
	at org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:348)
	at
org.apache.beam.runners.direct.DirectRunner$DirectPipelineResult.waitUntilFinish(DirectRunner.java:318)
	at
org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:213)
	at org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:67)
	at
org.apache.beam.sdk.Pipeline.run(Pipeline.java:317)
	at org.apache.beam.sdk.Pipeline.run(Pipeline.java:303)
	at
org.apache.beam.sdk.extensions.sql.impl.rel.BeamEnumerableConverter.runCollector(BeamEnumerableConverter.java:201)
	at
org.apache.beam.sdk.extensions.sql.impl.rel.BeamEnumerableConverter.collectRows(BeamEnumerableConverter.java:218)
	at
org.apache.beam.sdk.extensions.sql.impl.rel.BeamEnumerableConverter.toRowList(BeamEnumerableConverter.java:150)
	at
org.apache.beam.sdk.extensions.sql.impl.rel.BeamEnumerableConverter.toRowList(BeamEnumerableConverter.java:127)
	at
cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl.executeQuery(ExecuteQueryServiceServer.java:329)
	at
com.google.zetasql.testing.SqlComplianceServiceGrpc$MethodHandlers.invoke(SqlComplianceServiceGrpc.java:423)
	at
com.google.zetasql.io.grpc.stub.ServerCalls$UnaryServerCallHandler$UnaryServerCallListener.onHalfClose(ServerCalls.java:171)
	at
com.google.zetasql.io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.halfClosed(ServerCallImpl.java:283)
	at
com.google.zetasql.io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1HalfClosed.runInContext(ServerImpl.java:711)
	at
com.google.zetasql.io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
	at com.google.zetasql.io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123)
	at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at
java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.UnsupportedOperationException: Unsupported
Beam fieldType: LOGICAL_TYPE
	at org.apache.beam.sdk.extensions.sql.zetasql.ZetaSqlUtils.zetaSqlValueToJavaObject(ZetaSqlUtils.java:221)
	at
org.apache.beam.sdk.extensions.sql.zetasql.BeamZetaSqlCalcRel$CalcFn.processElement(BeamZetaSqlCalcRel.java:193)

Apr 01, 2020 6:00:21 PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl executeQuery
INFO:
Processing Sql statement: SELECT CAST(@p0 AS DATE) AS ColA
Apr 01, 2020 6:03:59 PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl
executeQuery
INFO: Processing Sql statement: SELECT DISTINCT val.DATE
from (select DATE"2014-01-01"
DATE union all
      select cast(NULL as date) union all
      select DATE"2014-01-02" union all

     select DATE"2014-01-01" union all
      select cast(NULL as date)) val
Apr 01, 2020 6:10:09 PM
cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl executeQuery
INFO: Processing
Sql statement: SELECT COALESCE(NULL, DATE '2014-12-18')
Apr 01, 2020 6:03:26 PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl
executeQuery
INFO: Processing Sql statement: SELECT CAST(null AS TIME),
       CAST('12:34:56.123456'
AS TIME),
       CAST(CAST(null AS TIME) AS STRING),
       CAST(CAST('12:34:56.123456' AS TIME) AS
STRING),
       CAST(TIME '12:34:56.123456' AS STRING),
       CAST(CAST(TIME '12:34:56.123456' AS
STRING) AS TIME)
Apr 01, 2020 5:59:59 PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl
executeQuery
INFO: Processing Sql statement: SELECT SAFE_CAST(@p0 AS DATE) AS ColA
Apr 01, 2020 6:07:07
PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl executeQuery
INFO: Processing
Sql statement: SELECT
    CAST(CAST(TIME "00:00:00" as STRING) as TIME),
    CAST(CAST(TIME "23:59:59.999999"
as STRING) as TIME),
    CAST(CAST(TIME "01:02:03.123456" as STRING) as TIME),
    CAST(CAST(TIME
"01:02:03.12345" as STRING) as TIME),
    CAST(CAST(TIME "01:02:03.120000" as STRING) as TIME),
 
  CAST(CAST(TIME "01:02:3" as STRING) as TIME),
    CAST(CAST(TIME "01:2:03" as STRING) as TIME),

   CAST(CAST(TIME "1:02:03" as STRING) as TIME),
    #Leap second cases
    CAST(CAST(TIME "23:59:60"
as STRING) as TIME),
    CAST(CAST(TIME "12:59:60" as STRING) as TIME),
    CAST(CAST(TIME "12:59:60.123456"
as STRING) as TIME),

    CAST(CAST("00:00:00" as TIME) as STRING),
    CAST(CAST("23:59:59.999999"
as TIME) as STRING),
    CAST(CAST("01:02:03.123456" as TIME) as STRING),
    CAST(CAST("01:02:03.12345"
as TIME) as STRING),
    CAST(CAST("01:02:03.120000" as TIME) as STRING),
    CAST(CAST("01:02:3"
as TIME) as STRING),
    CAST(CAST("01:2:03" as TIME) as STRING),
    CAST(CAST("1:02:03" as TIME)
as STRING),
    #Leap second cases
    CAST(CAST("23:59:60" as TIME) as STRING),
    CAST(CAST("12:59:60"
as TIME) as STRING),
    CAST(CAST("12:59:60.123456" as TIME) as STRING)
Apr 01, 2020 6:07:11 PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl
executeQuery
INFO: Processing Sql statement: SELECT
    CAST(TIMESTAMP "0001-01-01 00:00:00" as TIME),

   CAST(TIMESTAMP "9999-12-31 15:59:59.999999" as TIME),
    CAST(TIMESTAMP "2006-01-02" as TIME),

   # Leap second cases
    CAST(TIMESTAMP "2015-11-06 23:59:60" as TIME),
    CAST(TIMESTAMP "2015-11-06
12:59:60" as TIME),
    CAST(TIMESTAMP "2015-11-06 12:59:60.123456" as TIME)
Apr 01, 2020 6:07:12
PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl executeQuery
INFO: Processing
Sql statement: SELECT
    CAST(str_time_col_2 as TIME) as time_col_3,
    CAST(time_col_2 as STRING)
as str_time_col_3
FROM (
SELECT
    CAST(str_time_col as TIME) as time_col_2,
    CAST(time_col
as STRING) as str_time_col_2
FROM (
SELECT
    "12:34:56.123456" as str_time_col,
    TIME "12:34:56.123456"
as time_col
))
Apr 01, 2020 6:07:14 PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl
executeQuery
INFO: Processing Sql statement: SELECT
    CAST(DATETIME "0001-01-01 08:00:00" as TIME),

   CAST(DATETIME "0001-01-01 11:22:33.123456" as TIME),
    CAST(DATETIME "9999-12-31 13:59:59.999999"
as TIME),
    CAST(DATETIME "2006-01-02" as TIME),
    # Leap second cases
    CAST(DATETIME "2015-11-06
23:59:60" as TIME),
    CAST(DATETIME "2015-11-06 12:59:60" as TIME),
    CAST(DATETIME "2015-11-06
12:59:60.123456" as TIME)
Apr 01, 2020 6:05:02 PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl
executeQuery
INFO: Processing Sql statement: SELECT DATE "2014-07-18" date_val
Apr 01, 2020 6:05:10
PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl executeQuery
INFO: Processing
Sql statement: SELECT [DATE "2014-07-23", NULL, DATE "2014-07-18", NULL] date_val
Apr 01, 2020 6:00:02
PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl executeQuery
INFO: Processing
Sql statement: SELECT If(@p0, @p1, @p2) AS ColA
Apr 01, 2020 6:00:17 PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl
executeQuery
INFO: Processing Sql statement: SELECT IfNull(@p0, @p1) AS ColA
Apr 01, 2020 6:00:49
PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl executeQuery
INFO: Processing
Sql statement: SELECT Coalesce(@p0, @p1) AS ColA
Apr 01, 2020 6:01:27 PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl
executeQuery
INFO: Processing Sql statement: SELECT ARRAY<DATE>["1984-08-02", "2000-01-01", "2014-09-11"];
Apr
01, 2020 6:01:35 PM cloud.dataflow.sql.ExecuteQueryServiceServer$SqlComplianceServiceImpl executeQuery
INFO:
Processing Sql statement: SELECT ARRAY<DATE>["1984-08-02", NULL, "2014-09-11"];

Imported from Jira BEAM-9518. Original Jira may contain additional context.
Reported by: apilloud.