[jira] [Created] (FLINK-22968) String type cannot be used when creating Flink SQL

[Shang Yuanchun (Jira)]

DaChun created FLINK-22968:
------------------------------

             Summary:  String type cannot be used when creating Flink SQL
                 Key: FLINK-22968
                 URL: https://issues.apache.org/jira/browse/FLINK-22968
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / API
    Affects Versions: 1.13.1, 1.12.3
         Environment: D:\anzhuang\jdk_1.8_181\bin\java.exe "-javaagent:D:\anzhuang\idea_web\IntelliJ IDEA 2019.3.1\lib\idea_rt.jar=51865:D:\anzhuang\idea_web\IntelliJ IDEA 2019.3.1\bin" -Dfile.encoding=UTF-8 -classpath D:\anzhuang\jdk_1.8_181\jre\lib\charsets.jar;D:\anzhuang\jdk_1.8_181\jre\lib\deploy.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\access-bridge-64.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\cldrdata.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\dnsns.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\jaccess.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\jfxrt.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\localedata.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\nashorn.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\sunec.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\sunjce_provider.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\sunmscapi.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\sunpkcs11.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\zipfs.jar;D:\anzhuang\jdk_1.8_181\jre\lib\javaws.jar;D:\anzhuang\jdk_1.8_181\jre\lib\jce.jar;D:\anzhuang\jdk_1.8_181\jre\lib\jfr.jar;D:\anzhuang\jdk_1.8_181\jre\lib\jfxswt.jar;D:\anzhuang\jdk_1.8_181\jre\lib\jsse.jar;D:\anzhuang\jdk_1.8_181\jre\lib\management-agent.jar;D:\anzhuang\jdk_1.8_181\jre\lib\plugin.jar;D:\anzhuang\jdk_1.8_181\jre\lib\resources.jar;D:\anzhuang\jdk_1.8_181\jre\lib\rt.jar;D:\A_idea_project\flink-project\flink-sql\target\classes;D:\anzhuang\scala_2.12.10\lib\scala-library.jar;D:\anzhuang\scala_2.12.10\lib\scala-reflect.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-streaming-scala_2.12\1.13.1\flink-streaming-scala_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-streaming-java_2.12\1.13.1\flink-streaming-java_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-file-sink-common\1.13.1\flink-file-sink-common-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\commons\commons-math3\3.5\commons-math3-3.5.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-scala_2.12\1.13.1\flink-scala_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-shaded-asm-7\7.1-13.0\flink-shaded-asm-7-7.1-13.0.jar;D:\apache-maven-3.6.3\repository\org\slf4j\slf4j-api\1.7.15\slf4j-api-1.7.15.jar;D:\apache-maven-3.6.3\repository\com\google\code\findbugs\jsr305\1.3.9\jsr305-1.3.9.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\force-shading\1.13.1\force-shading-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-clients_2.12\1.13.1\flink-clients_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-core\1.13.1\flink-core-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-annotations\1.13.1\flink-annotations-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-metrics-core\1.13.1\flink-metrics-core-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\commons\commons-lang3\3.3.2\commons-lang3-3.3.2.jar;D:\apache-maven-3.6.3\repository\com\esotericsoftware\kryo\kryo\2.24.0\kryo-2.24.0.jar;D:\apache-maven-3.6.3\repository\com\esotericsoftware\minlog\minlog\1.2\minlog-1.2.jar;D:\apache-maven-3.6.3\repository\org\objenesis\objenesis\2.1\objenesis-2.1.jar;D:\apache-maven-3.6.3\repository\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;D:\apache-maven-3.6.3\repository\org\apache\commons\commons-compress\1.20\commons-compress-1.20.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-runtime_2.12\1.13.1\flink-runtime_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-queryable-state-client-java\1.13.1\flink-queryable-state-client-java-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-hadoop-fs\1.13.1\flink-hadoop-fs-1.13.1.jar;D:\apache-maven-3.6.3\repository\commons-io\commons-io\2.7\commons-io-2.7.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-shaded-zookeeper-3\3.4.14-13.0\flink-shaded-zookeeper-3-3.4.14-13.0.jar;D:\apache-maven-3.6.3\repository\org\javassist\javassist\3.24.0-GA\javassist-3.24.0-GA.jar;D:\apache-maven-3.6.3\repository\com\typesafe\akka\akka-actor_2.12\2.5.21\akka-actor_2.12-2.5.21.jar;D:\apache-maven-3.6.3\repository\com\typesafe\config\1.3.3\config-1.3.3.jar;D:\apache-maven-3.6.3\repository\org\scala-lang\modules\scala-java8-compat_2.12\0.8.0\scala-java8-compat_2.12-0.8.0.jar;D:\apache-maven-3.6.3\repository\com\typesafe\akka\akka-stream_2.12\2.5.21\akka-stream_2.12-2.5.21.jar;D:\apache-maven-3.6.3\repository\org\reactivestreams\reactive-streams\1.0.2\reactive-streams-1.0.2.jar;D:\apache-maven-3.6.3\repository\com\typesafe\ssl-config-core_2.12\0.3.7\ssl-config-core_2.12-0.3.7.jar;D:\apache-maven-3.6.3\repository\org\scala-lang\modules\scala-parser-combinators_2.12\1.1.1\scala-parser-combinators_2.12-1.1.1.jar;D:\apache-maven-3.6.3\repository\com\typesafe\akka\akka-protobuf_2.12\2.5.21\akka-protobuf_2.12-2.5.21.jar;D:\apache-maven-3.6.3\repository\com\typesafe\akka\akka-slf4j_2.12\2.5.21\akka-slf4j_2.12-2.5.21.jar;D:\apache-maven-3.6.3\repository\org\clapper\grizzled-slf4j_2.12\1.3.2\grizzled-slf4j_2.12-1.3.2.jar;D:\apache-maven-3.6.3\repository\com\github\scopt\scopt_2.12\3.5.0\scopt_2.12-3.5.0.jar;D:\apache-maven-3.6.3\repository\org\xerial\snappy\snappy-java\1.1.8.3\snappy-java-1.1.8.3.jar;D:\apache-maven-3.6.3\repository\com\twitter\chill_2.12\0.7.6\chill_2.12-0.7.6.jar;D:\apache-maven-3.6.3\repository\com\twitter\chill-java\0.7.6\chill-java-0.7.6.jar;D:\apache-maven-3.6.3\repository\org\lz4\lz4-java\1.6.0\lz4-java-1.6.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-optimizer_2.12\1.13.1\flink-optimizer_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-java\1.13.1\flink-java-1.13.1.jar;D:\apache-maven-3.6.3\repository\commons-cli\commons-cli\1.3.1\commons-cli-1.3.1.jar;D:\apache-maven-3.6.3\repository\org\scala-lang\scala-library\2.12.10\scala-library-2.12.10.jar;D:\apache-maven-3.6.3\repository\org\scala-lang\scala-reflect\2.12.10\scala-reflect-2.12.10.jar;D:\apache-maven-3.6.3\repository\org\scala-lang\scala-compiler\2.12.10\scala-compiler-2.12.10.jar;D:\apache-maven-3.6.3\repository\org\scala-lang\modules\scala-xml_2.12\1.0.6\scala-xml_2.12-1.0.6.jar;D:\apache-maven-3.6.3\repository\org\apache\logging\log4j\log4j-1.2-api\2.10.0\log4j-1.2-api-2.10.0.jar;D:\apache-maven-3.6.3\repository\org\apache\logging\log4j\log4j-api\2.10.0\log4j-api-2.10.0.jar;D:\apache-maven-3.6.3\repository\org\apache\logging\log4j\log4j-core\2.10.0\log4j-core-2.10.0.jar;D:\apache-maven-3.6.3\repository\org\apache\logging\log4j\log4j-slf4j-impl\2.10.0\log4j-slf4j-impl-2.10.0.jar;D:\apache-maven-3.6.3\repository\mysql\mysql-connector-java\5.1.38\mysql-connector-java-5.1.38.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-connector-kafka_2.12\1.13.1\flink-connector-kafka_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\kafka\kafka-clients\2.4.1\kafka-clients-2.4.1.jar;D:\apache-maven-3.6.3\repository\com\github\luben\zstd-jni\1.4.3-1\zstd-jni-1.4.3-1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-connector-base\1.13.1\flink-connector-base-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-runtime-web_2.12\1.13.1\flink-runtime-web_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-shaded-netty\4.1.49.Final-13.0\flink-shaded-netty-4.1.49.Final-13.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-shaded-guava\18.0-13.0\flink-shaded-guava-18.0-13.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-shaded-jackson\2.12.1-13.0\flink-shaded-jackson-2.12.1-13.0.jar;D:\apache-maven-3.6.3\repository\redis\clients\jedis\3.0.1\jedis-3.0.1.jar;D:\apache-maven-3.6.3\repository\org\apache\commons\commons-pool2\2.4.3\commons-pool2-2.4.3.jar;D:\apache-maven-3.6.3\repository\org\apache\bahir\flink-connector-redis_2.11\1.0\flink-connector-redis_2.11-1.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-streaming-java_2.11\1.2.0\flink-streaming-java_2.11-1.2.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-runtime_2.11\1.2.0\flink-runtime_2.11-1.2.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-shaded-hadoop2\1.2.0\flink-shaded-hadoop2-1.2.0.jar;D:\apache-maven-3.6.3\repository\org\tukaani\xz\1.0\xz-1.0.jar;D:\apache-maven-3.6.3\repository\xmlenc\xmlenc\0.52\xmlenc-0.52.jar;D:\apache-maven-3.6.3\repository\commons-net\commons-net\3.1\commons-net-3.1.jar;D:\apache-maven-3.6.3\repository\javax\servlet\servlet-api\2.5\servlet-api-2.5.jar;D:\apache-maven-3.6.3\repository\org\mortbay\jetty\jetty-util\6.1.26\jetty-util-6.1.26.jar;D:\apache-maven-3.6.3\repository\com\sun\jersey\jersey-core\1.9\jersey-core-1.9.jar;D:\apache-maven-3.6.3\repository\commons-el\commons-el\1.0\commons-el-1.0.jar;D:\apache-maven-3.6.3\repository\com\jamesmurty\utils\java-xmlbuilder\0.4\java-xmlbuilder-0.4.jar;D:\apache-maven-3.6.3\repository\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;D:\apache-maven-3.6.3\repository\commons-configuration\commons-configuration\1.7\commons-configuration-1.7.jar;D:\apache-maven-3.6.3\repository\commons-digester\commons-digester\1.8.1\commons-digester-1.8.1.jar;D:\apache-maven-3.6.3\repository\org\codehaus\jackson\jackson-core-asl\1.8.8\jackson-core-asl-1.8.8.jar;D:\apache-maven-3.6.3\repository\org\codehaus\jackson\jackson-mapper-asl\1.8.8\jackson-mapper-asl-1.8.8.jar;D:\apache-maven-3.6.3\repository\org\apache\avro\avro\1.7.7\avro-1.7.7.jar;D:\apache-maven-3.6.3\repository\com\thoughtworks\paranamer\paranamer\2.3\paranamer-2.3.jar;D:\apache-maven-3.6.3\repository\com\jcraft\jsch\0.1.42\jsch-0.1.42.jar;D:\apache-maven-3.6.3\repository\commons-beanutils\commons-beanutils-bean-collections\1.8.3\commons-beanutils-bean-collections-1.8.3.jar;D:\apache-maven-3.6.3\repository\commons-daemon\commons-daemon\1.0.13\commons-daemon-1.0.13.jar;D:\apache-maven-3.6.3\repository\javax\xml\bind\jaxb-api\2.2.2\jaxb-api-2.2.2.jar;D:\apache-maven-3.6.3\repository\javax\xml\stream\stax-api\1.0-2\stax-api-1.0-2.jar;D:\apache-maven-3.6.3\repository\javax\activation\activation\1.1\activation-1.1.jar;D:\apache-maven-3.6.3\repository\io\netty\netty-all\4.0.27.Final\netty-all-4.0.27.Final.jar;D:\apache-maven-3.6.3\repository\com\data-artisans\flakka-actor_2.11\2.3-custom\flakka-actor_2.11-2.3-custom.jar;D:\apache-maven-3.6.3\repository\com\data-artisans\flakka-remote_2.11\2.3-custom\flakka-remote_2.11-2.3-custom.jar;D:\apache-maven-3.6.3\repository\io\netty\netty\3.8.0.Final\netty-3.8.0.Final.jar;D:\apache-maven-3.6.3\repository\com\google\protobuf\protobuf-java\2.5.0\protobuf-java-2.5.0.jar;D:\apache-maven-3.6.3\repository\org\uncommons\maths\uncommons-maths\1.2.2a\uncommons-maths-1.2.2a.jar;D:\apache-maven-3.6.3\repository\com\data-artisans\flakka-slf4j_2.11\2.3-custom\flakka-slf4j_2.11-2.3-custom.jar;D:\apache-maven-3.6.3\repository\org\clapper\grizzled-slf4j_2.11\1.0.2\grizzled-slf4j_2.11-1.0.2.jar;D:\apache-maven-3.6.3\repository\com\github\scopt\scopt_2.11\3.2.0\scopt_2.11-3.2.0.jar;D:\apache-maven-3.6.3\repository\com\fasterxml\jackson\core\jackson-core\2.7.4\jackson-core-2.7.4.jar;D:\apache-maven-3.6.3\repository\com\fasterxml\jackson\core\jackson-databind\2.7.4\jackson-databind-2.7.4.jar;D:\apache-maven-3.6.3\repository\com\fasterxml\jackson\core\jackson-annotations\2.7.0\jackson-annotations-2.7.0.jar;D:\apache-maven-3.6.3\repository\org\apache\zookeeper\zookeeper\3.4.6\zookeeper-3.4.6.jar;D:\apache-maven-3.6.3\repository\org\slf4j\slf4j-log4j12\1.6.1\slf4j-log4j12-1.6.1.jar;D:\apache-maven-3.6.3\repository\log4j\log4j\1.2.16\log4j-1.2.16.jar;D:\apache-maven-3.6.3\repository\jline\jline\0.9.94\jline-0.9.94.jar;D:\apache-maven-3.6.3\repository\junit\junit\3.8.1\junit-3.8.1.jar;D:\apache-maven-3.6.3\repository\com\twitter\chill_2.11\0.7.4\chill_2.11-0.7.4.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-clients_2.11\1.2.0\flink-clients_2.11-1.2.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-optimizer_2.11\1.2.0\flink-optimizer_2.11-1.2.0.jar;D:\apache-maven-3.6.3\repository\org\apache\sling\org.apache.sling.commons.json\2.0.6\org.apache.sling.commons.json-2.0.6.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-statebackend-rocksdb_2.12\1.13.1\flink-statebackend-rocksdb_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\com\data-artisans\frocksdbjni\5.17.2-artisans-2.0\frocksdbjni-5.17.2-artisans-2.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-planner-blink_2.12\1.13.1\flink-table-planner-blink_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-common\1.13.1\flink-table-common-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-connector-files\1.13.1\flink-connector-files-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-api-java\1.13.1\flink-table-api-java-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-api-scala_2.12\1.13.1\flink-table-api-scala_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-api-java-bridge_2.12\1.13.1\flink-table-api-java-bridge_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-api-scala-bridge_2.12\1.13.1\flink-table-api-scala-bridge_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-runtime-blink_2.12\1.13.1\flink-table-runtime-blink_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\codehaus\janino\janino\3.0.11\janino-3.0.11.jar;D:\apache-maven-3.6.3\repository\org\codehaus\janino\commons-compiler\3.0.11\commons-compiler-3.0.11.jar;D:\apache-maven-3.6.3\repository\org\apache\calcite\avatica\avatica-core\1.17.0\avatica-core-1.17.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-connector-elasticsearch7_2.12\1.13.1\flink-connector-elasticsearch7_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-connector-elasticsearch-base_2.12\1.13.1\flink-connector-elasticsearch-base_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\client\elasticsearch-rest-high-level-client\7.5.1\elasticsearch-rest-high-level-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\elasticsearch\7.5.1\elasticsearch-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\elasticsearch-core\7.5.1\elasticsearch-core-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\elasticsearch-secure-sm\7.5.1\elasticsearch-secure-sm-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\elasticsearch-x-content\7.5.1\elasticsearch-x-content-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\yaml\snakeyaml\1.17\snakeyaml-1.17.jar;D:\apache-maven-3.6.3\repository\com\fasterxml\jackson\dataformat\jackson-dataformat-smile\2.8.11\jackson-dataformat-smile-2.8.11.jar;D:\apache-maven-3.6.3\repository\com\fasterxml\jackson\dataformat\jackson-dataformat-yaml\2.8.11\jackson-dataformat-yaml-2.8.11.jar;D:\apache-maven-3.6.3\repository\com\fasterxml\jackson\dataformat\jackson-dataformat-cbor\2.8.11\jackson-dataformat-cbor-2.8.11.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\elasticsearch-geo\7.5.1\elasticsearch-geo-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-core\8.3.0\lucene-core-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-analyzers-common\8.3.0\lucene-analyzers-common-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-backward-codecs\8.3.0\lucene-backward-codecs-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-grouping\8.3.0\lucene-grouping-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-highlighter\8.3.0\lucene-highlighter-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-join\8.3.0\lucene-join-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-memory\8.3.0\lucene-memory-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-misc\8.3.0\lucene-misc-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-queries\8.3.0\lucene-queries-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-queryparser\8.3.0\lucene-queryparser-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-sandbox\8.3.0\lucene-sandbox-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-spatial\8.3.0\lucene-spatial-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-spatial-extras\8.3.0\lucene-spatial-extras-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-spatial3d\8.3.0\lucene-spatial3d-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-suggest\8.3.0\lucene-suggest-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\elasticsearch-cli\7.5.1\elasticsearch-cli-7.5.1.jar;D:\apache-maven-3.6.3\repository\net\sf\jopt-simple\jopt-simple\5.0.2\jopt-simple-5.0.2.jar;D:\apache-maven-3.6.3\repository\com\carrotsearch\hppc\0.8.1\hppc-0.8.1.jar;D:\apache-maven-3.6.3\repository\joda-time\joda-time\2.10.3\joda-time-2.10.3.jar;D:\apache-maven-3.6.3\repository\com\tdunning\t-digest\3.2\t-digest-3.2.jar;D:\apache-maven-3.6.3\repository\org\hdrhistogram\HdrHistogram\2.1.9\HdrHistogram-2.1.9.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\jna\4.5.1\jna-4.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\client\elasticsearch-rest-client\7.5.1\elasticsearch-rest-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\apache\httpcomponents\httpclient\4.5.10\httpclient-4.5.10.jar;D:\apache-maven-3.6.3\repository\org\apache\httpcomponents\httpcore\4.4.12\httpcore-4.4.12.jar;D:\apache-maven-3.6.3\repository\org\apache\httpcomponents\httpasyncclient\4.1.4\httpasyncclient-4.1.4.jar;D:\apache-maven-3.6.3\repository\org\apache\httpcomponents\httpcore-nio\4.4.12\httpcore-nio-4.4.12.jar;D:\apache-maven-3.6.3\repository\commons-codec\commons-codec\1.11\commons-codec-1.11.jar;D:\apache-maven-3.6.3\repository\commons-logging\commons-logging\1.1.3\commons-logging-1.1.3.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\plugin\mapper-extras-client\7.5.1\mapper-extras-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\plugin\parent-join-client\7.5.1\parent-join-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\plugin\aggs-matrix-stats-client\7.5.1\aggs-matrix-stats-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\plugin\rank-eval-client\7.5.1\rank-eval-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\plugin\lang-mustache-client\7.5.1\lang-mustache-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\com\github\spullara\mustache\java\compiler\0.9.6\compiler-0.9.6.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-json\1.13.1\flink-json-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-csv\1.13.1\flink-csv-1.13.1.jar com.bytedance.one.testD:\anzhuang\jdk_1.8_181\bin\java.exe "-javaagent:D:\anzhuang\idea_web\IntelliJ IDEA 2019.3.1\lib\idea_rt.jar=51865:D:\anzhuang\idea_web\IntelliJ IDEA 2019.3.1\bin" -Dfile.encoding=UTF-8 -classpath D:\anzhuang\jdk_1.8_181\jre\lib\charsets.jar;D:\anzhuang\jdk_1.8_181\jre\lib\deploy.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\access-bridge-64.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\cldrdata.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\dnsns.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\jaccess.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\jfxrt.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\localedata.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\nashorn.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\sunec.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\sunjce_provider.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\sunmscapi.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\sunpkcs11.jar;D:\anzhuang\jdk_1.8_181\jre\lib\ext\zipfs.jar;D:\anzhuang\jdk_1.8_181\jre\lib\javaws.jar;D:\anzhuang\jdk_1.8_181\jre\lib\jce.jar;D:\anzhuang\jdk_1.8_181\jre\lib\jfr.jar;D:\anzhuang\jdk_1.8_181\jre\lib\jfxswt.jar;D:\anzhuang\jdk_1.8_181\jre\lib\jsse.jar;D:\anzhuang\jdk_1.8_181\jre\lib\management-agent.jar;D:\anzhuang\jdk_1.8_181\jre\lib\plugin.jar;D:\anzhuang\jdk_1.8_181\jre\lib\resources.jar;D:\anzhuang\jdk_1.8_181\jre\lib\rt.jar;D:\A_idea_project\flink-project\flink-sql\target\classes;D:\anzhuang\scala_2.12.10\lib\scala-library.jar;D:\anzhuang\scala_2.12.10\lib\scala-reflect.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-streaming-scala_2.12\1.13.1\flink-streaming-scala_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-streaming-java_2.12\1.13.1\flink-streaming-java_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-file-sink-common\1.13.1\flink-file-sink-common-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\commons\commons-math3\3.5\commons-math3-3.5.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-scala_2.12\1.13.1\flink-scala_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-shaded-asm-7\7.1-13.0\flink-shaded-asm-7-7.1-13.0.jar;D:\apache-maven-3.6.3\repository\org\slf4j\slf4j-api\1.7.15\slf4j-api-1.7.15.jar;D:\apache-maven-3.6.3\repository\com\google\code\findbugs\jsr305\1.3.9\jsr305-1.3.9.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\force-shading\1.13.1\force-shading-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-clients_2.12\1.13.1\flink-clients_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-core\1.13.1\flink-core-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-annotations\1.13.1\flink-annotations-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-metrics-core\1.13.1\flink-metrics-core-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\commons\commons-lang3\3.3.2\commons-lang3-3.3.2.jar;D:\apache-maven-3.6.3\repository\com\esotericsoftware\kryo\kryo\2.24.0\kryo-2.24.0.jar;D:\apache-maven-3.6.3\repository\com\esotericsoftware\minlog\minlog\1.2\minlog-1.2.jar;D:\apache-maven-3.6.3\repository\org\objenesis\objenesis\2.1\objenesis-2.1.jar;D:\apache-maven-3.6.3\repository\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;D:\apache-maven-3.6.3\repository\org\apache\commons\commons-compress\1.20\commons-compress-1.20.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-runtime_2.12\1.13.1\flink-runtime_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-queryable-state-client-java\1.13.1\flink-queryable-state-client-java-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-hadoop-fs\1.13.1\flink-hadoop-fs-1.13.1.jar;D:\apache-maven-3.6.3\repository\commons-io\commons-io\2.7\commons-io-2.7.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-shaded-zookeeper-3\3.4.14-13.0\flink-shaded-zookeeper-3-3.4.14-13.0.jar;D:\apache-maven-3.6.3\repository\org\javassist\javassist\3.24.0-GA\javassist-3.24.0-GA.jar;D:\apache-maven-3.6.3\repository\com\typesafe\akka\akka-actor_2.12\2.5.21\akka-actor_2.12-2.5.21.jar;D:\apache-maven-3.6.3\repository\com\typesafe\config\1.3.3\config-1.3.3.jar;D:\apache-maven-3.6.3\repository\org\scala-lang\modules\scala-java8-compat_2.12\0.8.0\scala-java8-compat_2.12-0.8.0.jar;D:\apache-maven-3.6.3\repository\com\typesafe\akka\akka-stream_2.12\2.5.21\akka-stream_2.12-2.5.21.jar;D:\apache-maven-3.6.3\repository\org\reactivestreams\reactive-streams\1.0.2\reactive-streams-1.0.2.jar;D:\apache-maven-3.6.3\repository\com\typesafe\ssl-config-core_2.12\0.3.7\ssl-config-core_2.12-0.3.7.jar;D:\apache-maven-3.6.3\repository\org\scala-lang\modules\scala-parser-combinators_2.12\1.1.1\scala-parser-combinators_2.12-1.1.1.jar;D:\apache-maven-3.6.3\repository\com\typesafe\akka\akka-protobuf_2.12\2.5.21\akka-protobuf_2.12-2.5.21.jar;D:\apache-maven-3.6.3\repository\com\typesafe\akka\akka-slf4j_2.12\2.5.21\akka-slf4j_2.12-2.5.21.jar;D:\apache-maven-3.6.3\repository\org\clapper\grizzled-slf4j_2.12\1.3.2\grizzled-slf4j_2.12-1.3.2.jar;D:\apache-maven-3.6.3\repository\com\github\scopt\scopt_2.12\3.5.0\scopt_2.12-3.5.0.jar;D:\apache-maven-3.6.3\repository\org\xerial\snappy\snappy-java\1.1.8.3\snappy-java-1.1.8.3.jar;D:\apache-maven-3.6.3\repository\com\twitter\chill_2.12\0.7.6\chill_2.12-0.7.6.jar;D:\apache-maven-3.6.3\repository\com\twitter\chill-java\0.7.6\chill-java-0.7.6.jar;D:\apache-maven-3.6.3\repository\org\lz4\lz4-java\1.6.0\lz4-java-1.6.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-optimizer_2.12\1.13.1\flink-optimizer_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-java\1.13.1\flink-java-1.13.1.jar;D:\apache-maven-3.6.3\repository\commons-cli\commons-cli\1.3.1\commons-cli-1.3.1.jar;D:\apache-maven-3.6.3\repository\org\scala-lang\scala-library\2.12.10\scala-library-2.12.10.jar;D:\apache-maven-3.6.3\repository\org\scala-lang\scala-reflect\2.12.10\scala-reflect-2.12.10.jar;D:\apache-maven-3.6.3\repository\org\scala-lang\scala-compiler\2.12.10\scala-compiler-2.12.10.jar;D:\apache-maven-3.6.3\repository\org\scala-lang\modules\scala-xml_2.12\1.0.6\scala-xml_2.12-1.0.6.jar;D:\apache-maven-3.6.3\repository\org\apache\logging\log4j\log4j-1.2-api\2.10.0\log4j-1.2-api-2.10.0.jar;D:\apache-maven-3.6.3\repository\org\apache\logging\log4j\log4j-api\2.10.0\log4j-api-2.10.0.jar;D:\apache-maven-3.6.3\repository\org\apache\logging\log4j\log4j-core\2.10.0\log4j-core-2.10.0.jar;D:\apache-maven-3.6.3\repository\org\apache\logging\log4j\log4j-slf4j-impl\2.10.0\log4j-slf4j-impl-2.10.0.jar;D:\apache-maven-3.6.3\repository\mysql\mysql-connector-java\5.1.38\mysql-connector-java-5.1.38.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-connector-kafka_2.12\1.13.1\flink-connector-kafka_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\kafka\kafka-clients\2.4.1\kafka-clients-2.4.1.jar;D:\apache-maven-3.6.3\repository\com\github\luben\zstd-jni\1.4.3-1\zstd-jni-1.4.3-1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-connector-base\1.13.1\flink-connector-base-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-runtime-web_2.12\1.13.1\flink-runtime-web_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-shaded-netty\4.1.49.Final-13.0\flink-shaded-netty-4.1.49.Final-13.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-shaded-guava\18.0-13.0\flink-shaded-guava-18.0-13.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-shaded-jackson\2.12.1-13.0\flink-shaded-jackson-2.12.1-13.0.jar;D:\apache-maven-3.6.3\repository\redis\clients\jedis\3.0.1\jedis-3.0.1.jar;D:\apache-maven-3.6.3\repository\org\apache\commons\commons-pool2\2.4.3\commons-pool2-2.4.3.jar;D:\apache-maven-3.6.3\repository\org\apache\bahir\flink-connector-redis_2.11\1.0\flink-connector-redis_2.11-1.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-streaming-java_2.11\1.2.0\flink-streaming-java_2.11-1.2.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-runtime_2.11\1.2.0\flink-runtime_2.11-1.2.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-shaded-hadoop2\1.2.0\flink-shaded-hadoop2-1.2.0.jar;D:\apache-maven-3.6.3\repository\org\tukaani\xz\1.0\xz-1.0.jar;D:\apache-maven-3.6.3\repository\xmlenc\xmlenc\0.52\xmlenc-0.52.jar;D:\apache-maven-3.6.3\repository\commons-net\commons-net\3.1\commons-net-3.1.jar;D:\apache-maven-3.6.3\repository\javax\servlet\servlet-api\2.5\servlet-api-2.5.jar;D:\apache-maven-3.6.3\repository\org\mortbay\jetty\jetty-util\6.1.26\jetty-util-6.1.26.jar;D:\apache-maven-3.6.3\repository\com\sun\jersey\jersey-core\1.9\jersey-core-1.9.jar;D:\apache-maven-3.6.3\repository\commons-el\commons-el\1.0\commons-el-1.0.jar;D:\apache-maven-3.6.3\repository\com\jamesmurty\utils\java-xmlbuilder\0.4\java-xmlbuilder-0.4.jar;D:\apache-maven-3.6.3\repository\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;D:\apache-maven-3.6.3\repository\commons-configuration\commons-configuration\1.7\commons-configuration-1.7.jar;D:\apache-maven-3.6.3\repository\commons-digester\commons-digester\1.8.1\commons-digester-1.8.1.jar;D:\apache-maven-3.6.3\repository\org\codehaus\jackson\jackson-core-asl\1.8.8\jackson-core-asl-1.8.8.jar;D:\apache-maven-3.6.3\repository\org\codehaus\jackson\jackson-mapper-asl\1.8.8\jackson-mapper-asl-1.8.8.jar;D:\apache-maven-3.6.3\repository\org\apache\avro\avro\1.7.7\avro-1.7.7.jar;D:\apache-maven-3.6.3\repository\com\thoughtworks\paranamer\paranamer\2.3\paranamer-2.3.jar;D:\apache-maven-3.6.3\repository\com\jcraft\jsch\0.1.42\jsch-0.1.42.jar;D:\apache-maven-3.6.3\repository\commons-beanutils\commons-beanutils-bean-collections\1.8.3\commons-beanutils-bean-collections-1.8.3.jar;D:\apache-maven-3.6.3\repository\commons-daemon\commons-daemon\1.0.13\commons-daemon-1.0.13.jar;D:\apache-maven-3.6.3\repository\javax\xml\bind\jaxb-api\2.2.2\jaxb-api-2.2.2.jar;D:\apache-maven-3.6.3\repository\javax\xml\stream\stax-api\1.0-2\stax-api-1.0-2.jar;D:\apache-maven-3.6.3\repository\javax\activation\activation\1.1\activation-1.1.jar;D:\apache-maven-3.6.3\repository\io\netty\netty-all\4.0.27.Final\netty-all-4.0.27.Final.jar;D:\apache-maven-3.6.3\repository\com\data-artisans\flakka-actor_2.11\2.3-custom\flakka-actor_2.11-2.3-custom.jar;D:\apache-maven-3.6.3\repository\com\data-artisans\flakka-remote_2.11\2.3-custom\flakka-remote_2.11-2.3-custom.jar;D:\apache-maven-3.6.3\repository\io\netty\netty\3.8.0.Final\netty-3.8.0.Final.jar;D:\apache-maven-3.6.3\repository\com\google\protobuf\protobuf-java\2.5.0\protobuf-java-2.5.0.jar;D:\apache-maven-3.6.3\repository\org\uncommons\maths\uncommons-maths\1.2.2a\uncommons-maths-1.2.2a.jar;D:\apache-maven-3.6.3\repository\com\data-artisans\flakka-slf4j_2.11\2.3-custom\flakka-slf4j_2.11-2.3-custom.jar;D:\apache-maven-3.6.3\repository\org\clapper\grizzled-slf4j_2.11\1.0.2\grizzled-slf4j_2.11-1.0.2.jar;D:\apache-maven-3.6.3\repository\com\github\scopt\scopt_2.11\3.2.0\scopt_2.11-3.2.0.jar;D:\apache-maven-3.6.3\repository\com\fasterxml\jackson\core\jackson-core\2.7.4\jackson-core-2.7.4.jar;D:\apache-maven-3.6.3\repository\com\fasterxml\jackson\core\jackson-databind\2.7.4\jackson-databind-2.7.4.jar;D:\apache-maven-3.6.3\repository\com\fasterxml\jackson\core\jackson-annotations\2.7.0\jackson-annotations-2.7.0.jar;D:\apache-maven-3.6.3\repository\org\apache\zookeeper\zookeeper\3.4.6\zookeeper-3.4.6.jar;D:\apache-maven-3.6.3\repository\org\slf4j\slf4j-log4j12\1.6.1\slf4j-log4j12-1.6.1.jar;D:\apache-maven-3.6.3\repository\log4j\log4j\1.2.16\log4j-1.2.16.jar;D:\apache-maven-3.6.3\repository\jline\jline\0.9.94\jline-0.9.94.jar;D:\apache-maven-3.6.3\repository\junit\junit\3.8.1\junit-3.8.1.jar;D:\apache-maven-3.6.3\repository\com\twitter\chill_2.11\0.7.4\chill_2.11-0.7.4.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-clients_2.11\1.2.0\flink-clients_2.11-1.2.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-optimizer_2.11\1.2.0\flink-optimizer_2.11-1.2.0.jar;D:\apache-maven-3.6.3\repository\org\apache\sling\org.apache.sling.commons.json\2.0.6\org.apache.sling.commons.json-2.0.6.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-statebackend-rocksdb_2.12\1.13.1\flink-statebackend-rocksdb_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\com\data-artisans\frocksdbjni\5.17.2-artisans-2.0\frocksdbjni-5.17.2-artisans-2.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-planner-blink_2.12\1.13.1\flink-table-planner-blink_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-common\1.13.1\flink-table-common-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-connector-files\1.13.1\flink-connector-files-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-api-java\1.13.1\flink-table-api-java-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-api-scala_2.12\1.13.1\flink-table-api-scala_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-api-java-bridge_2.12\1.13.1\flink-table-api-java-bridge_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-api-scala-bridge_2.12\1.13.1\flink-table-api-scala-bridge_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-table-runtime-blink_2.12\1.13.1\flink-table-runtime-blink_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\codehaus\janino\janino\3.0.11\janino-3.0.11.jar;D:\apache-maven-3.6.3\repository\org\codehaus\janino\commons-compiler\3.0.11\commons-compiler-3.0.11.jar;D:\apache-maven-3.6.3\repository\org\apache\calcite\avatica\avatica-core\1.17.0\avatica-core-1.17.0.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-connector-elasticsearch7_2.12\1.13.1\flink-connector-elasticsearch7_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-connector-elasticsearch-base_2.12\1.13.1\flink-connector-elasticsearch-base_2.12-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\client\elasticsearch-rest-high-level-client\7.5.1\elasticsearch-rest-high-level-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\elasticsearch\7.5.1\elasticsearch-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\elasticsearch-core\7.5.1\elasticsearch-core-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\elasticsearch-secure-sm\7.5.1\elasticsearch-secure-sm-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\elasticsearch-x-content\7.5.1\elasticsearch-x-content-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\yaml\snakeyaml\1.17\snakeyaml-1.17.jar;D:\apache-maven-3.6.3\repository\com\fasterxml\jackson\dataformat\jackson-dataformat-smile\2.8.11\jackson-dataformat-smile-2.8.11.jar;D:\apache-maven-3.6.3\repository\com\fasterxml\jackson\dataformat\jackson-dataformat-yaml\2.8.11\jackson-dataformat-yaml-2.8.11.jar;D:\apache-maven-3.6.3\repository\com\fasterxml\jackson\dataformat\jackson-dataformat-cbor\2.8.11\jackson-dataformat-cbor-2.8.11.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\elasticsearch-geo\7.5.1\elasticsearch-geo-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-core\8.3.0\lucene-core-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-analyzers-common\8.3.0\lucene-analyzers-common-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-backward-codecs\8.3.0\lucene-backward-codecs-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-grouping\8.3.0\lucene-grouping-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-highlighter\8.3.0\lucene-highlighter-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-join\8.3.0\lucene-join-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-memory\8.3.0\lucene-memory-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-misc\8.3.0\lucene-misc-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-queries\8.3.0\lucene-queries-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-queryparser\8.3.0\lucene-queryparser-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-sandbox\8.3.0\lucene-sandbox-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-spatial\8.3.0\lucene-spatial-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-spatial-extras\8.3.0\lucene-spatial-extras-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-spatial3d\8.3.0\lucene-spatial3d-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\apache\lucene\lucene-suggest\8.3.0\lucene-suggest-8.3.0.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\elasticsearch-cli\7.5.1\elasticsearch-cli-7.5.1.jar;D:\apache-maven-3.6.3\repository\net\sf\jopt-simple\jopt-simple\5.0.2\jopt-simple-5.0.2.jar;D:\apache-maven-3.6.3\repository\com\carrotsearch\hppc\0.8.1\hppc-0.8.1.jar;D:\apache-maven-3.6.3\repository\joda-time\joda-time\2.10.3\joda-time-2.10.3.jar;D:\apache-maven-3.6.3\repository\com\tdunning\t-digest\3.2\t-digest-3.2.jar;D:\apache-maven-3.6.3\repository\org\hdrhistogram\HdrHistogram\2.1.9\HdrHistogram-2.1.9.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\jna\4.5.1\jna-4.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\client\elasticsearch-rest-client\7.5.1\elasticsearch-rest-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\apache\httpcomponents\httpclient\4.5.10\httpclient-4.5.10.jar;D:\apache-maven-3.6.3\repository\org\apache\httpcomponents\httpcore\4.4.12\httpcore-4.4.12.jar;D:\apache-maven-3.6.3\repository\org\apache\httpcomponents\httpasyncclient\4.1.4\httpasyncclient-4.1.4.jar;D:\apache-maven-3.6.3\repository\org\apache\httpcomponents\httpcore-nio\4.4.12\httpcore-nio-4.4.12.jar;D:\apache-maven-3.6.3\repository\commons-codec\commons-codec\1.11\commons-codec-1.11.jar;D:\apache-maven-3.6.3\repository\commons-logging\commons-logging\1.1.3\commons-logging-1.1.3.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\plugin\mapper-extras-client\7.5.1\mapper-extras-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\plugin\parent-join-client\7.5.1\parent-join-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\plugin\aggs-matrix-stats-client\7.5.1\aggs-matrix-stats-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\plugin\rank-eval-client\7.5.1\rank-eval-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\org\elasticsearch\plugin\lang-mustache-client\7.5.1\lang-mustache-client-7.5.1.jar;D:\apache-maven-3.6.3\repository\com\github\spullara\mustache\java\compiler\0.9.6\compiler-0.9.6.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-json\1.13.1\flink-json-1.13.1.jar;D:\apache-maven-3.6.3\repository\org\apache\flink\flink-csv\1.13.1\flink-csv-1.13.1.jar com.bytedance.one.testSLF4J: Class path contains multiple SLF4J bindings.SLF4J: Found binding in [jar:file:/D:/apache-maven-3.6.3/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.10.0/log4j-slf4j-impl-2.10.0.jar!/org/slf4j/impl/StaticLoggerBinder.class]SLF4J: Found binding in [jar:file:/D:/apache-maven-3.6.3/repository/org/slf4j/slf4j-log4j12/1.6.1/slf4j-log4j12-1.6.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.SLF4J: Actual binding is of type [org.apache.logging.slf4j.Log4jLoggerFactory]ERROR StatusLogger No log4j2 configuration file found. Using default configuration: logging only errors to the console. Set system property 'log4j2.debug' to show Log4j2 internal initialization logging./* 1 *//* 2 */      public class SinkConversion$1 extends org.apache.flink.table.runtime.operators.TableStreamOperator/* 3 */          implements org.apache.flink.streaming.api.operators.OneInputStreamOperator \{/* 4 *//* 5 */        private final Object[] references;/* 6 */        private transient org.apache.flink.table.data.util.DataFormatConverters.StringConverter converter$0;/* 7 */        private final org.apache.flink.streaming.runtime.streamrecord.StreamRecord outElement = new org.apache.flink.streaming.runtime.streamrecord.StreamRecord(null);/* 8 *//* 9 */        public SinkConversion$1(/* 10 */            Object[] references,/* 11 */            org.apache.flink.streaming.runtime.tasks.StreamTask task,/* 12 */            org.apache.flink.streaming.api.graph.StreamConfig config,/* 13 */            org.apache.flink.streaming.api.operators.Output output,/* 14 */            org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService) throws Exception {/* 15 */          this.references = references;/* 16 */          converter$0 = (((org.apache.flink.table.data.util.DataFormatConverters.StringConverter) references[0]));/* 17 */          this.setup(task, config, output);/* 18 */          if (this instanceof org.apache.flink.streaming.api.operators.AbstractStreamOperator) {/* 19 */            ((org.apache.flink.streaming.api.operators.AbstractStreamOperator) this)/* 20 */              .setProcessingTimeService(processingTimeService);/* 21 */          }/* 22 */        }/* 23 *//* 24 */        @Override/* 25 */        public void open() throws Exception \{/* 26 */          super.open();/* 27 */          /* 28 */        }/* 29 *//* 30 */        @Override/* 31 */        public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord element) throws Exception \{/* 32 */          org.apache.flink.table.data.RowData in1 = (org.apache.flink.table.data.RowData) element.getValue();/* 33 */          /* 34 */          /* 35 */          /* 36 */          /* 37 */          /* 38 */          output.collect(outElement.replace((java.lang.String) converter$0.toExternal((org.apache.flink.table.data.binary.BinaryStringData) in1)));/* 39 */          /* 40 */        }/* 41 *//* 42 */        /* 43 *//* 44 */        @Override/* 45 */        public void close() throws Exception \{/* 46 */           super.close();/* 47 */          /* 48 */        }/* 49 *//* 50 */        /* 51 */      }/* 52 */    
Exception in thread "main" 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:602) at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577) at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962) at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736) at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962) at org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081) at akka.dispatch.OnComplete.internal(Future.scala:264) at akka.dispatch.OnComplete.internal(Future.scala:261) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64) at org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:72) at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:288) at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:288) at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:288) at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:536) at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33) at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64) at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23) at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:85) at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:91) at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44) at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)Caused 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:207) at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:197) at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:188) at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:677) at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:435) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 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.handleRpcInvocation(AkkaRpcActor.java:305) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) at scala.PartialFunction.applyOrElse(PartialFunction.scala:127) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176) at akka.actor.Actor.aroundReceive(Actor.scala:517) at akka.actor.Actor.aroundReceive$(Actor.scala:515) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) at akka.actor.ActorCell.invoke(ActorCell.scala:561) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) at akka.dispatch.Mailbox.run(Mailbox.scala:225) at akka.dispatch.Mailbox.exec(Mailbox.scala:235) ... 4 moreCaused by: java.lang.RuntimeException: Could not instantiate generated class 'SinkConversion$1' at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:66) at org.apache.flink.table.runtime.operators.CodeGenOperatorFactory.createStreamOperator(CodeGenOperatorFactory.java:40) at org.apache.flink.streaming.api.operators.StreamOperatorFactoryUtil.createOperator(StreamOperatorFactoryUtil.java:80) at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:652) at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:626) at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:566) at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:616) at org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:566) at org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:181) at org.apache.flink.streaming.runtime.tasks.StreamTask.executeRestore(StreamTask.java:548) at org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:647) at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:537) at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:759) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566) at java.lang.Thread.run(Thread.java:748)Caused by: org.apache.flink.util.FlinkRuntimeException: org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue. at org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:76) at org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:77) at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:64) ... 14 moreCaused by: org.apache.flink.shaded.guava18.com.google.common.util.concurrent.UncheckedExecutionException: org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue. at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2203) at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache.get(LocalCache.java:3937) at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4739) at org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:74) ... 16 moreCaused by: org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue. at org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:89) at org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:74) at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4742) at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3527) at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2319) at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2282) at org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2197) ... 19 moreCaused by: org.codehaus.commons.compiler.CompileException: Line 38, Column 144: Cannot cast "org.apache.flink.table.data.RowData" to "org.apache.flink.table.data.binary.BinaryStringData" at org.codehaus.janino.UnitCompiler.compileError(UnitCompiler.java:12211) at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5051) at org.codehaus.janino.UnitCompiler.access$8600(UnitCompiler.java:215) at org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4418) at org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4396) at org.codehaus.janino.Java$Cast.accept(Java.java:4898) at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4396) at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5662) at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5182) at org.codehaus.janino.UnitCompiler.access$9100(UnitCompiler.java:215) at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4423) at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4396) at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5073) at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4396) at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5662) at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5021) at org.codehaus.janino.UnitCompiler.access$8600(UnitCompiler.java:215) at org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4418) at org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4396) at org.codehaus.janino.Java$Cast.accept(Java.java:4898) at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4396) at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5662) at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5182) at org.codehaus.janino.UnitCompiler.access$9100(UnitCompiler.java:215) at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4423) at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4396) at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5073) at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4396) at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5662) at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5182) at org.codehaus.janino.UnitCompiler.access$9100(UnitCompiler.java:215) at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4423) at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4396) at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5073) at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4396) at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5662) at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:3783) at org.codehaus.janino.UnitCompiler.access$5900(UnitCompiler.java:215) at org.codehaus.janino.UnitCompiler$13.visitMethodInvocation(UnitCompiler.java:3762) at org.codehaus.janino.UnitCompiler$13.visitMethodInvocation(UnitCompiler.java:3734) at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5073) at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3734) at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2360) at org.codehaus.janino.UnitCompiler.access$1800(UnitCompiler.java:215) at org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1494) at org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1487) at org.codehaus.janino.Java$ExpressionStatement.accept(Java.java:2874) at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487) at org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1567) at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3388) at org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1357) at org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1330) at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:822) at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:432) at org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:215) at org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:411) at org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:406) at org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1414) at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:406) at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:378) at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:237) at org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:465) at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:216) at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:207) at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:80) at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:75) at org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:86) ... 25 more
Process finished with exit code 1
            Reporter: DaChun
         Attachments: test.scala, this_error.txt

When I run the program, the error is as follows:

The specific error is in this_ error.txt,

But the error prompts me to write an issue

Caused by: org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

It's very easy to read a stream and convert it into a table mode. The generic type is string

Then an error is reported. The code is in test. Scala and the error is in this_ error.txt

But I try to create an entity class by myself, and then assign generics to this entity class, and then I can pass it normally,

Or with row type, do you have to create your own entity class, not with string type?

 

 

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)