[jira] [Commented] (FLINK-8756) Support ClusterClient.getAccumulators() in RestClusterClient

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

[GitHub] flink issue #5573: [FLINK-8756][Client] Support ClusterClient.getAccumulator...

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5573 HI @tillrohrmann and @aljoscha , who would review this PR? Thanks! ---

[jira] [Commented] (FLINK-8690) Update logical rule set to generate FlinkLogicalAggregate explicitly allow distinct agg on DataStream

[ https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16375920#comment-16375920 ] Hequn Cheng commented on FLINK-8690: Hi, currently, {{FlinkLogicalWindowAggregate}} doesn't support

[jira] [Updated] (FLINK-8661) Replace Collections.EMPTY_MAP with Collections.emptyMap()

[ https://issues.apache.org/jira/browse/FLINK-8661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8661: -- Description: The use of Collections.EMPTY_SET and Collections.EMPTY_MAP often causes unchecked assignment and

[jira] [Updated] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

[ https://issues.apache.org/jira/browse/FLINK-8687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-8687: -- Description: Currently MaterializedCollectStreamResult#retrievePage checks page range and calls

[jira] [Commented] (FLINK-8660) Enable the user to provide custom HAServices implementation

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

[GitHub] flink issue #5530: [FLINK-8660] Enable the user to provide custom HAServices...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5530 You could rebase on the latest master and force push to retrigger the build. ---

[jira] [Closed] (FLINK-8746) Support rescaling of jobs which are not fully running

[ https://issues.apache.org/jira/browse/FLINK-8746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8746. Resolution: Fixed Fixed via 662ed3df5270befae92af3f59ed28e0cfea4e55d > Support rescaling of jobs

[jira] [Commented] (FLINK-8746) Support rescaling of jobs which are not fully running

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

[jira] [Commented] (FLINK-8748) Cancel slot requests for alternatively completed slots in SlotPool

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

[jira] [Commented] (FLINK-8749) Release slots when scheduling operation is canceled in ExecutionGraph

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

[jira] [Resolved] (FLINK-8138) Race in TaskAsyncCallTest leads to test time out

[ https://issues.apache.org/jira/browse/FLINK-8138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-8138. -- Resolution: Fixed Fixed via 28c2616b80d4c87229c9e74caf53006776408713 > Race in

[GitHub] flink pull request #5561: [FLINK-8748] [flip6] Cancel slot allocations for a...

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

[GitHub] flink pull request #5560: [FLINK-8746] [flip6] Rescale partially running job...

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

[GitHub] flink pull request #5562: [FLINK-8749] [flip6] Release slots when scheduling...

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

[jira] [Closed] (FLINK-8749) Release slots when scheduling operation is canceled in ExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-8749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8749. Resolution: Fixed Fixed via 3969170f5c2dba5ab76bed617648531b1e9aa435 > Release slots when

[jira] [Closed] (FLINK-8748) Cancel slot requests for alternatively completed slots in SlotPool

[ https://issues.apache.org/jira/browse/FLINK-8748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8748. Resolution: Fixed Fixed via 107c8e04be86e9fd893a5c9e0f9c528d1453c3de > Cancel slot requests for

[GitHub] flink pull request #:

Github user kbialek commented on the pull request: https://github.com/apache/flink/commit/13bb32ef891428fe9e0e14b6ecc525f15c52c40a#commitcomment-27763936 This change broke my flink-consul implementation. That is not a big deal, however I wonder if it wouldn't break ZK recovery. As

[jira] [Commented] (FLINK-8775) Make shut down of MiniCluster non blocking

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

[GitHub] flink pull request #5576: [FLINK-8775] [flip6] Non blocking MiniCluster shut...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5576 [FLINK-8775] [flip6] Non blocking MiniCluster shut down ## What is the purpose of the change Shuts down the `MiniCluster` in a non blocking fashion. ## Verifying this change

[jira] [Created] (FLINK-8775) Make shut down of MiniCluster non blocking

Till Rohrmann created FLINK-8775: Summary: Make shut down of MiniCluster non blocking Key: FLINK-8775 URL: https://issues.apache.org/jira/browse/FLINK-8775 Project: Flink Issue Type:

[jira] [Created] (FLINK-8774) Make shut down of ResourceManagerRunner non blocking

Till Rohrmann created FLINK-8774: Summary: Make shut down of ResourceManagerRunner non blocking Key: FLINK-8774 URL: https://issues.apache.org/jira/browse/FLINK-8774 Project: Flink Issue

[GitHub] flink issue #5530: [FLINK-8660] Enable the user to provide custom HAServices...

Github user kbialek commented on the issue: https://github.com/apache/flink/pull/5530 Looks like build process was terminated by kernel. Can someone retrigger it? ---

[jira] [Commented] (FLINK-8660) Enable the user to provide custom HAServices implementation

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

[jira] [Commented] (FLINK-8773) Make shut down of JobManagerRunner non blocking

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

[GitHub] flink pull request #5575: [FLINK-8773] [flip6] Make JobManagerRunner shut do...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5575 [FLINK-8773] [flip6] Make JobManagerRunner shut down non blocking ## What is the purpose of the change The Dispatcher no longer shuts down the JobManagerRunner in a blocking fashion.

[jira] [Created] (FLINK-8773) Make shut down of JobManagerRunner non blocking

Till Rohrmann created FLINK-8773: Summary: Make shut down of JobManagerRunner non blocking Key: FLINK-8773 URL: https://issues.apache.org/jira/browse/FLINK-8773 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8772) FlinkKafkaConsumerBase partitions discover missing a log parameter

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

[GitHub] flink pull request #5574: [FLINK-8772][kafka] fix missing log parameter

GitHub user Matrix42 opened a pull request: https://github.com/apache/flink/pull/5574 [FLINK-8772][kafka] fix missing log parameter ## Brief change log fix FlinkKafkaConsumerBase missing log parameter You can merge this pull request into a Git repository by running:

[jira] [Created] (FLINK-8772) FlinkKafkaConsumerBase partitions discover missing a log parameter

Matrix42 created FLINK-8772: --- Summary: FlinkKafkaConsumerBase partitions discover missing a log parameter Key: FLINK-8772 URL: https://issues.apache.org/jira/browse/FLINK-8772 Project: Flink

[jira] [Commented] (FLINK-8660) Enable the user to provide custom HAServices implementation

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

[GitHub] flink issue #5530: [FLINK-8660] Enable the user to provide custom HAServices...

Github user kbialek commented on the issue: https://github.com/apache/flink/pull/5530 Now uses high-availability configuration property can be set either to none, zookeeper or FQN of factory class ---

[jira] [Commented] (FLINK-8660) Enable the user to provide custom HAServices implementation

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

[GitHub] flink pull request #5530: [FLINK-8660] Enable the user to provide custom HAS...

GitHub user kbialek reopened a pull request: https://github.com/apache/flink/pull/5530 [FLINK-8660] Enable the user to provide custom HAServices implementation ## What is the purpose of the change This pull request makes it possible to use alternative (to ZK) HA backend

[jira] [Updated] (FLINK-8769) Quickstart job execution in IDE logs contain several exceptions

[ https://issues.apache.org/jira/browse/FLINK-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8769: Summary: Quickstart job execution in IDE logs contain several exceptions (was: Quickstart

[jira] [Closed] (FLINK-8678) Make AkkaRpcService#stopService non-blocking

[ https://issues.apache.org/jira/browse/FLINK-8678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8678. Resolution: Fixed Fixed via c27e2a77005db355da9e72656af8b0df8b1dfe75 > Make

[jira] [Closed] (FLINK-8664) Change termination future type of RpcEndpoint to Void

[ https://issues.apache.org/jira/browse/FLINK-8664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8664. Resolution: Fixed Fixed via c131546eaadd07baf950bd6a44d07ee42d109e4c > Change termination future

[jira] [Closed] (FLINK-8670) Make MetricRegistryImpl#shutdown non blocking

[ https://issues.apache.org/jira/browse/FLINK-8670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8670. Resolution: Fixed Fixed via e29ec0fbd2cb03a42b98142f63ce73b97dc2e915 > Make

[jira] [Closed] (FLINK-8665) Allow RpcEndpoint#postStop to complete asynchronously

[ https://issues.apache.org/jira/browse/FLINK-8665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8665. Resolution: Fixed Fixed via d9b28e817351eb2eb6b4cdd9597061713d9160e8 > Allow RpcEndpoint#postStop

[jira] [Closed] (FLINK-8666) Use AkkaUtils#testDispatcherConfig in MiniCluster

[ https://issues.apache.org/jira/browse/FLINK-8666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8666. Resolution: Fixed Fixed via 65081ac72d18f610db210c5fe030805141a9b2e5 > Use

[jira] [Closed] (FLINK-8677) Make ClusterEntrypoint shut down non-blocking

[ https://issues.apache.org/jira/browse/FLINK-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8677. Resolution: Fixed Fixed via fba655af1a4a543f01eecf222826a0821e6e1c17 > Make ClusterEntrypoint shut

[jira] [Commented] (FLINK-8666) Use AkkaUtils#testDispatcherConfig in MiniCluster

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

[jira] [Commented] (FLINK-8664) Change termination future type of RpcEndpoint to Void

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

[GitHub] flink pull request #5517: [FLINK-8678] [flip6] Make RpcService shut down non...

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

[jira] [Commented] (FLINK-8677) Make ClusterEntrypoint shut down non-blocking

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

[GitHub] flink pull request #5499: [FLINK-8666] [test] Use testDispatcherConfig in Mi...

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

[jira] [Commented] (FLINK-8670) Make MetricRegistryImpl#shutdown non blocking

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

[jira] [Commented] (FLINK-8678) Make AkkaRpcService#stopService non-blocking

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

[jira] [Commented] (FLINK-8665) Allow RpcEndpoint#postStop to complete asynchronously

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

[GitHub] flink pull request #5498: [FLINK-8665] [rest] Let RpcEndpoint#postStop retur...

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

[GitHub] flink pull request #5512: [FLINK-8677] [flip6] Make ClusterEntrypoint shut d...

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

[GitHub] flink pull request #5504: [FLINK-8670] Make MetricRegistryImpl#shutdown non ...

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

[GitHub] flink pull request #5496: [FLINK-8664] [rest] Change RpcEndpoint#Termination...

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

[GitHub] flink issue #5327: [FLINK-8428] [table] Implement stream-stream non-window l...

Github user hequn8128 commented on the issue: https://github.com/apache/flink/pull/5327 hi, @twalthr Look forward to your review, thanks :-) ---

[jira] [Commented] (FLINK-8428) Implement stream-stream non-window left outer join

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

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16375447#comment-16375447 ] tarun razdan commented on FLINK-7756: - [~aljoscha] Here is the link to the minimal example for your

[jira] [Assigned] (FLINK-7836) specifying node label for flink job to run on yarn

[ https://issues.apache.org/jira/browse/FLINK-7836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-7836: --- Assignee: vinoyang > specifying node label for flink job to run on yarn >

[jira] [Commented] (FLINK-8761) Various improvements to the Quickstarts

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

[GitHub] flink pull request #5569: [FLINK-8761] [quickstarts] Big improvements to the...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5569#discussion_r170415569 --- Diff: flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/pom.xml --- @@ -50,181 +51,113 @@ under the License.

[jira] [Commented] (FLINK-8761) Various improvements to the Quickstarts

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

[GitHub] flink pull request #5569: [FLINK-8761] [quickstarts] Big improvements to the...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5569#discussion_r170415181 --- Diff: flink-quickstart/flink-quickstart-java/src/main/resources/archetype-resources/pom.xml --- @@ -50,181 +51,113 @@ under the License.