Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart

Hi Erik, Are your suggesting all options together ? Which of version of flink has this solved ? I am currently using 1.5.5 . -Thanks Sohi -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: BucketingSink - Could not invoke truncate while recovering from state

Any help ? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: StandAlone job on k8s fails with "Unknown method truncate" on restore

Any one ? I am sure there are hadoop 2.6 integrations with 1.7.1 OR I am overlooking something... On Fri, Feb 15, 2019 at 2:44 PM Vishal Santoshi wrote: > Not sure, but it seems this > https://issues.apache.org/jira/browse/FLINK-10203 may be a connected > issue. > > On Fri, Feb 15, 2019 at

flink sink es

flink sink es exception，也暂时没有思路。2019-02-23 19:46:34.460 +0800 [Source: order_label_map -> Flat Map -> Map (1/1)] WARN [com.imdada.parse.OrderLabelParse] [AbstractParseModel.scala:20] - fail parse json

flink sink es

阿里大神，这问题无思路了。偶先。暂时不清楚会不会丢数据。从falcon对es的监控来看，es正常。2019-02-23 19:46:30.965 +0800 [Source: jd_mall_order -> Flat Map -> (Sink: Unnamed, Sink: Unnamed) (1/1)] WARN [com.imdada.parse.PublishTimeParse] [AbstractParseModel.scala:20] - fail parse json