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

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: Improv

[jira] [Created] (FLINK-4600) Support min/max aggregations for Date/Time/Timestamp/Intervals

Timo Walther created FLINK-4600: --- Summary: Support min/max aggregations for Date/Time/Timestamp/Intervals Key: FLINK-4600 URL: https://issues.apache.org/jira/browse/FLINK-4600 Project: Flink I

Flink HA on AWS: Network related issue

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 it

[jira] [Created] (FLINK-4601) Check for empty string properly

Alexander Pivovarov created FLINK-4601: -- Summary: Check for empty string properly Key: FLINK-4601 URL: https://issues.apache.org/jira/browse/FLINK-4601 Project: Flink Issue Type: Bug