[GitHub] [flink] AHeise opened a new pull request #14279: [FLINK-20418][core] Fixing checkpointing of IteratorSourceReader.

AHeise opened a new pull request #14279: URL: https://github.com/apache/flink/pull/14279 ## What is the purpose of the change IteratorSourceReader fails checkpointing when assignment has not yet happened with NPE. Furthermore, if the last element of a split has been

[GitHub] [flink] tillrohrmann commented on a change in pull request #14268: [FLINK-20428][test] Fix the unstable test ZooKeeperLeaderElectionConnectionHandlingTest#testConnectionSuspendedHandlingDurin

tillrohrmann commented on a change in pull request #14268: URL: https://github.com/apache/flink/pull/14268#discussion_r533296691 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionConnectionHandlingTest.java ## @@ -281,6

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241445#comment-17241445 ] Thomas Wozniakowski commented on FLINK-19970: - Hi [~wind_ljy], No, we didn't identify a

[GitHub] [flink] flinkbot commented on pull request #14273: [FLINK-20441] Deprecate CheckpointConfig.setPreferCheckpointForRecovery and .isPreferCheckpointForRecovery

flinkbot commented on pull request #14273: URL: https://github.com/apache/flink/pull/14273#issuecomment-736437400 ## CI report: * 842a2f76ac5abee4c8c7f9bf88309650a3565b74 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] JingsongLi merged pull request #14224: [FLINK-20274][docs-zh] Translate page 'testing' into Chinese

JingsongLi merged pull request #14224: URL: https://github.com/apache/flink/pull/14224 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] wangyang0918 commented on pull request #14268: [FLINK-20428][test] Fix the unstable test ZooKeeperLeaderElectionConnectionHandlingTest#testConnectionSuspendedHandlingDuringInitializat

wangyang0918 commented on pull request #14268: URL: https://github.com/apache/flink/pull/14268#issuecomment-736479379 @tillrohrmann Thanks for the review. I have addressed the comments. This is an automated message from the

[jira] [Updated] (FLINK-19396) Fix properties type cast error

[ https://issues.apache.org/jira/browse/FLINK-19396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19396: --- Labels: pull-request-available (was: ) > Fix properties type cast error >

[GitHub] [flink] zhuzhurk commented on a change in pull request #13641: [FLINK-17760][tests] Rework tests to not rely on legacy scheduling codes in ExecutionGraph components

zhuzhurk commented on a change in pull request #13641: URL: https://github.com/apache/flink/pull/13641#discussion_r533363159 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/GlobalModVersionTest.java ## @@ -1,200 +0,0 @@ -/* - * Licensed to

[GitHub] [flink] tillrohrmann commented on a change in pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

tillrohrmann commented on a change in pull request #14028: URL: https://github.com/apache/flink/pull/14028#discussion_r533368080 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java ## @@ -221,7 +222,7 @@ public static

[jira] [Commented] (FLINK-19285) Kafka sql connector fixed partitioner not work

[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241490#comment-17241490 ] Dawid Wysakowicz commented on FLINK-19285: -- [~Leiyanrui] I don't think I understand what you

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241492#comment-17241492 ] Leonard Xu commented on FLINK-19863: I create a PR to fix this,

[jira] [Assigned] (FLINK-20354) Rework standalone deployment documentation page

[ https://issues.apache.org/jira/browse/FLINK-20354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20354: -- Assignee: Robert Metzger > Rework standalone deployment documentation page >

[GitHub] [flink] flinkbot commented on pull request #14274: [FLINK-19863][test] Fix SQLClientHBaseITCase.testHBase failed with process timeout

flinkbot commented on pull request #14274: URL: https://github.com/apache/flink/pull/14274#issuecomment-736529051 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-19285) Kafka sql connector fixed partitioner not work

[ https://issues.apache.org/jira/browse/FLINK-19285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241503#comment-17241503 ] Lyr commented on FLINK-19285: - ok  i understand thank you > Kafka sql connector fixed partitioner not work

[GitHub] [flink] flinkbot edited a comment on pull request #13488: [FLINK-19381][docs] Fix docs for savepoint relocation

flinkbot edited a comment on pull request #13488: URL: https://github.com/apache/flink/pull/13488#issuecomment-699590439 ## CI report: * d2f6bab0042629cb0f03e5fe27d3a6e18ba0368a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14235: [FLINK-20298][docs] Replace usage of {{ site.baseurl }} in documentation

flinkbot edited a comment on pull request #14235: URL: https://github.com/apache/flink/pull/14235#issuecomment-734255724 ## CI report: * 112c3acbd7f25adadb40e24e505e4bac6cc08ffa UNKNOWN * 2af22dd3561638813b91faad96f5e886dfcad8fd Azure:

[GitHub] [flink] 1996fanrui commented on pull request #13885: [FLINK-19911] add read buffer for input stream

1996fanrui commented on pull request #13885: URL: https://github.com/apache/flink/pull/13885#issuecomment-736582174 Hi @AHeise , I've updated the PR, Please help reviewing it when you have time. Thanks. This is an

[GitHub] [flink] AHeise commented on a change in pull request #14279: [FLINK-20418][core] Fixing checkpointing of IteratorSourceReader.

AHeise commented on a change in pull request #14279: URL: https://github.com/apache/flink/pull/14279#discussion_r533452326 ## File path: flink-tests/src/test/java/org/apache/flink/api/connector/source/lib/NumberSequenceSourceITCase.java ## @@ -0,0 +1,59 @@ +/* + * Licensed to

[GitHub] [flink] dawidwys commented on pull request #14272: [FLINK-20426][docs] Fix broken links after Hadoop page removal

dawidwys commented on pull request #14272: URL: https://github.com/apache/flink/pull/14272#issuecomment-736590018 The navigation bar works for me as well. Maybe try firing a full jekyll build? If you run only the incremental build it might not update all the pages. (Just if you're

[jira] [Commented] (FLINK-20426) Broken links to hadoop.md

[ https://issues.apache.org/jira/browse/FLINK-20426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241594#comment-17241594 ] Robert Metzger commented on FLINK-20426: Fixed on master in

[GitHub] [flink] flinkbot edited a comment on pull request #13885: [FLINK-19911] add read buffer for input stream

flinkbot edited a comment on pull request #13885: URL: https://github.com/apache/flink/pull/13885#issuecomment-720452604 ## CI report: * be7f3c7a5db0320f94ae49c57cb72f56c477bcdd Azure:

[GitHub] [flink] twalthr commented on pull request #14230: [FLINK-20371][docs] Add docs for outer interval joins

twalthr commented on pull request #14230: URL: https://github.com/apache/flink/pull/14230#issuecomment-736613815 @sjwiesman sure, go ahead This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #14276: [FLINK-20372] Update Kafka SQL connector page to mention properties.*…

flinkbot edited a comment on pull request #14276: URL: https://github.com/apache/flink/pull/14276#issuecomment-736554867 ## CI report: * 1597ca9662e44eac7875d0f0b3bafac272717501 Azure:

[jira] [Updated] (FLINK-20442) Fix license documentation mistakes in flink-python.jar

[ https://issues.apache.org/jira/browse/FLINK-20442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20442: --- Labels: pull-request-available (was: ) > Fix license documentation mistakes in

[GitHub] [flink] flinkbot edited a comment on pull request #14273: [FLINK-20441] Deprecate CheckpointConfig.setPreferCheckpointForRecovery and .isPreferCheckpointForRecovery

flinkbot edited a comment on pull request #14273: URL: https://github.com/apache/flink/pull/14273#issuecomment-736437400 ## CI report: * 842a2f76ac5abee4c8c7f9bf88309650a3565b74 Azure:

[GitHub] [flink] rmetzger commented on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

rmetzger commented on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-736641116 The `META-INF/licenses/ASM` file is still around. This is an automated message from the Apache Git Service. To

[GitHub] [flink] rmetzger commented on a change in pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

rmetzger commented on a change in pull request #14282: URL: https://github.com/apache/flink/pull/14282#discussion_r533529791 ## File path: flink-python/lib/LICENSE.py4j ## @@ -1,26 +0,0 @@ -Copyright (c) 2009-2018, Barthelemy Dagenais and individual contributors. All Review

[GitHub] [flink] flinkbot commented on pull request #14281: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes setup

flinkbot commented on pull request #14281: URL: https://github.com/apache/flink/pull/14281#issuecomment-736654087 ## CI report: * 6a43ad75129ec9332f82134fe4c98329bd6db7b5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14268: [FLINK-20428][test] Fix the unstable test ZooKeeperLeaderElectionConnectionHandlingTest#testConnectionSuspendedHandlingDuringInitiali

flinkbot edited a comment on pull request #14268: URL: https://github.com/apache/flink/pull/14268#issuecomment-736254887 ## CI report: * 6afa53e362117ed9caddb4432f95fe23e22b4f7b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14235: [FLINK-20298][docs] Replace usage of {{ site.baseurl }} in documentation

flinkbot edited a comment on pull request #14235: URL: https://github.com/apache/flink/pull/14235#issuecomment-734255724 ## CI report: * 112c3acbd7f25adadb40e24e505e4bac6cc08ffa UNKNOWN * 2af22dd3561638813b91faad96f5e886dfcad8fd Azure:

[GitHub] [flink] AHeise commented on a change in pull request #14279: [FLINK-20418][core] Fixing checkpointing of IteratorSourceReader.

AHeise commented on a change in pull request #14279: URL: https://github.com/apache/flink/pull/14279#discussion_r533450362 ## File path: flink-tests/src/test/java/org/apache/flink/api/connector/source/lib/NumberSequenceSourceITCase.java ## @@ -0,0 +1,59 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot commented on pull request #14279: [FLINK-20418][core] Fixing checkpointing of IteratorSourceReader.

flinkbot commented on pull request #14279: URL: https://github.com/apache/flink/pull/14279#issuecomment-736588058 ## CI report: * 05490783d40bea9c1a38f1af4c731f23bb5160c1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-20341) Rework Deployment / Coordination Documentation

[ https://issues.apache.org/jira/browse/FLINK-20341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241579#comment-17241579 ] Leonard Xu commented on FLINK-20341: Hi, [~rmetzger] [~trohrmann] Kindly remind,  we'd better use

[jira] [Updated] (FLINK-20359) Support adding Owner Reference to Job Manager in native kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-20359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20359: --- Labels: pull-request-available (was: ) > Support adding Owner Reference to Job Manager in

[GitHub] [flink] flinkbot edited a comment on pull request #14229: [FLINK-20292][doc] Improve the document about table formats overlap in user fat jar

flinkbot edited a comment on pull request #14229: URL: https://github.com/apache/flink/pull/14229#issuecomment-734175831 ## CI report: * 65380924b30878760771fe7d498f66b53ce7be0b Azure:

[jira] [Closed] (FLINK-20445) NoMatchingTableFactoryException

[ https://issues.apache.org/jira/browse/FLINK-20445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-20445. Resolution: Duplicate Closing this because it is a duplicate of FLINK-20260 >

[jira] [Commented] (FLINK-19398) Hive connector fails with IllegalAccessError if submitted as usercode

[ https://issues.apache.org/jira/browse/FLINK-19398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241647#comment-17241647 ] Leonard Xu commented on FLINK-19398: [~gaoyunhaii] Could you raise a PR for 1.11 branch and then we

[GitHub] [flink] blublinsky opened a new pull request #14283: FLINK-15649 Support mounting volumes

blublinsky opened a new pull request #14283: URL: https://github.com/apache/flink/pull/14283 ## What is the purpose of the change This pull request let user can mount customized volume to JobManager or TaskManager pod. ## Brief change log And the

[GitHub] [flink] flinkbot edited a comment on pull request #14229: [FLINK-20292][doc] Improve the document about table formats overlap in user fat jar

flinkbot edited a comment on pull request #14229: URL: https://github.com/apache/flink/pull/14229#issuecomment-734175831 ## CI report: * 65380924b30878760771fe7d498f66b53ce7be0b Azure:

[GitHub] [flink] rmetzger commented on a change in pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

rmetzger commented on a change in pull request #14282: URL: https://github.com/apache/flink/pull/14282#discussion_r533540240 ## File path: flink-python/lib/LICENSE.py4j ## @@ -1,26 +0,0 @@ -Copyright (c) 2009-2018, Barthelemy Dagenais and individual contributors. All Review

[jira] [Updated] (FLINK-20324) Support customizing of containers for native kubernetes setup

[ https://issues.apache.org/jira/browse/FLINK-20324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20324: --- Labels: pull-request-available (was: ) > Support customizing of containers for native

[GitHub] [flink] dianfu commented on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

dianfu commented on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-736667438 PS: Byte buddy is used in Beam's Java SDK harness and isn't used by PyFlink and should be safe to remove. This

[GitHub] [flink] flinkbot commented on pull request #14283: FLINK-15649 Support mounting volumes

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #14279: [FLINK-20418][core] Fixing checkpointing of IteratorSourceReader.

rkhachatryan commented on a change in pull request #14279: URL: https://github.com/apache/flink/pull/14279#discussion_r533439656 ## File path: flink-tests/src/test/java/org/apache/flink/api/connector/source/lib/NumberSequenceSourceITCase.java ## @@ -0,0 +1,59 @@ +/* + *

[GitHub] [flink] XComp commented on pull request #14272: [FLINK-20426][docs] Fix broken links after Hadoop page removal

XComp commented on pull request #14272: URL: https://github.com/apache/flink/pull/14272#issuecomment-736592008 > The navigation bar works for me as well. Maybe try firing a full jekyll build? If you run only the incremental build it might not update all the pages. > > (Just if

[GitHub] [flink] wangxlong opened a new pull request #14280: [FLINK-20110][table-planner] Support 'merge' method for first_value a…

wangxlong opened a new pull request #14280: URL: https://github.com/apache/flink/pull/14280 …nd last_value UDAF ## What is the purpose of the change Support 'merge' method for first_value and last_value UDAF ## Brief change log 1. add merge method for first_value

[jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

[ https://issues.apache.org/jira/browse/FLINK-20110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20110: --- Labels: pull-request-available (was: ) > Support 'merge' method for first_value and

[GitHub] [flink] flinkbot edited a comment on pull request #14279: [FLINK-20418][core] Fixing checkpointing of IteratorSourceReader.

flinkbot edited a comment on pull request #14279: URL: https://github.com/apache/flink/pull/14279#issuecomment-736588058 ## CI report: * 05490783d40bea9c1a38f1af4c731f23bb5160c1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14271: [FLINK-12130][clients] Apply command line options to configuration be…

flinkbot edited a comment on pull request #14271: URL: https://github.com/apache/flink/pull/14271#issuecomment-736366741 ## CI report: * 6c4ebb2cb758b46c601e9f7d50feee5244aa5195 Azure:

[GitHub] [flink] leonardBang commented on pull request #14274: [FLINK-19863][test] Fix SQLClientHBaseITCase.testHBase failed with process timeout

leonardBang commented on pull request #14274: URL: https://github.com/apache/flink/pull/14274#issuecomment-736628919 cc: @openinx Could you help review this PR? This is an automated message from the Apache Git Service.

[jira] [Commented] (FLINK-20445) NoMatchingTableFactoryException

[ https://issues.apache.org/jira/browse/FLINK-20445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241644#comment-17241644 ] Timo Walther commented on FLINK-20445: -- [~15652768278] only legacy connectors

[GitHub] [flink] haseeb1431 commented on a change in pull request #14003: [FLINK-19527][Doc]Flink SQL Getting Started

haseeb1431 commented on a change in pull request #14003: URL: https://github.com/apache/flink/pull/14003#discussion_r533522981 ## File path: docs/dev/table/sql/gettingStarted.md ## @@ -0,0 +1,226 @@ +--- +title: "Getting Started - Flink SQL" +nav-parent_id: sql +nav-pos: 0

[jira] [Commented] (FLINK-15649) Support mounting volumes

[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241651#comment-17241651 ] Boris Lublinsky commented on FLINK-15649: - Simplified PR is here 

[GitHub] [flink] rmetzger commented on a change in pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

rmetzger commented on a change in pull request #14282: URL: https://github.com/apache/flink/pull/14282#discussion_r533529968 ## File path: flink-python/lib/LICENSE.cloudpickle ## @@ -1,32 +0,0 @@ -This module was extracted from the `cloud` package, developed by Review

[GitHub] [flink] flinkbot commented on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

flinkbot commented on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-736657230 ## CI report: * 63f04e148ad295e4a4c03df7e7b56825f2333655 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14284: FLINK-20324 Added Configuration mount support

flinkbot commented on pull request #14284: URL: https://github.com/apache/flink/pull/14284#issuecomment-736661194 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] dianfu commented on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

dianfu commented on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-736665251 @rmetzger I pushed a new commit which removed the byte bundle(also META-INF/licenses/ASM) and the *.proto files from the fat jar.

[GitHub] [flink] dianfu edited a comment on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

dianfu edited a comment on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-736667438 PS: Byte buddy is used in Beam's Java SDK and isn't used by PyFlink and should be safe to remove. This

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241540#comment-17241540 ] Matthias commented on FLINK-16947: --

[GitHub] [flink] flinkbot edited a comment on pull request #14272: [FLINK-20426][docs] Fix broken links after Hadoop page removal

flinkbot edited a comment on pull request #14272: URL: https://github.com/apache/flink/pull/14272#issuecomment-736367051 ## CI report: * c6ca708974068e8a6da537fb04b306bb909c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14277: [FLINK-20443][API/DataStream]fix lost data in last interval in per window

flinkbot edited a comment on pull request #14277: URL: https://github.com/apache/flink/pull/14277#issuecomment-736556006 ## CI report: * 81f15556a782db8b8958cf6498a654ac28e525f7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14275: [FLINK-20432] Add timeouts to SQLClientSchemaRegistryITCase

flinkbot edited a comment on pull request #14275: URL: https://github.com/apache/flink/pull/14275#issuecomment-736553908 ## CI report: * 30a8290a055ba720d2ffe39d759359b0cb62a0af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14276: [FLINK-20372] Update Kafka SQL connector page to mention properties.*…

flinkbot edited a comment on pull request #14276: URL: https://github.com/apache/flink/pull/14276#issuecomment-736554867 ## CI report: * 1597ca9662e44eac7875d0f0b3bafac272717501 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14274: [FLINK-19863][test] Fix SQLClientHBaseITCase.testHBase failed with process timeout

flinkbot edited a comment on pull request #14274: URL: https://github.com/apache/flink/pull/14274#issuecomment-736553229 ## CI report: * f7b6f4456a3aebd0272fd60c6861ad1936575615 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14278: [FLINK-20444][runtime] Chain YieldingOperatorFactory to new sources.

flinkbot edited a comment on pull request #14278: URL: https://github.com/apache/flink/pull/14278#issuecomment-736557462 ## CI report: * 6dc29a18d93752eb9b08a219278a0b855b1d7d23 Azure:

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241580#comment-17241580 ] Robert Metzger commented on FLINK-19863:

[jira] [Assigned] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20431: Assignee: Jiangjie Qin >

[GitHub] [flink] rmetzger closed pull request #14272: [FLINK-20426][docs] Fix broken links after Hadoop page removal

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

[jira] [Comment Edited] (FLINK-19725) Logger cannot be initialized due to timeout: LoggerInitializationException is thrown

[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241371#comment-17241371 ] Matthias edited comment on FLINK-19725 at 12/1/20, 2:52 PM: Another build

[jira] [Closed] (FLINK-20426) Broken links to hadoop.md

[ https://issues.apache.org/jira/browse/FLINK-20426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-20426. -- Resolution: Fixed > Broken links to hadoop.md > - > >

[jira] [Commented] (FLINK-20426) Broken links to hadoop.md

[ https://issues.apache.org/jira/browse/FLINK-20426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241600#comment-17241600 ] Robert Metzger commented on FLINK-20426: Fixed in release-1.12 in

[GitHub] [flink] flinkbot edited a comment on pull request #13885: [FLINK-19911] add read buffer for input stream

flinkbot edited a comment on pull request #13885: URL: https://github.com/apache/flink/pull/13885#issuecomment-720452604 ## CI report: * 4f972fcfd74e2d74c5cc7af7cc8561faadd21d1f Azure:

[GitHub] [flink] flinkbot commented on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

flinkbot commented on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-736621610 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] flinkbot commented on pull request #14281: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes setup

flinkbot commented on pull request #14281: URL: https://github.com/apache/flink/pull/14281#issuecomment-736621636 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] rmetzger commented on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

rmetzger commented on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-736640290 There are a lot of .proto files in the jar. Are they needed? afaik they are used for generating protobuf files, which is probably not happening at the user's side, right?

[GitHub] [flink] flinkbot commented on pull request #14283: FLINK-15649 Support mounting volumes

flinkbot commented on pull request #14283: URL: https://github.com/apache/flink/pull/14283#issuecomment-736645552 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-statefun] igalshilman commented on a change in pull request #182: [FLINK-20334] Introduce module YAML format version 3.0 and function endpoint templating

igalshilman commented on a change in pull request #182: URL: https://github.com/apache/flink-statefun/pull/182#discussion_r58407 ## File path: statefun-examples/statefun-async-python-example/statefun/module.yaml ## @@ -12,20 +12,23 @@ # WITHOUT WARRANTIES OR CONDITIONS OF

[GitHub] [flink] flinkbot edited a comment on pull request #13995: [FLINK-20055] [runtime/config] - hide sensitive datadog API key from logs

flinkbot edited a comment on pull request #13995: URL: https://github.com/apache/flink/pull/13995#issuecomment-723899378 ## CI report: * 3536c698c6b9d80c3f959f5e5bc9c4e98fcb6671 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13722: [FLINK-19636][coordination] Add DeclarativeSlotPool

flinkbot edited a comment on pull request #13722: URL: https://github.com/apache/flink/pull/13722#issuecomment-713509789 ## CI report: * 7cdd555313da89f3b6be3da396e6782460a482d8 UNKNOWN * d270f9a8685dc9d2184de39a4c26b70d68552886 Azure:

[GitHub] [flink] dianfu commented on a change in pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

dianfu commented on a change in pull request #14282: URL: https://github.com/apache/flink/pull/14282#discussion_r533538517 ## File path: flink-python/lib/LICENSE.py4j ## @@ -1,26 +0,0 @@ -Copyright (c) 2009-2018, Barthelemy Dagenais and individual contributors. All Review

[GitHub] [flink] dianfu commented on a change in pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

dianfu commented on a change in pull request #14282: URL: https://github.com/apache/flink/pull/14282#discussion_r533544292 ## File path: flink-python/lib/LICENSE.py4j ## @@ -1,26 +0,0 @@ -Copyright (c) 2009-2018, Barthelemy Dagenais and individual contributors. All Review

[GitHub] [flink] blublinsky opened a new pull request #14284: FLINK-20324 Added Configuration mount support

blublinsky opened a new pull request #14284: URL: https://github.com/apache/flink/pull/14284 ## What is the purpose of the change Currently Flink provides secrets mount decorator, which provides limited support for Secret's mounting. This PR extends this solution by

[GitHub] [flink] dianfu edited a comment on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

dianfu edited a comment on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-736665251 @rmetzger I pushed a new commit which removed the byte buddy(also META-INF/licenses/ASM) and the *.proto files from the fat jar.

[GitHub] [flink] flinkbot edited a comment on pull request #14282: [FLINK-20442][python][legal] Updated flink-python NOTICE

flinkbot edited a comment on pull request #14282: URL: https://github.com/apache/flink/pull/14282#issuecomment-736657230 ## CI report: * 63f04e148ad295e4a4c03df7e7b56825f2333655 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14281: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes setup

flinkbot edited a comment on pull request #14281: URL: https://github.com/apache/flink/pull/14281#issuecomment-736654087 ## CI report: * 6a43ad75129ec9332f82134fe4c98329bd6db7b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14271: [FLINK-12130][clients] Apply command line options to configuration be…

flinkbot edited a comment on pull request #14271: URL: https://github.com/apache/flink/pull/14271#issuecomment-736366741 ## CI report: * 8331b7dc7159127a752634ff239e4ed6ee2aa7b1 UNKNOWN * 46fe1473c6744ae1df47a12f7a5a4b1ab8f81a66 Azure:

[GitHub] [flink] flinkbot commented on pull request #14284: FLINK-20324 Added Configuration mount support

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

[jira] [Updated] (FLINK-20418) NPE in IteratorSourceReader

[ https://issues.apache.org/jira/browse/FLINK-20418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20418: --- Fix Version/s: 1.12.0 > NPE in IteratorSourceReader > --- > >

[GitHub] [flink] flinkbot edited a comment on pull request #14195: [FLINK-20300] Add Flink 1.12 release notes

flinkbot edited a comment on pull request #14195: URL: https://github.com/apache/flink/pull/14195#issuecomment-732780194 ## CI report: * 7148d3b4cb4f3e688079c5e03d8fa027ad1861fa Azure:

[GitHub] [flink] AHeise commented on a change in pull request #14279: [FLINK-20418][core] Fixing checkpointing of IteratorSourceReader.

AHeise commented on a change in pull request #14279: URL: https://github.com/apache/flink/pull/14279#discussion_r533453802 ## File path: flink-tests/src/test/java/org/apache/flink/api/connector/source/lib/NumberSequenceSourceITCase.java ## @@ -0,0 +1,59 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-20341) Rework Deployment / Coordination Documentation

[ https://issues.apache.org/jira/browse/FLINK-20341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241583#comment-17241583 ] Robert Metzger commented on FLINK-20341: The issues in yarn.zh.md are being fixed in

[jira] [Assigned] (FLINK-19725) Logger cannot be initialized due to timeout: LoggerInitializationException is thrown

[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias reassigned FLINK-19725: Assignee: Matthias > Logger cannot be initialized due to timeout: LoggerInitializationException

[jira] [Commented] (FLINK-19725) Logger cannot be initialized due to timeout: LoggerInitializationException is thrown

[ https://issues.apache.org/jira/browse/FLINK-19725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17241649#comment-17241649 ] Matthias commented on FLINK-19725: -- Several SO threads (e.g. [that

<    1   2   3   4