简单示例：
public class TableA implements LookupTableSource {
@Nullable
private final LookupCache cache;
public TableA(@Nullable LookupCache cache) {
this.cache = cache;
}
@Override
public LookupRuntimeProvider
getLookupRuntimeProvider(LookupContext context) {
e/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 Karl wrote:
> > > Ic
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
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
>
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?
