[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: Improvement
Components: Table API & SQL
Reporter: Timo Walther
Currenlty, only the BatchTableEnvironment supports the {{explain}} command for
tables. We should also support it for the StreamTableEnvironment.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[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 Issue Type: Improvement Components: Table API & SQL Reporter: Timo Walther Currently no aggregation supports temporal types. At least min/max should be added for Date/Time/Timestamp/Intervals. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
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 worked but Taskmanager does not succeed in connecting again. It attaches only after I restart it. I tried following settings but still the problem persists. akka.ask.timeout: 20 s akka.lookup.timeout: 20 s akka.watch.heartbeat.interval: 20 s Please find attached snapshot on one of the Taskmanager. Is there any setting that I need to do ? -- Thanks, Deepak Jha
[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 Affects Versions: 1.1.2 Reporter: Alexander Pivovarov Priority: Trivial UdfAnalyzerExamplesTest.java and UdfAnalyzerTest.java use == to check for empty string. We should use isEmpty() instead -- This message was sent by Atlassian JIRA (v6.3.4#6332)
