adding core-site xml to flink1.11

2020-10-24 Thread Shachar Carmeli
Hi, I'm trying to define filesystem to flink 1.11 using core-site.xml I tried adding in the flink-conf.yaml env.hadoop.conf.dir and I see it is added to the classpath also adding environment variable HADOOP_CONF_DIR didn't help The flink 1.11.2 is running on docker using kubernetes I added hado

Re: pull access denied for flink-statefun

2020-10-24 Thread Lian Jiang
It worked by replacing FROM flink-statefun:2.3-SNAPSHOT with FROM ververica/flink-statefun:2.2.0 Thanks! On Sat, Oct 24, 2020 at 8:13 PM Lian Jiang wrote: > Hi, > > I am following https://github.com/apache/flink-statefun#build to build > the greeter example but got below error. I have logge

Could you add some example about this document? Thanks`1

2020-10-24 Thread ??????
Dear Mr  Timo Walther: I'm learing  document  and have send 3 mails about executeinsert/flataggregate/GroupBy Window Aggregation from the document   to  user@flink.apache.org each of which is provided with full code,but no replies. I found the authors of above 3 parts are NOT in the mailing li

pull access denied for flink-statefun

2020-10-24 Thread Lian Jiang
Hi, I am following https://github.com/apache/flink-statefun#build to build the greeter example but got below error. I have logged in docker hub. Any idea? Thanks. $ docker-compose build zookeeper uses an image, skipping kafka-broker uses an image, skipping Building master Step 1/3 : FROM flink-st