Hi, 看着像是版本冲突了，你有在你的flink session集群目录里放hbase的包吗？可以检查一下跟flink hbase shaded的hbase版本是否一致
Best, Shammon FY On Sat, Aug 5, 2023 at 9:33 PM 杨东树 <yangdongshu_l...@163.com> wrote: > 各位好， > 目前使用sql-client查询hbase数据时，无法查询成功，麻烦指导下，谢谢。 > 复现方法： > 1、hbase操作: > hbase(main):005:0> create 'flink_to_hbase','cf1' > 0 row(s) in 2.2900 seconds > hbase(main):006:0> put 'flink_to_hbase', 'rk0001', 'cf1:username', > 'zhangsan' > 0 row(s) in 0.0510 seconds > > > 2、flink操作: > ./start-cluster.sh > ./sql-client.sh > CREATE TABLE flink_to_hbase( > rowkey STRING, > cf1 ROW<username STRING>, > PRIMARY KEY (rowkey) NOT ENFORCED > )WITH( > 'connector'='hbase-1.4', > 'table-name'='flink_to_hbase', > 'zookeeper.quorum'='192.168.21.128:2181', > 'zookeeper.znode.parent'='/hbase' > ); > > > 3、flink 报错日志： > 2023-08-05 21:00:35,081 INFO org.apache.flink.table.client.cli.CliClient > [] - Command history file path: /root/.flink-sql-history > 2023-08-05 21:00:52,011 INFO > org.apache.flink.configuration.Configuration [] - Config > uses fallback configuration key 'jobmanager.rpc.address' instead of key > 'rest.address' > 2023-08-05 21:00:52,026 INFO > org.apache.flink.client.program.rest.RestClusterClient [] - > Submitting job 'collect' (0c147bc0da5a43a5a382f2ec20740b45). > 2023-08-05 21:00:52,480 INFO > org.apache.flink.client.program.rest.RestClusterClient [] - > Successfully submitted job 'collect' (0c147bc0da5a43a5a382f2ec20740b45) to ' > http://localhost:8081'. > 2023-08-05 21:00:55,809 INFO > org.apache.flink.configuration.Configuration [] - Config > uses fallback configuration key 'jobmanager.rpc.address' instead of key > 'rest.address' > 2023-08-05 21:00:55,830 INFO > org.apache.flink.configuration.Configuration [] - Config > uses fallback configuration key 'jobmanager.rpc.address' instead of key > 'rest.address' > 2023-08-05 21:07:52,481 INFO > org.apache.flink.configuration.Configuration [] - Config > uses fallback configuration key 'jobmanager.rpc.address' instead of key > 'rest.address' > 2023-08-05 21:07:52,484 INFO > org.apache.flink.client.program.rest.RestClusterClient [] - > Submitting job 'collect' (d29904103fa3c83e3089c09f093372c9). > 2023-08-05 21:07:52,728 INFO > org.apache.flink.client.program.rest.RestClusterClient [] - > Successfully submitted job 'collect' (d29904103fa3c83e3089c09f093372c9) to ' > http://localhost:8081'. > 2023-08-05 21:07:55,972 WARN org.apache.flink.table.client.cli.CliClient > [] - Could not execute SQL statement. > org.apache.flink.table.client.gateway.SqlExecutionException: Could not > execute SQL statement. > at > org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:211) > ~[flink-sql-client_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.client.gateway.local.LocalExecutor.executeQuery(LocalExecutor.java:231) > ~[flink-sql-client_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.client.cli.CliClient.callSelect(CliClient.java:532) > ~[flink-sql-client_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.client.cli.CliClient.callOperation(CliClient.java:423) > ~[flink-sql-client_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.client.cli.CliClient.lambda$executeStatement$1(CliClient.java:332) > [flink-sql-client_2.11-1.14.5.jar:1.14.5] > at java.util.Optional.ifPresent(Optional.java:159) ~[?:1.8.0_231] > at > org.apache.flink.table.client.cli.CliClient.executeStatement(CliClient.java:325) > [flink-sql-client_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.client.cli.CliClient.executeInteractive(CliClient.java:297) > [flink-sql-client_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.client.cli.CliClient.executeInInteractiveMode(CliClient.java:221) > [flink-sql-client_2.11-1.14.5.jar:1.14.5] > at org.apache.flink.table.client.SqlClient.openCli(SqlClient.java:151) > [flink-sql-client_2.11-1.14.5.jar:1.14.5] > at org.apache.flink.table.client.SqlClient.start(SqlClient.java:95) > [flink-sql-client_2.11-1.14.5.jar:1.14.5] > at org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:187) > [flink-sql-client_2.11-1.14.5.jar:1.14.5] > at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161) > [flink-sql-client_2.11-1.14.5.jar:1.14.5] > Caused by: org.apache.flink.table.api.TableException: Failed to execute sql > at > org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:828) > ~[flink-table_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1274) > ~[flink-table_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeOperation$3(LocalExecutor.java:209) > ~[flink-sql-client_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88) > ~[flink-sql-client_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:209) > ~[flink-sql-client_2.11-1.14.5.jar:1.14.5] > ... 12 more > Caused by: org.apache.flink.util.FlinkException: Failed to execute job > 'collect'. > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2055) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:95) > ~[flink-table_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:811) > ~[flink-table_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1274) > ~[flink-table_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.client.gateway.local.LocalExecutor.lambda$executeOperation$3(LocalExecutor.java:209) > ~[flink-sql-client_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.client.gateway.context.ExecutionContext.wrapClassLoader(ExecutionContext.java:88) > ~[flink-sql-client_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.table.client.gateway.local.LocalExecutor.executeOperation(LocalExecutor.java:209) > ~[flink-sql-client_2.11-1.14.5.jar:1.14.5] > ... 12 more > Caused by: java.lang.RuntimeException: > org.apache.flink.runtime.client.JobInitializationException: Could not start > the JobMaster. > at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:316) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedFunction$2(FunctionUtils.java:75) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:602) > ~[?:1.8.0_231] > at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577) > ~[?:1.8.0_231] > at > java.util.concurrent.CompletableFuture$Completion.exec(CompletableFuture.java:443) > ~[?:1.8.0_231] > at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) > ~[?:1.8.0_231] > at > java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) > ~[?:1.8.0_231] > at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) > ~[?:1.8.0_231] > at > java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) > ~[?:1.8.0_231] > Caused by: org.apache.flink.runtime.client.JobInitializationException: > Could not start the JobMaster. > at > org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) > ~[?:1.8.0_231] > at > java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736) > ~[?:1.8.0_231] > at > java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) > ~[?:1.8.0_231] > at > java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1595) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > ~[?:1.8.0_231] > at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_231] > Caused by: java.util.concurrent.CompletionException: > java.lang.RuntimeException: org.apache.flink.runtime.JobException: Creating > the input splits caused an error: > java.lang.reflect.InvocationTargetException > at > java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) > ~[?:1.8.0_231] > at > java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) > ~[?:1.8.0_231] > at > java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1592) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > ~[?:1.8.0_231] > at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_231] > Caused by: java.lang.RuntimeException: > org.apache.flink.runtime.JobException: Creating the input splits caused an > error: java.lang.reflect.InvocationTargetException > at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:316) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > ~[?:1.8.0_231] > at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_231] > Caused by: org.apache.flink.runtime.JobException: Creating the input > splits caused an error: java.lang.reflect.InvocationTargetException > at > org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:247) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:791) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:196) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:107) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:335) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:191) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:134) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:110) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:346) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:323) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:106) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:94) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > ~[?:1.8.0_231] > at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_231] > Caused by: java.io.IOException: java.lang.reflect.InvocationTargetException > at > org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:240) > ~[hbase-client-1.4.3.jar:1.4.3] > at > org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:218) > ~[hbase-client-1.4.3.jar:1.4.3] > at > org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:119) > ~[hbase-client-1.4.3.jar:1.4.3] > at > org.apache.flink.connector.hbase1.source.HBaseRowDataInputFormat.connectToTable(HBaseRowDataInputFormat.java:90) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.connector.hbase1.source.HBaseRowDataInputFormat.initTable(HBaseRowDataInputFormat.java:66) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.connector.hbase1.source.AbstractTableInputFormat.createInputSplits(AbstractTableInputFormat.java:228) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.connector.hbase1.source.AbstractTableInputFormat.createInputSplits(AbstractTableInputFormat.java:47) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:234) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:791) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:196) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:107) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:335) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:191) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:134) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:110) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:346) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:323) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:106) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:94) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > ~[?:1.8.0_231] > at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_231] > Caused by: java.lang.reflect.InvocationTargetException > at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) > ~[?:1.8.0_231] > at > sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) > ~[?:1.8.0_231] > at > sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) > ~[?:1.8.0_231] > at java.lang.reflect.Constructor.newInstance(Constructor.java:423) > ~[?:1.8.0_231] > at > org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:238) > ~[hbase-client-1.4.3.jar:1.4.3] > at > org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:218) > ~[hbase-client-1.4.3.jar:1.4.3] > at > org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:119) > ~[hbase-client-1.4.3.jar:1.4.3] > at > org.apache.flink.connector.hbase1.source.HBaseRowDataInputFormat.connectToTable(HBaseRowDataInputFormat.java:90) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.connector.hbase1.source.HBaseRowDataInputFormat.initTable(HBaseRowDataInputFormat.java:66) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.connector.hbase1.source.AbstractTableInputFormat.createInputSplits(AbstractTableInputFormat.java:228) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.connector.hbase1.source.AbstractTableInputFormat.createInputSplits(AbstractTableInputFormat.java:47) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:234) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:791) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:196) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:107) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:335) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:191) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:134) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:110) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:346) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:323) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:106) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:94) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > ~[?:1.8.0_231] > at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_231] > Caused by: java.lang.RuntimeException: java.lang.RuntimeException: class > org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.ClusterStatusListener$MulticastListener > not org.apache.hadoop.hbase.client.ClusterStatusListener$Listener > at org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2299) > ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0] > at > org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.<init>(ConnectionManager.java:714) > ~[hbase-client-1.4.3.jar:1.4.3] > at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) > ~[?:1.8.0_231] > at > sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) > ~[?:1.8.0_231] > at > sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) > ~[?:1.8.0_231] > at java.lang.reflect.Constructor.newInstance(Constructor.java:423) > ~[?:1.8.0_231] > at > org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:238) > ~[hbase-client-1.4.3.jar:1.4.3] > at > org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:218) > ~[hbase-client-1.4.3.jar:1.4.3] > at > org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:119) > ~[hbase-client-1.4.3.jar:1.4.3] > at > org.apache.flink.connector.hbase1.source.HBaseRowDataInputFormat.connectToTable(HBaseRowDataInputFormat.java:90) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.connector.hbase1.source.HBaseRowDataInputFormat.initTable(HBaseRowDataInputFormat.java:66) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.connector.hbase1.source.AbstractTableInputFormat.createInputSplits(AbstractTableInputFormat.java:228) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.connector.hbase1.source.AbstractTableInputFormat.createInputSplits(AbstractTableInputFormat.java:47) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:234) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:791) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:196) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:107) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:335) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:191) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:134) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:110) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:346) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:323) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:106) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:94) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > ~[?:1.8.0_231] > at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_231] > Caused by: java.lang.RuntimeException: class > org.apache.flink.hbase.shaded.org.apache.hadoop.hbase.client.ClusterStatusListener$MulticastListener > not org.apache.hadoop.hbase.client.ClusterStatusListener$Listener > at org.apache.hadoop.conf.Configuration.getClass(Configuration.java:2293) > ~[flink-shaded-hadoop-2-uber-2.7.5-10.0.jar:2.7.5-10.0] > at > org.apache.hadoop.hbase.client.ConnectionManager$HConnectionImplementation.<init>(ConnectionManager.java:714) > ~[hbase-client-1.4.3.jar:1.4.3] > at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) > ~[?:1.8.0_231] > at > sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) > ~[?:1.8.0_231] > at > sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) > ~[?:1.8.0_231] > at java.lang.reflect.Constructor.newInstance(Constructor.java:423) > ~[?:1.8.0_231] > at > org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:238) > ~[hbase-client-1.4.3.jar:1.4.3] > at > org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:218) > ~[hbase-client-1.4.3.jar:1.4.3] > at > org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(ConnectionFactory.java:119) > ~[hbase-client-1.4.3.jar:1.4.3] > at > org.apache.flink.connector.hbase1.source.HBaseRowDataInputFormat.connectToTable(HBaseRowDataInputFormat.java:90) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.connector.hbase1.source.HBaseRowDataInputFormat.initTable(HBaseRowDataInputFormat.java:66) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.connector.hbase1.source.AbstractTableInputFormat.createInputSplits(AbstractTableInputFormat.java:228) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.connector.hbase1.source.AbstractTableInputFormat.createInputSplits(AbstractTableInputFormat.java:47) > ~[flink-connector-hbase-1.4_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.ExecutionJobVertex.<init>(ExecutionJobVertex.java:234) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:791) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:196) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:107) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:335) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:191) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:140) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:134) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:110) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:346) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:323) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:106) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:94) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112) > ~[flink-dist_2.11-1.14.5.jar:1.14.5] > at > java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) > ~[?:1.8.0_231] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) > ~[?:1.8.0_231] > at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_231] > >
