Re: Storing offsets in Kafka

2020-01-13 Thread Marvin777
Hi jiangjie, Yeah I am using the second case. (Flink 1.7.1, Kafka 0.10.2, FlinkKafkaConsumer010) But now there is a problem, the data is consumed normally, but the commit offset is not continued. The following exception is found: [image: image.png] Becket Qin 于2019年9月5日周四 上午11:32写道: > Hi Do

[1.4.2] mvn clean package command takes to much time

2018-06-06 Thread Marvin777
Hi, all. It takes a long time to modify some of the code and recompile it. The process is painful. Is there any method that I can save time. Thanks!

Re: [1.4.2] mvn clean package command takes to much time

2018-06-06 Thread Marvin777
nay Schepler 于2018年6月6日周三 下午4:29写道: > you only have to compile the module that you changed along with > flink-dist to test things locally. > > On 06.06.2018 10:27, Marvin777 wrote: > > Hi, all. > > It takes a long time to modify some of the code and recompile it. The >

Re: [1.4.2] mvn clean package command takes to much time

2018-06-07 Thread Marvin777
> > Thanks for the help! >

Re: [DISCUSS] Adding new interfaces in [Stream]ExecutionEnvironment

2018-06-25 Thread Marvin777
Hi, Shuyi: What is the progress of the discussion? We also look forward to this feature. Thanks. Shuyi Chen 于2018年6月8日周五 下午3:04写道: > Thanks a lot for the comments, Till and Fabian. > > The RemoteEnvrionment does provide a way to specify jar files at > construction, but we want the jar files to

Re: Remove the HDFS directory in org.apache.flink.util.FileUtils.deletePathIfEmpty

2017-11-08 Thread Marvin777
That has been solved, Because of the hadoop version issue. Thanks. 2017-11-08 17:54 GMT+08:00 Chesnay Schepler : > For me they showed in user mailing list, but not in dev. (or maybe the > reverse, not quite sure...) > > On 08.11.2017 10:47, Aljoscha Krettek wrote: > >> Hi, >> >> You images did no

Re: [jira] [Created] (FLINK-7608) LatencyGauge change to histogram metric

2018-01-02 Thread Marvin777
Hi, all: I have some question about LatencyGauge change to histogram metric. Whether such a scheme is feasible? I want to know the latest progress on the question of FLINK-7608. @zentol, you suggested that we should delay merging this PR by a week or 2, and now What should I do in my version 1.3

Re: [jira] [Created] (FLINK-7608) LatencyGauge change to histogram metric

2018-01-09 Thread Marvin777
I had an offline discussion with @zentol, he said: "I hope to get this change in for 1.5; the core implementation is done but some details must be ironed out first.". Best. 2018-01-03 11:25 GMT+08:00 Marvin777 : > Hi, all: > > I have some question about LatencyGauge change