[jira] [Updated] (FLINK-6116) Watermarks don't work when unioning with same DataStream

2017-05-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6116: Fix Version/s: 1.3.0 > Watermarks don't work when unioning with same DataStream > --

[jira] [Closed] (FLINK-3581) Add Special Aligned Event-Time WindowOperator

2017-05-07 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-3581. --- Resolution: Duplicate > Add Special Aligned Event-Time WindowOperator > --

[jira] [Assigned] (FLINK-6448) Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap'

2017-05-07 Thread yanghua (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanghua reassigned FLINK-6448: -- Assignee: yanghua > Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap' > -

[GitHub] flink pull request #3835: [FLINK-6448] Web UI TaskManager view: Rename 'Free...

2017-05-07 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/3835 [FLINK-6448] Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap' Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into conside

[jira] [Commented] (FLINK-6448) Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap'

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999722#comment-15999722 ] ASF GitHub Bot commented on FLINK-6448: --- GitHub user yanghua opened a pull request:

[jira] [Assigned] (FLINK-6451) Web UI: Rename 'Metrics' view to 'Task Metrics'

2017-05-07 Thread yanghua (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanghua reassigned FLINK-6451: -- Assignee: yanghua > Web UI: Rename 'Metrics' view to 'Task Metrics' > -

[GitHub] flink pull request #3810: [FLINK-6397] MultipleProgramsTestBase does not res...

2017-05-07 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/3810#discussion_r115137365 --- Diff: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MultipleProgramsTestBase.java --- @@ -80,29 +80,36 @@

[jira] [Commented] (FLINK-6397) MultipleProgramsTestBase does not reset ContextEnvironment

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999736#comment-15999736 ] ASF GitHub Bot commented on FLINK-6397: --- Github user zentol commented on a diff in t

[GitHub] flink pull request #3835: [FLINK-6448] Web UI TaskManager view: Rename 'Free...

2017-05-07 Thread yanghua
Github user yanghua closed the pull request at: https://github.com/apache/flink/pull/3835 --- 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 ena

[jira] [Commented] (FLINK-6448) Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap'

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999745#comment-15999745 ] ASF GitHub Bot commented on FLINK-6448: --- Github user yanghua closed the pull request

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999749#comment-15999749 ] ASF GitHub Bot commented on FLINK-4821: --- Github user tzulitai commented on the issue

[GitHub] flink issue #3001: [FLINK-4821] [kinesis] Implement rescalable non-partition...

2017-05-07 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3001 @tony810430 Thanks for the update! I've did a final review + test run, this is good to merge. Merging .. --- If your project is set up for it, you can reply to this email and have your

[GitHub] flink pull request #3836: [FLINK-6448] Web UI TaskManager view: Rename 'Free...

2017-05-07 Thread yanghua
GitHub user yanghua opened a pull request: https://github.com/apache/flink/pull/3836 [FLINK-6448] Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap' Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into conside

[jira] [Commented] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

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

[GitHub] flink pull request #3001: [FLINK-4821] [kinesis] Implement rescalable non-pa...

2017-05-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3001 --- 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-6448) Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap'

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999752#comment-15999752 ] ASF GitHub Bot commented on FLINK-6448: --- GitHub user yanghua opened a pull request:

[jira] [Resolved] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-4821. Resolution: Fixed Merged for 1.3.0 with https://git-wip-us.apache.org/repos/asf/fli

[jira] [Closed] (FLINK-4821) Implement rescalable non-partitioned state for Kinesis Connector

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-4821. -- > Implement rescalable non-partitioned state for Kinesis Connector > ---

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115139044 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -1473,

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999769#comment-15999769 ] ASF GitHub Bot commented on FLINK-6425: --- Github user StefanRRichter commented on a d

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115139339 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -1473,

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999776#comment-15999776 ] ASF GitHub Bot commented on FLINK-6425: --- Github user StefanRRichter commented on a d

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115139379 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/MigrationStrategy.java --- @@ -0,0 +1,87 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999777#comment-15999777 ] ASF GitHub Bot commented on FLINK-6425: --- Github user StefanRRichter commented on a d

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115139440 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializer.java --- @@ -161,7 +162,93 @@ public abstract i

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999779#comment-15999779 ] ASF GitHub Bot commented on FLINK-6425: --- Github user StefanRRichter commented on a d

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999782#comment-15999782 ] ASF GitHub Bot commented on FLINK-6425: --- Github user StefanRRichter commented on a d

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115139530 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializer.java --- @@ -161,7 +162,93 @@ public abstract i

[GitHub] flink issue #3823: [FLINK-6438] Added a few links to the docs home page ...

2017-05-07 Thread greghogan
Github user greghogan commented on the issue: https://github.com/apache/flink/pull/3823 @alpinegizmo understood, and meant to say that with an eye to the future. Was only confirming that the community is not giving special consideration to data Artisians. --- If your project is set

[jira] [Commented] (FLINK-6438) Expand docs home page a little

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999783#comment-15999783 ] ASF GitHub Bot commented on FLINK-6438: --- Github user greghogan commented on the issu

[GitHub] flink pull request #3522: [FLINK-5823] [checkpoints] State Backends also han...

2017-05-07 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3522#discussion_r115140655 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointMetadataStreamFactory.java --- @@ -0,0 +1,101 @@ +/* + * Licensed

[GitHub] flink pull request #3522: [FLINK-5823] [checkpoints] State Backends also han...

2017-05-07 Thread StephanEwen
Github user StephanEwen commented on a diff in the pull request: https://github.com/apache/flink/pull/3522#discussion_r115140665 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java --- @@ -213,6 +218,23 @@ public boolean discard(JobSt

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

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

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999804#comment-15999804 ] ASF GitHub Bot commented on FLINK-5823: --- Github user StephanEwen commented on the is

[GitHub] flink issue #3522: [FLINK-5823] [checkpoints] State Backends also handle Che...

2017-05-07 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3522 I would like to merge this for 1.3 with a slightly reduced scope. I would include the refactoring to make the State Backends also responsible for storing the Metadata. I would NO

[GitHub] flink issue #3522: [FLINK-5823] [checkpoints] State Backends also handle Che...

2017-05-07 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/3522 Here is a summary of why I picked a String initially for the metadata persistence location: > The idea of the pointer is to have a state-backend independent string that indicates a check

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999811#comment-15999811 ] ASF GitHub Bot commented on FLINK-5823: --- Github user StephanEwen commented on the is

[GitHub] flink pull request #3793: flink-6033 Support UNNEST query in the stream SQL ...

2017-05-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3793 --- 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 #3697: [FLINK-6257][table]Optimize test cases

2017-05-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3697 --- 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-6257) Post-pass OVER windows

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

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115141541 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -1473,22 +14

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115141548 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -1473,22 +14

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999823#comment-15999823 ] ASF GitHub Bot commented on FLINK-6425: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115141585 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializer.java --- @@ -161,7 +162,93 @@ public abstract int has

[GitHub] flink issue #3522: [FLINK-5823] [checkpoints] State Backends also handle Che...

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3522 I agree that we can change the Strings to some proper types later. Besides what I mentioned before, I just thought that even if a string is the underlying data type for the moment, having it w

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999824#comment-15999824 ] ASF GitHub Bot commented on FLINK-6425: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/3834#discussion_r115141563 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializer.java --- @@ -161,7 +162,93 @@ public abstract int has

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999827#comment-15999827 ] ASF GitHub Bot commented on FLINK-5823: --- Github user StefanRRichter commented on the

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999828#comment-15999828 ] ASF GitHub Bot commented on FLINK-6425: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999826#comment-15999826 ] ASF GitHub Bot commented on FLINK-6425: --- Github user tzulitai commented on a diff in

[GitHub] flink issue #3834: [FLINK-6425] [runtime] Activate serializer upgrades in st...

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3834 I was already familiar with the high level design of this PR from my discussions with @tzulitai. As the feature freeze is already tomorrow, I had to focus my review on the functionality of the

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999832#comment-15999832 ] ASF GitHub Bot commented on FLINK-6425: --- Github user StefanRRichter commented on the

[GitHub] flink issue #3834: [FLINK-6425] [runtime] Activate serializer upgrades in st...

2017-05-07 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/3834 Thanks a lot @StefanRRichter for the review, especially on the weekends :) I'll proceed to merge this after addressing also the comment on the priority flow between the serialized old serial

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999833#comment-15999833 ] ASF GitHub Bot commented on FLINK-6425: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-6471) RocksDBStateBackendTest#testCancelRunningSnapshot sometimes fails

2017-05-07 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999837#comment-15999837 ] Stefan Richter commented on FLINK-6471: --- Thanks for reporting this problem. This is

[GitHub] flink pull request #3837: [FLINK-6471] [checkpoint] Fix RocksDBStateBackendT...

2017-05-07 Thread StefanRRichter
GitHub user StefanRRichter opened a pull request: https://github.com/apache/flink/pull/3837 [FLINK-6471] [checkpoint] Fix RocksDBStateBackendTest `RocksDBStateBackendTest::testCancelRunningSnapshot` sometimes failes. This is cause by a problem that I fixed in `BlockerCheckpointStrea

[jira] [Commented] (FLINK-6471) RocksDBStateBackendTest#testCancelRunningSnapshot sometimes fails

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999839#comment-15999839 ] ASF GitHub Bot commented on FLINK-6471: --- GitHub user StefanRRichter opened a pull re

[jira] [Commented] (FLINK-6448) Web UI TaskManager view: Rename 'Free Memory' to 'JVM Heap'

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999849#comment-15999849 ] ASF GitHub Bot commented on FLINK-6448: --- Github user yanghua closed the pull request

[GitHub] flink pull request #3836: [FLINK-6448] Web UI TaskManager view: Rename 'Free...

2017-05-07 Thread yanghua
Github user yanghua closed the pull request at: https://github.com/apache/flink/pull/3836 --- 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 ena

[jira] [Closed] (FLINK-6257) Post-pass OVER windows

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6257. Resolution: Done Fix Version/s: 1.3.0 Done with 9f2293cfdab960246fe1aea1d705eea18a011761 > P

[jira] [Closed] (FLINK-6033) Support UNNEST query in the stream SQL API

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6033. Resolution: Implemented Fix Version/s: 1.3.0 Implemented with fe4e96a726dd32fb948db050b975312

[jira] [Closed] (FLINK-4682) Add TumbleRow row-windows for batch tables.

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4682. Resolution: Won't Do > Add TumbleRow row-windows for batch tables. > ---

[jira] [Updated] (FLINK-5047) Add sliding group-windows for batch tables

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5047: - Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-4557) > Add sliding group

[jira] [Closed] (FLINK-4683) Add SlideRow row-windows for batch tables

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4683. Resolution: Won't Do > Add SlideRow row-windows for batch tables > -

[jira] [Closed] (FLINK-4678) Add SessionRow row-windows to Table API

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4678. Resolution: Won't Do > Add SessionRow row-windows to Table API > ---

[jira] [Closed] (FLINK-4681) Add SessionRow row-windows for batch tables.

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4681. Resolution: Won't Do > Add SessionRow row-windows for batch tables. > --

[jira] [Closed] (FLINK-4679) Add TumbleRow row-windows to Table API

2017-05-07 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-4679. Resolution: Won't Do > Add TumbleRow row-windows to Table API >

[GitHub] flink issue #3837: [FLINK-6471] [checkpoint] Fix RocksDBStateBackendTest

2017-05-07 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/3837 lgtm --- 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

[jira] [Commented] (FLINK-6471) RocksDBStateBackendTest#testCancelRunningSnapshot sometimes fails

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999854#comment-15999854 ] ASF GitHub Bot commented on FLINK-6471: --- Github user tedyu commented on the issue:

[jira] [Created] (FLINK-6473) Add OVER window support for batch tables

2017-05-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-6473: Summary: Add OVER window support for batch tables Key: FLINK-6473 URL: https://issues.apache.org/jira/browse/FLINK-6473 Project: Flink Issue Type: New Featur

[GitHub] flink pull request #3838: [FLINK-5886] Python API for streaming applications

2017-05-07 Thread zohar-mizrahi
GitHub user zohar-mizrahi opened a pull request: https://github.com/apache/flink/pull/3838 [FLINK-5886] Python API for streaming applications Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration. If y

[jira] [Commented] (FLINK-5886) Python API for streaming applications

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15999873#comment-15999873 ] ASF GitHub Bot commented on FLINK-5886: --- GitHub user zohar-mizrahi opened a pull req

[jira] [Created] (FLINK-6474) Potential loss of precision in 32 bit integer multiplication

2017-05-07 Thread Ted Yu (JIRA)
Ted Yu created FLINK-6474: - Summary: Potential loss of precision in 32 bit integer multiplication Key: FLINK-6474 URL: https://issues.apache.org/jira/browse/FLINK-6474 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6475) Incremental snapshots in RocksDB hold lock during async file upload

2017-05-07 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6475: - Summary: Incremental snapshots in RocksDB hold lock during async file upload Key: FLINK-6475 URL: https://issues.apache.org/jira/browse/FLINK-6475 Project: Flink

[jira] [Created] (FLINK-6476) Table environment register row data stream

2017-05-07 Thread radu (JIRA)
radu created FLINK-6476: --- Summary: Table environment register row data stream Key: FLINK-6476 URL: https://issues.apache.org/jira/browse/FLINK-6476 Project: Flink Issue Type: Improvement Comp

[jira] [Commented] (FLINK-6476) Table environment register row data stream

2017-05-07 Thread radu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1591#comment-1591 ] radu commented on FLINK-6476: - [~fhueske] [~sunjincheng121] [~shijinkui] [~stefano.bortoli] [~

[GitHub] flink pull request #3839: FLINK-6474 Potential loss of precision in 32 bit i...

2017-05-07 Thread tedyu
GitHub user tedyu opened a pull request: https://github.com/apache/flink/pull/3839 FLINK-6474 Potential loss of precision in 32 bit integer multiplication Cast numNetworkBuffers to long before multiplication. You can merge this pull request into a Git repository by running: $ g

[jira] [Commented] (FLINK-6474) Potential loss of precision in 32 bit integer multiplication

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1607#comment-1607 ] ASF GitHub Bot commented on FLINK-6474: --- GitHub user tedyu opened a pull request:

[GitHub] flink pull request #3804: [FLINK-6190] [core] Reconfigurable TypeSerializers

2017-05-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3804 --- 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 #3834: [FLINK-6425] [runtime] Activate serializer upgrade...

2017-05-07 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3834 --- 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-6190) Write "Serializer Configurations" metainfo along with state

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

[jira] [Resolved] (FLINK-6178) Allow upgrades to state serializers

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6178. Resolution: Fixed Merged for 1.3.0 with https://git-wip-us.apache.org/repos/asf/fli

[jira] [Resolved] (FLINK-6190) Write "Serializer Configurations" metainfo along with state

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6190. Resolution: Fixed Merged for 1.3.0 with https://git-wip-us.apache.org/repos/asf/fli

[jira] [Resolved] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6425. Resolution: Fixed Merged for 1.3.0 with https://git-wip-us.apache.org/repos/asf/fli

[jira] [Resolved] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6191. Resolution: Fixed Merged for 1.3.0 with https://git-wip-us.apache.org/repos/asf/fli

[jira] [Commented] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

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

[jira] [Updated] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6191: --- Fix Version/s: 1.3.0 > Make non-primitive, internal built-in serializers reconfigurabl

[jira] [Closed] (FLINK-6190) Write "Serializer Configurations" metainfo along with state

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6190. -- > Write "Serializer Configurations" metainfo along with state >

[jira] [Closed] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6425. -- > Integrate serializer reconfiguration into state restore flow to activate > serializer upg

[jira] [Updated] (FLINK-6425) Integrate serializer reconfiguration into state restore flow to activate serializer upgrades

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6425: --- Fix Version/s: 1.3.0 > Integrate serializer reconfiguration into state restore flow to

[jira] [Updated] (FLINK-6190) Write "Serializer Configurations" metainfo along with state

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6190: --- Fix Version/s: 1.3.0 > Write "Serializer Configurations" metainfo along with state > -

[jira] [Closed] (FLINK-6191) Make non-primitive, internal built-in serializers reconfigurable

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6191. -- > Make non-primitive, internal built-in serializers reconfigurable > ---

[jira] [Closed] (FLINK-6178) Allow upgrades to state serializers

2017-05-07 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-6178. -- > Allow upgrades to state serializers > --- > >

[jira] [Closed] (FLINK-6471) RocksDBStateBackendTest#testCancelRunningSnapshot sometimes fails

2017-05-07 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-6471. - Resolution: Fixed Assignee: Stefan Richter Fix Version/s: 1.3.0 Fixed in b8ffacb1b

[jira] [Closed] (FLINK-6475) Incremental snapshots in RocksDB hold lock during async file upload

2017-05-07 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-6475. - Resolution: Fixed Fixed in 38003c2829. > Incremental snapshots in RocksDB hold lock during async

[GitHub] flink issue #3839: FLINK-6474 Potential loss of precision in 32 bit integer ...

2017-05-07 Thread tedyu
Github user tedyu commented on the issue: https://github.com/apache/flink/pull/3839 @StefanRRichter Can you take a look ? --- 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 enab

[jira] [Commented] (FLINK-6474) Potential loss of precision in 32 bit integer multiplication

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1644#comment-1644 ] ASF GitHub Bot commented on FLINK-6474: --- Github user tedyu commented on the issue:

[jira] [Commented] (FLINK-6474) Potential loss of precision in 32 bit integer multiplication

2017-05-07 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1650#comment-1650 ] ASF GitHub Bot commented on FLINK-6474: --- Github user StefanRRichter commented on the

[GitHub] flink issue #3839: FLINK-6474 Potential loss of precision in 32 bit integer ...

2017-05-07 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/3839 LGTM +1, will 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 feature enabled and wish

  1   2   >