You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by Summer <bi...@paat.com> on 2022/08/12 02:31:35 UTC
Client启动有异常： SQL Client must stop. Unexpected exception. This is a bug. Please consider filing an issue.
版本：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]
请问这是什么原因？？
Re:Client启动有异常： SQL Client must stop. Unexpected exception. This is a bug. Please consider filing an issue.
Posted by RS <ti...@163.com>.
Hi,
1. lib下只需要一个flink-sql-connector-hive的包，不再需要flink-connector-hive和hive-exec
2. flink-sql-connector-hive包版本不对，需要和flink的1.13.3版本一致
先试试看，不行的话，就是代码的问题了。
Thanks
At 2022-08-12 10:31:35, "Summer" <bi...@paat.com> wrote:
>
>
>版本：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]
>
>
>
>
>请问这是什么原因？？
>
>
>
>
>
>
>
>
>
Re:Client启动有异常： SQL Client must stop. Unexpected exception. This is a bug. Please consider filing an issue.
Posted by 许学伟 <xu...@163.com>.
TD
At 2022-08-12 10:31:35, "Summer" <bi...@paat.com> wrote:
>
>
>版本：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]
>
>
>
>
>请问这是什么原因？？
>
>
>
>
>
>
>
>
>