[jira] [Created] (FLINK-9771) "Show Plan" option under Submit New Job in WebUI not working

2018-07-05 Thread Yazdan Shirvany (JIRA)
Yazdan Shirvany created FLINK-9771: -- Summary: "Show Plan" option under Submit New Job in WebUI not working Key: FLINK-9771 URL: https://issues.apache.org/jira/browse/FLINK-9771 Project: Flink

Re: [CANCEL][VOTE] Release 1.5.1, release candidate #1

2018-07-05 Thread Chesnay Schepler
I've identified 2 issues related to the WebUI job submission and opened a PR for each of them: FLINK-9770: https://github.com/apache/flink/pull/6269 FLINK-9769: https://github.com/apache/flink/pull/6270 On 05.07.2018 22:13, Chesnay Schepler wrote: Note that this issue is isolated to the WebUI

[jira] [Created] (FLINK-9770) UI jar list broken

2018-07-05 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9770: --- Summary: UI jar list broken Key: FLINK-9770 URL: https://issues.apache.org/jira/browse/FLINK-9770 Project: Flink Issue Type: Bug Components:

Re: [CANCEL][VOTE] Release 1.5.1, release candidate #1

2018-07-05 Thread Chesnay Schepler
Note that this issue is isolated to the WebUI job submission, so feel free to do other release testing in the meantime. On 05.07.2018 22:13, Chesnay Schepler wrote: I'm canceling the RC due to https://issues.apache.org/jira/browse/FLINK-9769. On 05.07.2018 21:58, Chesnay Schepler wrote: I

[CANCEL][VOTE] Release 1.5.1, release candidate #1

2018-07-05 Thread Chesnay Schepler
I'm canceling the RC due to https://issues.apache.org/jira/browse/FLINK-9769. On 05.07.2018 21:58, Chesnay Schepler wrote: I could reproduce the issue, investigating. On 05.07.2018 20:55, Yaz Sh wrote: [-1] I did follow validation release candidate guide line and when I tested the examples

[jira] [Created] (FLINK-9769) Job submission via WebUI broken

2018-07-05 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9769: --- Summary: Job submission via WebUI broken Key: FLINK-9769 URL: https://issues.apache.org/jira/browse/FLINK-9769 Project: Flink Issue Type: Bug

Re: [VOTE] Release 1.5.1, release candidate #1

2018-07-05 Thread Chesnay Schepler
I could reproduce the issue, investigating. On 05.07.2018 20:55, Yaz Sh wrote: [-1] I did follow validation release candidate guide line and when I tested the examples via web UI, I got some errors. here are the steps to reproduce the error. - Ran the cluster mode (./bin/start-cluster.sh) -

Re: [VOTE] Release 1.5.1, release candidate #1

2018-07-05 Thread Yaz Sh
[-1] I did follow validation release candidate guide line and when I tested the examples via web UI, I got some errors. here are the steps to reproduce the error. - Ran the cluster mode (./bin/start-cluster.sh) - Upload the WordCount.jar Example via web UI (I retry this with other examples

[jira] [Created] (FLINK-9768) Only build flink-dist for binary releases

2018-07-05 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9768: --- Summary: Only build flink-dist for binary releases Key: FLINK-9768 URL: https://issues.apache.org/jira/browse/FLINK-9768 Project: Flink Issue Type:

[VOTE] Release 1.5.1, release candidate #1

2018-07-05 Thread Chesnay Schepler
Hi everyone, Please review and vote on the release candidate #1 for the version 1.5.1, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes

[jira] [Created] (FLINK-9767) Add instructions to generate tag to release guide

2018-07-05 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9767: --- Summary: Add instructions to generate tag to release guide Key: FLINK-9767 URL: https://issues.apache.org/jira/browse/FLINK-9767 Project: Flink Issue

Re: [PROPOSAL] Introduce Elastic Bloom Filter For Flink

2018-07-05 Thread sihua zhou
Hi Stephan, Thank you very much for the reply and very happy for that! I'm not sure whether I understood your idea correctly. Does it means 1) we should add a new operator with the feature of Elastic Bloom Filter? or 2) we could support it as the current (version <= 1.5)

Re: Flink Kafka TimeoutException

2018-07-05 Thread Ted Yu
Have you tried increasing the request.timeout.ms parameter (Kafka) ? Which Flink / Kafka release are you using ? Cheers On Thu, Jul 5, 2018 at 5:39 AM Amol S - iProgrammer wrote: > Hello, > > I am using flink with kafka and getting below exception. > >

Re: Flink job failed with exception

2018-07-05 Thread Amol S - iProgrammer
sorry above logs are not complete. you can find complete logs in this mail. Error while emitting latency marker. java.lang.RuntimeException: Buffer pool is destroyed. at org.apache.flink.streaming.runtime.io.RecordWriterOutput.emitLatencyMarker(RecordWriterOutput.java:147)

Flink job failed with exception

2018-07-05 Thread Amol S - iProgrammer
My flink job is failed with below exception java.lang.RuntimeException: Buffer pool is destroyed. at org.apache.flink.streaming.runtime.io.RecordWriterOutput.emitLatencyMarker(RecordWriterOutput.java:147) ~[flink-streaming-java_2.11-1.5.0.jar:1.5.0] at

[jira] [Created] (FLINK-9766) Incomplete/incorrect cleanup in RemoteInputChannelTest

2018-07-05 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9766: -- Summary: Incomplete/incorrect cleanup in RemoteInputChannelTest Key: FLINK-9766 URL: https://issues.apache.org/jira/browse/FLINK-9766 Project: Flink Issue Type:

Re: Facing issue in RichSinkFunction

2018-07-05 Thread Ken Krugler
Hi Amol, > On Jul 5, 2018, at 2:23 AM, Amol S - iProgrammer > wrote: > > Hello folks, > > I am trying to write my streaming result into mongodb using > RIchSinkFunction as below. > > gonogoCustomerApplicationStream.addSink(mongoSink) > > where mongoSink is Autowired i.e. injected object and

Flink Kafka TimeoutException

2018-07-05 Thread Amol S - iProgrammer
Hello, I am using flink with kafka and getting below exception. org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for helloworld.t-7: 30525 ms has passed since last append --- *Amol Suryawanshi* Java Developer am...@iprogrammer.com

[jira] [Created] (FLINK-9765) Improve CLI responsiveness when cluster is not reachable

2018-07-05 Thread Timo Walther (JIRA)
Timo Walther created FLINK-9765: --- Summary: Improve CLI responsiveness when cluster is not reachable Key: FLINK-9765 URL: https://issues.apache.org/jira/browse/FLINK-9765 Project: Flink Issue

[jira] [Created] (FLINK-9764) Failure in LocalRecoveryRocksDBFullITCase

2018-07-05 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9764: -- Summary: Failure in LocalRecoveryRocksDBFullITCase Key: FLINK-9764 URL: https://issues.apache.org/jira/browse/FLINK-9764 Project: Flink Issue Type: Bug

Re: Facing issue in RichSinkFunction

2018-07-05 Thread Hequn Cheng
Hi Amol, The implementation of the RichSinkFunction probably contains a field that is not serializable. To avoid serializable exception, you can: 1. Marking the field as transient. This makes the serialization mechanism skip the field. 2. If the field is part of the object's persistent state, the

[jira] [Created] (FLINK-9763) Flink SQL Client bat script

2018-07-05 Thread Pavel Shvetsov (JIRA)
Pavel Shvetsov created FLINK-9763: - Summary: Flink SQL Client bat script Key: FLINK-9763 URL: https://issues.apache.org/jira/browse/FLINK-9763 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9762) CoreOptions.TMP_DIRS wrongly managed on Yarn

2018-07-05 Thread Oleksandr Nitavskyi (JIRA)
Oleksandr Nitavskyi created FLINK-9762: -- Summary: CoreOptions.TMP_DIRS wrongly managed on Yarn Key: FLINK-9762 URL: https://issues.apache.org/jira/browse/FLINK-9762 Project: Flink Issue

Re: 回复:[DISCUSS] Release Flink 1.5.1

2018-07-05 Thread Nico Kruber
I forgot to mention: there are some follow-ups on this but the gravity is not as high as the deadlock of FLINK-9676 and PRs are not quite ready yet ... https://issues.apache.org/jira/browse/FLINK-9755 https://issues.apache.org/jira/browse/FLINK-9756

[jira] [Created] (FLINK-9761) Potential buffer leak in PartitionRequestClientHandler during job failures

2018-07-05 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9761: -- Summary: Potential buffer leak in PartitionRequestClientHandler during job failures Key: FLINK-9761 URL: https://issues.apache.org/jira/browse/FLINK-9761 Project: Flink

Re: 回复:[DISCUSS] Release Flink 1.5.1

2018-07-05 Thread Chesnay Schepler
Alright then, I'll start building the artifacts. On 05.07.2018 12:24, Nico Kruber wrote: FYI: I just merged this to master as well as release-1.5 (hopefully - this is my first merge since I became a committer) On 05/07/18 10:22, Zhijiang(wangzhijiang999) wrote: I have reviewed FLINK-9676,

Re: 回复:[DISCUSS] Release Flink 1.5.1

2018-07-05 Thread Nico Kruber
FYI: I just merged this to master as well as release-1.5 (hopefully - this is my first merge since I became a committer) On 05/07/18 10:22, Zhijiang(wangzhijiang999) wrote: > I have reviewed FLINK-9676, wish it merged soon. > > Zhijiang >

[jira] [Created] (FLINK-9760) Return a single element from extractPatterns

2018-07-05 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-9760: --- Summary: Return a single element from extractPatterns Key: FLINK-9760 URL: https://issues.apache.org/jira/browse/FLINK-9760 Project: Flink Issue Type:

Facing issue in RichSinkFunction

2018-07-05 Thread Amol S - iProgrammer
Hello folks, I am trying to write my streaming result into mongodb using RIchSinkFunction as below. gonogoCustomerApplicationStream.addSink(mongoSink) where mongoSink is Autowired i.e. injected object and it is giving me below error. The implementation of the RichSinkFunction is not

[jira] [Created] (FLINK-9759) give an irrelevant answer about the savepoint restore when stateless operators be added etc

2018-07-05 Thread lamber-ken (JIRA)
lamber-ken created FLINK-9759: - Summary: give an irrelevant answer about the savepoint restore when stateless operators be added etc Key: FLINK-9759 URL: https://issues.apache.org/jira/browse/FLINK-9759

回复:[DISCUSS] Release Flink 1.5.1

2018-07-05 Thread Zhijiang(wangzhijiang999)
I have reviewed FLINK-9676, wish it merged soon. Zhijiang -- 发件人:Chesnay Schepler 发送时间:2018年7月5日(星期四) 15:58 收件人:dev@flink.apache.org ; wangzhijiang999 ; zjffdu ; Till Rohrmann 主 题:Re: [DISCUSS] Release Flink 1.5.1 Building the

Re: [DISCUSS] Release Flink 1.5.1

2018-07-05 Thread Chesnay Schepler
Building the binary releases overnight failed due to a configuration mistake on my side. Till has informed me that FLINK-9676 might occur more often than we initially suspected. A PR to address the issue was already opened by Nico. Given that I have to restart the process anyway today I'm