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

2016-12-06 Thread tonycox
Github user tonycox commented on the issue: https://github.com/apache/flink/pull/2810 Hi @fhueske, your PR do solve my problem. Thanks! --- 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 fe

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15724743#comment-15724743 ] ASF GitHub Bot commented on FLINK-3848: --- Github user tonycox commented on the issue:

[GitHub] flink issue #2949: [FLINK-5257] [table] display optimized logical plan when ...

2016-12-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2949 Thanks for the PR @KurtYoung. +1 to merge --- 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 featur

[GitHub] flink pull request #2950: [hotfix] Check for null in OperatorSnapshotResult#...

2016-12-06 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/2950 [hotfix] Check for null in OperatorSnapshotResult#cancel Hotfix for missing check on null values in OperatorSnapshotResult#cancel. You can merge this pull request into a Git repository

[GitHub] flink issue #2950: [hotfix] Check for null in OperatorSnapshotResult#cancel

2016-12-06 Thread rmetzger
Github user rmetzger commented on the issue: https://github.com/apache/flink/pull/2950 +1 I'll merge it --- 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

[GitHub] flink pull request #2950: [hotfix] Check for null in OperatorSnapshotResult#...

2016-12-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2950 --- 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 enab

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

2016-12-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2810 @tonycox, great. Thanks for the notice! Is the PR ready to review from your point of view or are you still working on it? @KurtYoung Thanks for reaching out to this PR. I'd like to propose th

[GitHub] flink issue #2949: [FLINK-5257] [table] display optimized logical plan when ...

2016-12-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2949 merging --- 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 fea

[GitHub] flink issue #2932: [FLINK-5249] [docs] description of datastream rescaling d...

2016-12-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2932 merging --- 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 fea

[GitHub] flink issue #2943: [FLINK-5259] [docs] wrong execution environment in batch ...

2016-12-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2943 merging --- 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 fea

[GitHub] flink issue #2934: [FLINK-5251] [Table] Decouple StreamTableSourceScan with ...

2016-12-06 Thread fhueske
Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2934 merging --- 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 fea

[GitHub] flink issue #2870: [FLINK-4565] Support for SQL IN operator

2016-12-06 Thread NickolayVasilishin
Github user NickolayVasilishin commented on the issue: https://github.com/apache/flink/pull/2870 I've fixed all things above. Though, I've faced some problems while moving to another test base. It uses testing expressions directly in SELECT query, so I had to add new case in

[GitHub] flink pull request #2949: [FLINK-5257] [table] display optimized logical pla...

2016-12-06 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2949#discussion_r91049096 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/BatchTableEnvironment.scala --- @@ -275,17 +278,27 @@ abstract class BatchTab

[GitHub] flink pull request #2949: [FLINK-5257] [table] display optimized logical pla...

2016-12-06 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/2949#discussion_r91049302 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/BatchTableEnvironment.scala --- @@ -275,17 +278,27 @@ abstract class BatchTab

[GitHub] flink issue #2870: [FLINK-4565] Support for SQL IN operator

2016-12-06 Thread NickolayVasilishin
Github user NickolayVasilishin commented on the issue: https://github.com/apache/flink/pull/2870 Also the last commit represents possible way of implementing subquery IN operator. On one hand, it's really simple implementation, all work delegates to already proprely working

[jira] [Comment Edited] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields

2016-12-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15724703#comment-15724703 ] Fabian Hueske edited comment on FLINK-5266 at 12/6/16 8:31 AM: -

[jira] [Updated] (FLINK-5238) Flip-6 mini cluster should start local TaskManagers if there is only one TaskManager

2016-12-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5238: - Labels: flip-6 (was: ) > Flip-6 mini cluster should start local TaskManagers if there is only one

[jira] [Updated] (FLINK-5254) Implement Yarn HA Services

2016-12-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5254: - Labels: flip-6 (was: ) > Implement Yarn HA Services > -- > >

[jira] [Commented] (FLINK-5251) Decouple StreamTableSourceScan with TableSourceTable

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15724975#comment-15724975 ] ASF GitHub Bot commented on FLINK-5251: --- Github user fhueske commented on the issue:

[jira] [Updated] (FLINK-5141) Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6 branch

2016-12-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5141: - Labels: flip-6 (was: ) > Implement Flip6LocalStreamEnvironment to run new mini cluster in flip-6

[jira] [Updated] (FLINK-5239) Properly unpack thrown exceptions in RPC methods

2016-12-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5239: - Labels: flip-6 (was: ) > Properly unpack thrown exceptions in RPC methods > -

[jira] [Updated] (FLINK-5252) Migrate all YARN related configurations to ConfigOptions

2016-12-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5252: - Labels: flip-6 (was: ) > Migrate all YARN related configurations to ConfigOptions > -

[jira] [Updated] (FLINK-5253) Remove special treatment of "dynamic properties"

2016-12-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5253: - Labels: flip-6 (was: ) > Remove special treatment of "dynamic properties" > -

[jira] [Commented] (FLINK-5257) Display optimized logical plan when explaining table

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15724971#comment-15724971 ] ASF GitHub Bot commented on FLINK-5257: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-5259) wrong execution environment in retry delays example

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15724973#comment-15724973 ] ASF GitHub Bot commented on FLINK-5259: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15724997#comment-15724997 ] ASF GitHub Bot commented on FLINK-4565: --- Github user NickolayVasilishin commented on

[jira] [Commented] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields

2016-12-06 Thread Kurt Young (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15724936#comment-15724936 ] Kurt Young commented on FLINK-5266: --- Actually these are two separate issues. The pull re

[jira] [Updated] (FLINK-5140) NoResourceAvailableException is thrown while starting a new job

2016-12-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5140: - Labels: flip-6 (was: ) > NoResourceAvailableException is thrown while starting a new job > --

[jira] [Commented] (FLINK-4565) Support for SQL IN operator

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725123#comment-15725123 ] ASF GitHub Bot commented on FLINK-4565: --- Github user NickolayVasilishin commented on

[jira] [Commented] (FLINK-5257) Display optimized logical plan when explaining table

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725041#comment-15725041 ] ASF GitHub Bot commented on FLINK-5257: --- Github user fhueske commented on a diff in

[jira] [Closed] (FLINK-4492) Cleanup files from canceled snapshots

2016-12-06 Thread Nikolay Vasilishin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nikolay Vasilishin closed FLINK-4492. - Resolution: Cannot Reproduce > Cleanup files from canceled snapshots > ---

[jira] [Assigned] (FLINK-5011) TraversableSerializer does not perform a deep copy of the elements it is traversing

2016-12-06 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-5011: --- Assignee: Timo Walther > TraversableSerializer does not perform a deep copy of the elements i

[jira] [Commented] (FLINK-5249) description of datastream rescaling doesn't match the figure

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15724974#comment-15724974 ] ASF GitHub Bot commented on FLINK-5249: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-5266) Eagerly project unused fields when selecting aggregation fields

2016-12-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725190#comment-15725190 ] Fabian Hueske commented on FLINK-5266: -- Sorry, I had linked the wrong JIRA and PR ini

[jira] [Commented] (FLINK-5257) Display optimized logical plan when explaining table

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15724834#comment-15724834 ] ASF GitHub Bot commented on FLINK-5257: --- Github user fhueske commented on the issue:

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15724956#comment-15724956 ] ASF GitHub Bot commented on FLINK-3848: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-5257) Display optimized logical plan when explaining table

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725044#comment-15725044 ] ASF GitHub Bot commented on FLINK-5257: --- Github user fhueske commented on a diff in

[GitHub] flink issue #2912: [FLINK-5114] [network] Handle partition producer state ch...

2016-12-06 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2912 Rebased on master and implemented feedback from #2913. --- 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 f

[jira] [Commented] (FLINK-5114) PartitionState update with finished execution fails

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725223#comment-15725223 ] ASF GitHub Bot commented on FLINK-5114: --- Github user uce commented on the issue:

[GitHub] flink issue #2947: [hotfix] [metris] [docs] Correct scope format keys

2016-12-06 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2947 Going to merge this with the next batch --- 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

[GitHub] flink issue #2944: [FLINK-5261] Clean up meters in ScheduledDropwizardReport...

2016-12-06 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2944 Going to merge this with the next batch --- 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

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725338#comment-15725338 ] ASF GitHub Bot commented on FLINK-5261: --- Github user uce commented on the issue:

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725372#comment-15725372 ] ASF GitHub Bot commented on FLINK-5179: --- Github user uce commented on the issue:

[GitHub] flink issue #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG lifecycle

2016-12-06 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/2886 Tested this vs. the current master and it works as expected. In the current master, the metrics are not updated after the TM disassociates from the JM. With this PR the reporter is closed, restarted and

[GitHub] flink pull request #2943: [FLINK-5259] [docs] wrong execution environment in...

2016-12-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2943 --- 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 enab

[GitHub] flink pull request #2934: [FLINK-5251] [Table] Decouple StreamTableSourceSca...

2016-12-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2934 --- 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 enab

[GitHub] flink pull request #2932: [FLINK-5249] [docs] description of datastream resc...

2016-12-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2932 --- 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 enab

[GitHub] flink pull request #2949: [FLINK-5257] [table] display optimized logical pla...

2016-12-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/2949 --- 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 enab

[jira] [Commented] (FLINK-5259) wrong execution environment in retry delays example

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725383#comment-15725383 ] ASF GitHub Bot commented on FLINK-5259: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-5249) description of datastream rescaling doesn't match the figure

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725386#comment-15725386 ] ASF GitHub Bot commented on FLINK-5249: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-5251) Decouple StreamTableSourceScan with TableSourceTable

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725384#comment-15725384 ] ASF GitHub Bot commented on FLINK-5251: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-5257) Display optimized logical plan when explaining table

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725385#comment-15725385 ] ASF GitHub Bot commented on FLINK-5257: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-5221) Checkpointed workless in Window Operator

2016-12-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725405#comment-15725405 ] Till Rohrmann commented on FLINK-5221: -- Hi [~shijinkui], the Flink distribution also

[GitHub] flink issue #2886: [FLINK-5179] Correct TM MetricRegistry and TmMG lifecycle

2016-12-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/2886 The reporter isn't closed and restarted; instead all metrics are being de-registered and then re-registered. This is necessary since the ID of the TM changes upon re-association with the JM.

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725421#comment-15725421 ] ASF GitHub Bot commented on FLINK-5179: --- Github user zentol commented on the issue:

[jira] [Closed] (FLINK-5249) description of datastream rescaling doesn't match the figure

2016-12-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5249. Resolution: Fixed Assignee: David Anderson Fix Version/s: 1.1.4 1.

[jira] [Closed] (FLINK-5257) Display optimized logical plan when explaining table

2016-12-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5257. Resolution: Implemented Fix Version/s: 1.2.0 Implemented in 1.2.0 with 6f9633cd9d3124e2abe503

[jira] [Closed] (FLINK-5251) Decouple StreamTableSourceScan with TableSourceTable

2016-12-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5251. Resolution: Implemented Fix Version/s: 1.2.0 Implemented in 1.2.0 with 98d1826030d1486a3d6446

[jira] [Closed] (FLINK-5259) wrong execution environment in retry delays example

2016-12-06 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-5259. Resolution: Fixed Assignee: David Anderson Fix Version/s: 1.1.4 1.

[GitHub] flink pull request #2947: [hotfix] [metris] [docs] Correct scope format keys

2016-12-06 Thread zentol
Github user zentol closed the pull request at: https://github.com/apache/flink/pull/2947 --- 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 enab

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

2016-12-06 Thread tonycox
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 o

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

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

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

2016-12-06 Thread mxm
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 https:

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

2016-12-06 Thread StephanEwen
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 Apa

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

2016-12-06 Thread StephanEwen
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...

2016-12-06 Thread StephanEwen
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...

2016-12-06 Thread StephanEwen
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 to

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

2016-12-06 Thread Anton Mushin (JIRA)
[ 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...

2016-12-06 Thread StephanEwen
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 t

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

2016-12-06 Thread StephanEwen
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 @@ +/* + * L

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

2016-12-06 Thread StephanEwen
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...

2016-12-06 Thread StephanEwen
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 to

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

2016-12-06 Thread StephanEwen
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...

2016-12-06 Thread StephanEwen
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 +10

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

2016-12-06 Thread StephanEwen
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 Apa

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

2016-12-06 Thread StephanEwen
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 t

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

2016-12-06 Thread StephanEwen
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 t

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

2016-12-06 Thread StephanEwen
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 t

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

2016-12-06 Thread StephanEwen
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...

2016-12-06 Thread StephanEwen
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...

2016-12-06 Thread StephanEwen
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...

2016-12-06 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/2781#discussion_r91082673 --- Diff: flink-core/src/main/java/org/apache/flink/core/memory/ByteArrayInputStreamWithPos.java --- @@ -0,0 +1,268 @@ +/* + * Licensed to the Ap

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

2016-12-06 Thread StephanEwen
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 @@ +/* + * Licen

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

2016-12-06 Thread StephanEwen
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 +10

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

2016-12-06 Thread StephanEwen
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...

2016-12-06 Thread StephanEwen
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...

2016-12-06 Thread StephanEwen
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...

2016-12-06 Thread StephanEwen
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 @@ +/* + * Lice

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725666#comment-15725666 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725645#comment-15725645 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725657#comment-15725657 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725651#comment-15725651 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725649#comment-15725649 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725643#comment-15725643 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725653#comment-15725653 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725663#comment-15725663 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725664#comment-15725664 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725661#comment-15725661 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725659#comment-15725659 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff

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

2016-12-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15725647#comment-15725647 ] ASF GitHub Bot commented on FLINK-5041: --- Github user StephanEwen commented on a diff

  1   2   3   >