版本: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] 请问这是什么原因??