TD
At 2022-08-12 10:31:35, "Summer" <binjie...@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]
>
>
>
>
>请问这是什么原因？？
>
>
>
>
>
>
>
>
>
