[jira] [Created] (FLINK-7689) Instrument the Flink JDBC connector

2017-09-25 Thread Martin Eden (JIRA)
Martin Eden created FLINK-7689: -- Summary: Instrument the Flink JDBC connector Key: FLINK-7689 URL: https://issues.apache.org/jira/browse/FLINK-7689 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7688) ContaineredTaskManagerParameters sets off heap memory size incorrectly unlimited

2017-09-25 Thread Bill Liu (JIRA)
Bill Liu created FLINK-7688: --- Summary: ContaineredTaskManagerParameters sets off heap memory size incorrectly unlimited Key: FLINK-7688 URL: https://issues.apache.org/jira/browse/FLINK-7688 Project: Flink

Re: Elasticsearch connector

2017-09-25 Thread Premkumar, Ramprabhu
Hi, Receiving this exception with the 1.3.2 dependencies for elastic search connector. java.lang.NoSuchMethodError: org.elasticsearch.action.bulk.BulkProcessor.add(Lorg/elasticsearch/action/ActionRequest;)Lorg/elasticsearch/action/bulk/BulkProcessor; at org.apache.flink.streaming.connectors.elast

[jira] [Created] (FLINK-7687) Clarify the master and slaves files are not necessary unless using the cluster start/stop scripts

2017-09-25 Thread Elias Levy (JIRA)
Elias Levy created FLINK-7687: - Summary: Clarify the master and slaves files are not necessary unless using the cluster start/stop scripts Key: FLINK-7687 URL: https://issues.apache.org/jira/browse/FLINK-7687

[jira] [Created] (FLINK-7686) Add Flink Forward Berlin 2017 conference slides to the flink website

2017-09-25 Thread Hai Zhou_UTC+8 (JIRA)
Hai Zhou_UTC+8 created FLINK-7686: - Summary: Add Flink Forward Berlin 2017 conference slides to the flink website Key: FLINK-7686 URL: https://issues.apache.org/jira/browse/FLINK-7686 Project: Flink

Re: Zookeeper failure handling

2017-09-25 Thread Gyula Fóra
Curator seems to auto reconnect anyways, the problem might be that there is a new leader elected before the old JM could reconnect. We will try to experiment with this tomorrow to see if increasing the timeouts do any good. Gyula Gyula Fóra ezt írta (időpont: 2017. szept. 25., H, 15:39): > I wi

[jira] [Created] (FLINK-7685) CompilerException: "Bug: Logic for branching plans (non-tree plans) has an error, and does not track the re-joining of branches correctly"

2017-09-25 Thread Gabor Gevay (JIRA)
Gabor Gevay created FLINK-7685: -- Summary: CompilerException: "Bug: Logic for branching plans (non-tree plans) has an error, and does not track the re-joining of branches correctly" Key: FLINK-7685 URL: https://issue

[jira] [Created] (FLINK-7684) Avoid multiple data copies in MergingWindowSet

2017-09-25 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-7684: - Summary: Avoid multiple data copies in MergingWindowSet Key: FLINK-7684 URL: https://issues.apache.org/jira/browse/FLINK-7684 Project: Flink Issue Type: Ne

[jira] [Created] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

2017-09-25 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-7683: - Summary: Add method to iterate over all of the existing keys in a statebackend Key: FLINK-7683 URL: https://issues.apache.org/jira/browse/FLINK-7683 Project: Flink

Re: Zookeeper failure handling

2017-09-25 Thread Gyula Fóra
I will try to check what Stephan suggested and get back to you! Thanks for the feedback Gyula On Mon, Sep 25, 2017, 15:33 Stephan Ewen wrote: > I think the question is whether the connection should be lost in the case > of a rolling ZK update. > > There should always be a quorum online, so Cura

Re: Zookeeper failure handling

2017-09-25 Thread Stephan Ewen
I think the question is whether the connection should be lost in the case of a rolling ZK update. There should always be a quorum online, so Curator should always be able to connect. So there is no need to revoke leadership. @gyula - can you check whether there is an option in Curator to reconnec

Re: Zookeeper failure handling

2017-09-25 Thread Till Rohrmann
Hi Gyula, Flink uses internally the Curator LeaderLatch recipe to do leader election. The LeaderLatch will revoke the leadership of a contender in case of a SUSPENDED or LOST connection to the ZooKeeper quorum. The assumption here is that if you cannot talk to ZooKeeper, then we can no longer be s

[jira] [Created] (FLINK-7682) Invalid state size formatting

2017-09-25 Thread Andrey (JIRA)
Andrey created FLINK-7682: - Summary: Invalid state size formatting Key: FLINK-7682 URL: https://issues.apache.org/jira/browse/FLINK-7682 Project: Flink Issue Type: Bug Affects Versions: 1.3.0

[jira] [Created] (FLINK-7681) Support arbitrary TypeInformation in Table API

2017-09-25 Thread Timo Walther (JIRA)
Timo Walther created FLINK-7681: --- Summary: Support arbitrary TypeInformation in Table API Key: FLINK-7681 URL: https://issues.apache.org/jira/browse/FLINK-7681 Project: Flink Issue Type: Improv