Rascal Wu created FLINK-36790:
-
Summary: Flink CDC to Paimon: DeletionVectorsMaintainer CME problem
Key: FLINK-36790
URL: https://issues.apache.org/jira/browse/FLINK-36790
Project: Flink
Issue
Hi,
May I consult one question about why there is no limit size of
`producerPool` in KafkaWriter. It seems that the current logical will
create a new producer during create KafkaWriter and start
checkpoint(snapshotState been invoked) if the producer pool is empty, and
then add the producer into po
Rascal Wu created FLINK-31198:
-
Summary: Class loader problem by incorrect classloader in flink
sql 1.16
Key: FLINK-31198
URL: https://issues.apache.org/jira/browse/FLINK-31198
Project: Flink
ache.org / user...@flink.apache.org (
> https://flink.apache.org/community.html#mailing-lists). This dev mailing
> list is mainly for development related discussions.
>
>
> Best,
> Lincoln Lee
>
>
> Rascal Wu 于2022年8月11日周四 13:18写道：
>
> > Thanks Lincoln a lot for your
condary index), only the
> 'id' column (rowkey in HBase) can be the index-lookup condition
>
> -- Customers is backed by the JDBC connector and can be used for
> lookup joinsCREATE TEMPORARY TABLE Customers ( id INT, name STRING,
> country STRING, zip STRING,
> PRIMAR
Hi here,
Sorry for digging up this old email.
May I consult one question about what's the final behavior we expected
after we enabled retryable mechanism. I viewed the FLIP-232 & FLIP-234, but
I didn't get a clear answer as lacking of some knowledge.
Let me take a example there, let's assume we
