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

2020-05-21 Thread GitBox
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…

2020-05-21 Thread GitBox
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…

2020-05-21 Thread GitBox
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

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

2020-05-21 Thread UnityLung (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113768#comment-17113768 ] UnityLung commented on FLINK-17690: --- Hi, I would like to fix this. Could you please assign it to me?

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

2020-05-21 Thread Piotr Nowojski (Jira)
[ 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

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

2020-05-21 Thread GitBox
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

[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 * 81a8f34c3108c7efc0ed350a50b59c2829a99eff Azure:

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

2020-05-21 Thread GitBox
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

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

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

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

[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

[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=17113747#comment-17113747 ] chaiyongqiang commented on FLINK-17874: --- When writing a filed to hbase, we serialize ti to bytes.

[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

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

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

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

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

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

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

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

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

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

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

[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=17113726#comment-17113726 ] Congxian Qiu(klion26) commented on FLINK-17468: --- [~qqibrow]  How's it going? do you need

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

[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: Component/s: Documentation Connectors / FileSystem > Update StreamingFileSink documents

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

[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

[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

[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

[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

[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

[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

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

[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

[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

[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

[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

[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=17113713#comment-17113713 ] Dian Fu commented on FLINK-13553: - Another instance:

[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

[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=17113710#comment-17113710 ] Dian Fu commented on FLINK-17730: - It seems that it's still happening:

[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

[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

[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

[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

[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

[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

[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

[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

[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

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

[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=17113707#comment-17113707 ] Dian Fu commented on FLINK-17771: - Merged via : master: 8b14cd807d165052da46df2fc0d9536eadc97fe7

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

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

[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

[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

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

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

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

[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] 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_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…

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}

[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=17113680#comment-17113680 ] Xintong Song commented on FLINK-17721: -- cc [~aljoscha] [~pnowojski] [~kkl0u] >

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

[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=17113678#comment-17113678 ] Xintong Song commented on FLINK-17560: -- If you can reproduce this issue, it would be helpful to

[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

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

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

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

[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

[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

[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=17113665#comment-17113665 ] Jiangjie Qin commented on FLINK-15778: -- This issue might be related to FLINK-14592 but I am not

[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

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

[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

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

[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

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

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

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

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

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

[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=17113567#comment-17113567 ] josson paul kalapparambath edited comment on FLINK-17560 at 5/21/20, 10:54 PM:

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

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

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

[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=17113567#comment-17113567 ] josson paul kalapparambath commented on FLINK-17560: [~xintongsong] I am able to

[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

  1   2   3   4   >