Re: Hbase Connector failed when deployed to yarn

2019-04-15 Thread Fabian Hueske
* user; Yun Tang > *Date:* Monday, Apr 15, 2019 17:16 > *Subject:* Re: Hbase Connector failed when deployed to yarn > > Hi, > > The Jira issue is still unassigned. > Would you be up to work on a fix? > > Best, Fabian > > Am Fr., 12. Apr. 2019 um 05:07 Uhr schrieb hai

Re: Hbase Connector failed when deployed to yarn

2019-04-15 Thread Hai
Hi Fabian: OK ,I am glad to do that. Regards Original Message Sender: Fabian Hueske Recipient: hai Cc: user; Yun Tang Date: Monday, Apr 15, 2019 17:16 Subject: Re: Hbase Connector failed when deployed to yarn Hi, The Jira issue is still unassigned. Would you be up to work on a fix

Re: Hbase Connector failed when deployed to yarn

2019-04-15 Thread Fabian Hueske
E/lib is a elegant solution. > > > Regards > > Original Message > *Sender:* Yun Tang > *Recipient:* hai; user > *Date:* Friday, Apr 12, 2019 02:02 > *Subject:* Re: Hbase Connector failed when deployed to yarn > > Hi > > I believe this is the same problem which

Re: Hbase Connector failed when deployed to yarn

2019-04-11 Thread hai
:02 Subject:Re: Hbase Connector failed when deployed to yarn Hi I believe this is the same problem which reported in https://issues.apache.org/jira/browse/FLINK-12163 , current work around solution is to put flink-hadoop-compatibility jar under FLINK_HOME/lib. Best Yun Tang From: hai h

Re: Hbase Connector failed when deployed to yarn

2019-04-11 Thread Yun Tang
To: user Subject: Re: Hbase Connector failed when deployed to yarn And my pom.xml dependencies is : org.scala-lang scala-library ${scala.version} org.scala-lang scala-compiler

Re: Hbase Connector failed when deployed to yarn

2019-04-11 Thread hai
And my pom.xml dependencies is : dependencies !-- Scala -- dependency groupIdorg.scala-lang/groupId artifactIdscala-library/artifactId version${scala.version}/version /dependency dependency groupIdorg.scala-lang/groupId artifactIdscala-compiler/artifa

Hbase Connector failed when deployed to yarn

2019-04-11 Thread hai
Hello: I am new to flink, and I copy the official Hbase connector examples from source flink/flink-connectors/flink-hbase/src/test/java/org/apache/flink/addons/hbase/example/HBaseWriteExample.java and run in a yarn-cluster with the command: bin/flink run -m yarn-cluster -yn 2 -c {class-path-pr