[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17182261#comment-17182261 ] ZhuShang commented on FLINK-18959: -- hi [~trohrmann],  FLINK-18685 is related to this issue?when i want

[jira] [Commented] (FLINK-18974) Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181653#comment-17181653 ] ZhuShang commented on FLINK-18974: -- hi [~RocMarshal] ,can i take this? > Translate the 'User-Defined

[jira] [Commented] (FLINK-18850) Add late records dropped metric for row time over windows

[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181190#comment-17181190 ] ZhuShang commented on FLINK-18850: -- sorry,i get it. > Add late records dropped metric for row time

[jira] [Commented] (FLINK-18850) Add late records dropped metric for row time over windows

[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181153#comment-17181153 ] ZhuShang commented on FLINK-18850: -- hi [~libenchao], can i take this,if no one else working on this

[jira] [Updated] (FLINK-18850) Add late records dropped metric for row time over windows

[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuShang updated FLINK-18850: - Attachment: (was: image-2020-08-20-20-25-03-981.png) > Add late records dropped metric for row time

[jira] [Issue Comment Deleted] (FLINK-18850) Add late records dropped metric for row time over windows

[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuShang updated FLINK-18850: - Comment: was deleted (was: hi,[~libenchao]  i found the accumulator in WindowOperator {code:java}

[jira] [Commented] (FLINK-18850) Add late records dropped metric for row time over windows

[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181149#comment-17181149 ] ZhuShang commented on FLINK-18850: -- hi,[~libenchao]  i found the accumulator in WindowOperator

[jira] [Updated] (FLINK-18850) Add late records dropped metric for row time over windows

[ https://issues.apache.org/jira/browse/FLINK-18850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuShang updated FLINK-18850: - Attachment: image-2020-08-20-20-25-03-981.png > Add late records dropped metric for row time over

[jira] [Commented] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17181104#comment-17181104 ] ZhuShang commented on FLINK-18959: -- i also found that archiveExecutionGraph can not be reached when the

[jira] [Commented] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178883#comment-17178883 ] ZhuShang commented on FLINK-18685: -- hi [~rmetzger], you didn't assign this to me and have a code review

[jira] [Commented] (FLINK-18930) Translate "Hive Dialect" page of "Hive Integration" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17178686#comment-17178686 ] ZhuShang commented on FLINK-18930: -- Hi,[~lirui]  i'm willing to do this translation,can you assign to

[jira] [Commented] (FLINK-18685) JobClient.getAccumulators() blocks until streaming job has finished in local environment

[ https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17177731#comment-17177731 ] ZhuShang commented on FLINK-18685: -- hi,[~rmetzger] i'm interested in this issue,can you assign to me?

[jira] [Commented] (FLINK-18146) The note of  StreamingJobGraphGenerator#createJobGraph has a misspelling

[ https://issues.apache.org/jira/browse/FLINK-18146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126472#comment-17126472 ] ZhuShang commented on FLINK-18146: -- [~jark] > The note of  StreamingJobGraphGenerator#createJobGraph

[jira] [Created] (FLINK-18146) The note of  StreamingJobGraphGenerator#createJobGraph has a misspelling

ZhuShang created FLINK-18146: Summary: The note of  StreamingJobGraphGenerator#createJobGraph has a misspelling Key: FLINK-18146 URL: https://issues.apache.org/jira/browse/FLINK-18146 Project: Flink

[jira] [Commented] (FLINK-18037) The doc of StreamTaskNetworkInput.java may has a redundant 'status'

[ https://issues.apache.org/jira/browse/FLINK-18037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17123949#comment-17123949 ] ZhuShang commented on FLINK-18037: -- [~jark] [~lzljs3620320] > The doc of StreamTaskNetworkInput.java

[jira] [Created] (FLINK-18037) The doc of StreamTaskNetworkInput.java may has a redundant 'status'

ZhuShang created FLINK-18037: Summary: The doc of StreamTaskNetworkInput.java may has a redundant 'status' Key: FLINK-18037 URL: https://issues.apache.org/jira/browse/FLINK-18037 Project: Flink