xuyang created FLINK-36968:
--
Summary: The "values" lookup table used for testing does not
deduplicate data with the same key.
Key: FLINK-36968
URL: https://issues.apache.org/jira/browse/FLINK-36968
Project:
Hi devs,
I'd like to push a new FLIP xxx: Kafka Enumerator assigns splits based on
the current assignment situation. Currently, when the Kafka enumerator
finds a new split, it will choose a reader using the following algorithm:
```java
static int getSplitOwner(TopicPartition tp, int numReaders)
Jeff Yang created FLINK-36967:
-
Summary: Bump dependency of Paimon Pipeline connector to 0.9.0
Key: FLINK-36967
URL: https://issues.apache.org/jira/browse/FLINK-36967
Project: Flink
Issue Type: I
Hi Md Aamir,
Apologies for the delayed response due to the festive season. Thank you for
providing the additional details.
The information shared is helpful but still sparse to pinpoint the root
cause of the backpressure issue. To proceed further, it would be great if
you could share the logs fro
Sergey Nuyanzin created FLINK-36966:
---
Summary: Bump mockito to 5.x
Key: FLINK-36966
URL: https://issues.apache.org/jira/browse/FLINK-36966
Project: Flink
Issue Type: Technical Debt
