[GitHub] [flink] flinkbot edited a comment on pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

flinkbot edited a comment on pull request #12147: URL: https://github.com/apache/flink/pull/12147#issuecomment-628530122 ## CI report: * 5339219ce34e998b7539eaace0a6535ae9b6bb3b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-17735][table] Add specialized collecting iterator to Blink planner

flinkbot edited a comment on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-626524463 ## CI report: * 424d752d1d5e49c752ccd79561ce5cfcd5ea7d1d UNKNOWN * ca26d6edd7772ee46d24b05c01952a10887eb3f7 Azure:

[GitHub] [flink] StephanEwen commented on pull request #12035: [FLINK-17569][FileSystemsems]support ViewFileSystem when wait lease revoke of hadoop filesystem

StephanEwen commented on pull request #12035: URL: https://github.com/apache/flink/pull/12035#issuecomment-629695726 Thank you for diagnosing this and suggesting this patch! The patch looks good. Any chance you could add a simple test that can verify this? Maybe extend the

[jira] [Commented] (FLINK-17569) to support ViewFileSystem when wait lease revoke of hadoop filesystem

[ https://issues.apache.org/jira/browse/FLINK-17569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109188#comment-17109188 ] Stephan Ewen commented on FLINK-17569: -- Good catch, and the suggested solution makes sense. +1 for

[GitHub] [flink] StephanEwen commented on a change in pull request #12041: [FLINK-17506][state-processor-api] SavepointEnvironment should honour 'io.tmp.dirs' property

StephanEwen commented on a change in pull request #12041: URL: https://github.com/apache/flink/pull/12041#discussion_r426183040 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/BootstrapTransformation.java ## @@ -36,13 +36,12

[GitHub] [flink] flinkbot edited a comment on pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

flinkbot edited a comment on pull request #12147: URL: https://github.com/apache/flink/pull/12147#issuecomment-628530122 ## CI report: * 5339219ce34e998b7539eaace0a6535ae9b6bb3b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-17735][table] Add specialized collecting iterator to Blink planner

flinkbot edited a comment on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-626524463 ## CI report: * 424d752d1d5e49c752ccd79561ce5cfcd5ea7d1d UNKNOWN * 7152ce26d8228590b5449280de54d95880bb1e5b Azure:

[GitHub] [flink] StephanEwen commented on pull request #12044: [FLINK-17582][quickstarts] Update quickstarts to use universal Kafka connector

StephanEwen commented on pull request #12044: URL: https://github.com/apache/flink/pull/12044#issuecomment-629694050 Good catch! Definitely +1 to this. Merging... This is an automated message from the Apache Git

[jira] [Commented] (FLINK-17762) Postgres Catalog should pass table's primary key to catalogTable

[ https://issues.apache.org/jira/browse/FLINK-17762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109181#comment-17109181 ] Flavio Pompermaier commented on FLINK-17762: Dies this depends on

[GitHub] [flink] StephanEwen commented on pull request #12064: [hotfix][javadocs]java doc error fix

StephanEwen commented on pull request #12064: URL: https://github.com/apache/flink/pull/12064#issuecomment-629693679 Thank you for fixing this! Merging the PR... This is an automated message from the Apache Git

[GitHub] [flink] StephanEwen commented on pull request #12066: [hotfix][runtime] Remove useless local variable in CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained

StephanEwen commented on pull request #12066: URL: https://github.com/apache/flink/pull/12066#issuecomment-629693420 Looks good, thank you for the patch! Merging this... This is an automated message from the Apache

[jira] [Created] (FLINK-17766) Use checkpoint lock instead of fine-grained locking in Kafka AbstractFetcher

Aljoscha Krettek created FLINK-17766: Summary: Use checkpoint lock instead of fine-grained locking in Kafka AbstractFetcher Key: FLINK-17766 URL: https://issues.apache.org/jira/browse/FLINK-17766

[GitHub] [flink] StephanEwen commented on pull request #12191: [hotfix][flink-core and docs] fix typos

StephanEwen commented on pull request #12191: URL: https://github.com/apache/flink/pull/12191#issuecomment-629692511 Looks good, thank you for fixing this! Merging... This is an automated message from the Apache Git

[GitHub] [flink] StephanEwen commented on pull request #12185: [FLINK-7267][connectors/rabbitmq] Allow overriding RMQ connection setup

StephanEwen commented on pull request #12185: URL: https://github.com/apache/flink/pull/12185#issuecomment-629692237 Thanks! The change looks good to me. Merging this... This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

flinkbot edited a comment on pull request #12147: URL: https://github.com/apache/flink/pull/12147#issuecomment-628530122 ## CI report: * 5339219ce34e998b7539eaace0a6535ae9b6bb3b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12176: [FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys

flinkbot edited a comment on pull request #12176: URL: https://github.com/apache/flink/pull/12176#issuecomment-629283127 ## CI report: * 057d8fa644c9a203a753fe184de8e204ea81918e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 80bbdd72c2aeb3c802deef71436882603590d147 UNKNOWN * fba63e0698c8c60a04efb10a8914ea548bacc653 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

flinkbot edited a comment on pull request #12168: URL: https://github.com/apache/flink/pull/12168#issuecomment-629179735 ## CI report: * 0824a047d1e106d1aa234c1659a98addb87012da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

flinkbot edited a comment on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628490262 ## CI report: * 3747e17ecf18448088dcb467d8bea240b00f12b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12190: [FLINK-17757] Implement format factory for Avro serialization and deseriazation schema of RowData type

flinkbot edited a comment on pull request #12190: URL: https://github.com/apache/flink/pull/12190#issuecomment-629650634 ## CI report: * ba32a1c937bd2452d5ac8018ae4742289d953813 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

flinkbot edited a comment on pull request #12108: URL: https://github.com/apache/flink/pull/12108#issuecomment-627804642 ## CI report: * 66bbeb2e19f810744287740e7a691da17ebb8b0c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-17735][table] Add specialized collecting iterator to Blink planner

flinkbot edited a comment on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-626524463 ## CI report: * 424d752d1d5e49c752ccd79561ce5cfcd5ea7d1d UNKNOWN * 7152ce26d8228590b5449280de54d95880bb1e5b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11854: [FLINK-17407] Introduce external resource framework

flinkbot edited a comment on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491 ## CI report: * bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN * dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN *

[GitHub] [flink] StephanEwen commented on pull request #12073: [FLINK-17735][table] Add specialized collecting iterator to Blink planner

StephanEwen commented on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-629691533 Is the description here correct? The classes do not seem to relate to the Blink planner, but are all in the `flink-streaming-java` module. I also don't understand how

[GitHub] [flink] flinkbot edited a comment on pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

flinkbot edited a comment on pull request #12184: URL: https://github.com/apache/flink/pull/12184#issuecomment-629425634 ## CI report: * 80bbdd72c2aeb3c802deef71436882603590d147 UNKNOWN * fba63e0698c8c60a04efb10a8914ea548bacc653 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

flinkbot edited a comment on pull request #12147: URL: https://github.com/apache/flink/pull/12147#issuecomment-628530122 ## CI report: * 5339219ce34e998b7539eaace0a6535ae9b6bb3b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

flinkbot edited a comment on pull request #12120: URL: https://github.com/apache/flink/pull/12120#issuecomment-628150581 ## CI report: * a60972a16e43987b8fda57c83171a4ca639492cf Azure:

[GitHub] [flink] aljoscha commented on a change in pull request #12057: [FLINK-16210][docs] Extending the "Flink Architecture" section.

aljoscha commented on a change in pull request #12057: URL: https://github.com/apache/flink/pull/12057#discussion_r426176348 ## File path: docs/concepts/flink-architecture.md ## @@ -129,4 +167,108 @@ two main benefits: +## Flink Application Execution + +A _Flink

[GitHub] [flink] dawidwys commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

dawidwys commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426176060 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

dawidwys commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426176060 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

flinkbot edited a comment on pull request #12120: URL: https://github.com/apache/flink/pull/12120#issuecomment-628150581 ## CI report: * a60972a16e43987b8fda57c83171a4ca639492cf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12171: [FLINK-17715][sql client] Supports function DDLs in SQL-CLI

flinkbot edited a comment on pull request #12171: URL: https://github.com/apache/flink/pull/12171#issuecomment-629218919 ## CI report: * 14bc25ea3f1f55ff6d6d67cbca3b02199a2bee31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12176: [FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys

flinkbot edited a comment on pull request #12176: URL: https://github.com/apache/flink/pull/12176#issuecomment-629283127 ## CI report: * d07c3a602f13eaf3ea441e11ece1bf671bfe5beb Azure:

[GitHub] [flink] fpompermaier commented on pull request #12090: [FLINK-17622][connectors / jdbc] Remove useless switch for decimal in PostgresCatalog

fpompermaier commented on pull request #12090: URL: https://github.com/apache/flink/pull/12090#issuecomment-629681822 Cone on guys...this is a really easy PR and it's open since 3 weeks..I don't want ro rebase again because of the other PR that is moving dbc dialects in dedicated classes

[GitHub] [flink] flinkbot edited a comment on pull request #12150: [FLINK-17026][kafka] Introduce a new Kafka connect or with new proper…

flinkbot edited a comment on pull request #12150: URL: https://github.com/apache/flink/pull/12150#issuecomment-628604536 ## CI report: * ebcb4954d7f87de2a9143299a26f4dc7d4308e1e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

flinkbot edited a comment on pull request #12147: URL: https://github.com/apache/flink/pull/12147#issuecomment-628530122 ## CI report: * 5339219ce34e998b7539eaace0a6535ae9b6bb3b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11109: [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner

flinkbot edited a comment on pull request #11109: URL: https://github.com/apache/flink/pull/11109#issuecomment-586932050 ## CI report: * ed2d32085cb24d4588ad5c834d41a1e65282c61d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12192: [FLINK-17758][runtime] Remove unused AdaptedRestartPipelinedRegionStrategyNG

flinkbot edited a comment on pull request #12192: URL: https://github.com/apache/flink/pull/12192#issuecomment-629673624 ## CI report: * 15ca64e3a20101239b30b90064f3b0f35238c828 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12193: [FLINK-17759][runtime] Remove unused RestartIndividualStrategy

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

[GitHub] [flink] dawidwys commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

dawidwys commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426164011 ## File path:

[GitHub] [flink] flinkbot commented on pull request #12193: [FLINK-17759][runtime] Remove unused RestartIndividualStrategy

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

[GitHub] [flink] flinkbot edited a comment on pull request #12176: [FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys

flinkbot edited a comment on pull request #12176: URL: https://github.com/apache/flink/pull/12176#issuecomment-629283127 ## CI report: * d07c3a602f13eaf3ea441e11ece1bf671bfe5beb Azure:

[GitHub] [flink] flinkbot commented on pull request #12192: [FLINK-17758][runtime] Remove unused AdaptedRestartPipelinedRegionStrategyNG

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

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-17735][table] Add specialized collecting iterator to Blink planner

flinkbot edited a comment on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-626524463 ## CI report: * 424d752d1d5e49c752ccd79561ce5cfcd5ea7d1d UNKNOWN * e85225100da7e5d3f06934fa331c1712a0ed4354 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11854: [FLINK-17407] Introduce external resource framework

flinkbot edited a comment on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491 ## CI report: * bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN * dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN *

[jira] [Resolved] (FLINK-17702) OperatorCoordinators must be notified of tasks cancelled as part of failover

[ https://issues.apache.org/jira/browse/FLINK-17702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17702. -- Resolution: Fixed Fixed in 1.11.0 via - (refactor) bfef3db4bd95d03b4d551d99cd10aedde1c326fc

[jira] [Closed] (FLINK-17702) OperatorCoordinators must be notified of tasks cancelled as part of failover

[ https://issues.apache.org/jira/browse/FLINK-17702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17702. > OperatorCoordinators must be notified of tasks cancelled as part of failover >

[jira] [Commented] (FLINK-17764) Update tips about the default planner when the planner parameter value is not recognized

[ https://issues.apache.org/jira/browse/FLINK-17764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109133#comment-17109133 ] xushiwei commented on FLINK-17764: -- Hi [~dianfu] , I created this issue and I want to contribute it.

[jira] [Closed] (FLINK-16357) Extend Checkpoint Coordinator to differentiate between "regional restore" and "full restore".

[ https://issues.apache.org/jira/browse/FLINK-16357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-16357. > Extend Checkpoint Coordinator to differentiate between "regional restore" and > "full restore". >

[jira] [Resolved] (FLINK-16357) Extend Checkpoint Coordinator to differentiate between "regional restore" and "full restore".

[ https://issues.apache.org/jira/browse/FLINK-16357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-16357. -- Resolution: Fixed Implemented in 1.11.0 via - 7ffa87b1f3c6089391d381d1a94cccf60860d0a3 -

[jira] [Resolved] (FLINK-17673) Add failure reason to OperatorCoordinator.failTask(...)

[ https://issues.apache.org/jira/browse/FLINK-17673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17673. -- Resolution: Fixed Fixed in 1.11.0 via - b3da4e18873dd6e31404c24ce877ff79c19c9300 (NOTE:

[jira] [Closed] (FLINK-17673) Add failure reason to OperatorCoordinator.failTask(...)

[ https://issues.apache.org/jira/browse/FLINK-17673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17673. > Add failure reason to OperatorCoordinator.failTask(...) >

[jira] [Closed] (FLINK-17672) OperatorCoordinators receive failure notifications on task failure instead of on task restarts

[ https://issues.apache.org/jira/browse/FLINK-17672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17672. > OperatorCoordinators receive failure notifications on task failure instead > of on task restarts

[jira] [Updated] (FLINK-17672) OperatorCoordinators receive failure notifications on task failure instead of on task restarts

[ https://issues.apache.org/jira/browse/FLINK-17672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-17672: - Summary: OperatorCoordinators receive failure notifications on task failure instead of on task

[jira] [Resolved] (FLINK-17672) OperatorCoordinators receive failure notifications on task failure instead of on task restarts

[ https://issues.apache.org/jira/browse/FLINK-17672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17672. -- Resolution: Fixed Fixed in 1.11.0 via - 2430dd8b8e38c284a69c71e9be6098e7db2d8ca4 >

[jira] [Resolved] (FLINK-16177) Integrate Operator Coordinators with Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-16177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-16177. -- Resolution: Fixed Fixed in 1.11.0 via - (feature part one)

[jira] [Closed] (FLINK-16177) Integrate Operator Coordinators with Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-16177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-16177. > Integrate Operator Coordinators with Checkpoints >

[jira] [Closed] (FLINK-17671) Simplify the ManuallyTriggeredScheduledExecutortriggering logic

[ https://issues.apache.org/jira/browse/FLINK-17671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17671. > Simplify the ManuallyTriggeredScheduledExecutortriggering logic >

[jira] [Resolved] (FLINK-17671) Simplify the ManuallyTriggeredScheduledExecutortriggering logic

[ https://issues.apache.org/jira/browse/FLINK-17671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17671. -- Resolution: Fixed Fixed in 1.11.0 via - 8ad1ba3b7cc9d80e7bcd09e140950bce971d7657 >

[jira] [Closed] (FLINK-17670) Savepoint handling of "non-restored" state should also take OperatorCoordinator state into account

[ https://issues.apache.org/jira/browse/FLINK-17670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17670. > Savepoint handling of "non-restored" state should also take > OperatorCoordinator state into

[jira] [Resolved] (FLINK-17670) Savepoint handling of "non-restored" state should also take OperatorCoordinator state into account

[ https://issues.apache.org/jira/browse/FLINK-17670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17670. -- Resolution: Fixed Fixed in 1.11.0 via (refactor) 90e4708c9a5ab24b5f50423a181d75be375e2d1e

[jira] [Closed] (FLINK-17674) OperatorCoordinator state in checkpoints should always be a ByteStreamStateHandle

[ https://issues.apache.org/jira/browse/FLINK-17674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17674. > OperatorCoordinator state in checkpoints should always be a > ByteStreamStateHandle >

[jira] [Resolved] (FLINK-17674) OperatorCoordinator state in checkpoints should always be a ByteStreamStateHandle

[ https://issues.apache.org/jira/browse/FLINK-17674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17674. -- Resolution: Fixed Fixes in 1.11.0 via - e3413106ccd030e44d5e4690430c841370a1f988 >

[GitHub] [flink] zentol commented on a change in pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

zentol commented on a change in pull request #12172: URL: https://github.com/apache/flink/pull/12172#discussion_r426168609 ## File path: flink-end-to-end-tests/test-scripts/common_docker.sh ## @@ -33,8 +33,25 @@ function containers_health_check() { done } -function

[GitHub] [flink] flinkbot commented on pull request #12193: [FLINK-17759][runtime] Remove unused RestartIndividualStrategy

flinkbot commented on pull request #12193: URL: https://github.com/apache/flink/pull/12193#issuecomment-629671260 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] asfgit closed pull request #12137: [FLINK-16177][FLINK-16357][checkpointing] Complete / improve checkpointing for OperatorCoordinators

asfgit closed pull request #12137: URL: https://github.com/apache/flink/pull/12137 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] zhuzhurk opened a new pull request #12193: [FLINK-17759][runtime] Remove unused RestartIndividualStrategy

zhuzhurk opened a new pull request #12193: URL: https://github.com/apache/flink/pull/12193 ## What is the purpose of the change RestartIndividualStrategy was used by the legacy scheduler and is not used anymore. Removing it can ease the work to further remove the legacy

[jira] [Updated] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17759: --- Labels: pull-request-available (was: ) > Remove RestartIndividualStrategy >

[GitHub] [flink] flinkbot commented on pull request #12192: [FLINK-17758][runtime] Remove unused AdaptedRestartPipelinedRegionStrategyNG

flinkbot commented on pull request #12192: URL: https://github.com/apache/flink/pull/12192#issuecomment-629670831 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-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17758: --- Labels: pull-request-available (was: ) > Remove AdaptedRestartPipelinedRegionStrategyNG >

[GitHub] [flink] zhuzhurk opened a new pull request #12192: [FLINK-17758][runtime] Remove unused AdaptedRestartPipelinedRegionStrategyNG

zhuzhurk opened a new pull request #12192: URL: https://github.com/apache/flink/pull/12192 ## What is the purpose of the change AdaptedRestartPipelinedRegionStrategyNG was used by the legacy scheduler and is not used anymore. Removing it can ease the work to further remove the

[GitHub] [flink] flinkbot edited a comment on pull request #12150: [FLINK-17026][kafka] Introduce a new Kafka connect or with new proper…

flinkbot edited a comment on pull request #12150: URL: https://github.com/apache/flink/pull/12150#issuecomment-628604536 ## CI report: * ba29e95dd5383933df8523acbdbaeb9fe6fe4b9e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

flinkbot edited a comment on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628490262 ## CI report: * dbdd467d3a700bdb64a57209e8ed1fe1c4c33887 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

flinkbot edited a comment on pull request #12147: URL: https://github.com/apache/flink/pull/12147#issuecomment-628530122 ## CI report: * 5339219ce34e998b7539eaace0a6535ae9b6bb3b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

flinkbot edited a comment on pull request #11920: URL: https://github.com/apache/flink/pull/11920#issuecomment-619909940 ## CI report: * a06b6bc5d3ff8d57e4610da4fe3ae1ec1f1d0b01 Azure:

[jira] [Assigned] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17758: --- Assignee: Zhu Zhu > Remove AdaptedRestartPipelinedRegionStrategyNG >

[jira] [Assigned] (FLINK-17759) Remove RestartIndividualStrategy

[ https://issues.apache.org/jira/browse/FLINK-17759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17759: --- Assignee: Zhu Zhu > Remove RestartIndividualStrategy > > >

[jira] [Issue Comment Deleted] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17075: -- Comment: was deleted (was: As a band aid I would suggest to add a small number of retries and

[jira] [Commented] (FLINK-17075) Add task status reconciliation between TM and JM

[ https://issues.apache.org/jira/browse/FLINK-17075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109116#comment-17109116 ] Till Rohrmann commented on FLINK-17075: --- As a band aid I would suggest to add a small number of

[jira] [Updated] (FLINK-17765) Verbose client error messages

[ https://issues.apache.org/jira/browse/FLINK-17765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17765: -- Component/s: Runtime / REST > Verbose client error messages > - >

[GitHub] [flink] wuchong commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

wuchong commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426167179 ## File path:

[jira] [Created] (FLINK-17765) Verbose client error messages

Till Rohrmann created FLINK-17765: - Summary: Verbose client error messages Key: FLINK-17765 URL: https://issues.apache.org/jira/browse/FLINK-17765 Project: Flink Issue Type: Bug

[GitHub] [flink] wuchong commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

wuchong commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426166966 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #12176: [FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys

wuchong commented on a change in pull request #12176: URL: https://github.com/apache/flink/pull/12176#discussion_r426165412 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java ## @@ -0,0 +1,169 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

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

[GitHub] [flink] flinkbot edited a comment on pull request #12090: [FLINK-17622][connectors / jdbc] Remove useless switch for decimal in PostgresCatalog

flinkbot edited a comment on pull request #12090: URL: https://github.com/apache/flink/pull/12090#issuecomment-626999634 ## CI report: * 571fa7b8465f82b73e1d1b78fb765fda4ec3a338 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12150: [FLINK-17026][kafka] Introduce a new Kafka connect or with new proper…

flinkbot edited a comment on pull request #12150: URL: https://github.com/apache/flink/pull/12150#issuecomment-628604536 ## CI report: * ba29e95dd5383933df8523acbdbaeb9fe6fe4b9e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

flinkbot edited a comment on pull request #12147: URL: https://github.com/apache/flink/pull/12147#issuecomment-628530122 ## CI report: * 5339219ce34e998b7539eaace0a6535ae9b6bb3b Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

dawidwys commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426165863 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

flinkbot edited a comment on pull request #11920: URL: https://github.com/apache/flink/pull/11920#issuecomment-619909940 ## CI report: * a06b6bc5d3ff8d57e4610da4fe3ae1ec1f1d0b01 Azure:

[GitHub] [flink] aljoscha commented on a change in pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

aljoscha commented on a change in pull request #12147: URL: https://github.com/apache/flink/pull/12147#discussion_r426165759 ## File path: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java ##

[GitHub] [flink] tillrohrmann commented on a change in pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

tillrohrmann commented on a change in pull request #11920: URL: https://github.com/apache/flink/pull/11920#discussion_r426163109 ## File path: flink-external-resources/flink-external-resource-gpu/src/main/java/org/apache/flink/externalresource/gpu/GPUDriver.java ## @@ -0,0

[GitHub] [flink] dawidwys commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

dawidwys commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426165174 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

dawidwys commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426165174 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

dawidwys commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426165174 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #12191: [hotfix][flink-core and docs] fix typos

flinkbot edited a comment on pull request #12191: URL: https://github.com/apache/flink/pull/12191#issuecomment-629660388 ## CI report: * a6f640ba12da96bedc6880dbf365d7599716008c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

flinkbot edited a comment on pull request #12108: URL: https://github.com/apache/flink/pull/12108#issuecomment-627804642 ## CI report: * 66bbeb2e19f810744287740e7a691da17ebb8b0c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12176: [FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys

flinkbot edited a comment on pull request #12176: URL: https://github.com/apache/flink/pull/12176#issuecomment-629283127 ## CI report: * 499722944af576d13757da75f4ad0d08c4538782 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11854: [FLINK-17407] Introduce external resource framework

flinkbot edited a comment on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491 ## CI report: * bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN * dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-17735][table] Add specialized collecting iterator to Blink planner

flinkbot edited a comment on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-626524463 ## CI report: * 424d752d1d5e49c752ccd79561ce5cfcd5ea7d1d UNKNOWN * e85225100da7e5d3f06934fa331c1712a0ed4354 Azure:

<    1   2   3   4   5   6   >