[jira] [Commented] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

[ https://issues.apache.org/jira/browse/FLINK-15447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009578#comment-17009578 ] xymaqingxiang commented on FLINK-15447: --- +1 We also set "java.io.tmpdir" to "

[jira] [Created] (FLINK-14094) Fix OperatorIOMetricGroup repeat register problem

xymaqingxiang created FLINK-14094: - Summary: Fix OperatorIOMetricGroup repeat register problem Key: FLINK-14094 URL: https://issues.apache.org/jira/browse/FLINK-14094 Project: Flink Issue Typ

[jira] [Commented] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16878942#comment-16878942 ] xymaqingxiang commented on FLINK-10908: --- [~yanghua] I'm sorry to bother you, pleas

[jira] [Commented] (FLINK-12909) add try catch when find a unique file name for the spilling channel

[ https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872183#comment-16872183 ] xymaqingxiang commented on FLINK-12909: --- I don't think it's necessary to wait some

[jira] [Comment Edited] (FLINK-12909) add try catch when find a unique file name for the spilling channel

[ https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871926#comment-16871926 ] xymaqingxiang edited comment on FLINK-12909 at 6/25/19 2:13 AM: --

[jira] [Comment Edited] (FLINK-12909) add try catch when find a unique file name for the spilling channel

[ https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871926#comment-16871926 ] xymaqingxiang edited comment on FLINK-12909 at 6/25/19 2:11 AM: --

[jira] [Commented] (FLINK-12909) add try catch when find a unique file name for the spilling channel

[ https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871926#comment-16871926 ] xymaqingxiang commented on FLINK-12909: --- First of all, thank you for the review [~

[jira] [Commented] (FLINK-12909) add try catch when find a unique file name for the spilling channel

[ https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870760#comment-16870760 ] xymaqingxiang commented on FLINK-12909: --- [~rmetzger] A little modification has bee

[jira] [Updated] (FLINK-12909) add try catch when find a unique file name for the spilling channel

[ https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-12909: -- Description: h2. What is the purpose of the change Catch exceptions thrown due to disk loss,

[jira] [Updated] (FLINK-12909) add try catch when find a unique file name for the spilling channel

[ https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-12909: -- Description: h2. What is the purpose of the change Catch exceptions thrown due to disk loss,

[jira] [Commented] (FLINK-12909) add try catch when find a unique file name for the spilling channel

[ https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16868406#comment-16868406 ] xymaqingxiang commented on FLINK-12909: --- [~Zentol]  I'm sorry to bother you, pleas

[jira] [Created] (FLINK-12909) add try catch when find a unique file name for the spilling channel

xymaqingxiang created FLINK-12909: - Summary: add try catch when find a unique file name for the spilling channel Key: FLINK-12909 URL: https://issues.apache.org/jira/browse/FLINK-12909 Project: Flink

[jira] [Commented] (FLINK-11963) Add time-based cleanup mechanism in history server

[ https://issues.apache.org/jira/browse/FLINK-11963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16868402#comment-16868402 ] xymaqingxiang commented on FLINK-11963: --- [~Zentol] [~klion26]  I'm sorry to bother

[jira] [Updated] (FLINK-11963) Add time-based cleanup mechanism in history server

[ https://issues.apache.org/jira/browse/FLINK-11963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-11963: -- Description: Flink has a history server that can be used to query the statistics of completed

[jira] [Updated] (FLINK-12896) modify :jobId key in TaskCheckpointStatisticDetailsHandler for History Server

[ https://issues.apache.org/jira/browse/FLINK-12896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-12896: -- Attachment: (was: image-2019-06-19-15-33-12-243.png) > modify :jobId key in TaskCheckpoint

[jira] [Updated] (FLINK-12896) modify :jobId key in TaskCheckpointStatisticDetailsHandler for History Server

[ https://issues.apache.org/jira/browse/FLINK-12896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-12896: -- Description: There are 2 bugs, as follows: 1. could not found the checkpoint details for subt

[jira] [Updated] (FLINK-12896) modify :jobId key in TaskCheckpointStatisticDetailsHandler for History Server

[ https://issues.apache.org/jira/browse/FLINK-12896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-12896: -- Summary: modify :jobId key in TaskCheckpointStatisticDetailsHandler for History Server (was:

[jira] [Commented] (FLINK-12896) Missing some information in History Server

[ https://issues.apache.org/jira/browse/FLINK-12896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16867317#comment-16867317 ] xymaqingxiang commented on FLINK-12896: --- [~Zentol] [~klion26]  I'm sorry to bother

[jira] [Created] (FLINK-12896) Missing some information in History Server

xymaqingxiang created FLINK-12896: - Summary: Missing some information in History Server Key: FLINK-12896 URL: https://issues.apache.org/jira/browse/FLINK-12896 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-11963) Add time-based cleanup mechanism in history server

xymaqingxiang created FLINK-11963: - Summary: Add time-based cleanup mechanism in history server Key: FLINK-11963 URL: https://issues.apache.org/jira/browse/FLINK-11963 Project: Flink Issue Ty

[jira] [Updated] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10908: -- Description: Add yarn.application.priority in YarnConfigOptions, changes the priority of the

[jira] [Updated] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10908: -- Description:   Changes the priority of the job. Allowed priority values are VERY_HIGH, HIGH,

[jira] [Updated] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10908: -- Description: Add yarn.application.priority in YarnConfigOptions, Changes the priority of the j

[jira] [Created] (FLINK-10908) Add yarn.application.priority in YarnConfigOptions

xymaqingxiang created FLINK-10908: - Summary: Add yarn.application.priority in YarnConfigOptions Key: FLINK-10908 URL: https://issues.apache.org/jira/browse/FLINK-10908 Project: Flink Issue Ty

[jira] [Updated] (FLINK-10898) Add yarn.application-attempts-failures-validity-interval in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10898: -- Description: The attempt failure validity interval says that an application is only killed af

[jira] [Created] (FLINK-10898) Add yarn.application-attempts-failures-validity-interval in YarnConfigOptions

xymaqingxiang created FLINK-10898: - Summary: Add yarn.application-attempts-failures-validity-interval in YarnConfigOptions Key: FLINK-10898 URL: https://issues.apache.org/jira/browse/FLINK-10898 Proje

[jira] [Updated] (FLINK-10898) Add yarn.application-attempts-failures-validity-interval in YarnConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-10898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10898: -- Description: The attempt failure validity interval says that an application is only killed af

[jira] [Closed] (FLINK-10161) Add host in checkpoint detail

[ https://issues.apache.org/jira/browse/FLINK-10161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang closed FLINK-10161. - Resolution: Duplicate Assignee: xymaqingxiang Sorry, it is duplicated with [FLINK-10162|h

[jira] [Updated] (FLINK-10162) Add host in checkpoint detail

[ https://issues.apache.org/jira/browse/FLINK-10162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10162: -- Attachment: image-2018-08-16-21-36-04-977.png > Add host in checkpoint detail > --

[jira] [Updated] (FLINK-10162) Add host in checkpoint detail

[ https://issues.apache.org/jira/browse/FLINK-10162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10162: -- Description: When a streaming job run for a long time,  there will be failures at checkpoint.

[jira] [Updated] (FLINK-10162) Add host in checkpoint detail

[ https://issues.apache.org/jira/browse/FLINK-10162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10162: -- Description:   When a streaming job run for a long time,  there will be failures at checkpoi

[jira] [Updated] (FLINK-10162) Add host in checkpoint detail

[ https://issues.apache.org/jira/browse/FLINK-10162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10162: -- Attachment: image-2018-08-16-21-15-42-167.png > Add host in checkpoint detail > --

[jira] [Updated] (FLINK-10162) Add host in checkpoint detail

[ https://issues.apache.org/jira/browse/FLINK-10162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10162: -- Attachment: image-2018-08-16-21-15-46-585.png > Add host in checkpoint detail > --

[jira] [Updated] (FLINK-10162) Add host in checkpoint detail

[ https://issues.apache.org/jira/browse/FLINK-10162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-10162: -- Attachment: image-2018-08-16-21-14-57-221.png > Add host in checkpoint detail > --

[jira] [Created] (FLINK-10162) Add host in checkpoint detail

xymaqingxiang created FLINK-10162: - Summary: Add host in checkpoint detail Key: FLINK-10162 URL: https://issues.apache.org/jira/browse/FLINK-10162 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10161) Add host in checkpoint detail

xymaqingxiang created FLINK-10161: - Summary: Add host in checkpoint detail Key: FLINK-10161 URL: https://issues.apache.org/jira/browse/FLINK-10161 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16572626#comment-16572626 ] xymaqingxiang commented on FLINK-8290: -- Hi, *all*   [group.id|http://group.id/] is a

[jira] [Comment Edited] (FLINK-9945) RocksDB state backend Checkpointing Failed

[ https://issues.apache.org/jira/browse/FLINK-9945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16558203#comment-16558203 ] xymaqingxiang edited comment on FLINK-9945 at 7/26/18 11:28 AM: ---

[jira] [Commented] (FLINK-9945) RocksDB state backend Checkpointing Failed

[ https://issues.apache.org/jira/browse/FLINK-9945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16558203#comment-16558203 ] xymaqingxiang commented on FLINK-9945: -- The flink job is as follows, no additional s

[jira] [Commented] (FLINK-9945) RocksDB state backend Checkpointing Failed

[ https://issues.apache.org/jira/browse/FLINK-9945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16558149#comment-16558149 ] xymaqingxiang commented on FLINK-9945: -- JobManager log, there is not an earlier exce

[jira] [Updated] (FLINK-9945) RocksDB state backend Checkpointing Failed

[ https://issues.apache.org/jira/browse/FLINK-9945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-9945: - Attachment: image-2018-07-26-18-31-21-429.png > RocksDB state backend Checkpointing Failed >

[jira] [Commented] (FLINK-9945) RocksDB state backend Checkpointing Failed

[ https://issues.apache.org/jira/browse/FLINK-9945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16556776#comment-16556776 ] xymaqingxiang commented on FLINK-9945: -- Versions: 1.4.2 > RocksDB state backend Che

[jira] [Created] (FLINK-9945) RocksDB state backend Checkpointing Failed

xymaqingxiang created FLINK-9945: Summary: RocksDB state backend Checkpointing Failed Key: FLINK-9945 URL: https://issues.apache.org/jira/browse/FLINK-9945 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9404) Adapter viewfs in BucketingSink when verify that truncate actually works

xymaqingxiang created FLINK-9404: Summary: Adapter viewfs in BucketingSink when verify that truncate actually works Key: FLINK-9404 URL: https://issues.apache.org/jira/browse/FLINK-9404 Project: Flink

[jira] [Comment Edited] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327118#comment-16327118 ] xymaqingxiang edited comment on FLINK-8290 at 1/16/18 1:33 PM: -

[jira] [Commented] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16327118#comment-16327118 ] xymaqingxiang commented on FLINK-8290: -- The description of “client.id” is “An id stri

[jira] [Updated] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

[ https://issues.apache.org/jira/browse/FLINK-8290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xymaqingxiang updated FLINK-8290: - Description: Now the Clientid that consumes the all topics are constant("flink-kafka-consumer-leg

[jira] [Created] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

xymaqingxiang created FLINK-8290: Summary: Modify clientId to groupId in flink-connector-kafka-0.8 Key: FLINK-8290 URL: https://issues.apache.org/jira/browse/FLINK-8290 Project: Flink Issue T