Flink HA on AWS: Network related issue

2016-09-08 Thread Deepak Jha
Hi, I've setup Flink HA on AWS ( 3 Taskmanagers and 2 Jobmanagers each are on EC2 m4.large instance with checkpoint enabled on S3 ). My topology works fine, but after few hours I do see that Taskmanagers gets detached with Jobmanager. I tried to reach Jobmanager using telnet at the same time and

[jira] [Created] (FLINK-4599) Add 'explain()' also to StreamTableEnvironment

2016-09-08 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4599: --- Summary: Add 'explain()' also to StreamTableEnvironment Key: FLINK-4599 URL: https://issues.apache.org/jira/browse/FLINK-4599 Project: Flink Issue Type:

[jira] [Created] (FLINK-4597) Improve Scalar Function section in Table API documentation

2016-09-08 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4597: -- Summary: Improve Scalar Function section in Table API documentation Key: FLINK-4597 URL: https://issues.apache.org/jira/browse/FLINK-4597 Project: Flink Issue Type:

Re: Re: [DISCUSS] how choose Scala and Java

2016-09-08 Thread Fabian Hueske
The Java and Scala APIs are organized in different Maven modules and the Scala APIs are based on the respective Java API. The benefit of this design is to keep Scala dependencies out of the Java APIs which is requested by many users. The Java and Scala counterparts of the DataSet and DataStream

Re: release-1.1.2 does not exist on github

2016-09-08 Thread Robert Metzger
Hi Alex, the problem is that the tag has not been created for the release. I'll add it. On Wed, Sep 7, 2016 at 11:09 PM, Alexander Pivovarov wrote: > Hi Everyone > > I noticed that release-1.1.2 does not exist on github > https://github.com/apache/flink/releases > >