版本:1.13.3


lib目录下:
-rw-r--r-- 1 root root   7759243 Aug 12 10:12 
flink-connector-hive_2.12-1.13.3.jar
-rw-r--r-- 1 root root     92313 Aug 12 10:12 flink-csv-1.13.3.jar
-rw-r--r-- 1 root root 106535831 Aug 12 10:12 flink-dist_2.12-1.13.3.jar
-rw-r--r-- 1 root root     78644 Aug 12 10:12 
flink-hadoop-compatibility_2.12-1.13.3.jar
-rw-r--r-- 1 root root    148127 Aug 12 10:12 flink-json-1.13.3.jar
-rw-r--r-- 1 root root  43317025 Aug 12 10:12 
flink-shaded-hadoop-2-uber-2.8.3-10.0.jar
-rwxr-xr-x 1 root root   7709740 Aug 12 10:12 flink-shaded-zookeeper-3.4.14.jar
-rw-r--r-- 1 root root  47172843 Aug 12 10:12 
flink-sql-connector-hive-3.1.2_2.11-1.12-SNAPSHOT.jar
-rw-r--r-- 1 root root  35051553 Aug 12 10:13 flink-table_2.12-1.13.3.jar
-rw-r--r-- 1 root root  38613339 Aug 12 10:13 flink-table-blink_2.12-1.13.3.jar
-rw-r--r-- 1 root root  40623959 Aug 12 10:13 hive-exec-3.1.2.jar
-rw-r--r-- 1 root root  31227259 Aug 11 18:08 
hudi-flink-bundle_2.11-0.10.1-rc1.jar
-rwxr-xr-x 1 root root     67114 Aug 12 10:13 log4j-1.2-api-2.12.1.jar
-rwxr-xr-x 1 root root    276771 Aug 12 10:13 log4j-api-2.12.1.jar
-rwxr-xr-x 1 root root   1674433 Aug 12 10:13 log4j-core-2.12.1.jar
-rwxr-xr-x 1 root root     23518 Aug 12 10:13 log4j-slf4j-impl-2.12.1.jar


在JobManager节点启动Sql-Client时有问题,异常如下:
2022-08-12 10:19:33,434 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: env.ssh.opts, -p 8808
2022-08-12 10:19:33,436 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: env.hadoop.conf.dir, /opt/flink-1.13.3/conf/hadoop
2022-08-12 10:19:33,436 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: rest.flamegraph.enabled, true
2022-08-12 10:19:33,437 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: jobmanager.rpc.address, 172.17.2.27
2022-08-12 10:19:33,437 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: jobmanager.rpc.port, 6123
2022-08-12 10:19:33,437 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: jobmanager.memory.process.size, 10480m
2022-08-12 10:19:33,437 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: jobmanager.memory.jvm-metaspace.size, 1024m
2022-08-12 10:19:33,437 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: taskmanager.memory.process.size, 10480m
2022-08-12 10:19:33,437 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: taskmanager.numberOfTaskSlots, 16
2022-08-12 10:19:33,437 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: parallelism.default, 1
2022-08-12 10:19:33,437 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: high-availability, zookeeper
2022-08-12 10:19:33,438 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: high-availability.storageDir, 
hdfs://emr-cluster/flink/v1/ha
2022-08-12 10:19:33,438 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: high-availability.zookeeper.quorum, 
172.17.2.26:2181,172.17.2.27:2181,172.17.2.29:2181
2022-08-12 10:19:33,438 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: high-availability.zookeeper.path.root, /flink
2022-08-12 10:19:33,438 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: high-availability.cluster-id, /v1
2022-08-12 10:19:33,438 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: state.backend, filesystem
2022-08-12 10:19:33,438 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: state.checkpoints.dir, 
hdfs://emr-cluster/flink/v1/flink-checkpoints/
2022-08-12 10:19:33,438 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: state.savepoints.dir, 
hdfs://emr-cluster/flink/v1/flink-savepoints/
2022-08-12 10:19:33,438 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: jobmanager.execution.failover-strategy, region
2022-08-12 10:19:33,439 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: web.tmpdir, /data/flink/v1/webtmp
2022-08-12 10:19:33,439 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: io.tmp.dirs, /data/flink/v1/iotmp
2022-08-12 10:19:33,439 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: classloader.resolve-order, parent-first
2022-08-12 10:19:33,439 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: jobmanager.archive.fs.dir, 
hdfs://emr-cluster/flink/v1/history
2022-08-12 10:19:33,439 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: historyserver.archive.fs.dir, 
hdfs://emr-cluster/flink/v1/history
2022-08-12 10:19:33,440 INFO  
org.apache.flink.configuration.GlobalConfiguration           [] - Loading 
configuration property: historyserver.web.tmpdir, /data/flink/v1/history
2022-08-12 10:19:33,460 INFO  
org.apache.flink.table.client.gateway.local.LocalContextUtils [] - Using 
default environment file: file:/opt/flink-1.13.3/conf/sql-client-defaults.yaml
2022-08-12 10:19:33,667 INFO  
org.apache.flink.table.client.config.entries.ExecutionEntry  [] - Property 
'execution.restart-strategy.type' not specified. Using default value: fallback
2022-08-12 10:19:33,671 INFO  
org.apache.flink.table.client.gateway.context.DefaultContext [] - Executor 
config: {execution.savepoint.ignore-unclaimed-state=false, 
execution.attached=true, execution.shutdown-on-attached-exit=false, 
pipeline.jars=[file:/opt/flink-1.13.3/opt/flink-sql-client_2.12-1.13.3.jar], 
pipeline.classpaths=[], execution.target=remote}
2022-08-12 10:19:34,442 ERROR org.apache.flink.table.client.SqlClient           
           [] - SQL Client must stop. Unexpected exception. This is a bug. 
Please consider filing an issue.
org.apache.flink.table.api.TableException: Required context of factory 
'org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory' must not be 
null.
        at 
org.apache.flink.table.factories.TableFactoryService.normalizeContext(TableFactoryService.java:340)
 ~[flink-table_2.12-1.13.3.jar:1.13.3]
        at 
org.apache.flink.table.factories.TableFactoryService.filterByContext(TableFactoryService.java:235)
 ~[flink-table_2.12-1.13.3.jar:1.13.3]
        at 
org.apache.flink.table.factories.TableFactoryService.filter(TableFactoryService.java:178)
 ~[flink-table_2.12-1.13.3.jar:1.13.3]
        at 
org.apache.flink.table.factories.TableFactoryService.findSingleInternal(TableFactoryService.java:139)
 ~[flink-table_2.12-1.13.3.jar:1.13.3]
        at 
org.apache.flink.table.factories.TableFactoryService.find(TableFactoryService.java:108)
 ~[flink-table_2.12-1.13.3.jar:1.13.3]
        at 
org.apache.flink.table.factories.FactoryUtil.createCatalog(FactoryUtil.java:243)
 ~[flink-table_2.12-1.13.3.jar:1.13.3]
        at 
org.apache.flink.table.client.gateway.context.LegacyTableEnvironmentInitializer.createCatalog(LegacyTableEnvironmentInitializer.java:217)
 ~[flink-sql-client_2.12-1.13.3.jar:1.13.3]
        at 
org.apache.flink.table.client.gateway.context.LegacyTableEnvironmentInitializer.lambda$initializeCatalogs$1(LegacyTableEnvironmentInitializer.java:120)
 ~[flink-sql-client_2.12-1.13.3.jar:1.13.3]
        at java.util.HashMap.forEach(HashMap.java:1289) ~[?:1.8.0_231]




请问这是什么原因??









回复