[GitHub] [flink] flinkbot edited a comment on pull request #19002: [FLINK-26501] extra log

flinkbot edited a comment on pull request #19002: URL: https://github.com/apache/flink/pull/19002#issuecomment-1060970183 ## CI report: * cbdee82a50ffe1a7c3fdc3b708bafd6258229afc Azure:

[jira] [Created] (FLINK-26548) the source parallelism is not set correctly with AdaptiveBatchScheduler

zl created FLINK-26548: -- Summary: the source parallelism is not set correctly with AdaptiveBatchScheduler Key: FLINK-26548 URL: https://issues.apache.org/jira/browse/FLINK-26548 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Myasuka commented on a change in pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

Myasuka commented on a change in pull request #18976: URL: https://github.com/apache/flink/pull/18976#discussion_r822531325 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/StateChangeFsUploader.java ## @@ -96,19 +91,20 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #19019: [FLINK-26547][coordination] No requirement adjustments for unmatched slots

flinkbot edited a comment on pull request #19019: URL: https://github.com/apache/flink/pull/19019#issuecomment-1062795247 ## CI report: * 79b8bf5bb7f39b00e94a2ef7b921a046e90be9b2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

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

[GitHub] [flink] flinkbot edited a comment on pull request #19001: [FLINK-26520][table] Implement SEARCH operator in codegen

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

[GitHub] [flink] flinkbot edited a comment on pull request #18940: [FLINK-26249][table-planner] Run BuiltInFunctionsTestBase and BuiltInAggregateFunctionsTestBase in parallel

flinkbot edited a comment on pull request #18940: URL: https://github.com/apache/flink/pull/18940#issuecomment-1055381485 ## CI report: * b963e2a9e1fc86e06f9149cbaa85e1b9d9d8614d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 414adf3bf2aa1467db7e089b10e18b4e9e349b56 Azure:

[jira] [Comment Edited] (FLINK-25235) Re-enable ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange

[ https://issues.apache.org/jira/browse/FLINK-25235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500246#comment-17500246 ] Niklas Semmler edited comment on FLINK-25235 at 3/9/22, 10:58 AM: --

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * Unknown: [CANCELED](TBD) * 57d064b16b3d5864299cb48d6cef678e31d1e4ef UNKNOWN Bot commands The @flinkbot bot supports the

[jira] [Resolved] (FLINK-25129) Update docs to use flink-table-planner-loader instead of flink-table-planner

[ https://issues.apache.org/jira/browse/FLINK-25129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser resolved FLINK-25129. Resolution: Fixed Fixed in master via e35385a76f9ea67d766ba590c459384dbf02a777 > Update

[jira] [Closed] (FLINK-25129) Update docs to use flink-table-planner-loader instead of flink-table-planner

[ https://issues.apache.org/jira/browse/FLINK-25129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25129. -- > Update docs to use flink-table-planner-loader instead of flink-table-planner >

[GitHub] [flink] MartijnVisser merged pull request #18812: [FLINK-25129][docs] Improvements to the table-planner-loader related docs

MartijnVisser merged pull request #18812: URL: https://github.com/apache/flink/pull/18812 -- 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] flinkbot commented on pull request #19019: [FLINK-26547][coordination] No requirement adjustments for unmatched slots

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

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * 3eab01550b5c5ee0d369d74e45fd516f698d83e6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19001: [FLINK-26520][table] Implement SEARCH operator in codegen

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

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

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

[GitHub] [flink] flinkbot edited a comment on pull request #18940: [FLINK-26249][table-planner] Run BuiltInFunctionsTestBase and BuiltInAggregateFunctionsTestBase in parallel

flinkbot edited a comment on pull request #18940: URL: https://github.com/apache/flink/pull/18940#issuecomment-1055381485 ## CI report: * b963e2a9e1fc86e06f9149cbaa85e1b9d9d8614d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 414adf3bf2aa1467db7e089b10e18b4e9e349b56 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * 759573c511f50f1a58ade039711e5bbb33ea854a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * f9628d0cc59529303359774663895e783a76a045 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-26547) Accepting slots without a matching requirement leads to unfulfillable requirements

[ https://issues.apache.org/jira/browse/FLINK-26547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26547: --- Labels: pull-request-available (was: ) > Accepting slots without a matching requirement

[GitHub] [flink] zentol opened a new pull request #19019: [FLINK-26547][coordination] No requirement adjustments for unmatched slots

zentol opened a new pull request #19019: URL: https://github.com/apache/flink/pull/19019 To allow recovered TMs to eagerly re-offer their slots we allowed the registration of slots without a matching requirement if the job is currently restarting. All slots that the pool accepts

[GitHub] [flink] flinkbot edited a comment on pull request #19009: [hotfix] [docs] Refer to Running in an IDE section early on

flinkbot edited a comment on pull request #19009: URL: https://github.com/apache/flink/pull/19009#issuecomment-1061628385 ## CI report: * e05693bd5f073885a2db29f0a06ee48d9463fb1f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19002: [FLINK-26501] extra log

flinkbot edited a comment on pull request #19002: URL: https://github.com/apache/flink/pull/19002#issuecomment-1060970183 ## CI report: * cbdee82a50ffe1a7c3fdc3b708bafd6258229afc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18949: [FLINK-25235][tests] re-enable zookeeper test

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

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * 759573c511f50f1a58ade039711e5bbb33ea854a Azure:

[jira] [Updated] (FLINK-26547) Accepting slots without a matching requirement leads to unfulfillable requirements

[ https://issues.apache.org/jira/browse/FLINK-26547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-26547: - Description: To allow recovered TMs to eagerly re-offer their slots we allowed the

[GitHub] [flink] flinkbot edited a comment on pull request #18812: [FLINK-25129][docs] Improvements to the table-planner-loader related docs

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

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * f9628d0cc59529303359774663895e783a76a045 Azure:

[GitHub] [flink] MartijnVisser commented on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

MartijnVisser commented on pull request #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-1062785296 @ZhangChaoming Please have a look first at the CI, because the build is currently not passing -- This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18464: --- Labels: auto-deprioritized-major pull-request-available (was: auto-deprioritized-major

[jira] [Updated] (FLINK-19930) Upgrade cassandra-driver-core to 4.X

[ https://issues.apache.org/jira/browse/FLINK-19930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19930: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-22455) FlinkRelBuilder#windowAggregate will throw ClassCastException when function reuse

[ https://issues.apache.org/jira/browse/FLINK-22455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22455: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16686: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-25480) Create dashboard/monitoring to see resource usage per E2E test

[ https://issues.apache.org/jira/browse/FLINK-25480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25480: --- Fix Version/s: (was: 1.15.0) > Create dashboard/monitoring to see resource usage per

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503475#comment-17503475 ] hehuiyuan commented on FLINK-26498: --- lateness and  out-of-order  , i got it.   [~jark] , the

[GitHub] [flink] slinkydeveloper commented on pull request #18940: [FLINK-26249][table-planner] Run BuiltInFunctionsTestBase and BuiltInAggregateFunctionsTestBase in parallel

slinkydeveloper commented on pull request #18940: URL: https://github.com/apache/flink/pull/18940#issuecomment-1062782029 @flinkbot run azure -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * 8ec121581b905809270debe0d5666f612548851b Azure:

[jira] [Updated] (FLINK-26547) Accepting slots without a matching requirement leads to unfulfillable requirements

[ https://issues.apache.org/jira/browse/FLINK-26547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-26547: - Description: To allow recovered TMs to eagerly re-offer their slots we allowed the

[jira] [Commented] (FLINK-26274) Test local recovery works across TaskManager process restarts

[ https://issues.apache.org/jira/browse/FLINK-26274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503471#comment-17503471 ] Chesnay Schepler commented on FLINK-26274: -- I'm tracking the fix in FLINK-26547. > Test local

[jira] [Updated] (FLINK-26547) Accepting slots without a matching requirement leads to unfulfillable requirements

[ https://issues.apache.org/jira/browse/FLINK-26547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-26547: - Summary: Accepting slots without a matching requirement leads to unfulfillable

[jira] [Created] (FLINK-26547) Accepting slots without a matching requirement lead to unfulfillable requirements

Chesnay Schepler created FLINK-26547: Summary: Accepting slots without a matching requirement lead to unfulfillable requirements Key: FLINK-26547 URL: https://issues.apache.org/jira/browse/FLINK-26547

[GitHub] [flink] flinkbot edited a comment on pull request #19018: [FLINK-25819][runtime] Reordered requesting and recycling buffers in order to avoid race condition in testIsAvailableOrNotAfterReques

flinkbot edited a comment on pull request #19018: URL: https://github.com/apache/flink/pull/19018#issuecomment-1062745397 ## CI report: * 33be62479b9cdc58021afa8cfb68bd87355b5f26 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19002: [FLINK-26501] extra log

flinkbot edited a comment on pull request #19002: URL: https://github.com/apache/flink/pull/19002#issuecomment-1060970183 ## CI report: * cbdee82a50ffe1a7c3fdc3b708bafd6258229afc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] Hive dialect supports queries with multiple same …

flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 2958fb85fccb9828a523db710cf2fcf1cf88baa3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 14ae6d15c25f454fe7675bf7b0e129834b99ae37 Azure:

[GitHub] [flink] imaffe edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

imaffe edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1060703762 > Looks mostly good. Can you quickly share with me how many runs did you do with the test code enabled? We are very close to the branch cut off and want to avoid

[GitHub] [flink] flinkbot edited a comment on pull request #18949: [FLINK-25235][tests] re-enable zookeeper test

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

[jira] [Assigned] (FLINK-26451) Test GCS FileSystem w/ RecoverableWriter manually

[ https://issues.apache.org/jira/browse/FLINK-26451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-26451: --- Assignee: Fabian Paul > Test GCS FileSystem w/ RecoverableWriter manually >

[jira] [Assigned] (FLINK-25069) YARNHighAvailabilityITCase.testJobRecoversAfterKillingTaskManager failed on AZP

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

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * 759573c511f50f1a58ade039711e5bbb33ea854a Azure:

[jira] [Commented] (FLINK-26416) Release Testing: Sink V2 sanity checks

[ https://issues.apache.org/jira/browse/FLINK-26416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503459#comment-17503459 ] Fabian Paul commented on FLINK-26416: - [~Jiangang] you should now be able to start the testing the

[jira] [Closed] (FLINK-26239) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26239. --- Fix Version/s: 1.15.0 Resolution: Duplicate >

[jira] [Commented] (FLINK-26239) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503456#comment-17503456 ] Yun Gao commented on FLINK-26239: - I'll first close this issue since it seems already fixed and it

[GitHub] [flink] JingGe commented on pull request #18996: [FLINK-26492][metric] deprecate umRecordsOutErrorsCounter

JingGe commented on pull request #18996: URL: https://github.com/apache/flink/pull/18996#issuecomment-1062752724 Thanks @alpreu ! @fapaul would you please merge this PR? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] ZhangChaoming commented on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

ZhangChaoming commented on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1062751689 @flinkbot run azure -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

flinkbot edited a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1015100174 ## CI report: * e0a1238340c360eaf676afa6e8a7fd0f9a9ede84 Azure:

[jira] [Closed] (FLINK-26164) Document watermark alignment

[ https://issues.apache.org/jira/browse/FLINK-26164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-26164. Resolution: Implemented Implemented in 106280e10a96d729943985986198b942446197d9 >

[GitHub] [flink] flinkbot commented on pull request #19018: [FLINK-25819][runtime] Reordered requesting and recycling buffers in order to avoid race condition in testIsAvailableOrNotAfterRequestAndRec

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

[GitHub] [flink] flinkbot commented on pull request #19017: [FLINK-26542][hive] Hive dialect supports queries with multiple same …

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

[jira] [Commented] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503453#comment-17503453 ] Etienne Chauchot commented on FLINK-23843: -- Thanks [~mapohl] for the backports ! > Exceptions

[GitHub] [flink] zhuzhurk commented on a change in pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

zhuzhurk commented on a change in pull request #19003: URL: https://github.com/apache/flink/pull/19003#discussion_r822468908 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java ## @@ -109,54 +116,90

[GitHub] [flink] zhuzhurk commented on a change in pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

zhuzhurk commented on a change in pull request #19003: URL: https://github.com/apache/flink/pull/19003#discussion_r822468908 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java ## @@ -109,54 +116,90

[GitHub] [flink] zhuzhurk commented on a change in pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

zhuzhurk commented on a change in pull request #19003: URL: https://github.com/apache/flink/pull/19003#discussion_r822468908 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/DefaultVertexParallelismDecider.java ## @@ -109,54 +116,90

[GitHub] [flink] flinkbot edited a comment on pull request #18980: [FLINK-26421] Use only EnvironmentSettings to configure the environment

flinkbot edited a comment on pull request #18980: URL: https://github.com/apache/flink/pull/18980#issuecomment-1059275933 ## CI report: * 91046dc10a250f5547cee5478c0b13f14d3903a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 14ae6d15c25f454fe7675bf7b0e129834b99ae37 Azure:

[jira] [Resolved] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-23843. --- Fix Version/s: 1.13.7 1.14.5 Resolution: Fixed > Exceptions

[jira] [Comment Edited] (FLINK-23843) Exceptions during "SplitEnumeratorContext.runInCoordinatorThread()" should cause Global Failure instead of Process Kill

[ https://issues.apache.org/jira/browse/FLINK-23843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502226#comment-17502226 ] Matthias Pohl edited comment on FLINK-23843 at 3/9/22, 9:44 AM:

[GitHub] [flink] XComp merged pull request #18999: [BP-1.13][FLINK-23843][runtime] Properly fail the job when SplitEnumeratorContext.runInCoordinatorThread() throws an exception.

XComp merged pull request #18999: URL: https://github.com/apache/flink/pull/18999 -- 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] XComp merged pull request #18998: [BP-1.14][FLINK-23843][runtime] Properly fail the job when SplitEnumeratorContext.runInCoordinatorThread() throws an exception.

XComp merged pull request #18998: URL: https://github.com/apache/flink/pull/18998 -- 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] (FLINK-25456) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-25456 ] Yun Gao deleted comment on FLINK-25456: - was (Author: gaoyunhaii): I'll first move some Kafka connector related instable test issues to the next cycle since the test infrastructure has been

[jira] [Commented] (FLINK-25456) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint

[ https://issues.apache.org/jira/browse/FLINK-25456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503449#comment-17503449 ] Yun Gao commented on FLINK-25456: - I'll first move some Kafka connector related instable test issues to

[jira] [Updated] (FLINK-25214) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce fails on AZP with incorrect result

[ https://issues.apache.org/jira/browse/FLINK-25214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25214: Fix Version/s: 1.16.0 (was: 1.15.0) >

[jira] [Commented] (FLINK-25214) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce fails on AZP with incorrect result

[ https://issues.apache.org/jira/browse/FLINK-25214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503448#comment-17503448 ] Yun Gao commented on FLINK-25214: - I'll first move some Kafka connector related instable test issues to

[jira] [Commented] (FLINK-24872) PulsarSourceITCase.testMultipleSplits failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-24872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503447#comment-17503447 ] Yun Gao commented on FLINK-24872: - Hi [~syhily] do we still want to fix this issue in 1.15? >

[jira] [Updated] (FLINK-24795) FlinkKafkaProducerITCase.testRunOutOfProducersInThePool times out on AZP

[ https://issues.apache.org/jira/browse/FLINK-24795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24795: Fix Version/s: 1.16.0 (was: 1.15.0) >

[jira] [Updated] (FLINK-24744) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce fails on Azure because org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does

[ https://issues.apache.org/jira/browse/FLINK-24744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24744: Fix Version/s: 1.16.0 (was: 1.15.0) >

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503443#comment-17503443 ] Yun Gao commented on FLINK-23944: - I'll first degrade the issue since it has been fixed on the master.

[jira] [Commented] (FLINK-24795) FlinkKafkaProducerITCase.testRunOutOfProducersInThePool times out on AZP

[ https://issues.apache.org/jira/browse/FLINK-24795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503445#comment-17503445 ] Yun Gao commented on FLINK-24795: - I'll first move some Kafka connector related instable test issues to

[jira] [Commented] (FLINK-24744) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce fails on Azure because org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server do

[ https://issues.apache.org/jira/browse/FLINK-24744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503444#comment-17503444 ] Yun Gao commented on FLINK-24744: - I'll first move some Kafka connector related instable test issues to

[GitHub] [flink] afedulov commented on a change in pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

afedulov commented on a change in pull request #18905: URL: https://github.com/apache/flink/pull/18905#discussion_r822459386 ## File path: flink-connectors/flink-sql-connector-kafka/pom.xml ## @@ -40,6 +40,12 @@ under the License. org.apache.flink

[jira] [Updated] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23944: Fix Version/s: 1.14.4 > PulsarSourceITCase.testTaskManagerFailure is instable >

[jira] [Closed] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-23828. --- Resolution: Cannot Reproduce > KafkaSourceITCase.testIdleReader fails on azure >

[jira] [Updated] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23944: Priority: Major (was: Critical) > PulsarSourceITCase.testTaskManagerFailure is instable >

[jira] [Reopened] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reopened FLINK-23828: - > KafkaSourceITCase.testIdleReader fails on azure > --- > >

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503441#comment-17503441 ] Yun Gao commented on FLINK-23828: - I'll first close this issue since it did not reproduce for half a

[jira] [Closed] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-23828. --- Resolution: Fixed > KafkaSourceITCase.testIdleReader fails on azure >

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503439#comment-17503439 ] Jark Wu commented on FLINK-26498: - They are different concepts: lateness vs out-of-order. The

[jira] [Commented] (FLINK-26546) Extract Observer Interface

[ https://issues.apache.org/jira/browse/FLINK-26546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503438#comment-17503438 ] Aitozi commented on FLINK-26546: +1. I'm willing to take the work > Extract Observer Interface >

[jira] [Updated] (FLINK-26532) SinkMetricsITCase.testMetrics failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-26532: Affects Version/s: 1.15.0 > SinkMetricsITCase.testMetrics failed on azure >

[jira] [Updated] (FLINK-26532) SinkMetricsITCase.testMetrics failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-26532: Affects Version/s: (was: 1.15.0) > SinkMetricsITCase.testMetrics failed on azure >

[GitHub] [flink] afedulov commented on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

afedulov commented on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1062730506 > CI fails with a compile error. I am looking into this. The CI was green before the recent rebase on master. Something changed in the tests setup for Kinesis. --

[jira] [Assigned] (FLINK-26532) SinkMetricsITCase.testMetrics failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-26532: --- Assignee: Jing Ge > SinkMetricsITCase.testMetrics failed on azure >

[GitHub] [flink] akalash commented on pull request #19002: [FLINK-26501] extra log

akalash commented on pull request #19002: URL: https://github.com/apache/flink/pull/19002#issuecomment-1062729383 @flinkbot run azure -- 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

[jira] [Commented] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503435#comment-17503435 ] Anton Kalashnikov commented on FLINK-25819: --- [~dwysakowicz] , yes, sure. PR -

[jira] [Updated] (FLINK-25481) SourceIndex comparison in SplitEnumeratorContextProxy

[ https://issues.apache.org/jira/browse/FLINK-25481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25481: Component/s: API / Core > SourceIndex comparison in SplitEnumeratorContextProxy >

[jira] [Commented] (FLINK-25481) SourceIndex comparison in SplitEnumeratorContextProxy

[ https://issues.apache.org/jira/browse/FLINK-25481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503434#comment-17503434 ] Yun Gao commented on FLINK-25481: - [~biyuhao] Thanks for the reporting! Do you want to open a PR for

<    2   3   4   5   6   7   8   >