[jira] [Created] (FLINK-7788) Allow port range for queryable state client proxy.

2017-10-09 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-7788: - Summary: Allow port range for queryable state client proxy. Key: FLINK-7788 URL: https://issues.apache.org/jira/browse/FLINK-7788 Project: Flink Issue Type

[jira] [Created] (FLINK-7787) Remove guava dependency in the cassandra connector

2017-10-09 Thread Haohui Mai (JIRA)
Haohui Mai created FLINK-7787: - Summary: Remove guava dependency in the cassandra connector Key: FLINK-7787 URL: https://issues.apache.org/jira/browse/FLINK-7787 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7786) JarActionHandler.tokenizeArguments removes all quotes from program arguments

2017-10-09 Thread Brice Bingman (JIRA)
Brice Bingman created FLINK-7786: Summary: JarActionHandler.tokenizeArguments removes all quotes from program arguments Key: FLINK-7786 URL: https://issues.apache.org/jira/browse/FLINK-7786 Project: F

[jira] [Created] (FLINK-7785) DispatcherTest failure

2017-10-09 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7785: --- Summary: DispatcherTest failure Key: FLINK-7785 URL: https://issues.apache.org/jira/browse/FLINK-7785 Project: Flink Issue Type: Bug Componen

[jira] [Created] (FLINK-7784) Don't fail TwoPhaseCommitSinkFunction when failing to commit

2017-10-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7784: --- Summary: Don't fail TwoPhaseCommitSinkFunction when failing to commit Key: FLINK-7784 URL: https://issues.apache.org/jira/browse/FLINK-7784 Project: Flink

[jira] [Created] (FLINK-7783) Don't always remove checkpoints ZooKeeperCompletedCheckpointStore#recover()

2017-10-09 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7783: --- Summary: Don't always remove checkpoints ZooKeeperCompletedCheckpointStore#recover() Key: FLINK-7783 URL: https://issues.apache.org/jira/browse/FLINK-7783 Proje

[jira] [Created] (FLINK-7782) Flink CEP not recognizing pattern

2017-10-09 Thread Ajay (JIRA)
Ajay created FLINK-7782: --- Summary: Flink CEP not recognizing pattern Key: FLINK-7782 URL: https://issues.apache.org/jira/browse/FLINK-7782 Project: Flink Issue Type: Bug Reporter: Ajay I

[jira] [Created] (FLINK-7781) Support sime on-demand metrics aggregation

2017-10-09 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7781: --- Summary: Support sime on-demand metrics aggregation Key: FLINK-7781 URL: https://issues.apache.org/jira/browse/FLINK-7781 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-7780) Integrate savepoint command into REST client

2017-10-09 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-7780: --- Summary: Integrate savepoint command into REST client Key: FLINK-7780 URL: https://issues.apache.org/jira/browse/FLINK-7780 Project: Flink Issue Type:

[jira] [Created] (FLINK-7779) Relocate Curator

2017-10-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7779: Summary: Relocate Curator Key: FLINK-7779 URL: https://issues.apache.org/jira/browse/FLINK-7779 Project: Flink Issue Type: Sub-task Components: Bui

[jira] [Created] (FLINK-7778) Relocate ZooKeeper

2017-10-09 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7778: Summary: Relocate ZooKeeper Key: FLINK-7778 URL: https://issues.apache.org/jira/browse/FLINK-7778 Project: Flink Issue Type: Sub-task Components: B

Re: Issue of Twitter streaming with CustomEndpoint

2017-10-09 Thread Till Rohrmann
Hi Devendra, thanks for reaching out to the Flink dev mailing list. I think your question will be better answered on the user mailing list. Cheers, Till On Fri, Oct 6, 2017 at 8:14 AM, Devendra Vishwakarma wrote: > Hi, > > I am following Apache Flink Twitter streaming example given in > https:

Re: Unable to write snapshots to S3 on EMR

2017-10-09 Thread Stephan Ewen
Hi! It looks like multiple Hadoop versions are in the classpath. Flink's hadoop jar and the EMR Hadoop jars. I would simply drop Flink's own Hadoop dependency and only use the EMR Hadoop jars. Delete the 'flink-shaded-h‌​adoop2-uber' jar from Flink, and make sure the setup is such that the Hadoop