Flink v1.12.2 Kubernetes Session Mode cannot mount log4j.properties in configMap

2021-06-19 Thread Chenyu Zheng
Hi contributors! I’m trying to setup Flink v1.12.2 in Kubernetes Session Mode, but I found that I cannot mount log4j.properties in configmap to the jobmanager container. Is this a expected behavior? Could you share me some ways to mount log4j.properties to my container? My yaml： apiVersion: v1

unsubscribe

2021-06-19 Thread SANDEEP PUNIYA

Re: Advancing watermark with low-traffic Kafka partitions

2021-06-19 Thread Aeden Jameson
One way to deal with this is by using the source idleness setting. https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/event-time/generating_watermarks/#dealing-with-idle-sources On Sat, Jun 19, 2021 at 12:06 PM Dan Hill wrote: > Hi. > > I remember listening to Flink For

Advancing watermark with low-traffic Kafka partitions

2021-06-19 Thread Dan Hill
Hi. I remember listening to Flink Forward talks about strategies for handling low-traffic Kafka partitions. One of the talks showed a technique for sending events to advance the watermarks through most levels of the event flow (Kafka source through the sinks). One of the talks mentioned there we

unsubscribe

2021-06-19 Thread 林俊良