[jira] [Commented] (FLINK-9411) Support parquet rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16519405#comment-16519405 ] Triones Deng commented on FLINK-9411: - [~StephanEwen] sure a design is necessary, her

[jira] [Comment Edited] (FLINK-9411) Support parquet rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16519405#comment-16519405 ] Triones Deng edited comment on FLINK-9411 at 6/21/18 2:29 PM: -

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16527633#comment-16527633 ] Triones Deng commented on FLINK-9231: - [~azagrebin] WebFrontendBootstrap is WebFronte

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16447086#comment-16447086 ] Triones Deng commented on FLINK-9231: - [~yuzhih...@gmail.com] i am interested in this

[jira] [Commented] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448079#comment-16448079 ] Triones Deng commented on FLINK-9231: - [~yuzhih...@gmail.com] I notice that there are

[jira] [Comment Edited] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448079#comment-16448079 ] Triones Deng edited comment on FLINK-9231 at 4/24/18 1:54 PM: --

[jira] [Comment Edited] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448079#comment-16448079 ] Triones Deng edited comment on FLINK-9231 at 4/24/18 1:56 PM: --

[jira] [Comment Edited] (FLINK-9231) Enable SO_REUSEADDR on listen sockets

[ https://issues.apache.org/jira/browse/FLINK-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16448079#comment-16448079 ] Triones Deng edited comment on FLINK-9231 at 4/24/18 2:05 PM: --

[jira] [Commented] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16465923#comment-16465923 ] Triones Deng commented on FLINK-9303: - [~tzulitai] i am interested in this issue. in y

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

[ https://issues.apache.org/jira/browse/FLINK-9284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16465962#comment-16465962 ] Triones Deng commented on FLINK-9284: - [~Zentol]  see the example link. there are two

[jira] [Commented] (FLINK-9340) ScheduleOrUpdateConsumersTest may fail with Address already in use

[ https://issues.apache.org/jira/browse/FLINK-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16474387#comment-16474387 ] Triones Deng commented on FLINK-9340: - [~yuzhih...@gmail.com] i am interested in this.

[jira] [Commented] (FLINK-9390) Shutdown of KafkaProducer causes confusing log message

[ https://issues.apache.org/jira/browse/FLINK-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16478931#comment-16478931 ] Triones Deng commented on FLINK-9390: - [~srichter] Could you please kindly let me konw

[jira] [Comment Edited] (FLINK-9390) Shutdown of KafkaProducer causes confusing log message

[ https://issues.apache.org/jira/browse/FLINK-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16478931#comment-16478931 ] Triones Deng edited comment on FLINK-9390 at 5/17/18 11:41 AM: -

[jira] [Commented] (FLINK-9390) Shutdown of KafkaProducer causes confusing log message

[ https://issues.apache.org/jira/browse/FLINK-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16481438#comment-16481438 ] Triones Deng commented on FLINK-9390: - [~StephanEwen] notice that now flink make use o

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421677#comment-16421677 ] Triones Deng commented on FLINK-9087: - [~mingleizhang] are you still working on this?

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421679#comment-16421679 ] Triones Deng commented on FLINK-9087: - Does anyone can give me a permission to contrib

[jira] [Commented] (FLINK-9056) Job submission fails with AskTimeoutException if not enough slots are available

[ https://issues.apache.org/jira/browse/FLINK-9056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16421687#comment-16421687 ] Triones Deng commented on FLINK-9056: - [~fhueske] when Job parallelism exceeds availab

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423367#comment-16423367 ] Triones Deng commented on FLINK-9087: - [~yuzhih...@gmail.com] notice that RecordWriter

[jira] [Comment Edited] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423367#comment-16423367 ] Triones Deng edited comment on FLINK-9087 at 4/3/18 1:59 AM: -

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16424169#comment-16424169 ] Triones Deng commented on FLINK-9087: - [~yuzhih...@gmail.com]   when i run the test. i

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429743#comment-16429743 ] Triones Deng commented on FLINK-9087: - thanks for your suggestions, i will follow this

[jira] [Commented] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-9087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16432385#comment-16432385 ] Triones Deng commented on FLINK-9087: - This PR is ready for having another review. [~N