[GitHub] [flink] sunhaibotb edited a comment on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11

sunhaibotb edited a comment on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11 URL: https://github.com/apache/flink/pull/9622#issuecomment-528714281 I used Java 11 and the Hadoop versions explicitly supported by Flink to

[GitHub] [flink] sunhaibotb commented on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11

sunhaibotb commented on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11 URL: https://github.com/apache/flink/pull/9622#issuecomment-528714281 I used Java 11 and the Hadoop versions explicitly supported by Flink to

[GitHub] [flink] walterddr commented on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem

walterddr commented on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem URL: https://github.com/apache/flink/pull/8468#issuecomment-528701147 thanks folks for the help and review :-) I will update the PR and

[GitHub] [flink] yangjf2019 commented on issue #9591: [FLINK-13937][docs] Fix the error of the hive connector dependency ve…

yangjf2019 commented on issue #9591: [FLINK-13937][docs] Fix the error of the hive connector dependency ve… URL: https://github.com/apache/flink/pull/9591#issuecomment-528692966 Hi, @bowenli86 @wuchong Thanks for your helping, and I will work hard in community.

[jira] [Comment Edited] (FLINK-13973) Checkpoint recovery failed after user set uidHash

[ https://issues.apache.org/jira/browse/FLINK-13973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923900#comment-16923900 ] apus66 edited comment on FLINK-13973 at 9/6/19 3:26 AM: I've solved the problem.

[jira] [Commented] (FLINK-13973) Checkpoint recovery failed after user set uidHash

[ https://issues.apache.org/jira/browse/FLINK-13973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923900#comment-16923900 ] apus66 commented on FLINK-13973: I've solved the problem. I have already tested in the production

[GitHub] [flink] flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#issuecomment-513425405 ## CI report: * bd7ade5e0b57dc8577d7f864afcbbb24c2513e56 : FAILURE

[jira] [Closed] (FLINK-13591) 'Completed Job List' in Flink web doesn't display right when job name is very long

[ https://issues.apache.org/jira/browse/FLINK-13591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13591. -- Resolution: Fixed merged in master: 60cf41ab6b9309979849e3310b4c32cf528a1568 > 'Completed Job List'

[GitHub] [flink] KurtYoung merged pull request #9621: [FLINK-13591][web]: fix job list display when job name is too long

KurtYoung merged pull request #9621: [FLINK-13591][web]: fix job list display when job name is too long URL: https://github.com/apache/flink/pull/9621 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] KurtYoung commented on issue #9621: [FLINK-13591][web]: fix job list display when job name is too long

KurtYoung commented on issue #9621: [FLINK-13591][web]: fix job list display when job name is too long URL: https://github.com/apache/flink/pull/9621#issuecomment-528688511 +1, thanks for fixing this This is an automated

[jira] [Closed] (FLINK-13952) PartitionableTableSink can not work with OverwritableTableSink

[ https://issues.apache.org/jira/browse/FLINK-13952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13952. Resolution: Fixed master: d32af521cbe83f88cd0b822c4d752a1b5102c47c > PartitionableTableSink can not work

[GitHub] [flink] flinkbot edited a comment on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api

flinkbot edited a comment on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api URL: https://github.com/apache/flink/pull/9555#issuecomment-526075111 ## CI report: * 64f02281954e69bcfbe858eb40b8f1846cfbe195 : FAILURE

[jira] [Updated] (FLINK-13986) Clean-up of legacy mode

[ https://issues.apache.org/jira/browse/FLINK-13986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13986: - Description: * Fix / update / remove test cases for legacy mode * Deprecate / remove legacy

[jira] [Assigned] (FLINK-13952) PartitionableTableSink can not work with OverwritableTableSink

[ https://issues.apache.org/jira/browse/FLINK-13952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-13952: Assignee: Rui Li > PartitionableTableSink can not work with OverwritableTableSink >

[GitHub] [flink] asfgit closed pull request #9615: [FLINK-13952][table-planner][hive] PartitionableTableSink can not wor…

asfgit closed pull request #9615: [FLINK-13952][table-planner][hive] PartitionableTableSink can not wor… URL: https://github.com/apache/flink/pull/9615 This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-13985) Use native memory for managed memory.

[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13985: - Description: * Allocate memory with {{Unsafe.allocateMemory}} ** {{MemoryManager}} Implement

[jira] [Updated] (FLINK-13983) Launch task executor with new memory calculation logics

[ https://issues.apache.org/jira/browse/FLINK-13983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13983: - Description: * Invoke data structures and utilities introduced in Step 2 to generate JVM

[jira] [Updated] (FLINK-13984) Separate on-heap and off-heap managed memory pools

[ https://issues.apache.org/jira/browse/FLINK-13984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13984: - Description: * Update {{MemoryManager}} to have two separated pools. * Extend 

[GitHub] [flink] bowenli86 commented on issue #9615: [FLINK-13952][table-planner][hive] PartitionableTableSink can not wor…

bowenli86 commented on issue #9615: [FLINK-13952][table-planner][hive] PartitionableTableSink can not wor… URL: https://github.com/apache/flink/pull/9615#issuecomment-528687096 LGTM. merging This is an automated message from

[jira] [Updated] (FLINK-13981) Introduce a switch for enabling the new task executor memory configurations

[ https://issues.apache.org/jira/browse/FLINK-13981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13981: - Description: Introduce a temporal config option as a switch between the current / new task

[jira] [Updated] (FLINK-13982) Implement memory calculation logics

[ https://issues.apache.org/jira/browse/FLINK-13982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-13982: - Description: * Introduce new configuration options * Introduce data structures and utilities.

[jira] [Created] (FLINK-13983) Launch task executor with new memory calculation logics

Xintong Song created FLINK-13983: Summary: Launch task executor with new memory calculation logics Key: FLINK-13983 URL: https://issues.apache.org/jira/browse/FLINK-13983 Project: Flink

[jira] [Created] (FLINK-13984) Separate on-heap and off-heap managed memory pools

Xintong Song created FLINK-13984: Summary: Separate on-heap and off-heap managed memory pools Key: FLINK-13984 URL: https://issues.apache.org/jira/browse/FLINK-13984 Project: Flink Issue

[jira] [Created] (FLINK-13986) Clean-up of legacy mode

Xintong Song created FLINK-13986: Summary: Clean-up of legacy mode Key: FLINK-13986 URL: https://issues.apache.org/jira/browse/FLINK-13986 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13985) Use native memory for managed memory.

Xintong Song created FLINK-13985: Summary: Use native memory for managed memory. Key: FLINK-13985 URL: https://issues.apache.org/jira/browse/FLINK-13985 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13982) Implement memory calculation logics

Xintong Song created FLINK-13982: Summary: Implement memory calculation logics Key: FLINK-13982 URL: https://issues.apache.org/jira/browse/FLINK-13982 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13981) Introduce a switch for enabling the new task executor memory configurations

Xintong Song created FLINK-13981: Summary: Introduce a switch for enabling the new task executor memory configurations Key: FLINK-13981 URL: https://issues.apache.org/jira/browse/FLINK-13981 Project:

[jira] [Created] (FLINK-13980) FLIP-49 Unified Memory Configuration for TaskExecutors

Xintong Song created FLINK-13980: Summary: FLIP-49 Unified Memory Configuration for TaskExecutors Key: FLINK-13980 URL: https://issues.apache.org/jira/browse/FLINK-13980 Project: Flink Issue

[GitHub] [flink] KurtYoung commented on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem

KurtYoung commented on issue #8468: [FLINK-12399][table] Adding PushDownTableSource interface to fix FilterableTableSource applyPredicate problem URL: https://github.com/apache/flink/pull/8468#issuecomment-52868 @walterddr sounds good to me.

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923874#comment-16923874 ] Congxian Qiu(klion26) commented on FLINK-13808: --- After analysis with [~Caesar], this issue

[GitHub] [flink] sunhaibotb edited a comment on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11

sunhaibotb edited a comment on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11 URL: https://github.com/apache/flink/pull/9622#issuecomment-528677356 No, other modules using MiniKdc only were tested with the version 2.4.1

[GitHub] [flink] sunhaibotb commented on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11

sunhaibotb commented on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11 URL: https://github.com/apache/flink/pull/9622#issuecomment-528677356 No, today I'll verify that.

[GitHub] [flink] flinkbot edited a comment on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api

flinkbot edited a comment on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api URL: https://github.com/apache/flink/pull/9555#issuecomment-526075111 ## CI report: * 64f02281954e69bcfbe858eb40b8f1846cfbe195 : FAILURE

[GitHub] [flink] jinglining removed a comment on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api

jinglining removed a comment on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api URL: https://github.com/apache/flink/pull/9555#issuecomment-528669226 @flinkbot travil This is an automated message

[GitHub] [flink] jinglining commented on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api

jinglining commented on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api URL: https://github.com/apache/flink/pull/9555#issuecomment-528669531 @flinkbot run travis This is an automated message from

[GitHub] [flink] jinglining commented on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api

jinglining commented on issue #9555: [FLINK-13868][REST] Job vertex add taskmanager id in rest api URL: https://github.com/apache/flink/pull/9555#issuecomment-528669226 @flinkbot travil This is an automated message from the

[jira] [Commented] (FLINK-13771) Support kqueue Netty transports (MacOS)

[ https://issues.apache.org/jira/browse/FLINK-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923797#comment-16923797 ] Nico Kruber commented on FLINK-13771: - [~aitozi] I'm not working on this and I also do not know how

[jira] [Assigned] (FLINK-13771) Support kqueue Netty transports (MacOS)

[ https://issues.apache.org/jira/browse/FLINK-13771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-13771: --- Assignee: Aitozi > Support kqueue Netty transports (MacOS) >

[jira] [Reopened] (FLINK-13821) Website must link to License etc

[ https://issues.apache.org/jira/browse/FLINK-13821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebb reopened FLINK-13821: -- Please see: https://whimsy.apache.org/site/project/flink There are still two issues listed > Website must link

[jira] [Closed] (FLINK-13937) Fix the error of the hive connector dependency version

[ https://issues.apache.org/jira/browse/FLINK-13937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13937. Resolution: Fixed merged in master: d6ff17d908932d867a6c0a02ac317a4f59e855b 1.9.1:

[GitHub] [flink] asfgit closed pull request #9591: [FLINK-13937][docs] Fix the error of the hive connector dependency ve…

asfgit closed pull request #9591: [FLINK-13937][docs] Fix the error of the hive connector dependency ve… URL: https://github.com/apache/flink/pull/9591 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] bowenli86 commented on issue #9591: [FLINK-13937][docs] Fix the error of the hive connector dependency ve…

bowenli86 commented on issue #9591: [FLINK-13937][docs] Fix the error of the hive connector dependency ve… URL: https://github.com/apache/flink/pull/9591#issuecomment-528581132 LGTM, thanks for the contribution. Merging This

[jira] [Closed] (FLINK-13930) Support Hive version 3.1.x

[ https://issues.apache.org/jira/browse/FLINK-13930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13930. Resolution: Fixed merged in master: e670b929ae124e04c6cdec560d4432ae9c561ff9 > Support Hive version

[GitHub] [flink] asfgit closed pull request #9580: [FLINK-13930][hive] Support Hive version 3.1.x

asfgit closed pull request #9580: [FLINK-13930][hive] Support Hive version 3.1.x URL: https://github.com/apache/flink/pull/9580 This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot edited a comment on issue #9604: [FLINK-13845][docs] Drop all the content of removed Checkpointed interface

flinkbot edited a comment on issue #9604: [FLINK-13845][docs] Drop all the content of removed Checkpointed interface URL: https://github.com/apache/flink/pull/9604#issuecomment-527447402 ## CI report: * 66ade45fec93a56dde7609dffa0ad9dd241d0713 : FAILURE

[GitHub] [flink] kl0u commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

kl0u commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-528577524 I will have a look first thing in the morning. In

[GitHub] [flink] zentol commented on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11

zentol commented on issue #9622: [FLINK-13516][test] Bump MiniKdc to 3.2.0 to fix the failure of YARNSessionFIFOSecuredITCase on Java 11 URL: https://github.com/apache/flink/pull/9622#issuecomment-528556899 minikdc isn't just used by `flink-yarn-tests` but also kafka and the filesystem

[GitHub] [flink] flinkbot edited a comment on issue #9633: [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue

flinkbot edited a comment on issue #9633: [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue URL: https://github.com/apache/flink/pull/9633#issuecomment-528481813 ## CI report: * 9d6fb73a077e26ec84d3cdf5a9835b0b5b567a0a : SUCCESS

[GitHub] [flink] zentol commented on a change in pull request #9632: [FLINK-13978] Add azure-pipelines.yml

zentol commented on a change in pull request #9632: [FLINK-13978] Add azure-pipelines.yml URL: https://github.com/apache/flink/pull/9632#discussion_r321372910 ## File path: azure-pipelines.yml ## @@ -0,0 +1,79 @@ +# Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink] flinkbot edited a comment on issue #9604: [FLINK-13845][docs] Drop all the content of removed Checkpointed interface

flinkbot edited a comment on issue #9604: [FLINK-13845][docs] Drop all the content of removed Checkpointed interface URL: https://github.com/apache/flink/pull/9604#issuecomment-527447402 ## CI report: * 66ade45fec93a56dde7609dffa0ad9dd241d0713 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9632: [FLINK-13978] Add azure-pipelines.yml

flinkbot edited a comment on issue #9632: [FLINK-13978] Add azure-pipelines.yml URL: https://github.com/apache/flink/pull/9632#issuecomment-528440893 ## CI report: * d9002418d222d1e7bedea5ed2dab38076fdaeaba : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/126086359)

[jira] [Commented] (FLINK-12389) flink codegen set String type for ByteBuffer fields

[ https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923694#comment-16923694 ] Yu Yang commented on FLINK-12389: - Resolving this issue as `not a bug`  as we had been able to resolve

[jira] [Resolved] (FLINK-12389) flink codegen set String type for ByteBuffer fields

[ https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Yang resolved FLINK-12389. - Resolution: Fixed > flink codegen set String type for ByteBuffer fields >

[GitHub] [flink] Myasuka commented on issue #9604: [FLINK-13845][docs] Drop all the content of removed Checkpointed interface

Myasuka commented on issue #9604: [FLINK-13845][docs] Drop all the content of removed Checkpointed interface URL: https://github.com/apache/flink/pull/9604#issuecomment-528523385 @flinkbot run travis This is an automated

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9625: [FLINK-13968][travis] Check correctness of binary licensing

flinkbot edited a comment on issue #9625: [FLINK-13968][travis] Check correctness of binary licensing URL: https://github.com/apache/flink/pull/9625#issuecomment-528246792 ## CI report: * e56dd0731c3aa8932e69cf0383ca6205336d5ddc : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9633: [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue

flinkbot edited a comment on issue #9633: [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue URL: https://github.com/apache/flink/pull/9633#issuecomment-528481813 ## CI report: * 9d6fb73a077e26ec84d3cdf5a9835b0b5b567a0a : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9631: [FLINK-13977] Replace HighAvailabilityServices#getWebMonitorLeaderElectionService with #getClusterRestEndpointLeaderElectionService

flinkbot edited a comment on issue #9631: [FLINK-13977] Replace HighAvailabilityServices#getWebMonitorLeaderElectionService with #getClusterRestEndpointLeaderElectionService URL: https://github.com/apache/flink/pull/9631#issuecomment-528394274 ## CI report: *

[jira] [Comment Edited] (FLINK-13974) isAssignable function return wrong result

[ https://issues.apache.org/jira/browse/FLINK-13974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923582#comment-16923582 ] forideal edited comment on FLINK-13974 at 9/5/19 5:22 PM: -- [~Zentol]  i use

[GitHub] [flink] zentol commented on a change in pull request #9632: [FLINK-13978] Add azure-pipelines.yml

zentol commented on a change in pull request #9632: [FLINK-13978] Add azure-pipelines.yml URL: https://github.com/apache/flink/pull/9632#discussion_r321384493 ## File path: azure-pipelines.yml ## @@ -0,0 +1,79 @@ +# Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink] flinkbot commented on issue #9633: [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue

flinkbot commented on issue #9633: [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue URL: https://github.com/apache/flink/pull/9633#issuecomment-528481813 ## CI report: * 9d6fb73a077e26ec84d3cdf5a9835b0b5b567a0a : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9624: [FLINK-13967][licensing] Fully generate binary licensing

flinkbot edited a comment on issue #9624: [FLINK-13967][licensing] Fully generate binary licensing URL: https://github.com/apache/flink/pull/9624#issuecomment-528246748 ## CI report: * 3c3290ae04fc1c8e732f50135c34563add5b82a8 : SUCCESS

[GitHub] [flink] zentol commented on a change in pull request #9632: [FLINK-13978] Add azure-pipelines.yml

zentol commented on a change in pull request #9632: [FLINK-13978] Add azure-pipelines.yml URL: https://github.com/apache/flink/pull/9632#discussion_r321373629 ## File path: azure-pipelines.yml ## @@ -0,0 +1,79 @@ +# Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink] zentol commented on a change in pull request #9632: [FLINK-13978] Add azure-pipelines.yml

zentol commented on a change in pull request #9632: [FLINK-13978] Add azure-pipelines.yml URL: https://github.com/apache/flink/pull/9632#discussion_r321372910 ## File path: azure-pipelines.yml ## @@ -0,0 +1,79 @@ +# Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink] tweise commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

tweise commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-528458812 @kl0u could you please comment if this solution is

[GitHub] [flink] flinkbot commented on issue #9633: [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue

flinkbot commented on issue #9633: [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue URL: https://github.com/apache/flink/pull/9633#issuecomment-528458285 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[jira] [Updated] (FLINK-13970) Remove LifoSetQueue and SetQueue

[ https://issues.apache.org/jira/browse/FLINK-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13970: --- Labels: pull-request-available (was: ) > Remove LifoSetQueue and SetQueue >

[GitHub] [flink] TisonKun opened a new pull request #9633: [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue

TisonKun opened a new pull request #9633: [FLINK-13970][coordinate] Remove LifoSetQueue and SetQueue URL: https://github.com/apache/flink/pull/9633 ## What is the purpose of the change Dead code removal. ## Verifying this change This change is a code cleanup without

[jira] [Commented] (FLINK-13970) Remove LifoSetQueue and SetQueue

[ https://issues.apache.org/jira/browse/FLINK-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923602#comment-16923602 ] TisonKun commented on FLINK-13970: -- With another pass I find {{SetQueue}} is quite similar with

[jira] [Updated] (FLINK-13970) Remove LifoSetQueue and SetQueue

[ https://issues.apache.org/jira/browse/FLINK-13970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-13970: - Summary: Remove LifoSetQueue and SetQueue (was: Remove or move LifoSetQueue) > Remove LifoSetQueue

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321355744 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321363043 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321351907 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321337838 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321363183 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321353063 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321354028 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321322010 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321358028 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321359916 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321357522 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321361257 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321359402 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321353802 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321345857 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321345725 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321356663 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321331829 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321356421 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321360968 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321349868 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321363402 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321346394 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321347548 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321330691 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321354880 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321362123 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321333846 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321343055 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

tillrohrmann commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r321344351 ## File path:

  1   2   3   4   >