[jira] [Closed] (FLINK-8747) The tag of waiting for floating buffers in RemoteInputChannel should be updated properly

[ https://issues.apache.org/jira/browse/FLINK-8747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-8747. --- > The tag of waiting for floating buffers in RemoteInputChannel should be > updated properly > --

[jira] [Updated] (FLINK-8523) Stop assigning floating buffers for blocked input channels in exactly-once mode

[ https://issues.apache.org/jira/browse/FLINK-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-8523: Affects Version/s: 1.6.0 > Stop assigning floating buffers for blocked input channels in exactly-once > mod

[jira] [Commented] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

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

[GitHub] flink issue #5394: [FLINK-6571][tests] Catch InterruptedException in StreamS...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5394 I think neither solve the problem. Variant 2 looks identical to what we have in master. Variant 1 only allows interrupts after the task was canceled. According to what @StephanEwen

[jira] [Commented] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

[ https://issues.apache.org/jira/browse/FLINK-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429896#comment-16429896 ] Chesnay Schepler commented on FLINK-6571: - Occurred on travis: https://travis-ci.o

[jira] [Updated] (FLINK-9148) when deploying flink on kubernetes, the taskmanager report "java.net.UnknownHostException: flink-jobmanager: Temporary failure in name resolution"

[ https://issues.apache.org/jira/browse/FLINK-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] You Chu updated FLINK-9148: --- Description: refer to https://ci.apache.org/projects/flink/flink-docs-release-1.4/ops/deployment/kubernetes.h

[jira] [Created] (FLINK-9148) when deploying flink on kubernetes, the taskmanager report "java.net.UnknownHostException: flink-jobmanager: Temporary failure in name resolution"

You Chu created FLINK-9148: -- Summary: when deploying flink on kubernetes, the taskmanager report "java.net.UnknownHostException: flink-jobmanager: Temporary failure in name resolution" Key: FLINK-9148 URL: https://issue

[jira] [Commented] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument

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

[GitHub] flink issue #5825: [FLINK-9040][local runtime] check maxParallelism in JobVe...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5825 I only fix the javadoc for `JobVertex#setMaxParallelism()`, because if we validate `maxParallism` in that function we will break some current code, and I'am not sure whether these code also need to

[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-9147) PrometheusReporter jar does not include Prometheus dependencies

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

[GitHub] flink issue #5828: [FLINK-9147] [metrics] Include shaded Prometheus dependen...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5828 +1 ---

[jira] [Commented] (FLINK-9008) End-to-end test: Quickstarts

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

[GitHub] flink issue #5823: [FLINK-9008] [e2e] Implements quickstarts end to end test

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5823 Since Saturday and Sunday, sorry for later. Thanks @zentol . I need confirm some points here with you before I getting start again with this issue. 1. I have to create an actual

[jira] [Commented] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument

[ https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16429655#comment-16429655 ] Sihua Zhou commented on FLINK-9040: --- Hi [~Zentol] I think the javadoc here is also incor