[GitHub] [flink] flinkbot edited a comment on pull request #17152: [FLINK-24131][datastream/kafka] Reliably shutdown producer

flinkbot edited a comment on pull request #17152: URL: https://github.com/apache/flink/pull/17152#issuecomment-913235346 ## CI report: * ddc241c3ce922b83edff8cd73fd3215ec5eda330 Azure:

[jira] [Updated] (FLINK-24134) Docker "Enabling Python" documentation results in failed Docker builds

[ https://issues.apache.org/jira/browse/FLINK-24134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-24134: Fix Version/s: 1.12.6 > Docker "Enabling Python" documentation results in failed Docker builds >

[jira] [Comment Edited] (FLINK-24134) Docker "Enabling Python" documentation results in failed Docker builds

[ https://issues.apache.org/jira/browse/FLINK-24134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410377#comment-17410377 ] Dian Fu edited comment on FLINK-24134 at 9/6/21, 5:52 AM: -- Merged to: - master

[GitHub] [flink] flinkbot commented on pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

flinkbot commented on pull request #17155: URL: https://github.com/apache/flink/pull/17155#issuecomment-913359400 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-19883) Support "IF EXISTS" in DDL for ALTER TABLE

[ https://issues.apache.org/jira/browse/FLINK-19883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19883: --- Labels: pull-request-available (was: ) > Support "IF EXISTS" in DDL for ALTER TABLE >

[GitHub] [flink] SteNicholas opened a new pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

SteNicholas opened a new pull request #17155: URL: https://github.com/apache/flink/pull/17155 ## What is the purpose of the change *`ALTER TABLE` does not seem to support the `IF EXISTS` part in the DDL, but the corresponding methods `Catalog#renameTable` and `Catalog#alterTable` do

[jira] [Updated] (FLINK-24134) Docker "Enabling Python" documentation results in failed Docker builds

[ https://issues.apache.org/jira/browse/FLINK-24134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-24134: Fix Version/s: 1.13.3 > Docker "Enabling Python" documentation results in failed Docker builds >

[jira] [Closed] (FLINK-24134) Docker "Enabling Python" documentation results in failed Docker builds

[ https://issues.apache.org/jira/browse/FLINK-24134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-24134. --- Resolution: Fixed Merged to: - master via 7bee34d69f386e86616696c56029e21597dca61e - release-1.14 via

[GitHub] [flink] dianfu closed pull request #17154: [FLINK-24134][python][docs] Update the documentation about how to install PyFlink in docker

dianfu closed pull request #17154: URL: https://github.com/apache/flink/pull/17154 -- 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 the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] mans2singh commented on pull request #16763: [hotfix][state_processor_api][union_state][doc] Updated variable name to match method invocation

mans2singh commented on pull request #16763: URL: https://github.com/apache/flink/pull/16763#issuecomment-913338933 Hi @leonardBang @tisonkun - This PR is about renaming variable (`DataSet listState`) to be consistent with the `readUnionState` method invocation

[jira] [Commented] (FLINK-24061) RMQSourceITCase.testAckFailure fails on azure

[ https://issues.apache.org/jira/browse/FLINK-24061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410375#comment-17410375 ] Michał Ciesielczyk commented on FLINK-24061: Hi, I'm not sure if increasing the timeout

[GitHub] [flink] RocMarshal commented on pull request #17023: [FLINK-24043][runtime] Reuse the code of 'check savepoint preconditions'.

RocMarshal commented on pull request #17023: URL: https://github.com/apache/flink/pull/17023#issuecomment-91450 @tillrohrmann @tisonkun @gaoyunhaii Could you help me to review this PR if you have time? Thank you. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #17154: [FLINK-24134][python][docs] Update the documentation about how to install PyFlink in docker

flinkbot edited a comment on pull request #17154: URL: https://github.com/apache/flink/pull/17154#issuecomment-913317006 ## CI report: * 1f49ce4a5d7d17e1fd2bea4959996d912a12cd73 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16959: [FLINK-23912] Remove unnecessary "Clearing resource requirements of job" in SlotManager

flinkbot edited a comment on pull request #16959: URL: https://github.com/apache/flink/pull/16959#issuecomment-904476350 ## CI report: * 9b6925fe65d15dbede54fb888c51e4ba96c39f44 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * 5240b15bd61f4b040a2f807780b081cab6ab9113 UNKNOWN * 0157b9a476cc31fd3d430ba8fc25d07abcc9f9d2 Azure:

[jira] [Commented] (FLINK-23864) The document for Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-23864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410362#comment-17410362 ] Xintong Song commented on FLINK-23864: -- Hi [~syhily], Do we have any updates for the documentation?

[jira] [Updated] (FLINK-23864) The document for Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-23864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23864: - Labels: documentation r (was: documentation) > The document for Pulsar Source >

[jira] [Updated] (FLINK-23864) The document for Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-23864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23864: - Priority: Blocker (was: Major) > The document for Pulsar Source >

[jira] [Assigned] (FLINK-22603) The digest can be produced by SourceAbilitySpec

[ https://issues.apache.org/jira/browse/FLINK-22603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-22603: -- Assignee: zhongxuyang > The digest can be produced by SourceAbilitySpec >

[jira] [Updated] (FLINK-22603) The digest can be produced by SourceAbilitySpec

[ https://issues.apache.org/jira/browse/FLINK-22603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-22603: --- Fix Version/s: (was: 1.14.0) 1.15.0 > The digest can be produced by

[jira] [Commented] (FLINK-23456) Manually test on cluster

[ https://issues.apache.org/jira/browse/FLINK-23456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410361#comment-17410361 ] Xintong Song commented on FLINK-23456: -- Hi [~akalashnikov], How are things going with the testings?

[jira] [Commented] (FLINK-23821) Test loopback mode to allow Python UDF worker and client reuse the same Python VM

[ https://issues.apache.org/jira/browse/FLINK-23821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410360#comment-17410360 ] Xintong Song commented on FLINK-23821: -- Hi [~Jiangang], how are the testings going? Do we have any

[jira] [Updated] (FLINK-24155) Translate documentation for how to configure the CheckpointFailureManager

[ https://issues.apache.org/jira/browse/FLINK-24155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24155: - Priority: Major (was: Critical) > Translate documentation for how to configure the

[jira] [Commented] (FLINK-24137) Python tests fail with "Exception in thread read_grpc_client_inputs"

[ https://issues.apache.org/jira/browse/FLINK-24137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410359#comment-17410359 ] Xintong Song commented on FLINK-24137: -- Thanks [~hxbks2ks]. Shall I assign this to you? > Python

[GitHub] [flink] flinkbot commented on pull request #17154: [FLINK-24134][python][docs] Update the documentation about how to install PyFlink in docker

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

[GitHub] [flink] flinkbot edited a comment on pull request #17153: (1.14) [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

flinkbot edited a comment on pull request #17153: URL: https://github.com/apache/flink/pull/17153#issuecomment-913306007 ## CI report: * e1c7ffe73833a91d25a0ed988eee5a04d8cafe6e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

flinkbot edited a comment on pull request #17064: URL: https://github.com/apache/flink/pull/17064#issuecomment-908893945 ## CI report: * 167a600021ec50d0fa82e8806593391fe57a545a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16959: [FLINK-23912] Remove unnecessary "Clearing resource requirements of job" in SlotManager

flinkbot edited a comment on pull request #16959: URL: https://github.com/apache/flink/pull/16959#issuecomment-904476350 ## CI report: * 9b6925fe65d15dbede54fb888c51e4ba96c39f44 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * 5240b15bd61f4b040a2f807780b081cab6ab9113 UNKNOWN * 0157b9a476cc31fd3d430ba8fc25d07abcc9f9d2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16224: Added LoadRebalancePartitioner in order to select the freest subparti…

flinkbot edited a comment on pull request #16224: URL: https://github.com/apache/flink/pull/16224#issuecomment-865133220 ## CI report: * cdefe703b7d7706c52ab78bda36cb43c0e5230d8 Azure:

[jira] [Commented] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410356#comment-17410356 ] Rui Li commented on FLINK-23857: [~luoyuxia] Please also verify with different hive versions. IIRC hive

[jira] [Commented] (FLINK-24162) PartiallyFinishedSourcesITCase fails due to assertion error in DrainingValidator.validateOperatorLifecycle

[ https://issues.apache.org/jira/browse/FLINK-24162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410355#comment-17410355 ] Xintong Song commented on FLINK-24162: --

[jira] [Commented] (FLINK-24096) Table planner tests fails due to NPE in FailingCollectionSource.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-24096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410354#comment-17410354 ] Xintong Song commented on FLINK-24096: --

[jira] [Commented] (FLINK-24137) Python tests fail with "Exception in thread read_grpc_client_inputs"

[ https://issues.apache.org/jira/browse/FLINK-24137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410353#comment-17410353 ] Xintong Song commented on FLINK-24137: --

[jira] [Commented] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410352#comment-17410352 ] Yun Tang commented on FLINK-23886: -- [~pnowojski] I think FLINK-19741 is not like the problem we meet. I

[jira] [Updated] (FLINK-24131) KafkaSinkITCase "Detected producer leak"

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24131: - Fix Version/s: 1.15.0 1.13.3 1.14.0 > KafkaSinkITCase

[jira] [Updated] (FLINK-24131) KafkaSinkITCase "Detected producer leak"

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24131: - Priority: Blocker (was: Critical) > KafkaSinkITCase "Detected producer leak" >

[jira] [Updated] (FLINK-24131) KafkaSinkITCase "Detected producer leak"

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24131: - Affects Version/s: 1.13.2 > KafkaSinkITCase "Detected producer leak" >

[jira] [Updated] (FLINK-24131) KafkaSinkITCase "Detected producer leak"

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24131: - Affects Version/s: 1.14.0 > KafkaSinkITCase "Detected producer leak" >

[jira] [Commented] (FLINK-24131) KafkaSinkITCase "Detected producer leak"

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410350#comment-17410350 ] Xintong Song commented on FLINK-24131: --

[jira] [Commented] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410349#comment-17410349 ] Xintong Song commented on FLINK-22869: --

[jira] [Updated] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24163: - Priority: Blocker (was: Major) > PartiallyFinishedSourcesITCase fails due to timeout >

[jira] [Updated] (FLINK-24162) PartiallyFinishedSourcesITCase fails due to assertion error in DrainingValidator.validateOperatorLifecycle

[ https://issues.apache.org/jira/browse/FLINK-24162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24162: - Priority: Blocker (was: Major) > PartiallyFinishedSourcesITCase fails due to assertion error

[jira] [Commented] (FLINK-24162) PartiallyFinishedSourcesITCase fails due to assertion error in DrainingValidator.validateOperatorLifecycle

[ https://issues.apache.org/jira/browse/FLINK-24162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410347#comment-17410347 ] Xintong Song commented on FLINK-24162: --

[jira] [Commented] (FLINK-24131) KafkaSinkITCase "Detected producer leak"

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410346#comment-17410346 ] Xintong Song commented on FLINK-24131: --

[jira] [Commented] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410345#comment-17410345 ] Xintong Song commented on FLINK-24163: --

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410344#comment-17410344 ] Xintong Song commented on FLINK-22889: --

[jira] [Commented] (FLINK-24162) PartiallyFinishedSourcesITCase fails due to assertion error in DrainingValidator.validateOperatorLifecycle

[ https://issues.apache.org/jira/browse/FLINK-24162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410342#comment-17410342 ] Xintong Song commented on FLINK-24162: --

[jira] [Commented] (FLINK-22971) Initialization of Testcontainers unstable on Azure

[ https://issues.apache.org/jira/browse/FLINK-22971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410340#comment-17410340 ] Xintong Song commented on FLINK-22971: --

[jira] [Commented] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410336#comment-17410336 ] Xintong Song commented on FLINK-24163: --

[jira] [Commented] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410337#comment-17410337 ] Xintong Song commented on FLINK-24163: --

[jira] [Closed] (FLINK-23748) Testing window TVF session window

[ https://issues.apache.org/jira/browse/FLINK-23748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-23748. Resolution: Won't Do > Testing window TVF session window > - > >

[jira] [Comment Edited] (FLINK-23748) Testing window TVF session window

[ https://issues.apache.org/jira/browse/FLINK-23748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410327#comment-17410327 ] JING ZHANG edited comment on FLINK-23748 at 9/6/21, 3:16 AM: - [~liliwei]  We

[GitHub] [flink] yangjunhan edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

yangjunhan edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-913307348 > @yangjunhan I've also noticed now that you are migrating the package-lock.json back from version 2 to 1. Can you please fix that commit to have it generated as

[jira] [Commented] (FLINK-22971) Initialization of Testcontainers unstable on Azure

[ https://issues.apache.org/jira/browse/FLINK-22971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410331#comment-17410331 ] Xintong Song commented on FLINK-22971: --

[GitHub] [flink] yangjunhan commented on pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

yangjunhan commented on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-913307348 > @yangjunhan I've also noticed now that you are migrating the package-lock.json back from version 2 to 1. Can you please fix that commit to have it generated as version 2?

[jira] [Commented] (FLINK-22603) The digest can be produced by SourceAbilitySpec

[ https://issues.apache.org/jira/browse/FLINK-22603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410329#comment-17410329 ] zhongxuyang commented on FLINK-22603: - please assign to me > The digest can be produced by

[jira] [Commented] (FLINK-23493) python tests hang on Azure

[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410330#comment-17410330 ] Xintong Song commented on FLINK-23493: --

[jira] [Commented] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410328#comment-17410328 ] Xintong Song commented on FLINK-22869: --

[jira] [Commented] (FLINK-23748) Testing window TVF session window

[ https://issues.apache.org/jira/browse/FLINK-23748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410327#comment-17410327 ] JING ZHANG commented on FLINK-23748: [~liliwei]  We have move

[GitHub] [flink] flinkbot commented on pull request #17153: (1.14) [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

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

[GitHub] [flink] flinkbot edited a comment on pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

flinkbot edited a comment on pull request #17064: URL: https://github.com/apache/flink/pull/17064#issuecomment-908893945 ## CI report: * 167a600021ec50d0fa82e8806593391fe57a545a Azure:

[jira] [Commented] (FLINK-24162) PartiallyFinishedSourcesITCase fails due to assertion error in DrainingValidator.validateOperatorLifecycle

[ https://issues.apache.org/jira/browse/FLINK-24162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410326#comment-17410326 ] Xintong Song commented on FLINK-24162: --

[jira] [Commented] (FLINK-24131) KafkaSinkITCase "Detected producer leak"

[ https://issues.apache.org/jira/browse/FLINK-24131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410325#comment-17410325 ] Xintong Song commented on FLINK-24131: --

[GitHub] [flink] flinkbot edited a comment on pull request #16902: [FLINK-23113][runtime-web] Migrate to ESLint, add Stylint and address dependency vulnerabilities

flinkbot edited a comment on pull request #16902: URL: https://github.com/apache/flink/pull/16902#issuecomment-902393531 ## CI report: * 5240b15bd61f4b040a2f807780b081cab6ab9113 UNKNOWN * 0157b9a476cc31fd3d430ba8fc25d07abcc9f9d2 Azure:

[jira] [Commented] (FLINK-24137) Python tests fail with "Exception in thread read_grpc_client_inputs"

[ https://issues.apache.org/jira/browse/FLINK-24137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410324#comment-17410324 ] Xintong Song commented on FLINK-24137: --

[jira] [Updated] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24163: - Component/s: API / DataStream > PartiallyFinishedSourcesITCase fails due to timeout >

[jira] [Updated] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24163: - Fix Version/s: 1.15.0 1.14.0 > PartiallyFinishedSourcesITCase fails due to

[jira] [Updated] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24163: - Affects Version/s: 1.15.0 1.14.0 > PartiallyFinishedSourcesITCase fails

[jira] [Commented] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410323#comment-17410323 ] Xintong Song commented on FLINK-24163: -- cc [~roman] > PartiallyFinishedSourcesITCase fails due to

[jira] [Created] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

Xintong Song created FLINK-24163: Summary: PartiallyFinishedSourcesITCase fails due to timeout Key: FLINK-24163 URL: https://issues.apache.org/jira/browse/FLINK-24163 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #17154: [FLINK-24134][python][docs] Update the documentation about how to install PyFlink in docker

flinkbot commented on pull request #17154: URL: https://github.com/apache/flink/pull/17154#issuecomment-913303679 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-22971) Initialization of Testcontainers unstable on Azure

[ https://issues.apache.org/jira/browse/FLINK-22971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410321#comment-17410321 ] Xintong Song commented on FLINK-22971: --

[jira] [Updated] (FLINK-24134) Docker "Enabling Python" documentation results in failed Docker builds

[ https://issues.apache.org/jira/browse/FLINK-24134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24134: --- Labels: pull-request-available (was: ) > Docker "Enabling Python" documentation results in

[GitHub] [flink] dianfu opened a new pull request #17154: [FLINK-24134][python][docs] Update the documentation about how to install PyFlink in docker

dianfu opened a new pull request #17154: URL: https://github.com/apache/flink/pull/17154 ## What is the purpose of the change *This pull request fixes the documentation about how to install PyFlink in docker as it has bumped the Python version from Python 3.7 to Python 3.9 in

[jira] [Commented] (FLINK-24162) PartiallyFinishedSourcesITCase fails due to assertion error in DrainingValidator.validateOperatorLifecycle

[ https://issues.apache.org/jira/browse/FLINK-24162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410320#comment-17410320 ] Xintong Song commented on FLINK-24162: -- cc [~roman] > PartiallyFinishedSourcesITCase fails due to

[jira] [Created] (FLINK-24162) PartiallyFinishedSourcesITCase fails due to assertion error in DrainingValidator.validateOperatorLifecycle

Xintong Song created FLINK-24162: Summary: PartiallyFinishedSourcesITCase fails due to assertion error in DrainingValidator.validateOperatorLifecycle Key: FLINK-24162 URL:

[GitHub] [flink] crazyzhou commented on a change in pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

crazyzhou commented on a change in pull request #17064: URL: https://github.com/apache/flink/pull/17064#discussion_r702533725 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testutils/source/reader/SourceReaderTestBase.java

[GitHub] [flink] crazyzhou commented on a change in pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

crazyzhou commented on a change in pull request #17064: URL: https://github.com/apache/flink/pull/17064#discussion_r702533561 ## File path: flink-test-utils-parent/flink-connector-test-utils/src/main/java/org/apache/flink/connector/testutils/source/reader/SourceReaderTestBase.java

[jira] [Updated] (FLINK-24160) PartiallyFinishedSourcesITCase fails due to 'Size of the state is larger than the maximum permitted memory-backed state.'

[ https://issues.apache.org/jira/browse/FLINK-24160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24160: - Component/s: API / DataStream > PartiallyFinishedSourcesITCase fails due to 'Size of the state

[jira] [Updated] (FLINK-24160) PartiallyFinishedSourcesITCase fails due to 'Size of the state is larger than the maximum permitted memory-backed state.'

[ https://issues.apache.org/jira/browse/FLINK-24160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24160: - Affects Version/s: 1.15.0 1.14.0 > PartiallyFinishedSourcesITCase fails

[jira] [Updated] (FLINK-24160) PartiallyFinishedSourcesITCase fails due to 'Size of the state is larger than the maximum permitted memory-backed state.'

[ https://issues.apache.org/jira/browse/FLINK-24160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-24160: - Fix Version/s: 1.15.0 1.14.0 > PartiallyFinishedSourcesITCase fails due to

[GitHub] [flink] flinkbot commented on pull request #17153: (1.14) [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

flinkbot commented on pull request #17153: URL: https://github.com/apache/flink/pull/17153#issuecomment-913300253 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-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410317#comment-17410317 ] Xintong Song commented on FLINK-20928: --

[jira] [Commented] (FLINK-24160) PartiallyFinishedSourcesITCase fails due to 'Size of the state is larger than the maximum permitted memory-backed state.'

[ https://issues.apache.org/jira/browse/FLINK-24160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410316#comment-17410316 ] Xintong Song commented on FLINK-24160: -- [~roman], is this necessary that the testing job needs more

[jira] [Commented] (FLINK-24149) Make checkpoint relocatable

[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410315#comment-17410315 ] Yun Tang commented on FLINK-24149: -- [~Feifan Wang] The incremental checkpoint might have different path

[GitHub] [flink] gaoyunhaii opened a new pull request #17153: (1.14) [FLINK-24068][checkpoint] Also check for alignment start when received EndOfPartition from pending channels

gaoyunhaii opened a new pull request #17153: URL: https://github.com/apache/flink/pull/17153 This picks https://github.com/apache/flink/pull/17131 to release-1.14 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Issue Comment Deleted] (FLINK-24096) Table planner tests fails due to NPE in FailingCollectionSource.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-24096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24096: Comment: was deleted (was: Fix on master via

[jira] [Issue Comment Deleted] (FLINK-24096) Table planner tests fails due to NPE in FailingCollectionSource.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-24096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24096: Comment: was deleted (was: I'll temporarily close this issue, if it re-occurs we could reopen the

[jira] [Commented] (FLINK-24096) Table planner tests fails due to NPE in FailingCollectionSource.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-24096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410314#comment-17410314 ] Yun Gao commented on FLINK-24096: - I'll temporarily close this issue, if it re-occurs we could reopen

[jira] [Commented] (FLINK-24161) Can not stop the job with savepoint while a task is finishing

[ https://issues.apache.org/jira/browse/FLINK-24161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410313#comment-17410313 ] Yangze Guo commented on FLINK-24161: cc [~gaoyunhaii] > Can not stop the job with savepoint while a

[jira] [Updated] (FLINK-24161) Can not stop the job with savepoint while a task is finishing

[ https://issues.apache.org/jira/browse/FLINK-24161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-24161: --- Attachment: flink-yangze-standalonesession-0-IT-C02YV0L8LVDL.local.log

[jira] [Commented] (FLINK-24096) Table planner tests fails due to NPE in FailingCollectionSource.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-24096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410312#comment-17410312 ] Yun Gao commented on FLINK-24096: - Fix on master via

[jira] [Closed] (FLINK-23831) Verify the final checkpoint and stop-with-savepoint --drain

[ https://issues.apache.org/jira/browse/FLINK-23831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-23831. -- Resolution: Fixed > Verify the final checkpoint and stop-with-savepoint --drain >

[jira] [Commented] (FLINK-23831) Verify the final checkpoint and stop-with-savepoint --drain

[ https://issues.apache.org/jira/browse/FLINK-23831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410311#comment-17410311 ] Yangze Guo commented on FLINK-23831: Testing job: 4 sources, 3 of which are bounded and will finish

[jira] [Commented] (FLINK-24137) Python tests fail with "Exception in thread read_grpc_client_inputs"

[ https://issues.apache.org/jira/browse/FLINK-24137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410309#comment-17410309 ] Huang Xingbo commented on FLINK-24137: -- It is the same problem with FLINK-24100 failed in

[GitHub] [flink] gaoyunhaii closed pull request #17123: [FLINK-24096][checkpoint] Skip the complete notification for checkpoints before task startup

gaoyunhaii closed pull request #17123: URL: https://github.com/apache/flink/pull/17123 -- 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 the specific comment. To unsubscribe, e-mail:

[jira] [Created] (FLINK-24160) PartiallyFinishedSourcesITCase fails due to 'Size of the state is larger than the maximum permitted memory-backed state.'

Xintong Song created FLINK-24160: Summary: PartiallyFinishedSourcesITCase fails due to 'Size of the state is larger than the maximum permitted memory-backed state.' Key: FLINK-24160 URL:

[jira] [Created] (FLINK-24161) Can not stop the job with savepoint while a task is finishing

Yangze Guo created FLINK-24161: -- Summary: Can not stop the job with savepoint while a task is finishing Key: FLINK-24161 URL: https://issues.apache.org/jira/browse/FLINK-24161 Project: Flink

[GitHub] [flink] gaoyunhaii commented on pull request #17123: [FLINK-24096][checkpoint] Skip the complete notification for checkpoints before task startup

gaoyunhaii commented on pull request #17123: URL: https://github.com/apache/flink/pull/17123#issuecomment-913297350 Very thanks @dawidwys for the review! I'll merge the code~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

  1   2   >