[jira] [Commented] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask

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

[GitHub] flink issue #5777: [FLINK-7897] Consider using nio.Files for file deletion i...

Github user yuqi1129 commented on the issue: https://github.com/apache/flink/pull/5777 @tedyu , You are right, I ignore the code below which do not show in the change. +1 ---

[jira] [Commented] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16431593#comment-16431593 ] ASF GitHub Bot commented on FLINK-4534: --- Github user zhangminglei commented on the i

[GitHub] flink issue #4482: [FLINK-4534] Fix synchronization issue in BucketingSink

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4482 This PR is ready for review again now. ---

[jira] [Assigned] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers

[ https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9151: --- Assignee: vinoyang > standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task >

[jira] [Commented] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16431583#comment-16431583 ] ASF GitHub Bot commented on FLINK-4534: --- Github user zhangminglei commented on the i

[GitHub] flink issue #4482: [FLINK-4534] Fix synchronization issue in BucketingSink

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4482 This PR has conflicts, I will fix soon. ---

[jira] [Comment Edited] (FLINK-7525) Add config option to disable Cancel functionality on UI

[ https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16361702#comment-16361702 ] Ted Yu edited comment on FLINK-7525 at 4/10/18 12:29 AM: - I will w

[jira] [Comment Edited] (FLINK-4534) Lack of synchronization in BucketingSink#restoreState()

[ https://issues.apache.org/jira/browse/FLINK-4534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16304163#comment-16304163 ] Ted Yu edited comment on FLINK-4534 at 4/10/18 12:29 AM: - Can this

[jira] [Commented] (FLINK-9152) Harmonize BroadcastProcessFunction Context names

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

[jira] [Updated] (FLINK-9152) Harmonize BroadcastProcessFunction Context names

[ https://issues.apache.org/jira/browse/FLINK-9152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-9152: Affects Version/s: 1.5.0 > Harmonize BroadcastProcessFunction Context names > --

[GitHub] flink pull request #5830: [FLINK-9152] Harmonize BroadcastProcessFunction Co...

GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/5830 [FLINK-9152] Harmonize BroadcastProcessFunction Context names R: @kl0u You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink jira-915

[jira] [Created] (FLINK-9152) Harmonize BroadcastProcessFunction Context names

Aljoscha Krettek created FLINK-9152: --- Summary: Harmonize BroadcastProcessFunction Context names Key: FLINK-9152 URL: https://issues.apache.org/jira/browse/FLINK-9152 Project: Flink Issue Ty

[jira] [Comment Edited] (FLINK-7795) Utilize error-prone to discover common coding mistakes

[ https://issues.apache.org/jira/browse/FLINK-7795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16345955#comment-16345955 ] Ted Yu edited comment on FLINK-7795 at 4/9/18 8:58 PM: --- error-prone

[GitHub] flink issue #5777: [FLINK-7897] Consider using nio.Files for file deletion i...

Github user tedyu commented on the issue: https://github.com/apache/flink/pull/5777 @yuqi1129 What do you think ? ---

[jira] [Commented] (FLINK-7897) Consider using nio.Files for file deletion in TransientBlobCleanupTask

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

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

[ https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7488. --- Resolution: Fixed Assignee: Chesnay Schepler Fix Version/s: 1.5.0 master: 767d

[jira] [Closed] (FLINK-9149) The creation of the ExecutionPlan fails when you combine a SideOutput with an SplitStream.

[ https://issues.apache.org/jira/browse/FLINK-9149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9149. --- Resolution: Duplicate > The creation of the ExecutionPlan fails when you combine a SideOutput

[jira] [Updated] (FLINK-9126) Ability for CassandraInputFormat to output data into a Custom Cassandra Annotated Pojo

[ https://issues.apache.org/jira/browse/FLINK-9126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeffrey Carter updated FLINK-9126: -- Fix Version/s: (was: 1.5.0) 1.6.0 > Ability for CassandraInputFormat to o

[jira] [Updated] (FLINK-9150) Prepare for Java 10

[ https://issues.apache.org/jira/browse/FLINK-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9150: -- Description: Java 9 is not a LTS release. When compiling with Java 10, I see the following compilation error: {

[jira] [Updated] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers

[ https://issues.apache.org/jira/browse/FLINK-9151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christopher Ng updated FLINK-9151: -- Affects Version/s: 1.4.1 > standalone cluster scripts should pass FLINK_CONF_DIR to job manager

[jira] [Created] (FLINK-9151) standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers

Christopher Ng created FLINK-9151: - Summary: standalone cluster scripts should pass FLINK_CONF_DIR to job manager and task managers Key: FLINK-9151 URL: https://issues.apache.org/jira/browse/FLINK-9151

[jira] [Comment Edited] (FLINK-7488) TaskManagerHeapSizeCalculationJavaBashTest sometimes fails

[ https://issues.apache.org/jira/browse/FLINK-7488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16402299#comment-16402299 ] Ted Yu edited comment on FLINK-7488 at 4/9/18 4:14 PM: --- {code} comp

[jira] [Created] (FLINK-9150) Prepare for Java 10

Ted Yu created FLINK-9150: - Summary: Prepare for Java 10 Key: FLINK-9150 URL: https://issues.apache.org/jira/browse/FLINK-9150 Project: Flink Issue Type: Task Reporter: Ted Yu When comp

[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=16430562#comment-16430562 ] ASF GitHub Bot commented on FLINK-9056: --- GitHub user yuqi1129 opened a pull request:

[GitHub] flink pull request #5829: [FLINK-9056] [jobmanager] Job submission fails wit...

GitHub user yuqi1129 opened a pull request: https://github.com/apache/flink/pull/5829 [FLINK-9056] [jobmanager] Job submission fails with AskTimeoutExcepti… ## What is the purpose of the change This pull request makes the jobmanager return specific information if there is

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16430550#comment-16430550 ] Sihua Zhou commented on FLINK-9070: --- Hi [~kien_truong] nice catch! Thanks for your revie

[jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear()

[ https://issues.apache.org/jira/browse/FLINK-9070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16430525#comment-16430525 ] Truong Duc Kien commented on FLINK-9070: This is definitely a safer way than my id

[jira] [Created] (FLINK-9149) The creation of the ExecutionPlan fails when you combine a SideOutput with an SplitStream.

Fred Teunissen created FLINK-9149: - Summary: The creation of the ExecutionPlan fails when you combine a SideOutput with an SplitStream. Key: FLINK-9149 URL: https://issues.apache.org/jira/browse/FLINK-9149