Is there any example that use hbase connector in stream API

2023-09-21 Thread
hi community: I'm trying to write some data to hbase in a stream job ,with flink-connector-hbase-2.2 . I have no idea about instantiate org.apache.flink.connector.hbase.util.HBaseTableSchema and org.apache.flink.connector.hbase.sink.HBaseMutationConverter . Regards, Teii

Re: Is there any example that use hbase connector in stream API

2023-09-26 Thread
n overrided map > method. > > 22.09.2023, 05:01, "碳酸君" : > > hi community: > > I'm trying to write some data to hbase in a stream job ,with > flink-connector-hbase-2.2 . > I have no idea about instantiate >

Yarn application mode cancel issure

2024-01-11 Thread
Hi community: I'm working on a flink cluster on YARN application mode,which is authenticated by Kuberos. It works well on flink run and flink list command as follows : ./bin/flink run-application -t yarn-application > ./examples/streaming/TopSpeedWindowing.jar > ./bin/flink list -t yarn-applicati