[jira] [Created] (FLINK-6219) Add a state backend which supports sorting

2017-03-30 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6219: -- Summary: Add a state backend which supports sorting Key: FLINK-6219 URL: https://issues.apache.org/jira/browse/FLINK-6219 Project: Flink Issue Type: New Feature

[Bug]Question about StreamExecutionEnvironment.createRemoteEnvironment

2017-03-30 Thread canbinzheng
I run two examples in the same client. first one use / ExecutionEnvironment.createRemoteEnvironment("10.75.203.170", 59551)/ second one use /StreamExecutionEnvironment.createRemoteEnvironment("10.75.203.170", 59551)/ the first example run successfully, but the second example failed(c

[jira] [Created] (FLINK-6220) Fine-grained copy-on-write for Heap(Map/List)States in CopyOnWriteStateTable

2017-03-30 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6220: - Summary: Fine-grained copy-on-write for Heap(Map/List)States in CopyOnWriteStateTable Key: FLINK-6220 URL: https://issues.apache.org/jira/browse/FLINK-6220 Project:

Re: [Bug]Question about StreamExecutionEnvironment.createRemoteEnvironment

2017-03-30 Thread Till Rohrmann
Hi, this is definitely a bug you're describing. The problem is that with FLINK-2821 [1], we can no longer resolve the hostname on the JobManager. Thus, you should specify the external hostname of the machine on which you have started the JobManager (given that you've used the very same hostname fo

[jira] [Created] (FLINK-6221) Add Promethus support to metrics

2017-03-30 Thread Joshua Griffith (JIRA)
Joshua Griffith created FLINK-6221: -- Summary: Add Promethus support to metrics Key: FLINK-6221 URL: https://issues.apache.org/jira/browse/FLINK-6221 Project: Flink Issue Type: Improvement

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

2017-03-30 Thread Aljoscha Krettek
https://issues.apache.org/jira/browse/FLINK-6188 turns out to be a bit more involved, see my comments on the PR: https://github.com/apache/flink/pull/3616. As I said there, maybe we should revert the commits regarding parallelism/max-parallelism changes and release and then fix it later. On Wed,

[jira] [Created] (FLINK-6222) YARN: setting environment variables in an easier fashion

2017-03-30 Thread Craig Foster (JIRA)
Craig Foster created FLINK-6222: --- Summary: YARN: setting environment variables in an easier fashion Key: FLINK-6222 URL: https://issues.apache.org/jira/browse/FLINK-6222 Project: Flink Issue Ty

[jira] [Created] (FLINK-6223) Rework PythonPlanBinder generics

2017-03-30 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6223: --- Summary: Rework PythonPlanBinder generics Key: FLINK-6223 URL: https://issues.apache.org/jira/browse/FLINK-6223 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6224) RemoteStreamEnvironment not resolve hostname of JobManager

2017-03-30 Thread CanBin Zheng (JIRA)
CanBin Zheng created FLINK-6224: --- Summary: RemoteStreamEnvironment not resolve hostname of JobManager Key: FLINK-6224 URL: https://issues.apache.org/jira/browse/FLINK-6224 Project: Flink Issue

Re: [Bug]Question about StreamExecutionEnvironment.createRemoteEnvironment

2017-03-30 Thread canbinzheng
Hi, I have opened an issue for the probelm https://issues.apache.org/jira/browse/FLINK-6224 -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Bug-Question-about-StreamExecutionEnvironment-createRemoteEnvironment-tp16854p16862.html Sent from the Apa

[jira] [Created] (FLINK-6225) Support Row Stream for CassandraSink

2017-03-30 Thread Jing Fan (JIRA)
Jing Fan created FLINK-6225: --- Summary: Support Row Stream for CassandraSink Key: FLINK-6225 URL: https://issues.apache.org/jira/browse/FLINK-6225 Project: Flink Issue Type: New Feature Co