[FLINK-24424] CAST from invalid CHAR/VARCHAR/STRING to TIMESTAMP_LTZ throws NPE - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Sub-task
Status: Resolved
Priority: Major
Resolution: Duplicate
Affects Version/s: None
Fix Version/s: None
Component/s: None
Labels:
None

Description

.from(CHAR(3), "foo").resultsIn(null) throws:

/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/bin/java -ea -DforkNumber=01 -Dhadoop.version=2.4.1 -Dcheckpointing.randomization=true -Dbuffer-debloat.randomization=true -Dcheckpointing.changelog=random -Dproject.basedir=/Users/matriv/ververica/flink/flink-table/flink-table-planner -Dtest.randomization.seed -Xms256m -Xmx2048m -Dmvn.forkNumber=1 -XX:+UseG1GC -Didea.test.cyclic.buffer.size=1048576 -javaagent:/Users/matriv/Library/Application Support/JetBrains/Toolbox/apps/IDEA-C/ch-0/212.5080.55/IntelliJ IDEA CE.app/Contents/lib/idea_rt.jar=65497:/Users/matriv/Library/Application Support/JetBrains/Toolbox/apps/IDEA-C/ch-0/212.5080.55/IntelliJ IDEA CE.app/Contents/bin -Dfile.encoding=UTF-8 -classpath /Users/matriv/Library/Application Support/JetBrains/Toolbox/apps/IDEA-C/ch-0/212.5080.55/IntelliJ IDEA CE.app/Contents/lib/idea_rt.jar:/Users/matriv/Library/Application Support/JetBrains/Toolbox/apps/IDEA-C/ch-0/212.5080.55/IntelliJ IDEA CE.app/Contents/plugins/junit/lib/junit5-rt.jar:/Users/matriv/Library/Application Support/JetBrains/Toolbox/apps/IDEA-C/ch-0/212.5080.55/IntelliJ IDEA CE.app/Contents/plugins/junit/lib/junit-rt.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/charsets.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/cldrdata.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/dnsns.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/jaccess.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/localedata.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/nashorn.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/sunec.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/sunjce_provider.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/sunpkcs11.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/zipfs.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/jce.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/jfr.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/jsse.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/management-agent.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/resources.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/rt.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/lib/dt.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/lib/jconsole.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/lib/sa-jdi.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/lib/tools.jar:/Users/matriv/ververica/flink/flink-table/flink-table-planner/target/test-classes:/Users/matriv/ververica/flink/flink-table/flink-table-planner/target/classes:/Users/matriv/.m2/repository/com/google/guava/guava/29.0-jre/guava-29.0-jre.jar:/Users/matriv/.m2/repository/com/google/guava/failureaccess/1.0.1/failureaccess-1.0.1.jar:/Users/matriv/.m2/repository/com/google/guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/Users/matriv/.m2/repository/org/checkerframework/checker-qual/2.11.1/checker-qual-2.11.1.jar:/Users/matriv/.m2/repository/com/google/errorprone/error_prone_annotations/2.3.4/error_prone_annotations-2.3.4.jar:/Users/matriv/.m2/repository/com/google/j2objc/j2objc-annotations/1.3/j2objc-annotations-1.3.jar:/Users/matriv/.m2/repository/org/codehaus/janino/commons-compiler/3.0.11/commons-compiler-3.0.11.jar:/Users/matriv/.m2/repository/org/codehaus/janino/janino/3.0.11/janino-3.0.11.jar:/Users/matriv/ververica/flink/flink-table/flink-table-common/target/classes:/Users/matriv/ververica/flink/flink-core/target/classes:/Users/matriv/ververica/flink/flink-connectors/flink-connector-files/target/classes:/Users/matriv/ververica/flink/flink-connectors/flink-connector-base/target/classes:/Users/matriv/.m2/repository/org/apache/flink/flink-shaded-asm-7/7.1-14.0/flink-shaded-asm-7-7.1-14.0.jar:/Users/matriv/ververica/flink/flink-table/flink-table-api-java/target/classes:/Users/matriv/ververica/flink/flink-table/flink-table-api-scala/target/classes:/Users/matriv/.m2/repository/org/scala-lang/scala-reflect/2.11.12/scala-reflect-2.11.12.jar:/Users/matriv/.m2/repository/org/scala-lang/scala-library/2.11.12/scala-library-2.11.12.jar:/Users/matriv/.m2/repository/org/scala-lang/scala-compiler/2.11.12/scala-compiler-2.11.12.jar:/Users/matriv/.m2/repository/org/scala-lang/modules/scala-xml_2.11/1.0.5/scala-xml_2.11-1.0.5.jar:/Users/matriv/ververica/flink/flink-table/flink-table-api-java-bridge/target/classes:/Users/matriv/ververica/flink/flink-java/target/classes:/Users/matriv/ververica/flink/flink-streaming-java/target/classes:/Users/matriv/ververica/flink/flink-table/flink-table-api-scala-bridge/target/classes:/Users/matriv/ververica/flink/flink-table/flink-sql-parser/target/classes:/Users/matriv/ververica/flink/flink-annotations/target/classes:/Users/matriv/ververica/flink/flink-table/flink-sql-parser-hive/target/classes:/Users/matriv/ververica/flink/flink-table/flink-table-runtime/target/classes:/Users/matriv/ververica/flink/flink-table/flink-table-code-splitter/target/classes:/Users/matriv/.m2/repository/org/antlr/antlr4-runtime/4.7/antlr4-runtime-4.7.jar:/Users/matriv/.m2/repository/org/apache/calcite/avatica/avatica-core/1.17.0/avatica-core-1.17.0.jar:/Users/matriv/ververica/flink/flink-scala/target/classes:/Users/matriv/.m2/repository/com/twitter/chill_2.11/0.7.6/chill_2.11-0.7.6.jar:/Users/matriv/.m2/repository/com/twitter/chill-java/0.7.6/chill-java-0.7.6.jar:/Users/matriv/ververica/flink/flink-streaming-scala/target/classes:/Users/matriv/ververica/flink/flink-libraries/flink-cep/target/classes:/Users/matriv/.m2/repository/org/apache/flink/flink-shaded-guava/30.1.1-jre-14.0/flink-shaded-guava-30.1.1-jre-14.0.jar:/Users/matriv/.m2/repository/org/apache/calcite/calcite-core/1.26.0/calcite-core-1.26.0.jar:/Users/matriv/.m2/repository/org/apache/calcite/calcite-linq4j/1.26.0/calcite-linq4j-1.26.0.jar:/Users/matriv/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.12.1/jackson-annotations-2.12.1.jar:/Users/matriv/.m2/repository/org/apiguardian/apiguardian-api/1.1.0/apiguardian-api-1.1.0.jar:/Users/matriv/.m2/repository/com/esri/geometry/esri-geometry-api/2.2.0/esri-geometry-api-2.2.0.jar:/Users/matriv/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.12.1/jackson-core-2.12.1.jar:/Users/matriv/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.12.1/jackson-databind-2.12.1.jar:/Users/matriv/.m2/repository/com/jayway/jsonpath/json-path/2.4.0/json-path-2.4.0.jar:/Users/matriv/.m2/repository/net/minidev/json-smart/2.3/json-smart-2.3.jar:/Users/matriv/.m2/repository/net/minidev/accessors-smart/1.2/accessors-smart-1.2.jar:/Users/matriv/.m2/repository/org/ow2/asm/asm/5.0.4/asm-5.0.4.jar:/Users/matriv/.m2/repository/commons-codec/commons-codec/1.15/commons-codec-1.15.jar:/Users/matriv/.m2/repository/org/apache/commons/commons-lang3/3.3.2/commons-lang3-3.3.2.jar:/Users/matriv/.m2/repository/commons-io/commons-io/2.11.0/commons-io-2.11.0.jar:/Users/matriv/.m2/repository/com/ibm/icu/icu4j/67.1/icu4j-67.1.jar:/Users/matriv/.m2/repository/org/scala-lang/modules/scala-parser-combinators_2.11/1.1.1/scala-parser-combinators_2.11-1.1.1.jar:/Users/matriv/ververica/flink/flink-test-utils-parent/flink-test-utils/target/classes:/Users/matriv/ververica/flink/flink-test-utils-parent/flink-test-utils-junit/target/classes:/Users/matriv/ververica/flink/flink-runtime/target/classes:/Users/matriv/ververica/flink/flink-rpc/flink-rpc-core/target/classes:/Users/matriv/ververica/flink/flink-rpc/flink-rpc-akka-loader/target/classes:/Users/matriv/ververica/flink/flink-queryable-state/flink-queryable-state-client-java/target/classes:/Users/matriv/ververica/flink/flink-filesystems/flink-hadoop-fs/target/classes:/Users/matriv/.m2/repository/org/apache/flink/flink-shaded-netty/4.1.65.Final-14.0/flink-shaded-netty-4.1.65.Final-14.0.jar:/Users/matriv/.m2/repository/org/apache/flink/flink-shaded-jackson/2.12.4-14.0/flink-shaded-jackson-2.12.4-14.0.jar:/Users/matriv/.m2/repository/org/apache/flink/flink-shaded-zookeeper-3/3.4.14-14.0/flink-shaded-zookeeper-3-3.4.14-14.0.jar:/Users/matriv/.m2/repository/commons-cli/commons-cli/1.4/commons-cli-1.4.jar:/Users/matriv/.m2/repository/org/xerial/snappy/snappy-java/1.1.8.3/snappy-java-1.1.8.3.jar:/Users/matriv/.m2/repository/org/lz4/lz4-java/1.8.0/lz4-java-1.8.0.jar:/Users/matriv/ververica/flink/flink-runtime/target/test-classes:/Users/matriv/ververica/flink/flink-clients/target/classes:/Users/matriv/ververica/flink/flink-optimizer/target/classes:/Users/matriv/.m2/repository/io/netty/netty/3.10.6.Final/netty-3.10.6.Final.jar:/Users/matriv/.m2/repository/org/apache/curator/curator-test/2.12.0/curator-test-2.12.0.jar:/Users/matriv/.m2/repository/org/apache/zookeeper/zookeeper/3.4.14/zookeeper-3.4.14.jar:/Users/matriv/.m2/repository/com/github/spotbugs/spotbugs-annotations/3.1.9/spotbugs-annotations-3.1.9.jar:/Users/matriv/.m2/repository/org/apache/yetus/audience-annotations/0.5.0/audience-annotations-0.5.0.jar:/Users/matriv/ververica/flink/flink-state-backends/flink-statebackend-changelog/target/classes:/Users/matriv/ververica/flink/flink-core/target/test-classes:/Users/matriv/ververica/flink/flink-metrics/flink-metrics-core/target/classes:/Users/matriv/.m2/repository/com/esotericsoftware/kryo/kryo/2.24.0/kryo-2.24.0.jar:/Users/matriv/.m2/repository/com/esotericsoftware/minlog/minlog/1.2/minlog-1.2.jar:/Users/matriv/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/matriv/.m2/repository/org/apache/commons/commons-compress/1.21/commons-compress-1.21.jar:/Users/matriv/ververica/flink/flink-tests/target/test-classes:/Users/matriv/ververica/flink/flink-table/flink-table-common/target/test-classes:/Users/matriv/ververica/flink/flink-table/flink-table-api-java/target/test-classes:/Users/matriv/ververica/flink/flink-table/flink-table-runtime/target/test-classes:/Users/matriv/ververica/flink/flink-streaming-java/target/test-classes:/Users/matriv/ververica/flink/flink-connectors/flink-file-sink-common/target/classes:/Users/matriv/.m2/repository/org/apache/commons/commons-math3/3.6.1/commons-math3-3.6.1.jar:/Users/matriv/ververica/flink/flink-state-backends/flink-statebackend-rocksdb/target/classes:/Users/matriv/.m2/repository/com/ververica/frocksdbjni/6.20.3-ververica-1.0/frocksdbjni-6.20.3-ververica-1.0.jar:/Users/matriv/.m2/repository/org/reflections/reflections/0.9.10/reflections-0.9.10.jar:/Users/matriv/.m2/repository/org/javassist/javassist/3.24.0-GA/javassist-3.24.0-GA.jar:/Users/matriv/.m2/repository/org/apache/flink/flink-shaded-force-shading/14.0/flink-shaded-force-shading-14.0.jar:/Users/matriv/.m2/repository/org/slf4j/slf4j-api/1.7.15/slf4j-api-1.7.15.jar:/Users/matriv/.m2/repository/com/google/code/findbugs/jsr305/1.3.9/jsr305-1.3.9.jar:/Users/matriv/.m2/repository/org/junit/jupiter/junit-jupiter/5.7.2/junit-jupiter-5.7.2.jar:/Users/matriv/.m2/repository/org/junit/jupiter/junit-jupiter-api/5.7.2/junit-jupiter-api-5.7.2.jar:/Users/matriv/.m2/repository/org/opentest4j/opentest4j/1.2.0/opentest4j-1.2.0.jar:/Users/matriv/.m2/repository/org/junit/platform/junit-platform-commons/1.7.2/junit-platform-commons-1.7.2.jar:/Users/matriv/.m2/repository/org/junit/jupiter/junit-jupiter-params/5.7.2/junit-jupiter-params-5.7.2.jar:/Users/matriv/.m2/repository/org/junit/jupiter/junit-jupiter-engine/5.7.2/junit-jupiter-engine-5.7.2.jar:/Users/matriv/.m2/repository/org/junit/vintage/junit-vintage-engine/5.7.2/junit-vintage-engine-5.7.2.jar:/Users/matriv/.m2/repository/org/junit/platform/junit-platform-engine/1.7.2/junit-platform-engine-1.7.2.jar:/Users/matriv/.m2/repository/junit/junit/4.13.2/junit-4.13.2.jar:/Users/matriv/.m2/repository/org/mockito/mockito-core/2.21.0/mockito-core-2.21.0.jar:/Users/matriv/.m2/repository/net/bytebuddy/byte-buddy/1.8.15/byte-buddy-1.8.15.jar:/Users/matriv/.m2/repository/net/bytebuddy/byte-buddy-agent/1.8.15/byte-buddy-agent-1.8.15.jar:/Users/matriv/.m2/repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar:/Users/matriv/.m2/repository/org/powermock/powermock-module-junit4/2.0.4/powermock-module-junit4-2.0.4.jar:/Users/matriv/.m2/repository/org/powermock/powermock-module-junit4-common/2.0.4/powermock-module-junit4-common-2.0.4.jar:/Users/matriv/.m2/repository/org/powermock/powermock-reflect/2.0.4/powermock-reflect-2.0.4.jar:/Users/matriv/.m2/repository/org/powermock/powermock-core/2.0.4/powermock-core-2.0.4.jar:/Users/matriv/.m2/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar:/Users/matriv/.m2/repository/org/powermock/powermock-api-mockito2/2.0.4/powermock-api-mockito2-2.0.4.jar:/Users/matriv/.m2/repository/org/powermock/powermock-api-support/2.0.4/powermock-api-support-2.0.4.jar:/Users/matriv/.m2/repository/org/hamcrest/hamcrest-all/1.3/hamcrest-all-1.3.jar:/Users/matriv/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.14.1/log4j-slf4j-impl-2.14.1.jar:/Users/matriv/.m2/repository/org/apache/logging/log4j/log4j-api/2.14.1/log4j-api-2.14.1.jar:/Users/matriv/.m2/repository/org/apache/logging/log4j/log4j-core/2.14.1/log4j-core-2.14.1.jar:/Users/matriv/.m2/repository/org/apache/logging/log4j/log4j-1.2-api/2.14.1/log4j-1.2-api-2.14.1.jar com.intellij.rt.junit.JUnitStarter -ideVersion5 -junit4 org.apache.flink.table.planner.functions.CastFunctionsITCase/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/bin/java -ea -DforkNumber=01 -Dhadoop.version=2.4.1 -Dcheckpointing.randomization=true -Dbuffer-debloat.randomization=true -Dcheckpointing.changelog=random -Dproject.basedir=/Users/matriv/ververica/flink/flink-table/flink-table-planner -Dtest.randomization.seed -Xms256m -Xmx2048m -Dmvn.forkNumber=1 -XX:+UseG1GC -Didea.test.cyclic.buffer.size=1048576 -javaagent:/Users/matriv/Library/Application Support/JetBrains/Toolbox/apps/IDEA-C/ch-0/212.5080.55/IntelliJ IDEA CE.app/Contents/lib/idea_rt.jar=65497:/Users/matriv/Library/Application Support/JetBrains/Toolbox/apps/IDEA-C/ch-0/212.5080.55/IntelliJ IDEA CE.app/Contents/bin -Dfile.encoding=UTF-8 -classpath /Users/matriv/Library/Application Support/JetBrains/Toolbox/apps/IDEA-C/ch-0/212.5080.55/IntelliJ IDEA CE.app/Contents/lib/idea_rt.jar:/Users/matriv/Library/Application Support/JetBrains/Toolbox/apps/IDEA-C/ch-0/212.5080.55/IntelliJ IDEA CE.app/Contents/plugins/junit/lib/junit5-rt.jar:/Users/matriv/Library/Application Support/JetBrains/Toolbox/apps/IDEA-C/ch-0/212.5080.55/IntelliJ IDEA CE.app/Contents/plugins/junit/lib/junit-rt.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/charsets.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/cldrdata.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/dnsns.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/jaccess.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/localedata.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/nashorn.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/sunec.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/sunjce_provider.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/sunpkcs11.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/ext/zipfs.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/jce.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/jfr.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/jsse.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/management-agent.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/resources.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/jre/lib/rt.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/lib/dt.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/lib/jconsole.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/lib/sa-jdi.jar:/Users/matriv/.sdkman/candidates/java/8.0.292.hs-adpt/lib/tools.jar:/Users/matriv/ververica/flink/flink-table/flink-table-planner/target/test-classes:/Users/matriv/ververica/flink/flink-table/flink-table-planner/target/classes:/Users/matriv/.m2/repository/com/google/guava/guava/29.0-jre/guava-29.0-jre.jar:/Users/matriv/.m2/repository/com/google/guava/failureaccess/1.0.1/failureaccess-1.0.1.jar:/Users/matriv/.m2/repository/com/google/guava/listenablefuture/9999.0-empty-to-avoid-conflict-with-guava/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/Users/matriv/.m2/repository/org/checkerframework/checker-qual/2.11.1/checker-qual-2.11.1.jar:/Users/matriv/.m2/repository/com/google/errorprone/error_prone_annotations/2.3.4/error_prone_annotations-2.3.4.jar:/Users/matriv/.m2/repository/com/google/j2objc/j2objc-annotations/1.3/j2objc-annotations-1.3.jar:/Users/matriv/.m2/repository/org/codehaus/janino/commons-compiler/3.0.11/commons-compiler-3.0.11.jar:/Users/matriv/.m2/repository/org/codehaus/janino/janino/3.0.11/janino-3.0.11.jar:/Users/matriv/ververica/flink/flink-table/flink-table-common/target/classes:/Users/matriv/ververica/flink/flink-core/target/classes:/Users/matriv/ververica/flink/flink-connectors/flink-connector-files/target/classes:/Users/matriv/ververica/flink/flink-connectors/flink-connector-base/target/classes:/Users/matriv/.m2/repository/org/apache/flink/flink-shaded-asm-7/7.1-14.0/flink-shaded-asm-7-7.1-14.0.jar:/Users/matriv/ververica/flink/flink-table/flink-table-api-java/target/classes:/Users/matriv/ververica/flink/flink-table/flink-table-api-scala/target/classes:/Users/matriv/.m2/repository/org/scala-lang/scala-reflect/2.11.12/scala-reflect-2.11.12.jar:/Users/matriv/.m2/repository/org/scala-lang/scala-library/2.11.12/scala-library-2.11.12.jar:/Users/matriv/.m2/repository/org/scala-lang/scala-compiler/2.11.12/scala-compiler-2.11.12.jar:/Users/matriv/.m2/repository/org/scala-lang/modules/scala-xml_2.11/1.0.5/scala-xml_2.11-1.0.5.jar:/Users/matriv/ververica/flink/flink-table/flink-table-api-java-bridge/target/classes:/Users/matriv/ververica/flink/flink-java/target/classes:/Users/matriv/ververica/flink/flink-streaming-java/target/classes:/Users/matriv/ververica/flink/flink-table/flink-table-api-scala-bridge/target/classes:/Users/matriv/ververica/flink/flink-table/flink-sql-parser/target/classes:/Users/matriv/ververica/flink/flink-annotations/target/classes:/Users/matriv/ververica/flink/flink-table/flink-sql-parser-hive/target/classes:/Users/matriv/ververica/flink/flink-table/flink-table-runtime/target/classes:/Users/matriv/ververica/flink/flink-table/flink-table-code-splitter/target/classes:/Users/matriv/.m2/repository/org/antlr/antlr4-runtime/4.7/antlr4-runtime-4.7.jar:/Users/matriv/.m2/repository/org/apache/calcite/avatica/avatica-core/1.17.0/avatica-core-1.17.0.jar:/Users/matriv/ververica/flink/flink-scala/target/classes:/Users/matriv/.m2/repository/com/twitter/chill_2.11/0.7.6/chill_2.11-0.7.6.jar:/Users/matriv/.m2/repository/com/twitter/chill-java/0.7.6/chill-java-0.7.6.jar:/Users/matriv/ververica/flink/flink-streaming-scala/target/classes:/Users/matriv/ververica/flink/flink-libraries/flink-cep/target/classes:/Users/matriv/.m2/repository/org/apache/flink/flink-shaded-guava/30.1.1-jre-14.0/flink-shaded-guava-30.1.1-jre-14.0.jar:/Users/matriv/.m2/repository/org/apache/calcite/calcite-core/1.26.0/calcite-core-1.26.0.jar:/Users/matriv/.m2/repository/org/apache/calcite/calcite-linq4j/1.26.0/calcite-linq4j-1.26.0.jar:/Users/matriv/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.12.1/jackson-annotations-2.12.1.jar:/Users/matriv/.m2/repository/org/apiguardian/apiguardian-api/1.1.0/apiguardian-api-1.1.0.jar:/Users/matriv/.m2/repository/com/esri/geometry/esri-geometry-api/2.2.0/esri-geometry-api-2.2.0.jar:/Users/matriv/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.12.1/jackson-core-2.12.1.jar:/Users/matriv/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.12.1/jackson-databind-2.12.1.jar:/Users/matriv/.m2/repository/com/jayway/jsonpath/json-path/2.4.0/json-path-2.4.0.jar:/Users/matriv/.m2/repository/net/minidev/json-smart/2.3/json-smart-2.3.jar:/Users/matriv/.m2/repository/net/minidev/accessors-smart/1.2/accessors-smart-1.2.jar:/Users/matriv/.m2/repository/org/ow2/asm/asm/5.0.4/asm-5.0.4.jar:/Users/matriv/.m2/repository/commons-codec/commons-codec/1.15/commons-codec-1.15.jar:/Users/matriv/.m2/repository/org/apache/commons/commons-lang3/3.3.2/commons-lang3-3.3.2.jar:/Users/matriv/.m2/repository/commons-io/commons-io/2.11.0/commons-io-2.11.0.jar:/Users/matriv/.m2/repository/com/ibm/icu/icu4j/67.1/icu4j-67.1.jar:/Users/matriv/.m2/repository/org/scala-lang/modules/scala-parser-combinators_2.11/1.1.1/scala-parser-combinators_2.11-1.1.1.jar:/Users/matriv/ververica/flink/flink-test-utils-parent/flink-test-utils/target/classes:/Users/matriv/ververica/flink/flink-test-utils-parent/flink-test-utils-junit/target/classes:/Users/matriv/ververica/flink/flink-runtime/target/classes:/Users/matriv/ververica/flink/flink-rpc/flink-rpc-core/target/classes:/Users/matriv/ververica/flink/flink-rpc/flink-rpc-akka-loader/target/classes:/Users/matriv/ververica/flink/flink-queryable-state/flink-queryable-state-client-java/target/classes:/Users/matriv/ververica/flink/flink-filesystems/flink-hadoop-fs/target/classes:/Users/matriv/.m2/repository/org/apache/flink/flink-shaded-netty/4.1.65.Final-14.0/flink-shaded-netty-4.1.65.Final-14.0.jar:/Users/matriv/.m2/repository/org/apache/flink/flink-shaded-jackson/2.12.4-14.0/flink-shaded-jackson-2.12.4-14.0.jar:/Users/matriv/.m2/repository/org/apache/flink/flink-shaded-zookeeper-3/3.4.14-14.0/flink-shaded-zookeeper-3-3.4.14-14.0.jar:/Users/matriv/.m2/repository/commons-cli/commons-cli/1.4/commons-cli-1.4.jar:/Users/matriv/.m2/repository/org/xerial/snappy/snappy-java/1.1.8.3/snappy-java-1.1.8.3.jar:/Users/matriv/.m2/repository/org/lz4/lz4-java/1.8.0/lz4-java-1.8.0.jar:/Users/matriv/ververica/flink/flink-runtime/target/test-classes:/Users/matriv/ververica/flink/flink-clients/target/classes:/Users/matriv/ververica/flink/flink-optimizer/target/classes:/Users/matriv/.m2/repository/io/netty/netty/3.10.6.Final/netty-3.10.6.Final.jar:/Users/matriv/.m2/repository/org/apache/curator/curator-test/2.12.0/curator-test-2.12.0.jar:/Users/matriv/.m2/repository/org/apache/zookeeper/zookeeper/3.4.14/zookeeper-3.4.14.jar:/Users/matriv/.m2/repository/com/github/spotbugs/spotbugs-annotations/3.1.9/spotbugs-annotations-3.1.9.jar:/Users/matriv/.m2/repository/org/apache/yetus/audience-annotations/0.5.0/audience-annotations-0.5.0.jar:/Users/matriv/ververica/flink/flink-state-backends/flink-statebackend-changelog/target/classes:/Users/matriv/ververica/flink/flink-core/target/test-classes:/Users/matriv/ververica/flink/flink-metrics/flink-metrics-core/target/classes:/Users/matriv/.m2/repository/com/esotericsoftware/kryo/kryo/2.24.0/kryo-2.24.0.jar:/Users/matriv/.m2/repository/com/esotericsoftware/minlog/minlog/1.2/minlog-1.2.jar:/Users/matriv/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/matriv/.m2/repository/org/apache/commons/commons-compress/1.21/commons-compress-1.21.jar:/Users/matriv/ververica/flink/flink-tests/target/test-classes:/Users/matriv/ververica/flink/flink-table/flink-table-common/target/test-classes:/Users/matriv/ververica/flink/flink-table/flink-table-api-java/target/test-classes:/Users/matriv/ververica/flink/flink-table/flink-table-runtime/target/test-classes:/Users/matriv/ververica/flink/flink-streaming-java/target/test-classes:/Users/matriv/ververica/flink/flink-connectors/flink-file-sink-common/target/classes:/Users/matriv/.m2/repository/org/apache/commons/commons-math3/3.6.1/commons-math3-3.6.1.jar:/Users/matriv/ververica/flink/flink-state-backends/flink-statebackend-rocksdb/target/classes:/Users/matriv/.m2/repository/com/ververica/frocksdbjni/6.20.3-ververica-1.0/frocksdbjni-6.20.3-ververica-1.0.jar:/Users/matriv/.m2/repository/org/reflections/reflections/0.9.10/reflections-0.9.10.jar:/Users/matriv/.m2/repository/org/javassist/javassist/3.24.0-GA/javassist-3.24.0-GA.jar:/Users/matriv/.m2/repository/org/apache/flink/flink-shaded-force-shading/14.0/flink-shaded-force-shading-14.0.jar:/Users/matriv/.m2/repository/org/slf4j/slf4j-api/1.7.15/slf4j-api-1.7.15.jar:/Users/matriv/.m2/repository/com/google/code/findbugs/jsr305/1.3.9/jsr305-1.3.9.jar:/Users/matriv/.m2/repository/org/junit/jupiter/junit-jupiter/5.7.2/junit-jupiter-5.7.2.jar:/Users/matriv/.m2/repository/org/junit/jupiter/junit-jupiter-api/5.7.2/junit-jupiter-api-5.7.2.jar:/Users/matriv/.m2/repository/org/opentest4j/opentest4j/1.2.0/opentest4j-1.2.0.jar:/Users/matriv/.m2/repository/org/junit/platform/junit-platform-commons/1.7.2/junit-platform-commons-1.7.2.jar:/Users/matriv/.m2/repository/org/junit/jupiter/junit-jupiter-params/5.7.2/junit-jupiter-params-5.7.2.jar:/Users/matriv/.m2/repository/org/junit/jupiter/junit-jupiter-engine/5.7.2/junit-jupiter-engine-5.7.2.jar:/Users/matriv/.m2/repository/org/junit/vintage/junit-vintage-engine/5.7.2/junit-vintage-engine-5.7.2.jar:/Users/matriv/.m2/repository/org/junit/platform/junit-platform-engine/1.7.2/junit-platform-engine-1.7.2.jar:/Users/matriv/.m2/repository/junit/junit/4.13.2/junit-4.13.2.jar:/Users/matriv/.m2/repository/org/mockito/mockito-core/2.21.0/mockito-core-2.21.0.jar:/Users/matriv/.m2/repository/net/bytebuddy/byte-buddy/1.8.15/byte-buddy-1.8.15.jar:/Users/matriv/.m2/repository/net/bytebuddy/byte-buddy-agent/1.8.15/byte-buddy-agent-1.8.15.jar:/Users/matriv/.m2/repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar:/Users/matriv/.m2/repository/org/powermock/powermock-module-junit4/2.0.4/powermock-module-junit4-2.0.4.jar:/Users/matriv/.m2/repository/org/powermock/powermock-module-junit4-common/2.0.4/powermock-module-junit4-common-2.0.4.jar:/Users/matriv/.m2/repository/org/powermock/powermock-reflect/2.0.4/powermock-reflect-2.0.4.jar:/Users/matriv/.m2/repository/org/powermock/powermock-core/2.0.4/powermock-core-2.0.4.jar:/Users/matriv/.m2/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar:/Users/matriv/.m2/repository/org/powermock/powermock-api-mockito2/2.0.4/powermock-api-mockito2-2.0.4.jar:/Users/matriv/.m2/repository/org/powermock/powermock-api-support/2.0.4/powermock-api-support-2.0.4.jar:/Users/matriv/.m2/repository/org/hamcrest/hamcrest-all/1.3/hamcrest-all-1.3.jar:/Users/matriv/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.14.1/log4j-slf4j-impl-2.14.1.jar:/Users/matriv/.m2/repository/org/apache/logging/log4j/log4j-api/2.14.1/log4j-api-2.14.1.jar:/Users/matriv/.m2/repository/org/apache/logging/log4j/log4j-core/2.14.1/log4j-core-2.14.1.jar:/Users/matriv/.m2/repository/org/apache/logging/log4j/log4j-1.2-api/2.14.1/log4j-1.2-api-2.14.1.jar com.intellij.rt.junit.JUnitStarter -ideVersion5 -junit4 org.apache.flink.table.planner.functions.CastFunctionsITCase
java.lang.AssertionError: Failing test item: [API] cast(f0, TIMESTAMP_LTZ(9))cast(f1, TIMESTAMP_LTZ(9))cast(f2, TIMESTAMP_LTZ(9))cast(f3, TIMESTAMP_LTZ(9))cast(f4, TIMESTAMP_LTZ(9))cast(f5, TIMESTAMP_LTZ(9))cast(f6, TIMESTAMP_LTZ(9))cast(f7, TIMESTAMP_LTZ(9))
{{ at org.apache.flink.table.planner.functions.BuiltInFunctionTestBase.testFunction(BuiltInFunctionTestBase.java:115) at sun.reflect.GeneratedMethodAccessor56.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59) at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12) at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56) at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17) at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100) at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366) at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103) at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63) at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) at org.junit.runners.ParentRunner.run(ParentRunner.java:413) at org.junit.runners.Suite.runChild(Suite.java:128) at org.junit.runners.Suite.runChild(Suite.java:27) at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331) at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79) at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329) at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66) at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293) at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54) at org.junit.rules.RunRules.evaluate(RunRules.java:20) at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306) at org.junit.runners.ParentRunner.run(ParentRunner.java:413) at org.junit.runner.JUnitCore.run(JUnitCore.java:137) at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:69) at com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:33) at com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:235) at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:54)Caused by: java.lang.RuntimeException: Failed to fetch next result at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109) at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) at org.apache.flink.table.api.internal.TableResultImpl$CloseableRowIteratorWrapper.hasNext(TableResultImpl.java:370) at org.apache.flink.table.planner.functions.BuiltInFunctionTestBase.testResult(BuiltInFunctionTestBase.java:145) at org.apache.flink.table.planner.functions.BuiltInFunctionTestBase.testFunction(BuiltInFunctionTestBase.java:110) ... 34 moreCaused by: java.io.IOException: Failed to fetch job execution result at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184) at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121) at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106) ... 38 moreCaused by: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928) at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182) ... 40 moreCaused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616) at java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:628) at java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:1996) at org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobExecutionResult(MiniClusterJobClient.java:134) at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:181) ... 40 moreCaused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:228) at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:218) at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:209) at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:678) at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444) at sun.reflect.GeneratedMethodAccessor24.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316) at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at akka.actor.Actor.aroundReceive(Actor.scala:537) at akka.actor.Actor.aroundReceive$(Actor.scala:535) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580) at akka.actor.ActorCell.invoke(ActorCell.scala:548) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270) at akka.dispatch.Mailbox.run(Mailbox.scala:231) at akka.dispatch.Mailbox.exec(Mailbox.scala:243) at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)Caused by: java.lang.NullPointerException at StreamExecCalc$1797.processElement(Unknown Source) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:82) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:57) at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29) at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56) at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29) at org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:418) at org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:513) at org.apache.flink.streaming.api.operators.StreamSourceContexts$SwitchingOnClose.collect(StreamSourceContexts.java:103) at org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction.run(InputFormatSourceFunction.java:92) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:116) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:73) at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323)}}

Attachments

Issue Links

is duplicated by

FLINK-24563 Comparing timstamp_ltz with random string throws NullPointerException

Closed

Activity

People

Assignee:: Marios Trivyzas

Reporter:: Marios Trivyzas

Votes:: 0 Vote for this issue

Watchers:: 2 Start watching this issue

Dates

Created:: 30/Sep/21 10:20

Updated:: 18/Oct/21 14:59

Resolved:: 18/Oct/21 14:59