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
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
>
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