[
https://issues.apache.org/jira/browse/BEAM-9518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Pilloud updated BEAM-9518:
---------------------------------
Description:
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
{code}
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)
{code}
{code}
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"];
{code}
was:
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
{code}
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)
{code}
{code}
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
{code}
> BeamZetaSqlCalcRel$CalcFn.processElement Unsupported Beam fieldType:
> LOGICAL_TYPE
> ---------------------------------------------------------------------------------
>
> Key: BEAM-9518
> URL: https://issues.apache.org/jira/browse/BEAM-9518
> Project: Beam
> Issue Type: Bug
> Components: dsl-sql-zetasql
> Reporter: Andrew Pilloud
> Priority: Minor
> Labels: zetasql-compliance
>
> 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
> {code}
> 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)
> {code}
> {code}
> 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"];
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
