[jira] [Closed] (FLINK-5416) Function wrappers should support CheckpointedFunction

[ https://issues.apache.org/jira/browse/FLINK-5416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright closed FLINK-5416. --- Resolution: Duplicate Seems to a duplicate of FLINK-5250, and the fix there looks good. > Function wr

[GitHub] flink issue #3061: [FLINK-5030] Support hostname verification

Github user EronWright commented on the issue: https://github.com/apache/flink/pull/3061 @StephanEwen unfortunately Akka doesn't support hostname verification, so the Akka remoting code wasn't touched. I suppose we could fix it in Flakka, at which time we'd need to move to full ca

[GitHub] flink issue #3107: [FLINK-5441] [table] Directly allow SQL queries on a Tabl...

Github user KurtYoung commented on the issue: https://github.com/apache/flink/pull/3107 I still think this is weird. Currently all API from `Table` is somehow act on the table object, just like a normal OOP program. After introducing `sql` method to `Table`, it can do something comple

[jira] [Commented] (FLINK-5441) Directly allow SQL queries on a Table

[ https://issues.apache.org/jira/browse/FLINK-5441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822913#comment-15822913 ] ASF GitHub Bot commented on FLINK-5441: --- Github user KurtYoung commented on the issu

[jira] [Created] (FLINK-5490) ContextEnvironment.getExecutionPlan() clears Sinks

Robert Schmidtke created FLINK-5490: --- Summary: ContextEnvironment.getExecutionPlan() clears Sinks Key: FLINK-5490 URL: https://issues.apache.org/jira/browse/FLINK-5490 Project: Flink Issue

[jira] [Commented] (FLINK-3427) Add watermark monitoring to JobManager web frontend

[ https://issues.apache.org/jira/browse/FLINK-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822779#comment-15822779 ] Robert Metzger commented on FLINK-3427: --- Hi Ivan, Sadly, the person who wanted to wo

[jira] [Commented] (FLINK-5413) Convert TableEnvironmentITCases to unit tests

[ https://issues.apache.org/jira/browse/FLINK-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822775#comment-15822775 ] GaoLun commented on FLINK-5413: --- Hi Timo, is it proper just validating the correctness of th

[jira] [Commented] (FLINK-5394) the estimateRowCount method of DataSetCalc didn't work

[ https://issues.apache.org/jira/browse/FLINK-5394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15822763#comment-15822763 ] ASF GitHub Bot commented on FLINK-5394: --- Github user beyond1920 commented on a diff

[GitHub] flink pull request #3058: [FLINK-5394] [Table API & SQL]the estimateRowCount...

Github user beyond1920 commented on a diff in the pull request: https://github.com/apache/flink/pull/3058#discussion_r96112195 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetSort.scala --- @@ -71,6 +72,21 @@ class DataSetSort(