Re: Flink K8S operator does not support IPv6

2023-08-07 Thread Xiaolong Wang
Ok, thank you. On Tue, Aug 8, 2023 at 11:22 AM Peter Huang wrote: > We will handle it asap. Please check the status of this jira > https://issues.apache.org/jira/browse/FLINK-32777 > > On Mon, Aug 7, 2023 at 8:08 PM Xiaolong Wang > wrote: > >> Hi, >> >> I was testing flink-kubernetes-operator i

Re: Flink K8S operator does not support IPv6

2023-08-07 Thread Peter Huang
We will handle it asap. Please check the status of this jira https://issues.apache.org/jira/browse/FLINK-32777 On Mon, Aug 7, 2023 at 8:08 PM Xiaolong Wang wrote: > Hi, > > I was testing flink-kubernetes-operator in an IPv6 cluster and found out > the below issues: > > *Caused by: javax.net.ssl.

Flink K8S operator does not support IPv6

2023-08-07 Thread Xiaolong Wang
Hi, I was testing flink-kubernetes-operator in an IPv6 cluster and found out the below issues: *Caused by: javax.net.ssl.SSLPeerUnverifiedException: Hostname > fd70:e66a:970d::1 not verified:* > > *certificate: sha256/EmX0EhNn75iJO353Pi+1rClwZyVLe55HN3l5goaneKQ=* > > *DN: CN=kube-apiserve

Easiest way to do a batch outer join

2023-08-07 Thread Flavio Pompermaier
Hello everybody, I have a use case where I need to exclude from a DataStream (that is technically a DataSet since I work in batch mode) all already-indexed documents. My idea is to perfrom an outer join but I didn't find any simple example on DataStream working on batch mode..I've tried using coGro

Can issues with Kafka consumption influence the watermark?

2023-08-07 Thread Piotr Domagalski
Hi! We have a rather simple Flink job which has the main purpose is concatenating events read from Kafka and outputting them in session windows with a gap of 1 minute, 1 minute out of order and 1h idleness setting: [image: Screenshot 2023-08-07 at 13.44.09.png] The problem we are facing is that we