Fwd: Flink Python API and HADOO_CLASSPATH

2021-05-17 Thread Eduard Tudenhoefner
Hello, I was wondering whether anyone has tried and/or had any luck creating a custom catalog with Iceberg + Flink via the Python API ( https://iceberg.apache.org/flink/#custom-catalog)? When doing so, the docs mention that dependencies need to be specified via *pipeline.jars* / *pipeline.classpa

Re: Flink Python API and HADOO_CLASSPATH

2021-05-18 Thread Eduard Tudenhoefner
r > this. > > 3) How to support HADOOP_CLASSPATH in remote mode (e.g. submitted via > `flink run`) > You could export HADOOP_CLASSPATH=`hadoop classpath` manually before > executing `flink run`. > > Regards, > Dian > > 2021年5月17日 下午8:45,Eduard Tudenhoefner 写道: > &g