Marios Trivyzas created FLINK-24424:
---------------------------------------
Summary: CAST from invalid CHAR/VARCHAR/STRING to TIMESTAMP_LTZ
throws NPE
Key: FLINK-24424
URL: https://issues.apache.org/jira/browse/FLINK-24424
Project: Flink
Issue Type: Sub-task
Reporter: Marios Trivyzas
*.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)}}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
