Re: Regarding increasing Parallelism of the keyby and window function while migrating

Hi Pedro, I tried using disabling changing but it is not working Providing code snippets for better understanding ``` Datastream> discrepancy= db2input.keyBy((Key selector) .coGroup(kafkaInput) .where(key) .equalTo(key)

Re: Regarding increasing Parallelism of the keyby and window function while migrating

Hi all, Following up on request Thanks On Mon, 26 May 2025, 15:18 Sambhav Gupta, wrote: > Hey, > > There is no error with the parallelism .I want to increase it for this > function as it is creating a bottleneck for the disk space which I am not > able to do. > > I tried using setParallelism()

Re: Regarding increasing Parallelism of the keyby and window function while migrating

Hello there Sambhav! > I tried using setParallelism() here but I think it doesn't comply with flink schema and is using default parallelism instead So are you disabling chaining to set a

Help - Unable to read Key from Kafka messages in Flink SQL Client

Hello, I am new to Flink. Running into an issue to read Key from Kafka messages in Flink SQL Client. I have an Order Kafka topic with below messages: Key: {"orderNumber":"1234"} Value: {"orderDate":"20250528","productId":"Product123"}

Unsubscribe.

-Luyi.

Re: Help - Unable to read Key from Kafka messages in Flink SQL Client

fka messages > in Flink SQL Client. > > I have an Order Kafka topic with below messages: > > Key: {"orderNumber":"1234"} > Value: {"orderDate":"20250528","productId":"Product123"} > > I am able to get the key and va

Re: Kafka Sink Timestamp Behavior Change From 1.14.0 to 1.20.1

Any advice for this problem? Thanks. ---Original--- From: "guoliubin85"