[jira] [Assigned] (FLINK-8255) Key expressions on named row types do not work

[ https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-8255: Assignee: Sergey Nuyanzin > Key expressions on named row types do not work >

[GitHub] flink pull request #5930: [FLINK-9263][state] Fix concurrency problem in Def...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5930 ---

[jira] [Commented] (FLINK-8780) Add Broadcast State documentation.

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

[jira] [Commented] (FLINK-9263) Kafka010ITCase failed on travis because of the concurrency problem in DefaultOperateStateBackend

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

[GitHub] flink pull request #5922: [FLINK-8780] [docs] Add Broadcast State documentat...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5922#discussion_r185452174 --- Diff: docs/dev/stream/state/broadcast_state.md --- @@ -0,0 +1,281 @@ +--- +title: "The Broadcast State Pattern" +nav-parent_id:

[jira] [Commented] (FLINK-8780) Add Broadcast State documentation.

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

[GitHub] flink issue #5922: [FLINK-8780] [docs] Add Broadcast State documentation.

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/5922 Thanks a lot for the comments @alpinegizmo and @tzulitai ! I integrated most of them and I am not sure how to integrate your comment @tzulitai . Do you have any proposal on how this can be made

[jira] [Commented] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async

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

[jira] [Commented] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6

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

[GitHub] flink issue #5901: [FLINK-9235][Security] Add integration tests for YARN ker...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5901 If I only remove this line I mentioned earlier from `master` the test actually fails for me:

[GitHub] flink issue #5934: [FLINK-9269][state] fix concurrency problem when performi...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5934 Hi @StefanRRichter Thanks for your reply, I have updated the PR and add a test to guard this, but I not sure whether the test is indeed required because it looks a bit wired in my mind... ---

[GitHub] flink pull request #5922: [FLINK-8780] [docs] Add Broadcast State documentat...

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5922#discussion_r185449653 --- Diff: docs/dev/stream/state/broadcast_state.md --- @@ -0,0 +1,281 @@ +--- +title: "The Broadcast State Pattern" +nav-parent_id: streaming_state

[jira] [Commented] (FLINK-8780) Add Broadcast State documentation.

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

[jira] [Commented] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6

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

[jira] [Commented] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6

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

[jira] [Commented] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6

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

[GitHub] flink pull request #5901: [FLINK-9235][Security] Add integration tests for Y...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5901#discussion_r185448995 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -85,54 +88,75 @@ public void

[GitHub] flink pull request #5901: [FLINK-9235][Security] Add integration tests for Y...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5901#discussion_r185449426 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -85,54 +88,75 @@ public void

[GitHub] flink pull request #5901: [FLINK-9235][Security] Add integration tests for Y...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5901#discussion_r185449249 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -85,54 +88,75 @@ public void

[jira] [Commented] (FLINK-9269) Concurrency problem in HeapKeyedStateBackend when performing checkpoint async

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

[jira] [Assigned] (FLINK-9280) Extend JobSubmitHandler to accept jar files

[ https://issues.apache.org/jira/browse/FLINK-9280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-9280: --- Assignee: Chesnay Schepler > Extend JobSubmitHandler to accept jar files >

[GitHub] flink issue #5934: [FLINK-9269][state] fix concurrency problem when performi...

Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/5934 Yes, there is a theoretical problem if the serialization would not be threadsafe. I think currently the silent assumption that holds is that serializers are immutable w.r.t. serialization

[jira] [Commented] (FLINK-9286) Update classloading debugging page

[ https://issues.apache.org/jira/browse/FLINK-9286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460805#comment-16460805 ] ASF GitHub Bot commented on FLINK-9286: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5948: [FLINK-9286][docs] Update classloading docs

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5948 [FLINK-9286][docs] Update classloading docs ## What is the purpose of the change This PR updates the `Configuring ClassLoader Resolution Order` section of the `Debugging Classloading` page.

[jira] [Commented] (FLINK-8978) End-to-end test: Job upgrade

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

[jira] [Commented] (FLINK-8978) End-to-end test: Job upgrade

[ https://issues.apache.org/jira/browse/FLINK-8978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460797#comment-16460797 ] ASF GitHub Bot commented on FLINK-8978: --- GitHub user azagrebin opened a pull request:

[jira] [Commented] (FLINK-9285) Update REST API page

[ https://issues.apache.org/jira/browse/FLINK-9285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460796#comment-16460796 ] ASF GitHub Bot commented on FLINK-9285: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #5946: [FLINK-9285][REST][docs] Update REST API docs

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5946 [FLINK-9285][REST][docs] Update REST API docs ## What is the purpose of the change This PR updates the REST API documentation for 1.5. ## Brief change log * move legacy

[GitHub] flink issue #5947: [FLINK-8978] Stateful generic stream job upgrade e2e test

Github user azagrebin commented on the issue: https://github.com/apache/flink/pull/5947 cc @StefanRRichter ---

[GitHub] flink pull request #5947: [FLINK-8978] Stateful generic stream job upgrade e...

GitHub user azagrebin opened a pull request: https://github.com/apache/flink/pull/5947 [FLINK-8978] Stateful generic stream job upgrade e2e test ## What is the purpose of the change e2e test for generic state job upgrade and state recovery based operator uid. ##

[jira] [Updated] (FLINK-9286) Update classloading debugging page

[ https://issues.apache.org/jira/browse/FLINK-9286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9286: Summary: Update classloading debugging page (was: Upadte classloading debugging page) >

[jira] [Commented] (FLINK-9119) example code error in Concepts & Common API

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

[GitHub] flink issue #5935: [FLINK-9119] example code error in Concepts & Common API

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/5935 Thanks for the fix @yanghua! +1 to merge ---

[jira] [Assigned] (FLINK-9286) Upadte classloading debugging page

[ https://issues.apache.org/jira/browse/FLINK-9286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-9286: --- Assignee: Chesnay Schepler > Upadte classloading debugging page >

[jira] [Commented] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6

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

[GitHub] flink pull request #5901: [FLINK-9235][Security] Add integration tests for Y...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5901#discussion_r185445414 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -85,54 +88,75 @@ public void

[jira] [Assigned] (FLINK-9178) Add rate control for kafka source

[ https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9178: Assignee: Tarush Grover > Add rate control for kafka source >

[jira] [Comment Edited] (FLINK-9250) JoinTaskExternalITCase deadlocks on travis

[ https://issues.apache.org/jira/browse/FLINK-9250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460776#comment-16460776 ] Chesnay Schepler edited comment on FLINK-9250 at 5/2/18 9:33 AM: - The test

[jira] [Commented] (FLINK-9250) JoinTaskExternalITCase deadlocks on travis

[ https://issues.apache.org/jira/browse/FLINK-9250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460776#comment-16460776 ] Chesnay Schepler commented on FLINK-9250: - The test usually finishes within ~15 seconds, but in

[jira] [Commented] (FLINK-9283) Update cluster execution docs

[ https://issues.apache.org/jira/browse/FLINK-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460770#comment-16460770 ] Chesnay Schepler commented on FLINK-9283: - because the client now talks via REST (default port:

[jira] [Assigned] (FLINK-9284) Update CLI page

[ https://issues.apache.org/jira/browse/FLINK-9284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9284: --- Assignee: yuqi > Update CLI page > --- > > Key: FLINK-9284 >

[jira] [Assigned] (FLINK-9283) Update cluster execution docs

[ https://issues.apache.org/jira/browse/FLINK-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuqi reassigned FLINK-9283: --- Assignee: yuqi > Update cluster execution docs > - > > Key:

[jira] [Comment Edited] (FLINK-9283) Update cluster execution docs

[ https://issues.apache.org/jira/browse/FLINK-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460740#comment-16460740 ] yuqi edited comment on FLINK-9283 at 5/2/18 9:04 AM: - Could not understand why change

[jira] [Commented] (FLINK-9283) Update cluster execution docs

[ https://issues.apache.org/jira/browse/FLINK-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460740#comment-16460740 ] yuqi commented on FLINK-9283: - Could not understand why change port 6124 to 8081 ? > The [RemoteEnvironment

[jira] [Comment Edited] (FLINK-9283) Update cluster execution docs

[ https://issues.apache.org/jira/browse/FLINK-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460740#comment-16460740 ] yuqi edited comment on FLINK-9283 at 5/2/18 8:55 AM: - Could not understand why change

[jira] [Created] (FLINK-9286) Upadte classloading debugging page

Chesnay Schepler created FLINK-9286: --- Summary: Upadte classloading debugging page Key: FLINK-9286 URL: https://issues.apache.org/jira/browse/FLINK-9286 Project: Flink Issue Type:

[jira] [Created] (FLINK-9285) Update REST API page

Chesnay Schepler created FLINK-9285: --- Summary: Update REST API page Key: FLINK-9285 URL: https://issues.apache.org/jira/browse/FLINK-9285 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9284) Update CLI page

Chesnay Schepler created FLINK-9284: --- Summary: Update CLI page Key: FLINK-9284 URL: https://issues.apache.org/jira/browse/FLINK-9284 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

[ https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9257: Priority: Blocker (was: Critical) > End-to-end tests prints "All tests PASS" even if

[jira] [Updated] (FLINK-9257) End-to-end tests prints "All tests PASS" even if individual test-script returns non-zero exit code

[ https://issues.apache.org/jira/browse/FLINK-9257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9257: Priority: Critical (was: Blocker) > End-to-end tests prints "All tests PASS" even if

[jira] [Created] (FLINK-9283) Update cluster execution docs

Chesnay Schepler created FLINK-9283: --- Summary: Update cluster execution docs Key: FLINK-9283 URL: https://issues.apache.org/jira/browse/FLINK-9283 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9282) Update quickstart page

Chesnay Schepler created FLINK-9282: --- Summary: Update quickstart page Key: FLINK-9282 URL: https://issues.apache.org/jira/browse/FLINK-9282 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8780) Add Broadcast State documentation.

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

[GitHub] flink pull request #5922: [FLINK-8780] [docs] Add Broadcast State documentat...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5922#discussion_r185417488 --- Diff: docs/dev/stream/state/broadcast_state.md --- @@ -0,0 +1,281 @@ +--- +title: "The Broadcast State Pattern" +nav-parent_id:

[jira] [Commented] (FLINK-9169) NPE when restoring from old savepoint and state serializer could not be deserialized

[ https://issues.apache.org/jira/browse/FLINK-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460706#comment-16460706 ] ASF GitHub Bot commented on FLINK-9169: --- GitHub user tzulitai opened a pull request:

[jira] [Assigned] (FLINK-8480) Implement Java API to expose join functionality of TimeBoundedStreamJoinOperator

[ https://issues.apache.org/jira/browse/FLINK-8480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Florian Schmidt reassigned FLINK-8480: -- Assignee: Florian Schmidt > Implement Java API to expose join functionality of >

[GitHub] flink pull request #5945: [FLINK-9169] [runtime] Allow KeyedBackendSerializa...

GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5945 [FLINK-9169] [runtime] Allow KeyedBackendSerializationProxy to specify whether serializer presence is required ## What is the purpose of the change Previously, in both the RocksDB and

[jira] [Commented] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6

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

[GitHub] flink pull request #5901: [FLINK-9235][Security] Add integration tests for Y...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5901#discussion_r185423908 --- Diff: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java --- @@ -85,54 +88,75 @@ public void

[jira] [Commented] (FLINK-8286) Fix Flink-Yarn-Kerberos integration for FLIP-6

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

[GitHub] flink pull request #5896: [FLINK-8286][Security] Fix kerberos security confi...

Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5896#discussion_r185422695 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunnerFactory.java --- @@ -73,61 +105,68 @@ public static void main(String[]

[GitHub] flink issue #5919: [hotfix][state.md]modify typo in the state.md

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5919 merging. ---

[jira] [Commented] (FLINK-9154) Include WebSubmissionExtension in REST API docs

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

[GitHub] flink issue #5833: [FLINK-9154][REST][docs] Document WebSubmissionExtension ...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5833 merging. ---

[jira] [Commented] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes

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

[GitHub] flink issue #5903: [FLINK-9211][REST] JarRunHandler submits job to Dispatche...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5903 merging. ---

[jira] [Closed] (FLINK-9270) Upgrade RocksDB to 5.11.3, and resolve concurrent test invocation problem of @RetryOnFailure

[ https://issues.apache.org/jira/browse/FLINK-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-9270. - Resolution: Won't Fix Won't fix until we figure out a way around the performance regression of

[jira] [Commented] (FLINK-9235) Add Integration test for Flink-Yarn-Kerberos integration for flip-6

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

[GitHub] flink issue #5901: [FLINK-9235][Security] Add integration tests for YARN ker...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5901 Shouldn't this fail without the changes in #5896? ---

[jira] [Commented] (FLINK-8743) Add annotation to override documented default

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

[jira] [Commented] (FLINK-9249) Add convenience profile for skipping non-essential plugins

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

[GitHub] flink issue #5822: [FLINK-8743][docs] Allow overriding documented default

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5822 merging. ---

[GitHub] flink issue #5904: [FLINK-9249][build] Add convenience profile for skipping ...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5904 merging. ---

[jira] [Commented] (FLINK-9267) Classloading issues when using RemoteEnvironment ...

[ https://issues.apache.org/jira/browse/FLINK-9267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460652#comment-16460652 ] Chesnay Schepler commented on FLINK-9267: - That exception means that the client and server are

[jira] [Commented] (FLINK-9201) same merge window will be fired twice if watermark already passed the merge window

[ https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16460606#comment-16460606 ] yuemeng commented on FLINK-9201: [~jark]，[~StephanEwen]   can you  check this issue？ thanks   > same

<    1   2   3