[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725569#comment-15725569 ] ASF GitHub Bot commented on FLINK-3848: --- Github user tonycox commented on the issue:

[GitHub] flink issue #2810: [FLINK-3848] Add ProjectableTableSource interface and tra...

Github user tonycox commented on the issue: https://github.com/apache/flink/pull/2810 @fhueske Basically yes, but I think we need finish projection rule for Stream, after FLINK-5251 merging --- If your project is set up for it, you can reply to this email and have your reply appear

[GitHub] flink pull request #2951: [docs] clarify default restart behavior when check...

GitHub user mxm opened a pull request: https://github.com/apache/flink/pull/2951 [docs] clarify default restart behavior when checkpointing is enabled Merging this to `master` and `release-1.1`. You can merge this pull request into a Git repository by running: $ git pull

[GitHub] flink pull request #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG li...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2886 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] flink pull request #2923: [FLINK-5220] [Table API & SQL] Flink SQL projectio...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2923#discussion_r91088241 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/util/DataSetCalcConverter.scala --- @@ -0,0 +1,111 @@ +/*

[GitHub] flink pull request #2923: [FLINK-5220] [Table API & SQL] Flink SQL projectio...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2923#discussion_r91083035 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/PushProjectIntoBatchTableSourceScanRule.scala --- @@ -0,0

[GitHub] flink pull request #2923: [FLINK-5220] [Table API & SQL] Flink SQL projectio...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2923#discussion_r91083411 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/util/DataSetCalcConverter.scala --- @@ -0,0 +1,111 @@ +/*

[GitHub] flink pull request #2923: [FLINK-5220] [Table API & SQL] Flink SQL projectio...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2923#discussion_r91082726 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/PushProjectIntoBatchTableSourceScanRule.scala --- @@ -0,0

[jira] [Commented] (FLINK-5002) Lack of synchronization in LocalBufferPool#getNumberOfUsedBuffers

[ https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725804#comment-15725804 ] ASF GitHub Bot commented on FLINK-5002: --- Github user StephanEwen commented on the issue:

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91083375 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/TaskState.java --- @@ -0,0 +1,166 @@ +/* + * Licensed to the

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91087691 --- Diff: flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala --- @@ -1317,9 +1320,13 @@ class JobManager(

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91084426 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/state/MigrationKeyGroupStateHandle.java --- @@ -0,0 +1,39 @@ +/* + * Licensed

[jira] [Assigned] (FLINK-4704) Move Table API to org.apache.flink.table

[ https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Mushin reassigned FLINK-4704: --- Assignee: Anton Mushin (was: Timo Walther) > Move Table API to org.apache.flink.table >

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91072181 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/state/MigrationStreamStateHandle.java --- @@ -0,0 +1,52 @@ +/* + * Licensed to

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91084701 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/streaming/runtime/tasks/StreamTaskStateList.java --- @@ -0,0 +1,121 @@ +/* + *

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91058148 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0Serializer.java --- @@ -0,0 +1,390 @@ +/*

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91083520 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/runtime/state/AbstractStateBackend.java --- @@ -0,0 +1,68 @@ +/* + * Licensed

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91071609 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0Serializer.java --- @@ -0,0 +1,390 @@ +/*

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91076930 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -994,4

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91081808 --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/AbstractMultiFSDataInputStream.java --- @@ -0,0 +1,113 @@ +/* + * Licensed to the

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91083191 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/KeyGroupState.java --- @@ -0,0 +1,88 @@ +/* + * Licensed to

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91083302 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/SubtaskState.java --- @@ -0,0 +1,108 @@ +/* + * Licensed to

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91058419 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/SubtaskState.java --- @@ -0,0 +1,108 @@ +/* + * Licensed to

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91085218 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java --- @@ -346,4 +359,130 @@ public String toString()

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91086437 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java --- @@ -346,4 +359,130 @@ public String toString()

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91087211 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java --- @@ -346,4 +359,130 @@ public String toString()

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91084572 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/streaming/runtime/tasks/StreamTaskState.java --- @@ -0,0 +1,177 @@ +/* + *

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91077409 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -994,4

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91059047 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0Serializer.java --- @@ -0,0 +1,390 @@ +/*

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91053522 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0Serializer.java --- @@ -0,0 +1,390 @@ +/*

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91081657 --- Diff: flink-core/pom.xml --- @@ -112,7 +112,15 @@ under the License. joda-convert test

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91051952 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0.java --- @@ -0,0 +1,102 @@ +/* + *

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725645#comment-15725645 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725657#comment-15725657 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725651#comment-15725651 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725649#comment-15725649 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725643#comment-15725643 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725653#comment-15725653 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725663#comment-15725663 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725664#comment-15725664 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725661#comment-15725661 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725659#comment-15725659 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725647#comment-15725647 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725654#comment-15725654 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725662#comment-15725662 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725660#comment-15725660 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725656#comment-15725656 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725655#comment-15725655 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725658#comment-15725658 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725650#comment-15725650 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725646#comment-15725646 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725648#comment-15725648 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725652#comment-15725652 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725644#comment-15725644 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91076224 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/MultiStreamStateHandle.java --- @@ -0,0 +1,96 @@ +/* + * Licensed to the

[jira] [Closed] (FLINK-5179) MetricRegistry life-cycle issues with HA

[ https://issues.apache.org/jira/browse/FLINK-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5179. -- Resolution: Fixed Fixed in e5f4e3d (master). > MetricRegistry life-cycle issues with HA >

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r91051264 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/BatchTableEnvironment.scala --- @@ -251,6 +251,7 @@ abstract class

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r91086281 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchProjectableTableSourceScanRule.scala --- @@ -0,0

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r91054316 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetScan.scala --- @@ -42,6 +43,11 @@ class

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r91051611 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchTableSourceScan.scala --- @@ -48,6 +57,11 @@ class

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r91075690 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchProjectableTableSourceScanRule.scala --- @@ -0,0

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r91077345 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/sources/CsvTableSource.scala --- @@ -51,9 +51,12 @@ class CsvTableSource(

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r91078629 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/scala/batch/ExplainTest.scala --- @@ -20,6 +20,7 @@ package

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r91079799 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/api/table/ProjectableTableSourceTest.scala --- @@ -0,0 +1,116 @@ +/* + *

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r91056853 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchProjectableTableSourceScanRule.scala --- @@ -0,0

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725765#comment-15725765 ] ASF GitHub Bot commented on FLINK-3848: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-4982) quickstart example: Can't see the output

[ https://issues.apache.org/jira/browse/FLINK-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725794#comment-15725794 ] Stephan Ewen commented on FLINK-4982: - As I said, it goes to standard out, if you run a standalone

[jira] [Assigned] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API.

[ https://issues.apache.org/jira/browse/FLINK-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Chermenin reassigned FLINK-2980: -- Assignee: Alexander Chermenin > Add CUBE/ROLLUP/GROUPING SETS operator in

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725774#comment-15725774 ] ASF GitHub Bot commented on FLINK-3848: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725768#comment-15725768 ] ASF GitHub Bot commented on FLINK-3848: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725777#comment-15725777 ] ASF GitHub Bot commented on FLINK-3848: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-4983) Web UI: Add favicon

[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725869#comment-15725869 ] ASF GitHub Bot commented on FLINK-4983: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-4982) quickstart example: Can't see the output

[ https://issues.apache.org/jira/browse/FLINK-4982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725705#comment-15725705 ] Mischa Krüger commented on FLINK-4982: -- Ping, still can't find the output^^ > quickstart example:

[GitHub] flink issue #2923: [FLINK-5220] [Table API & SQL] Flink SQL projection pushd...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2923 Hi @beyond1920 and @KurtYoung, please see my [comment](https://github.com/apache/flink/pull/2810#issuecomment-265180294) on PR #2810 for how to continue with this PR. Please let me know

[jira] [Commented] (FLINK-5220) Flink SQL projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725829#comment-15725829 ] ASF GitHub Bot commented on FLINK-5220: --- Github user fhueske commented on the issue:

[jira] [Closed] (FLINK-5261) ScheduledDropwizardReporter does not properly clean up metrics

[ https://issues.apache.org/jira/browse/FLINK-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-5261. -- Resolution: Fixed Fixed in f7f7b48 (master). > ScheduledDropwizardReporter does not properly clean up

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725749#comment-15725749 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StefanRRichter commented on a diff in the pull

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r91058946 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/util/CalcConverter.scala --- @@ -0,0 +1,111 @@ +/* + *

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r91087223 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/BatchProjectableTableSourceScanRule.scala --- @@ -0,0

[GitHub] flink pull request #2810: [FLINK-3848] Add ProjectableTableSource interface ...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2810#discussion_r91059867 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/datastream/StreamProjectableTableSourceScanRule.scala --- @@ -0,0

[GitHub] flink pull request #2923: [FLINK-5220] [Table API & SQL] Flink SQL projectio...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2923#discussion_r91081832 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/BatchScan.scala --- @@ -45,7 +45,8 @@ abstract class

[GitHub] flink issue #2865: [FLINK-5002] Renamed getNumberOfUsedBuffers() method to b...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2865 Looks good. The test is almost a bit overkill, I think. A adding a simple `Math.max(0, value)` to ensure the value is non-negative probably does the trick. --- If your project is set up for

[jira] [Commented] (FLINK-3848) Add ProjectableTableSource interface and translation rule

[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725823#comment-15725823 ] ASF GitHub Bot commented on FLINK-3848: --- Github user fhueske commented on the issue:

[jira] [Updated] (FLINK-4983) Web UI: Add favicon

[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan updated FLINK-4983: -- Fix Version/s: 1.2.0 > Web UI: Add favicon > --- > > Key: FLINK-4983 >

[jira] [Commented] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725665#comment-15725665 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff in the pull

[jira] [Commented] (FLINK-5147) StreamingOperatorsITCase.testGroupedFoldOperation failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-5147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725708#comment-15725708 ] Ufuk Celebi commented on FLINK-5147: Ocurred again

[GitHub] flink pull request #2781: [FLINK-5041] Savepoint backwards compatibility 1.1...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91095772 --- Diff: flink-runtime/src/main/java/org/apache/flink/migration/runtime/checkpoint/savepoint/SavepointV0.java --- @@ -0,0 +1,102 @@ +/* + *

[jira] [Commented] (FLINK-5007) Retain externalized checkpoint on suspension

[ https://issues.apache.org/jira/browse/FLINK-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725895#comment-15725895 ] ASF GitHub Bot commented on FLINK-5007: --- Github user StephanEwen commented on the issue:

[GitHub] flink pull request #2952: [FLINK-5011] [types] TraversableSerializer does no...

GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/2952 [FLINK-5011] [types] TraversableSerializer does not perform a deep co… This pull requests fixes a bug in the `TraverableSerializer` and in the tests itself. It adds a special test to check if

[GitHub] flink pull request #2923: [FLINK-5220] [Table API & SQL] Flink SQL projectio...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2923#discussion_r91083315 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/util/DataSetCalcConverter.scala --- @@ -0,0 +1,111 @@ +/*

[jira] [Commented] (FLINK-5220) Flink SQL projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725760#comment-15725760 ] ASF GitHub Bot commented on FLINK-5220: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5220) Flink SQL projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725755#comment-15725755 ] ASF GitHub Bot commented on FLINK-5220: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5220) Flink SQL projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725759#comment-15725759 ] ASF GitHub Bot commented on FLINK-5220: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5220) Flink SQL projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725757#comment-15725757 ] ASF GitHub Bot commented on FLINK-5220: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5220) Flink SQL projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725762#comment-15725762 ] ASF GitHub Bot commented on FLINK-5220: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5220) Flink SQL projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725758#comment-15725758 ] ASF GitHub Bot commented on FLINK-5220: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5220) Flink SQL projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725756#comment-15725756 ] ASF GitHub Bot commented on FLINK-5220: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-5220) Flink SQL projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-5220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15725761#comment-15725761 ] ASF GitHub Bot commented on FLINK-5220: --- Github user fhueske commented on a diff in the pull

[jira] [Closed] (FLINK-4983) Web UI: Add favicon

[ https://issues.apache.org/jira/browse/FLINK-4983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Hogan closed FLINK-4983. - Resolution: Implemented Implemented in ba6b08794b22dfc586d32926a6af488e5edac2d6 > Web UI: Add favicon >

[GitHub] flink issue #2750: [FLINK-5007] [checkpointing] Retain externalized checkpoi...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/2750 A suspension is usually a master failure or loss of leadership. Suspending a job does not delete/remove any HA checkpoints. The same should be the case for externalized checkpoints, in

  1   2   3   >