I find kafka consumer can not auto commit, when I test kudu async client
with flink async io today.
- i do not enable checkpoint, and with procress time.
- the consumer strategy that i set in connector is: setStartFromEarliest()
the consumer config printed in console as follow:
auto.commit.interv
hi，everyone:
today, i test Sliding ProcessTime TimeWindow with print some merties. i
find a same sliding window be printed twice, as fllower:
now ===> 2018-09-16 15:11:44
start ===> 2018-09-16 15:10:45
end ===> 2018-09-16 15:11:45
max ===> 2018-09-16 15:11:44
TimeWindow{start=1537081845000,
-- Forwarded message -
From: 远远
Date: 2018年9月16日周日 下午4:08
Subject: Re: why same Sliding ProcessTime TimeWindow triggered twice
To:
hi, the flink version that i test is 1.4.2, and i just run test code with
local env in IDEA, and all the setting in the test code.
my os is deepin
+1， it‘s time to drop it😂
Zhijiang(wangzhijiang999) 于2018年9月29日周六
下午1:53写道：
> Very agree with to drop it. +1
>
> --
> 发件人：Jeff Carter
> 发送时间：2018年9月29日(星期六) 10:18
> 收件人：dev
> 抄 送：chesnay ; Till Rohrmann ;
> user
> 主 题：Re: [DISCUS
invoke FlinkKafkaProducer011 constructor in scala:
val producer = new
FlinkKafkaProducer011[PVEvent.Entity](appConf.getPvEventTopic, new
PvEventSerializeSchema,
producerProps, Optional.of(FlinkRebalancePartitioner[PVEvent.Entity]))
and the constructor is :
/**
* Creates a FlinkKafkaProducer
IDEA only show "cannot resolve constructor" error message, without other
error message.
Dawid Wysakowicz 于2018年10月10日周三 下午5:55写道：
> Hi,
>
> what is the exact error message you are getting?
>
> Best,
>
> Dawid
>
> On 10/10/18 11:51, 远远 wrote:
>
> invoke
hi，
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/cancel-with-savepoint-404-Not-Found-td19227.html
it may help you.
and for flink on yarn cancel job , "yarn-cancel" work well not "cancel"
the below python code for trigging savepoint work well.
json = {"cancel-job": False}
r =
the flink app ruuning on flink1.5.4 on yarn, it should be triggered every 5
min...
[image: image.png]
