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

flinkbot edited a comment on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-632089755 ## CI report: * 09833d3d171cfdd17286f53d7917df6bbfe8a8c8 UNKNOWN * 81a8f34c3108c7efc0ed350a50b59c2829a99eff Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-17876) Add documentation on how to use Python UDF in SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Summary: Add documentation on how to use Python UDF in SQL DDL (was: Add documents for Python UDF SQL DDL

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Summary: Add documents for Python UDF SQL DDL (was: Add documents for Python UDF SQL DDL.) > Add documen

[jira] [Assigned] (FLINK-17876) Add documents for Python UDF SQL DDL.

[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17876: --- Assignee: Wei Zhong > Add documents for Python UDF SQL DDL. > -

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Issue Type: Task (was: Improvement) > Add documents for Python UDF SQL DDL. > ---

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Component/s: Documentation > Add documents for Python UDF SQL DDL. > -

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Fix Version/s: 1.11.0 > Add documents for Python UDF SQL DDL. > - > >

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Priority: Major (was: Minor) > Add documents for Python UDF SQL DDL. > --

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Affects Version/s: 1.11.0 > Add documents for Python UDF SQL DDL. > -

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17876: Issue Type: Improvement (was: Task) > Add documents for Python UDF SQL DDL. > ---

[jira] [Updated] (FLINK-17876) Add documents for Python UDF SQL DDL.

[ https://issues.apache.org/jira/browse/FLINK-17876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-17876: -- Summary: Add documents for Python UDF SQL DDL. (was: Add documents for the Python UDF SQL DDL.) > Ad

[jira] [Created] (FLINK-17876) Add documents for the Python UDF SQL DDL.

Wei Zhong created FLINK-17876: - Summary: Add documents for the Python UDF SQL DDL. Key: FLINK-17876 URL: https://issues.apache.org/jira/browse/FLINK-17876 Project: Flink Issue Type: Improvement

[GitHub] [flink-web] chaojianok commented on pull request #247: [FLINK-13683] Translate "Code Style - Component Guide" page into Chinese

chaojianok commented on pull request #247: URL: https://github.com/apache/flink-web/pull/247#issuecomment-632518734 @klion26 Thanks a lot for your review, I've optimized it according to your comments, please help me review again. ---

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

flinkbot edited a comment on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-632089755 ## CI report: * 09833d3d171cfdd17286f53d7917df6bbfe8a8c8 UNKNOWN * 81a8f34c3108c7efc0ed350a50b59c2829a99eff Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-17194) TPC-DS end-to-end test fails due to missing execution attempt

[ https://issues.apache.org/jira/browse/FLINK-17194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113790#comment-17113790 ] Robert Metzger commented on FLINK-17194: Another case in the Hadoop 3.1.3 profil

[jira] [Commented] (FLINK-17822) Nightly Flink CLI end-to-end test failed with "JavaGcCleanerWrapper$PendingCleanersRunner cannot access class jdk.internal.misc.SharedSecrets" in Java 11

[ https://issues.apache.org/jira/browse/FLINK-17822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113788#comment-17113788 ] Robert Metzger commented on FLINK-17822: I don't think it is a good idea to intr

[GitHub] [flink] azagrebin commented on pull request #12270: [FLINK-17822][MemMan] Use private Reference.tryHandlePending|waitForReferenceProcessing to trigger GC cleaner

azagrebin commented on pull request #12270: URL: https://github.com/apache/flink/pull/12270#issuecomment-632510359 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] flinkbot edited a comment on pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

flinkbot edited a comment on pull request #12289: URL: https://github.com/apache/flink/pull/12289#issuecomment-632492310 ## CI report: * cda1c81b986bf87f0fd95abfdc60638813a43c0b Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/167718532) Bot comman

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

[ https://issues.apache.org/jira/browse/FLINK-17805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113472#comment-17113472 ] Piotr Nowojski edited comment on FLINK-17805 at 5/22/20, 6:16 AM:

[jira] [Updated] (FLINK-17869) Fix the race condition of aborting unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-17869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17869: - Description: On ChannelStateWriter side, the lifecycle of checkpoint should be as follows: start -> in

[jira] [Resolved] (FLINK-17504) Update translation of Getting Started / Overview

[ https://issues.apache.org/jira/browse/FLINK-17504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-17504. Fix Version/s: 1.12.0 Resolution: Fixed Resolved in https://github.com/apache/flin

[GitHub] [flink] rmetzger commented on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

rmetzger commented on pull request #12230: URL: https://github.com/apache/flink/pull/12230#issuecomment-632506180 @yangyichao-mango Thanks a lot for your contribution, and thank you for your review @klion26. Merging now ... --

[GitHub] [flink] rmetzger closed pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

rmetzger closed pull request #12230: URL: https://github.com/apache/flink/pull/12230 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

[GitHub] [flink] wtog commented on pull request #12179: [FLINK-16144] get client.timeout for the client, with a fallback to the akka.client…

wtog commented on pull request #12179: URL: https://github.com/apache/flink/pull/12179#issuecomment-632498106 hi @aljoscha and @kl0u this pr is updated, please help to review This is an automated message from the Apache Git

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

klion26 commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r429050613 ## File path: docs/training/streaming_analytics.zh.md ## @@ -29,123 +29,99 @@ under the License. ## Event Time and Watermarks -### Introduction +###

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

klion26 commented on a change in pull request #12237: URL: https://github.com/apache/flink/pull/12237#discussion_r429050101 ## File path: docs/training/streaming_analytics.zh.md ## @@ -3,7 +3,7 @@ title: Streaming Analytics nav-id: analytics nav-pos: 4 nav-title: Streaming A

[jira] [Commented] (FLINK-17690) Python function wrapper omits docstr

[ https://issues.apache.org/jira/browse/FLINK-17690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113768#comment-17113768 ] UnityLung commented on FLINK-17690: --- Hi, I would like to fix this. Could you please

[jira] [Closed] (FLINK-17860) Recursively remove channel state directories

[ https://issues.apache.org/jira/browse/FLINK-17860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17860. -- Resolution: Duplicate It looks like this is a duplicate of FLINK-13856, which contains a valua

[GitHub] [flink] flinkbot commented on pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

flinkbot commented on pull request #12289: URL: https://github.com/apache/flink/pull/12289#issuecomment-632492310 ## CI report: * cda1c81b986bf87f0fd95abfdc60638813a43c0b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

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

flinkbot edited a comment on pull request #12282: URL: https://github.com/apache/flink/pull/12282#issuecomment-632089755 ## CI report: * 09833d3d171cfdd17286f53d7917df6bbfe8a8c8 UNKNOWN * 81a8f34c3108c7efc0ed350a50b59c2829a99eff Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #12289: [FLINK-17874][Connectors/HBase]Handling the NPE for hbase-connector

flinkbot commented on pull request #12289: URL: https://github.com/apache/flink/pull/12289#issuecomment-632489396 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] [Updated] (FLINK-17874) Writing to hbase throws NPE

[ 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

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

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

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

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

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

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

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

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

[ 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-17874) Writing to hbase throws NPE

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

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

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'

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

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

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'

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

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 #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

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

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

[ 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 > ---

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

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

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

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'

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] [Commented] (FLINK-17468) Provide more detailed metrics why asynchronous part of checkpoint is taking long time

[ 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

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

[ 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 > ---

[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

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

[ 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

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

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

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

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

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

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 commented on a change in pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

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

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] flinkbot commented on pull request #12288: [FLINK-17870]. dependent jars are missing to be shipped to cluster in scala shell

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] flinkbot commented on pull request #12287: [FLINK-16077][docs-zh] Translate Custom State Serialization page into Chinese

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 edited a comment on pull request #12078: [FLINK-17610][state] Align the behavior of result of internal map state to return empty iterator

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] curcur commented on a change in pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

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

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

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

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

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

[ 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

[ 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] flinkbot commented on pull request #12288: [FLINK-17870]. dependent jars are missing to be shipped to cluster in scala shell

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] [Commented] (FLINK-17730) HadoopS3RecoverableWriterITCase.testRecoverAfterMultiplePersistsStateWithMultiPart times out

[ 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

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

[ 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

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

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

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

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

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] flinkbot commented on pull request #12287: [FLINK-16077][docs-zh] Translate Custom State Serialization page into Chinese

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

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] zhijiangW commented on pull request #12261: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

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] zhijiangW commented on a change in pull request #12261: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

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

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

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

[ 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

[ 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] klion26 opened a new pull request #12287: [FLINK-16077][docs-zh] Translate Custom State Serialization page into Chinese

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

[ 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] [Closed] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

[ 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

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

[ 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

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

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

[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.

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 commented on pull request #12279: [FLINK-17771][python][e2e] Fix the OOM of the PyFlink end to end test on JDK11.

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] curcur commented on a change in pull request #12269: [FLINK-17351] [runtime] Increase `continuousFailureCounter` in `CheckpointFailureManager` for CHECKPOINT_EXPIRED

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] TisonKun commented on pull request #12259: [hotfix][k8s] Remove unused constant variable

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] flinkbot edited a comment on pull request #12286: [FLINK-14592][connector/kafka][test-stability] Use random port for broker creation.

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] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

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] 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

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…

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] yangyichao-mango commented on a change in pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

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} -

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

[ 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] flinkbot edited a comment on pull request #12286: [FLINK-14592][connector/kafka][test-stability] Use random port for broker creation.

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-17560) No Slots available exception in Apache Flink Job Manager while Scheduling

[ 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

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

[ 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

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

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] [Created] (FLINK-17871) Make the default value of attemptFailuresValidityInterval more reasonable

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] flinkbot commented on pull request #12286: [FLINK-14592][connector/kafka][test-stability] Use random port for broker creation.

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

  1   2   3   4   >