[GitHub] [flink] pnowojski merged pull request #12243: [FLINK-17805][networ] Fix ArrayIndexOutOfBound for rotated input gate indexes

2020-05-21 Thread GitBox
pnowojski merged pull request #12243: URL: https://github.com/apache/flink/pull/12243 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go t

[jira] [Closed] (FLINK-17805) InputProcessorUtil doesn't handle indexes for multiple inputs operators correctly

2020-05-21 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17805. -- Resolution: Fixed merged to master as c9fd502c5a^ and c9fd502c5a merged to release-1.11 as d04

[GitHub] [flink] flinkbot edited a comment on pull request #12284: [FLINK-17689][kafka][table] Add integration tests for changelog sourc…

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12284: URL: https://github.com/apache/flink/pull/12284#issuecomment-632089951 ## CI report: * 760f994e14c290dd4c31b67e15751862d6ee520f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

2020-05-21 Thread Hunter Herman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113493#comment-17113493 ] Hunter Herman edited comment on FLINK-17470 at 5/21/20, 7:38 PM: -

[jira] [Commented] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

2020-05-21 Thread Hunter Herman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113493#comment-17113493 ] Hunter Herman commented on FLINK-17470: --- Hey [~sewen]! Thanks for the reply. Here'

[GitHub] [flink] brandonbevans opened a new pull request #12285: [FLINK-17445] Add Scala support for OperatorTransformation

2020-05-21 Thread GitBox
brandonbevans opened a new pull request #12285: URL: https://github.com/apache/flink/pull/12285 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring t

[jira] [Updated] (FLINK-17445) Allow OperatorTransformation to bootstrapWith a Scala DataSet

2020-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17445: --- Labels: pull-request-available (was: ) > Allow OperatorTransformation to bootstrapWith a Sc

[GitHub] [flink] flinkbot commented on pull request #12285: [FLINK-17445] Add Scala support for OperatorTransformation

2020-05-21 Thread GitBox
flinkbot commented on pull request #12285: URL: https://github.com/apache/flink/pull/12285#issuecomment-632354131 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] flinkbot commented on pull request #12285: [FLINK-17445][State Processor] Add Scala support for OperatorTransformation

2020-05-21 Thread GitBox
flinkbot commented on pull request #12285: URL: https://github.com/apache/flink/pull/12285#issuecomment-632360179 ## CI report: * 754d93703e9ecf3043b9bf57121d1636a3a4c167 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-17560) No Slots available exception in Apache Flink Job Manager while Scheduling

2020-05-21 Thread josson paul kalapparambath (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113567#comment-17113567 ] josson paul kalapparambath commented on FLINK-17560: [~xintongsong]

[GitHub] [flink] opnarius commented on pull request #7226: FLINK-11050 add lowerBound and upperBound for optimizing RocksDBMapState's entries

2020-05-21 Thread GitBox
opnarius commented on pull request #7226: URL: https://github.com/apache/flink/pull/7226#issuecomment-632371433 Hello, any more thoughts on implementing ordering and filtering of MapState? This would really boost the inner join performance. ---

[GitHub] [flink] flinkbot edited a comment on pull request #12285: [FLINK-17445][State Processor] Add Scala support for OperatorTransformation

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12285: URL: https://github.com/apache/flink/pull/12285#issuecomment-632360179 ## CI report: * 754d93703e9ecf3043b9bf57121d1636a3a4c167 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] fpompermaier commented on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

2020-05-21 Thread GitBox
fpompermaier commented on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-632378430 Rebased again.. This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Comment Edited] (FLINK-17560) No Slots available exception in Apache Flink Job Manager while Scheduling

2020-05-21 Thread josson paul kalapparambath (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113567#comment-17113567 ] josson paul kalapparambath edited comment on FLINK-17560 at 5/21/20, 10:54 PM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-618914824 ## CI report: * 69bce2717b0279a894aa66d15cd4b9b72cd5a474 UNKNOWN * 4cf97b2be4447c2d2f94259ad559fefb79a0a727 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-618914824 ## CI report: * 69bce2717b0279a894aa66d15cd4b9b72cd5a474 UNKNOWN * 4cf97b2be4447c2d2f94259ad559fefb79a0a727 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] SteNicholas removed a comment on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-21 Thread GitBox
SteNicholas removed a comment on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-632082769 @Myasuka @klion26 @carp84 Please review the changes again, thanks. This is an automated message from

[GitHub] [flink] SteNicholas commented on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-21 Thread GitBox
SteNicholas commented on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-632400538 @Myasuka Sorry for merge mistake. Please check the `isOriginalEmptyValue()` change for `TtlMapStateAllEntriesTestContext`. -

[GitHub] [flink] SteNicholas edited a comment on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-21 Thread GitBox
SteNicholas edited a comment on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-632400538 @Myasuka Sorry for squash mistake. Please check the `isOriginalEmptyValue()` change for `TtlMapStateAllEntriesTestContext`. -

[GitHub] [flink] flinkbot edited a comment on pull request #11900: [FLINK-17284][jdbc][postgres] Support serial fields

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #11900: URL: https://github.com/apache/flink/pull/11900#issuecomment-618914824 ## CI report: * 69bce2717b0279a894aa66d15cd4b9b72cd5a474 UNKNOWN * ccd3b17332d5a7eb5bb97124cd1a9a4c3986d82d Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-626611802 ## CI report: * e3ffb15cc38bdbbf1f5a11014782d081edaecea6 UNKNOWN * 15aed4e77715ccfd4588c2a740b91fc1467c629a Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-17870) scala shell jars are missing to be shipped to cluster

2020-05-21 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-17870: -- Summary: scala shell jars are missing to be shipped to cluster Key: FLINK-17870 URL: https://issues.apache.org/jira/browse/FLINK-17870 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-626611802 ## CI report: * e3ffb15cc38bdbbf1f5a11014782d081edaecea6 UNKNOWN * 15aed4e77715ccfd4588c2a740b91fc1467c629a Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] becketqin opened a new pull request #12286: [FLINK-14592][connector/kafka][test-stability] Use random port for broker creation.

2020-05-21 Thread GitBox
becketqin opened a new pull request #12286: URL: https://github.com/apache/flink/pull/12286 ## What is the purpose of the change Before this patch, Kafka brokers in the IT cases are assigned with port from `NetUtils.getAvailablePort()`. This is a little fragile because there is no guara

[GitHub] [flink] becketqin commented on pull request #12286: [FLINK-14592][connector/kafka][test-stability] Use random port for broker creation.

2020-05-21 Thread GitBox
becketqin commented on pull request #12286: URL: https://github.com/apache/flink/pull/12286#issuecomment-632424729 @pnowojski Do you have time to take a look? Thanks. This is an automated message from the Apache Git Service.

[jira] [Updated] (FLINK-14592) FlinkKafkaInternalProducerITCase fails with BindException

2020-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14592: --- Labels: pull-request-available test-stability (was: test-stability) > FlinkKafkaInternalPro

[GitHub] [flink] flinkbot commented on pull request #12286: [FLINK-14592][connector/kafka][test-stability] Use random port for broker creation.

2020-05-21 Thread GitBox
flinkbot commented on pull request #12286: URL: https://github.com/apache/flink/pull/12286#issuecomment-632425120 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Commented] (FLINK-15778) SQL Client end-to-end test for Kafka 0.10 nightly run hung on travis

2020-05-21 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113665#comment-17113665 ] Jiangjie Qin commented on FLINK-15778: -- This issue might be related to FLINK-14592

[GitHub] [flink] zhengcanbin commented on pull request #12277: [FLINK-17230] Fix incorrect returned address of Endpoint for external Service of ClusterIP type

2020-05-21 Thread GitBox
zhengcanbin commented on pull request #12277: URL: https://github.com/apache/flink/pull/12277#issuecomment-632426186 cc @TisonKun. Could you help take a look? This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] zhengcanbin commented on pull request #12259: [hotfix][k8s] Remove unused constant variable

2020-05-21 Thread GitBox
zhengcanbin commented on pull request #12259: URL: https://github.com/apache/flink/pull/12259#issuecomment-632426867 cc @TisonKun This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] flinkbot edited a comment on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-626611802 ## CI report: * e3ffb15cc38bdbbf1f5a11014782d081edaecea6 UNKNOWN * d9fd98ae5664303184273f83e4afb0623e6406f0 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #12286: [FLINK-14592][connector/kafka][test-stability] Use random port for broker creation.

2020-05-21 Thread GitBox
flinkbot commented on pull request #12286: URL: https://github.com/apache/flink/pull/12286#issuecomment-632430830 ## CI report: * bfc52432ddb2fc1ea708230e23f449be23df0370 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Created] (FLINK-17871) Make the default value of attemptFailuresValidityInterval more reasonable

2020-05-21 Thread fanxin (Jira)
fanxin created FLINK-17871: -- Summary: Make the default value of attemptFailuresValidityInterval more reasonable Key: FLINK-17871 URL: https://issues.apache.org/jira/browse/FLINK-17871 Project: Flink

[GitHub] [flink] hequn8128 commented on pull request #12246: [FLINK-17303][python] Return TableResult for Python TableEnvironment

2020-05-21 Thread GitBox
hequn8128 commented on pull request #12246: URL: https://github.com/apache/flink/pull/12246#issuecomment-632431669 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[jira] [Updated] (FLINK-17871) Make the default value of attemptFailuresValidityInterval more reasonable

2020-05-21 Thread fanxin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanxin updated FLINK-17871: --- Description: Default value of `yarn.application-attempt-failures-validity-interval` is `1` milliseconds

[jira] [Commented] (FLINK-17560) No Slots available exception in Apache Flink Job Manager while Scheduling

2020-05-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113678#comment-17113678 ] Xintong Song commented on FLINK-17560: -- If you can reproduce this issue, it would b

[GitHub] [flink] flinkbot edited a comment on pull request #12286: [FLINK-14592][connector/kafka][test-stability] Use random port for broker creation.

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12286: URL: https://github.com/apache/flink/pull/12286#issuecomment-632430830 ## CI report: * bfc52432ddb2fc1ea708230e23f449be23df0370 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-17721) AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry fails with AssertionError

2020-05-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113680#comment-17113680 ] Xintong Song commented on FLINK-17721: -- cc [~aljoscha] [~pnowojski] [~kkl0u] > Abs

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-21 Thread GitBox
yangyichao-mango commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r427056510 ## File path: docs/training/streaming_analytics.zh.md ## @@ -27,125 +27,101 @@ under the License. * This will be replaced by the TOC {:toc} -

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-21 Thread GitBox
yangyichao-mango commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r427058760 ## File path: docs/training/streaming_analytics.zh.md ## @@ -27,125 +27,101 @@ under the License. * This will be replaced by the TOC {:toc} -

[GitHub] [flink] Myasuka commented on a change in pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-21 Thread GitBox
Myasuka commented on a change in pull request #12078: URL: https://github.com/apache/flink/pull/12078#discussion_r429010509 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/ttl/RocksDBTtlStateTestBase.java ##

[GitHub] [flink] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-05-21 Thread GitBox
yangyichao-mango commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r429011221 ## File path: docs/training/streaming_analytics.zh.md ## @@ -27,125 +27,101 @@ under the License. * This will be replaced by the TOC {:toc} -

[GitHub] [flink] flinkbot edited a comment on pull request #12286: [FLINK-14592][connector/kafka][test-stability] Use random port for broker creation.

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12286: URL: https://github.com/apache/flink/pull/12286#issuecomment-632430830 ## CI report: * bfc52432ddb2fc1ea708230e23f449be23df0370 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] TisonKun commented on pull request #12259: [hotfix][k8s] Remove unused constant variable

2020-05-21 Thread GitBox
TisonKun commented on pull request #12259: URL: https://github.com/apache/flink/pull/12259#issuecomment-632445802 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] curcur commented on a change in pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-21 Thread GitBox
curcur commented on a change in pull request #12269: URL: https://github.com/apache/flink/pull/12269#discussion_r429016185 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java ## @@ -262,6 +251,40 @@ public void failJobDu

[GitHub] [flink] dianfu commented on pull request #12279: [FLINK-17771][python][e2e] Fix the OOM of the PyFlink end to end test on JDK11.

2020-05-21 Thread GitBox
dianfu commented on pull request #12279: URL: https://github.com/apache/flink/pull/12279#issuecomment-632449422 @WeiZhong94 Thanks for the PR. LGTM. I have verified manually the PR and the end to end test of PyFlink could pass after applying this PR with Jdk 11 (Also verified that it will

[GitHub] [flink] dianfu edited a comment on pull request #12279: [FLINK-17771][python][e2e] Fix the OOM of the PyFlink end to end test on JDK11.

2020-05-21 Thread GitBox
dianfu edited a comment on pull request #12279: URL: https://github.com/apache/flink/pull/12279#issuecomment-632449422 @WeiZhong94 Thanks for the PR. LGTM. I have verified the PR manually and the end to end test of PyFlink could pass after applying this PR with Jdk 11 (Also verified that i

[GitHub] [flink] dianfu closed pull request #12279: [FLINK-17771][python][e2e] Fix the OOM of the PyFlink end to end test on JDK11.

2020-05-21 Thread GitBox
dianfu closed pull request #12279: URL: https://github.com/apache/flink/pull/12279 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[jira] [Assigned] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

2020-05-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17771: --- Assignee: Wei Zhong > "PyFlink end-to-end test" fails with "The output result: [] is not as > expe

[jira] [Closed] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

2020-05-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17771. --- Resolution: Fixed > "PyFlink end-to-end test" fails with "The output result: [] is not as > expected: [2, 3

[GitHub] [flink] klion26 opened a new pull request #12287: [FLINK-16077][docs-zh] Translate Custom State Serialization page into Chinese

2020-05-21 Thread GitBox
klion26 opened a new pull request #12287: URL: https://github.com/apache/flink/pull/12287 ## What is the purpose of the change Translate Custom State Serialization page into Chinese ## Verifying this change This change is a trivial rework / code cleanup without any t

[jira] [Commented] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

2020-05-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113707#comment-17113707 ] Dian Fu commented on FLINK-17771: - Merged via : master: 8b14cd807d165052da46df2fc0d9536e

[jira] [Updated] (FLINK-16077) Translate "Custom State Serialization" page into Chinese

2020-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16077: --- Labels: pull-request-available (was: ) > Translate "Custom State Serialization" page into C

[jira] [Updated] (FLINK-17870) dependent jars are missing to be shipped to cluster in scala shell

2020-05-21 Thread Jeff Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-17870: --- Summary: dependent jars are missing to be shipped to cluster in scala shell (was: scala shell jars

[GitHub] [flink] zhijiangW commented on a change in pull request #12261: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

2020-05-21 Thread GitBox
zhijiangW commented on a change in pull request #12261: URL: https://github.com/apache/flink/pull/12261#discussion_r429018568 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java ## @@ -1010,6 +1011,56 @@

[GitHub] [flink] curcur commented on a change in pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-21 Thread GitBox
curcur commented on a change in pull request #12269: URL: https://github.com/apache/flink/pull/12269#discussion_r429018621 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java ## @@ -262,6 +251,40 @@ public void failJobDu

[GitHub] [flink] zhijiangW commented on pull request #12261: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

2020-05-21 Thread GitBox
zhijiangW commented on pull request #12261: URL: https://github.com/apache/flink/pull/12261#issuecomment-632452440 Thanks for the review @pnowojski and @Jiayi-Liao . Merging! This is an automated message from the Apache Git S

[GitHub] [flink] flinkbot commented on pull request #12287: [FLINK-16077][docs-zh] Translate Custom State Serialization page into Chinese

2020-05-21 Thread GitBox
flinkbot commented on pull request #12287: URL: https://github.com/apache/flink/pull/12287#issuecomment-632452335 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] zhijiangW merged pull request #12261: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

2020-05-21 Thread GitBox
zhijiangW merged pull request #12261: URL: https://github.com/apache/flink/pull/12261 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go t

[GitHub] [flink] curcur commented on a change in pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-21 Thread GitBox
curcur commented on a change in pull request #12269: URL: https://github.com/apache/flink/pull/12269#discussion_r429016185 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java ## @@ -262,6 +251,40 @@ public void failJobDu

[GitHub] [flink] zjffdu opened a new pull request #12288: [FLINK-17870]. dependent jars are missing to be shipped to cluster in scala shell

2020-05-21 Thread GitBox
zjffdu opened a new pull request #12288: URL: https://github.com/apache/flink/pull/12288 ## What is the purpose of the change `executeAsync` doesn't add dependent jars which cause ClassNotFound issue. This PR does some refactoring and add dependent jars for both `execute` and `execu

[GitHub] [flink] SteNicholas commented on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-21 Thread GitBox
SteNicholas commented on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-632452729 @Myasuka I have already align the test between `emptyValue` and `ctx().getOriginal()`, and run `TtlStateTestBase` all test case passed. Therefore, very thanks to review agai

[jira] [Updated] (FLINK-17870) dependent jars are missing to be shipped to cluster in scala shell

2020-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17870: --- Labels: pull-request-available (was: ) > dependent jars are missing to be shipped to cluste

[jira] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

2020-05-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113710#comment-17113710 ] Dian Fu commented on FLINK-17730: - It seems that it's still happening: https://dev.azure

[GitHub] [flink] flinkbot commented on pull request #12288: [FLINK-17870]. dependent jars are missing to be shipped to cluster in scala shell

2020-05-21 Thread GitBox
flinkbot commented on pull request #12288: URL: https://github.com/apache/flink/pull/12288#issuecomment-632453444 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Resolved] (FLINK-17823) Resolve the race condition while releasing RemoteInputChannel

2020-05-21 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang resolved FLINK-17823. -- Resolution: Fixed Merged in release-1.11: 3eb1075ded64da20e6f7a5bc268f455eaf6573eb Will merge to mast

[jira] [Commented] (FLINK-13553) KvStateServerHandlerTest.readInboundBlocking unstable on Travis

2020-05-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113713#comment-17113713 ] Dian Fu commented on FLINK-13553: - Another instance: https://dev.azure.com/apache-flink

[GitHub] [flink] curcur commented on a change in pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-21 Thread GitBox
curcur commented on a change in pull request #12269: URL: https://github.com/apache/flink/pull/12269#discussion_r429018621 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java ## @@ -262,6 +251,40 @@ public void failJobDu

[GitHub] [flink] curcur commented on a change in pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-21 Thread GitBox
curcur commented on a change in pull request #12269: URL: https://github.com/apache/flink/pull/12269#discussion_r429018621 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java ## @@ -262,6 +251,40 @@ public void failJobDu

[GitHub] [flink] Myasuka commented on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-21 Thread GitBox
Myasuka commented on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-632455461 @SteNicholas Thanks for your update. Let's wait for a green build. This is an automated message from the Apache

[GitHub] [flink] curcur commented on a change in pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-21 Thread GitBox
curcur commented on a change in pull request #12269: URL: https://github.com/apache/flink/pull/12269#discussion_r429018621 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java ## @@ -262,6 +251,40 @@ public void failJobDu

[GitHub] [flink] flinkbot edited a comment on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-626611802 ## CI report: * e3ffb15cc38bdbbf1f5a11014782d081edaecea6 UNKNOWN * d9fd98ae5664303184273f83e4afb0623e6406f0 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #12287: [FLINK-16077][docs-zh] Translate Custom State Serialization page into Chinese

2020-05-21 Thread GitBox
flinkbot commented on pull request #12287: URL: https://github.com/apache/flink/pull/12287#issuecomment-632456334 ## CI report: * 02822f55955ef2c684e724fb254ba641f07d5871 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #12288: [FLINK-17870]. dependent jars are missing to be shipped to cluster in scala shell

2020-05-21 Thread GitBox
flinkbot commented on pull request #12288: URL: https://github.com/apache/flink/pull/12288#issuecomment-632456377 ## CI report: * 08bc3bf4a17f2e6a99ce5ff3af91ae1341254391 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] curcur commented on a change in pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-21 Thread GitBox
curcur commented on a change in pull request #12269: URL: https://github.com/apache/flink/pull/12269#discussion_r429024037 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java ## @@ -262,6 +251,40 @@ public void failJobDu

[GitHub] [flink] curcur commented on a change in pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-21 Thread GitBox
curcur commented on a change in pull request #12269: URL: https://github.com/apache/flink/pull/12269#discussion_r429024037 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java ## @@ -262,6 +251,40 @@ public void failJobDu

[GitHub] [flink] curcur commented on pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-21 Thread GitBox
curcur commented on pull request #12269: URL: https://github.com/apache/flink/pull/12269#issuecomment-632459439 address comments. This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] curcur edited a comment on pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-21 Thread GitBox
curcur edited a comment on pull request #12269: URL: https://github.com/apache/flink/pull/12269#issuecomment-632459439 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Created] (FLINK-17872) Update StreamingFileSink documents to add avro formats

2020-05-21 Thread Yun Gao (Jira)
Yun Gao created FLINK-17872: --- Summary: Update StreamingFileSink documents to add avro formats Key: FLINK-17872 URL: https://issues.apache.org/jira/browse/FLINK-17872 Project: Flink Issue Type: Impr

[jira] [Updated] (FLINK-17872) Update StreamingFileSink documents to add avro formats

2020-05-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17872: Component/s: Documentation Connectors / FileSystem > Update StreamingFileSink documents t

[GitHub] [flink] dianfu commented on pull request #12280: [FLINK-17866][python] Change the implementation of the LocalFileSystem#pathToFile to fix the test case failure of PyFlink when running on Wind

2020-05-21 Thread GitBox
dianfu commented on pull request #12280: URL: https://github.com/apache/flink/pull/12280#issuecomment-632460864 I'm not familiar with this part and so I'm not sure: 1) If this change will introduce potential problems 2) If there are also this kind of problems in the other codepaths

[jira] [Updated] (FLINK-17872) Update StreamingFileSink documents to add avro formats

2020-05-21 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-17872: Priority: Trivial (was: Major) > Update StreamingFileSink documents to add avro formats > ---

[jira] [Commented] (FLINK-17468) Provide more detailed metrics why asynchronous part of checkpoint is taking long time

2020-05-21 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113726#comment-17113726 ] Congxian Qiu(klion26) commented on FLINK-17468: --- [~qqibrow]  How's it goin

[GitHub] [flink] flinkbot edited a comment on pull request #12288: [FLINK-17870]. dependent jars are missing to be shipped to cluster in scala shell

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12288: URL: https://github.com/apache/flink/pull/12288#issuecomment-632456377 ## CI report: * 08bc3bf4a17f2e6a99ce5ff3af91ae1341254391 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12282: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-632089755 ## CI report: * 67bc5db95d319972e8a27f9de71b5edd9c457287 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-17873) Add check for max concurrent checkpoints under UC mode

2020-05-21 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-17873: Summary: Add check for max concurrent checkpoints under UC mode Key: FLINK-17873 URL: https://issues.apache.org/jira/browse/FLINK-17873 Project: Flink Issue Type: Su

[jira] [Assigned] (FLINK-17873) Add check for max concurrent checkpoints under UC mode

2020-05-21 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-17873: Assignee: Yuan Mei > Add check for max concurrent checkpoints under UC mode > ---

[GitHub] [flink] flinkbot edited a comment on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-626611802 ## CI report: * e3ffb15cc38bdbbf1f5a11014782d081edaecea6 UNKNOWN * d9fd98ae5664303184273f83e4afb0623e6406f0 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12269: URL: https://github.com/apache/flink/pull/12269#issuecomment-631541996 ## CI report: * 24c44fd00652a6b5859075b3afea1e4e9ca98445 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12282: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-632089755 ## CI report: * 67bc5db95d319972e8a27f9de71b5edd9c457287 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12287: [FLINK-16077][docs-zh] Translate Custom State Serialization page into Chinese

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12287: URL: https://github.com/apache/flink/pull/12287#issuecomment-632456334 ## CI report: * 02822f55955ef2c684e724fb254ba641f07d5871 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12269: URL: https://github.com/apache/flink/pull/12269#issuecomment-631541996 ## CI report: * 24c44fd00652a6b5859075b3afea1e4e9ca98445 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12282: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-632089755 ## CI report: * 09833d3d171cfdd17286f53d7917df6bbfe8a8c8 UNKNOWN * 3cc09ea7ebbfc658371206c1369aba9f061cca49 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-17874) Writing to hbase throws NPE

2020-05-21 Thread chaiyongqiang (Jira)
chaiyongqiang created FLINK-17874: - Summary: Writing to hbase throws NPE Key: FLINK-17874 URL: https://issues.apache.org/jira/browse/FLINK-17874 Project: Flink Issue Type: Bug Compo

[jira] [Commented] (FLINK-17874) Writing to hbase throws NPE

2020-05-21 Thread chaiyongqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113747#comment-17113747 ] chaiyongqiang commented on FLINK-17874: --- When writing a filed to hbase, we seriali

[jira] [Created] (FLINK-17875) Support state TTL for remote functions

2020-05-21 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-17875: --- Summary: Support state TTL for remote functions Key: FLINK-17875 URL: https://issues.apache.org/jira/browse/FLINK-17875 Project: Flink Issue Ty

[GitHub] [flink] flinkbot edited a comment on pull request #12287: [FLINK-16077][docs-zh] Translate Custom State Serialization page into Chinese

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12287: URL: https://github.com/apache/flink/pull/12287#issuecomment-632456334 ## CI report: * 02822f55955ef2c684e724fb254ba641f07d5871 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12282: [FLINK-17865][checkpoint] Increase default size of 'state.backend.fs.memory-threshold'

2020-05-21 Thread GitBox
flinkbot edited a comment on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-632089755 ## CI report: * 09833d3d171cfdd17286f53d7917df6bbfe8a8c8 UNKNOWN * 3cc09ea7ebbfc658371206c1369aba9f061cca49 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-17874) Writing to hbase throws NPE

2020-05-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17874: --- Labels: pull-request-available (was: ) > Writing to hbase throws NPE >

[GitHub] [flink] cyq89051127 opened a new pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

2020-05-21 Thread GitBox
cyq89051127 opened a new pull request #12289: URL: https://github.com/apache/flink/pull/12289 ## What is the purpose of the change Handling the NPE for HBase connector. ## Brief change log *adding the NULL check before really serializing the value* ## Verifyin

<    1   2   3   4   >