Unsubscribe

2023-07-25 Thread Lu Weizheng
Unsubscribe

Kafka Exception

2023-07-25 Thread Kenan Kılıçtepe
Any help is appreciated about the exception below. Also my Kafkasource code is below. The parallelism is 16 for this task. KafkaSource sourceStationsPeriodic = KafkaSource.< String>builder() .setBootstrapServers(parameter.get( KAFKA_SOURCE_STATIONS_B

Task manager creation in Flink native Kubernetes (application mode)

2023-07-25 Thread Alexis Sarda-Espinosa
Hi everyone, >From its inception (at least AFAIK), application mode for native Kubernetes has always created "unmanaged" pods for task managers. I would like to know if there are any specific benefits to this, or if on the other hand there are specific reasons not to use Kubernetes Deployments ins

RE: TCP server socket with Kubernetes Cluster

2023-07-25 Thread Kamal Mittal via user
Hello Community, Please share views for below mail or let me know if any more details needed? Rgds, Kamal From: Kamal Mittal Sent: 24 July 2023 07:55 AM To: Kamal Mittal ; user@flink.apache.org Subject: RE: TCP server socket with Kubernetes Cluster Hello Community, Please share views for belo