MuChen1.??Hbase??zk??"org.apache.flink.shaded.curator.org.apache.curator.ConnectionStatenbsp;
- Authentication failed JobManager Web Interface:
http://uhadoop-op3raf-core24:42976 "2.Hbase"Caused by:
org.apache.flink.runtime.client.JobExecutionException: Cannot initialize task
'Source: HBaseTableSource[schema=[key, cf1], projectFields=[0]] ;
SourceConversion(table=[default_catalog.default_database.hbase_video_pic_title_q70,
source: [HBaseTableSource[schema=[key, cf1], projectFields=[0,
fields=[key]) ; SinkConversionToTuple2 ; Sink: SQL Client Stream Collect Sink':
Configuring the input format (null) failed: Cannot create connection to
HBase."??HBASEHbaseHbase.Best,Roc
Marshal.
?? 2020-06-23 11:05:43??"MuChen" <9329...@qq.com> ??
>Hi,Roc Marshal:
>
>
>
>Best,
>MuChen.
>
>
>
>
>----
>??:"Roc Marshal":2020??6??23??(??) 10:27
>??:"user-zh"
>:Re:flinksqlhbase??
>
>
>
>MuChen
>Sourcezk???? Marshal.
>?? 2020-06-23 10:17:35??"MuChen" <9329...@qq.com ??
>Hi, All:
>
>
>??flinksqlhbase
>
>
>
>
>
>
>hadoop??masterflink??
>
>yarn-session:
>bin/yarn-session.sh -jm 1g -tm 4g -s 4 -qu root.flink -nm fsql-cli
>2gt;amp;1 amp; # ??
>[admin@uhadoop-op3raf-master2 flink10]$ 2020-06-23 09:30:56,402 ERROR
>org.apache.flink.shaded.curator.org.apache.curator.ConnectionState -
>Authentication failed 2020-06-23 09:30:56,515 ERROR
>org.apache.flink.shaded.curator.org.apache.curator.ConnectionState -
>Authentication failed JobManager Web Interface:
>http://uhadoop-op3raf-core24:42976
>sql-client:
>bin/sql-client.sh embedded
>hbaseflinksql??
># CREATE TABLE hbase_video_pic_title_q70 ( key
>string, cf1 ROW( 'connector.type' = 'hbase', 'connector.version' =
>'1.4.3', 'connector.table-name' =
>'hbase_video_pic_title_q70', 'connector.zookeeper.quorum' =
>'uhadoop-op3raf-master1:2181,uhadoop-op3raf-master2:2181,uhadoop-op3raf-core1:2181',
> 'connector.zookeeper.znode.parent' = '/hbase',
>'connector.write.buffer-flush.max-size' = '10mb',
>'connector.write.buffer-flush.max-rows' = '1000',
>'connector.write.buffer-flush.interval' = '2s' );
>??
>select key from hbase_video_pic_title_q70;
>??HBase
>[ERROR] Could not execute SQL statement. Reason:
>org.apache.flink.runtime.rest.util.RestClientException: [Internal server
>error., org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
>job. at
>org.apache.flink.runtime.dispatcher.Dispatcher.lambda$internalSubmitJob$3(Dispatcher.java:336)
> at
>java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:822)
> at
>java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:797)
> at
>java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442)
> at
>akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
> at
>akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44)
> at
>akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
> at
>akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
> at
>akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
> at
>akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
>Caused by: java.lang.RuntimeException:
>org.apache.flink.runtime.client.JobExecutionException: Could not set up
>JobManager at
>org.apache.flink.util.function.CheckedSupplier.lambda$unchecked$0(CheckedSupplier.java:36)
> at
>java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590)
> ... 6 more Caused by: org.apache.flink.runtime.client.JobExecutionException:
>Could not set up JobManager at
>org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl. at
>org.apache.flink.runtime.dispatcher.DefaultJobManagerRunnerFactory.createJobManagerRunner(DefaultJobManagerRunnerFactory.java:84)
> at
>org.apache.flink.runtime.dispatcher.Dispatcher.lambda$createJobManagerRunner$6(Dispatcher.java:379)
> at
>org.apache.flink.util.function.CheckedSupplier.lambda$unchecked$0(CheckedSupplier.java:34)
&
