剑行者

同样问题 求解

Listening for transport dt_socket at address: 5005 2023-01-05 20:19:46,210 - 0 INFO [main] org.apache.flink.runtime.util.EnvironmentInformation:-------------------------------------------------------------------------------- 2023-01-05 20:19:46,211 - 1 INFO [main] org.apache.flink.runtime.util.EnvironmentInformation: Starting YARN TaskExecutor runner (Version: 1.12.7, Scala: 2.12, Rev:88d9950,...

使用的是apache hive2.1.0

[root@hadoop01 ~]# hive SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/data/tools/bigdata/apache-hive-2.1.0-bin/lib/log4j-slf4j-impl-2.4.1.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/data/tools/bigdata/hadoop-2.7.7/share/hadoop/common/lib/slf4j-log4j12-1.7.10.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. SLF4J: Actual binding is...

> hive 是什么版本，apache hive2.1 吗？还是spark thrift server 呢？任务脚本及日志提供下，谢谢 日志提供过了

``` { "job": { "content": [ { "reader": { "name": "mysqlreader", "parameter": { "column": [ { "name": "ID", "type": "varchar" }, { "name": "DIR_ID", "type": "varchar" }, { "name": "UNAME",...