Unsubscribe from user list.

Hi team, Could you please remove this email from the subscription list? I have another email (juliehou...@gmail.com) subscribed as well. I can use that email to receive flink emails. Thank you! Best, Lijuan

Impact of BoundedOutOfOrderness on KeyedProcessFunction

Hi team, I have one question, hoping to get some help. Will BoundedOutOfOrderness have any impact on the KeyedProcessFunction? If so, in what way it can impact KeyedProcessFunction? Thanks! Best, Lijuan

Upgrading Flink to 1.17, facing org.apache.flink.util.FlinkException: Global failure triggered by OperatorCoordinator

Hi team, I am upgrading our flink version from 1.16 to 1.17.1, and currently facing this issue, can I get some help? What shall I do for this? Thanks! org.apache.flink.util.FlinkException: Global failure triggered by OperatorCoordinator for 'Source: Customer Product Summary Selected'

Reading parquet files using Flink

Hi team, Is there any defined way to read Parquet files for flink 1.17.1? I did some search, and found this

Flink job reading from s3 path

Hi team, I want to implement a flink job to read avro files from s3 path, and output to a kafka topic. Currently, I am using AvroInputFormat like this: AvroInputFormat avroInputFormat = new AvroInputFormat<>(new Path(S3PathString), Session.class); TypeInformation typeInfo =

Questions related to Autoscaler

Hi Ron, Thanks for the reply! > 1 - It seems for flink job using flink operator to realize autoscaling, the > only option to realize autoscaling is to enable the Autoscaler feature, and > KEDA won’t work, right? What is KEDA mean? -> KEDA is a Kubernetes based Event Driven Autoscaler. I

Questions related to Autoscaler

Hi Flink team, This is Lijuan. I am working on our flink job to realize autoscaling. We are currently using flink version of 1.16.1, and using flink operator version of 1.5.0. I have some questions need to confirm with you. 1 - It seems for flink job using flink operator to realize