Re: Native K8S not creating TMs

2020-06-05 Thread kb
Thanks Yang for the suggestion, I have tried it and I'm still getting the same exception. Is it possible its due to the null pod name? Operation: [create] for kind: [Pod] with name: [null] in namespace: [default] failed. Best, kevin -- Sent from: http://apache-flink-user-mailing-list-archiv

Re: Native K8S not creating TMs

2020-06-04 Thread kb
Thanks! I do not see any pods of the form `flink-taskmanager-1-1`, so I tried the exec suggestion. The logs are attached below. Is there a quick RBAC check I could perform? I followed the command on the docs page linked (kubectl create clusterrolebinding flink-role-binding-default --clusterrole=ed

Native K8S not creating TMs

2020-06-03 Thread kb
Hi We are using 1.10.1 with native k8s and while the service appears to be created and I can submit a job & see it via Web UI, TMs/pods are never created thus the jobs never start. org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not allocate the required slot wit

Re: Details of the downsides of “falling back” to Kyro rather than using Flink’s built in serde

2019-04-09 Thread kb
Hi Konstantin, Thank you! This is exactly what I was looking for. Thanks Kevin -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Details of the downsides of “falling back” to Kyro rather than using Flink’s built in serde

2019-04-09 Thread kb
avoid “falling back” to Kyro. Are the specific downsides listed anywhere? Thanks kb -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: StreamingFileSink on EMR

2019-02-26 Thread kb
Thanks! This fixed it. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: StreamingFileSink on EMR

2019-02-26 Thread kb
Hi, So 1.7.2 jar has the fix? Thanks Kevin -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: StreamingFileSink on EMR

2019-02-26 Thread kb
Hi Bruno, Thanks for verifying. We are aiming for the same. Best, Kevin -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: StreamingFileSink on EMR

2019-02-26 Thread kb
Hi Till, The only potential issue in the path I see is `/usr/share/aws/emr/emrfs/lib/emrfs-hadoop-assembly-2.29.0.jar`. I double checked my pom, the project is Hadoop-free. The JM log also shows `INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Hadoop version: 2.8.5-amzn-1`.