[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

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

[GitHub] flink issue #4605: [FLINK-4500] [C* Connector] CassandraSinkBase implements ...

Github user mcfongtw commented on the issue: https://github.com/apache/flink/pull/4605 Hi, @zentol , thanks for reviewing this PR. I recalled that I put a [caveat

[jira] [Commented] (FLINK-4575) DataSet aggregate methods should support POJOs

[ https://issues.apache.org/jira/browse/FLINK-4575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16248142#comment-16248142 ] Chuyang Wan commented on FLINK-4575: [~ggevay], if you are ok with converting the POJO to a Tuple via

[jira] [Commented] (FLINK-7702) Javadocs are not being built

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

[GitHub] flink pull request #4998: [FLINK-7702] Add maven-bundle-plugin to root pom

GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/4998 [FLINK-7702] Add maven-bundle-plugin to root pom Before, we had it in places that require it. This doesn't work when running mvn javadoc:aggregate because this will only run for the root

[jira] [Updated] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7488: -- Description: {code}

[jira] [Created] (FLINK-8047) Create HTTP Sink

Jessica Negara created FLINK-8047: - Summary: Create HTTP Sink Key: FLINK-8047 URL: https://issues.apache.org/jira/browse/FLINK-8047 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8046) ContinuousFileMonitoringFunction wrongly ignores files with exact same timestamp

[ https://issues.apache.org/jira/browse/FLINK-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247846#comment-16247846 ] Juan Miguel Cejuela commented on FLINK-8046: Since we are at this, it is in my humble opinion

[jira] [Commented] (FLINK-8046) ContinuousFileMonitoringFunction wrongly ignores files with exact same timestamp

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

[GitHub] flink pull request #4997: [FLINK-8046] [flink-streaming-java] Have filter of...

GitHub user juanmirocks opened a pull request: https://github.com/apache/flink/pull/4997 [FLINK-8046] [flink-streaming-java] Have filter of timestamp compare with strictly SMALLER (NOT smaller or equal) ## What is the purpose of the change This change fixes the wrong

[jira] [Created] (FLINK-8046) ContinuousFileMonitoringFunction wrongly ignores files with exact same timestamp

Juan Miguel Cejuela created FLINK-8046: -- Summary: ContinuousFileMonitoringFunction wrongly ignores files with exact same timestamp Key: FLINK-8046 URL: https://issues.apache.org/jira/browse/FLINK-8046

[jira] [Updated] (FLINK-7702) Javadocs are not being built

[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7702: Summary: Javadocs are not being built (was: Javadocs link broken) > Javadocs are not being

[jira] [Updated] (FLINK-8045) Add Internal DATE/TIME/TIMESTAMP as internal representation of DATE/TIME/TIMESTAMP

[ https://issues.apache.org/jira/browse/FLINK-8045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-8045: Description: Currently DATE/TIME/TIMESTAMP have internal representation. Such as Date is

[jira] [Created] (FLINK-8045) Add Internal DATE/TIME/TIMESTAMP as internal representation of DATE/TIME/TIMESTAMP

Zhenghua Gao created FLINK-8045: --- Summary: Add Internal DATE/TIME/TIMESTAMP as internal representation of DATE/TIME/TIMESTAMP Key: FLINK-8045 URL: https://issues.apache.org/jira/browse/FLINK-8045

[GitHub] flink pull request #4996: [hotfix][docs] Change mailing list link in quickst...

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

[GitHub] flink issue #4996: [hotfix][docs] Change mailing list link in quickstart to ...

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4996 Thanks @aljoscha for merging! ---

[jira] [Commented] (FLINK-7845) Netty Exception when submitting batch job repeatedly

[ https://issues.apache.org/jira/browse/FLINK-7845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247785#comment-16247785 ] Piotr Nowojski commented on FLINK-7845: --- Could you strip down your example to some minimal code

[jira] [Assigned] (FLINK-7880) flink-queryable-state-java fails with core-dump

[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7880: --- Assignee: Kostas Kloudas (was: Aljoscha Krettek) > flink-queryable-state-java fails

[jira] [Assigned] (FLINK-7880) flink-queryable-state-java fails with core-dump

[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7880: --- Assignee: Aljoscha Krettek (was: Kostas Kloudas) > flink-queryable-state-java fails

[jira] [Commented] (FLINK-7919) Join with Solution Set fails with NPE if Solution Set has no entry

[ https://issues.apache.org/jira/browse/FLINK-7919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247736#comment-16247736 ] Fabian Hueske commented on FLINK-7919: -- Hi [~greghogan], yes that would be an option as well. This

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

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

[GitHub] flink issue #4961: [FLINK-7973] fix shading and relocating Hadoop for the S3...

Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4961 I did include your end-to-end tests (with some fixes) and the fixes for the errors they found. Should be fine now, let's see what travis says... ---

[jira] [Commented] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

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

[GitHub] flink pull request #4939: [FLINK-4228][yarn/s3a] fix yarn resource upload s3...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4939#discussion_r150275387 --- Diff: flink-yarn/pom.xml --- @@ -153,6 +159,63 @@ under the License. + +

[jira] [Commented] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

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

[GitHub] flink pull request #4939: [FLINK-4228][yarn/s3a] fix yarn resource upload s3...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4939#discussion_r150275161 --- Diff: flink-yarn/pom.xml --- @@ -153,6 +159,63 @@ under the License. + +

[GitHub] flink issue #4939: [FLINK-4228][yarn/s3a] fix yarn resource upload s3a defau...

Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4939 1) yes, I have tested the changes on a YARN cluster as described in the PR comment (before the changes on the unit tests) 2) regarding the `pom.xml` changes: I actually took those from

[jira] [Commented] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

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

[jira] [Comment Edited] (FLINK-7999) Variable Join Window Boundaries

[ https://issues.apache.org/jira/browse/FLINK-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247674#comment-16247674 ] Seth Wiesman edited comment on FLINK-7999 at 11/10/17 3:47 PM: --- Sure, I will

[jira] [Commented] (FLINK-7999) Variable Join Window Boundaries

[ https://issues.apache.org/jira/browse/FLINK-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16247674#comment-16247674 ] Seth Wiesman commented on FLINK-7999: - Sure, I will use the example of my use case. I am using Flink

[jira] [Closed] (FLINK-6163) Document per-window state in ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-6163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-6163. --- Resolution: Fixed Documented on master in d98ba08a7a73dc93c839c77d11245aba70869ab5

[jira] [Commented] (FLINK-6163) Document per-window state in ProcessWindowFunction

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

[GitHub] flink pull request #4992: [FLINK-6163] Document per-window state in ProcessW...

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

[jira] [Commented] (FLINK-6163) Document per-window state in ProcessWindowFunction

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

[GitHub] flink issue #4992: [FLINK-6163] Document per-window state in ProcessWindowFu...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4992 Thanks for the review! 😃 ---

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[GitHub] flink pull request #4996: [hotfix][docs] Change mailing list link in quickst...

GitHub user pnowojski opened a pull request: https://github.com/apache/flink/pull/4996 [hotfix][docs] Change mailing list link in quickstart to flink-user Change mailing list link in quickstart to flink-user. Previously it was pointing to flink-dev. This change only fixes

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150243346 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java --- @@ -260,25

[jira] [Commented] (FLINK-7811) Add support for Scala 2.12

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

[GitHub] flink pull request #4995: [hotfix] [docs] Fix broken link to FLINK-7811

GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/4995 [hotfix] [docs] Fix broken link to FLINK-7811 This fixes a broken hyperlink on page https://ci.apache.org/projects/flink/flink-docs-release-1.4/start/building.html#scala-versions

[GitHub] flink pull request #4994: [hotfix][build] Disable dependency convergence in ...

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150232000 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java --- @@

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150231729 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java --- @@

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[jira] [Commented] (FLINK-7974) AbstractServerBase#shutdown does not wait for shutdown completion

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

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150230620 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -166,27

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150224448 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java --- @@

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150225368 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -166,27

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150228196 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -419,20

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150221573 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java ---

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150229482 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -483,27

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150225343 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java ---

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150224857 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java --- @@

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150228244 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -419,20

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150225411 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -166,27

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150228810 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -483,27

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150223999 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java --- @@

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150221248 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java ---

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150225215 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java --- @@

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150223049 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java --- @@

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150221458 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java ---

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150230125 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -419,20

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150226027 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -166,27

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150224310 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java --- @@

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150224362 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerBase.java --- @@

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150228785 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -483,27

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150226886 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -166,27

[GitHub] flink pull request #4993: [FLINK-7974][FLINK-7975][QS] Wait for shutdown in ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4993#discussion_r150227018 --- Diff: flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java --- @@ -309,31

  1   2   >