Re: Got NoClassDefFoundError on Flink native K8S cluster

ss, org/apache/flink/runtime/util/HadoopUtils, have > different Class objects for the type org/apache/hadoop/conf/Configuration > used in the signature at > org.apache.iceberg.flink.FlinkCatalogFactory.clusterHadoopConf(FlinkCatalogFactory.java:152) > > > > > > On 2021/08/21 08:11:33, Manong

Re: Got NoClassDefFoundError on Flink native K8S cluster

Iceberg v0.11 or v0.12 not capable with flink v1.13.x. L. C. Hsieh 于2021年8月21日周六 下午3:52写道： > Hi, I'm testing using Flink to write Iceberg table. I run Flink native K8S > cluster locally and submit a simple Java program that writes out Iceberg > table (https://github.com/spancer/flink-iceberg-dem

Re: Flink k8 HA mode + checkpoint management

Can You please share your configs? I'm using native kubernetes without HA and there's no issues. I'm curious how this happens. AFAIK jobid is generated randomly. Harsh Shah 于2021年8月4日周三 上午2:44写道： > Hello, > > I am trying to use Flink HA mode inside kubernetes >

Need help when using kubernetes.jobmanager.annotations

Hi Team, I have set the "kubernetes.jobmanager.annotations". But I can't find these in the k8s deployment. As these can be found in the job manager pod. Is it by design or just be missed?