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

2023-09-26 Thread Антон
Hi, I wrote to hbase using map extending RichMapFunction. I initialized the connection in overrided open method and wrote to hbase in overrided map method. 22.09.2023, 05:01, "碳酸君" :hi community: I'm trying to write some data to hbase in a stream job ,withflink-connector-hbase-2.2 . I have

Re: debezium/flink-oracle-cdc-connector large memory consumption for transactions

2023-03-03 Thread Антон
Hello,Try Infinispan - https://debezium.io/documentation/reference/stable/connectors/oracle.html#oracle-event-buffering15:12, 3 марта 2023 г., Alexandr Dmitrov :Hello! Maybe you could help with debezium/vervica connectors in optimizing memory consumption for large changes in a single transaction

Re: Deserialize avro message without reader schema.

2022-10-10 Thread Антон
Hi,What you mean by holding the schema? You don't have to hold it as schema registry does it for you.20:00, 10 октября 2022 г., Sucheth S :Hi,I'm trying to deserialize avro messages from the kafka topic as a consumer. As a kafka consumer, I do not want to hold the reader schema on my end.Is there

Illegal reflective access by org.apache.flink.api.java.ClosureCleaner

2022-02-10 Thread Антон
Hello, what could be the reason for warning like this:WARNING: An illegal reflective access operation has occurredWARNING: Illegal reflective access by org.apache.flink.api.java.ClosureCleaner (file:/var/flink/flink-1.13.2/lib/flink-dist_2.12-1.13.2.jar) to field java.lang.String.valueWARNING: