[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4dcee9f07135401160aae3f0d01bd480630f808f UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16810: [FLINK-23616][python] Support to chain the Python DataStream operators when mixing use of Python Table API and Python DataStream API

flinkbot edited a comment on pull request #16810: URL: https://github.com/apache/flink/pull/16810#issuecomment-898363303 ## CI report: * e1ce9d1e03b7aca66e11b217edec08d2de016bfd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16804: [FLINK-23616][python] Support to chain the Python DataStream operators in execute_and_collect

flinkbot edited a comment on pull request #16804: URL: https://github.com/apache/flink/pull/16804#issuecomment-898244461 ## CI report: * ce21982ab45c8299d2ea5e27b62df9cc1e31b286 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

flinkbot edited a comment on pull request #16687: URL: https://github.com/apache/flink/pull/16687#issuecomment-891705871 ## CI report: * 432987975bed85b5e6524adf38226e32baae4701 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4dcee9f07135401160aae3f0d01bd480630f808f UNKNOWN *

[jira] [Updated] (FLINK-21915) Optimize Execution#finishPartitionsAndUpdateConsumers

[ https://issues.apache.org/jira/browse/FLINK-21915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21915: - Labels: pull-request-available (was: auto-unassigned pull-request-available) > Optimize

[jira] [Updated] (FLINK-22767) Optimize the initialization of LocalInputPreferredSlotSharingStrategy

[ https://issues.apache.org/jira/browse/FLINK-22767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-22767: - Fix Version/s: 1.14.0 Description: Based on the scheduler benchmark introduced in

[GitHub] [flink] Thesharing commented on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

Thesharing commented on pull request #16687: URL: https://github.com/apache/flink/pull/16687#issuecomment-898995620 Thank you for your review! It helped me a lot. The commits have been squashed. Waiting for the CI to give green. -- This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4dcee9f07135401160aae3f0d01bd480630f808f UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4dcee9f07135401160aae3f0d01bd480630f808f UNKNOWN *

[jira] [Updated] (FLINK-23725) HadoopFsCommitter, file rename failure

[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd updated FLINK-23725: - Summary: HadoopFsCommitter, file rename failure (was: HadoopFsCommitter， file rename failure) >

[jira] [Updated] (FLINK-23725) HadoopFsCommitter， file rename failure

[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd updated FLINK-23725: - Summary: HadoopFsCommitter， file rename failure (was: HadoopFsCommitter， Prompt for file rename failure) >

[jira] [Updated] (FLINK-23725) HadoopFsCommitter， Prompt for file rename failure

[ https://issues.apache.org/jira/browse/FLINK-23725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] todd updated FLINK-23725: - Component/s: FileSystems > HadoopFsCommitter， Prompt for file rename failure >

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4dcee9f07135401160aae3f0d01bd480630f808f UNKNOWN *

[jira] [Updated] (FLINK-23711) Add an asynchronous HTTP transport for the RequestReply function

[ https://issues.apache.org/jira/browse/FLINK-23711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-23711: Issue Type: New Feature (was: Improvement) > Add an asynchronous HTTP transport

[jira] [Closed] (FLINK-23711) Add an asynchronous HTTP transport for the RequestReply function

[ https://issues.apache.org/jira/browse/FLINK-23711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-23711. --- Fix Version/s: statefun-3.1.0 Resolution: Fixed flink-statefun/master:

[GitHub] [flink-statefun] tzulitai closed pull request #252: [FLINK-23711] Add an asynchronous HTTP transport

tzulitai closed pull request #252: URL: https://github.com/apache/flink-statefun/pull/252 -- 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 edited a comment on pull request #16830: [hotfix][kinesis][docs] Configuring access

flinkbot edited a comment on pull request #16830: URL: https://github.com/apache/flink/pull/16830#issuecomment-898971040 ## CI report: * 548308c25b64aeec9808e8deb92943cce4f237e6 Azure:

[GitHub] [flink-statefun] tzulitai commented on pull request #252: [FLINK-23711] Add an asynchronous HTTP transport

tzulitai commented on pull request #252: URL: https://github.com/apache/flink-statefun/pull/252#issuecomment-898981024 Thanks a lot for this exciting new feature @igalshilman! I've been testing this with AWS Lambda, and it works like a charm. Given that Java smoke E2E is also using

[GitHub] [flink] flinkbot edited a comment on pull request #16830: [hotfix][kinesis][docs] Configuring access

flinkbot edited a comment on pull request #16830: URL: https://github.com/apache/flink/pull/16830#issuecomment-898971040 ## CI report: * 548308c25b64aeec9808e8deb92943cce4f237e6 Azure:

[GitHub] [flink] flinkbot commented on pull request #16830: [hotfix][kinesis][docs] Configuring access

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

[GitHub] [flink] flinkbot commented on pull request #16830: [hotfix][kinesis][docs] Configuring access

flinkbot commented on pull request #16830: URL: https://github.com/apache/flink/pull/16830#issuecomment-898969481 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] mans2singh opened a new pull request #16830: [hotfix][kinesis][docs] Configuring access

mans2singh opened a new pull request #16830: URL: https://github.com/apache/flink/pull/16830 ## What is the purpose of the change * Update to configuring access section ## Brief change log * Update to configuring access section ## Verifying this change

[jira] [Updated] (FLINK-21769) Encapsulate component meta data

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

[jira] [Updated] (FLINK-9925) ClientTest.testSimpleRequests fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9925: -- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability)

[jira] [Created] (FLINK-23776) Performance regression on 14.08.2021 in FLIP-27

Piotr Nowojski created FLINK-23776: -- Summary: Performance regression on 14.08.2021 in FLIP-27 Key: FLINK-23776 URL: https://issues.apache.org/jira/browse/FLINK-23776 Project: Flink Issue

[jira] [Closed] (FLINK-23189) Count and fail the task when the disk is error on JobManager

[ https://issues.apache.org/jira/browse/FLINK-23189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23189. -- Fix Version/s: 1.14.0 Release Note: IOExceptions thrown during triggering checkpoints on

[GitHub] [flink] flinkbot edited a comment on pull request #16828: [FLINK-23686][connector/kafka] Increase counter "commitsSucceeded" per commit instead of per partition

flinkbot edited a comment on pull request #16828: URL: https://github.com/apache/flink/pull/16828#issuecomment-898883840 ## CI report: * 78a97920d5087a2b4d8a329f6ba5397600468819 Azure:

[GitHub] [flink] pnowojski merged pull request #16829: [FLINK-23189][checkpoint] Count and fail the task in case of IOExceptions in CheckpointCoordinator

pnowojski merged pull request #16829: URL: https://github.com/apache/flink/pull/16829 -- 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] [Resolved] (FLINK-23652) Implement FLIP-179: Expose Standardized Operator Metrics

[ https://issues.apache.org/jira/browse/FLINK-23652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23652. - Release Note: Connectors using unified Source and Sink interface expose certain standardized

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * f11f93a01d1d0e769d04eb0b66a34914526096cc UNKNOWN * 61cc9c310c02dea756bc02436d7fab4654caaa1a UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16828: [FLINK-23686][connector/kafka] Increase counter "commitsSucceeded" per commit instead of per partition

flinkbot edited a comment on pull request #16828: URL: https://github.com/apache/flink/pull/16828#issuecomment-898883840 ## CI report: * d19e2c494af0ede85778b1e3c503de0ee3eed90b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16780: [FLINK-13092][docs-zh] Translate "deployment/resource-providers/standalone/kubernetes.md" page into Chinese

flinkbot edited a comment on pull request #16780: URL: https://github.com/apache/flink/pull/16780#issuecomment-896705916 ## CI report: * bb43d8daea78de87fa0d1a504cee8141fe09cec8 UNKNOWN * 2257f46bfb896943279f8800eaea1e26200df721 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

flinkbot edited a comment on pull request #16687: URL: https://github.com/apache/flink/pull/16687#issuecomment-891705871 ## CI report: * 432987975bed85b5e6524adf38226e32baae4701 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16313: [FLINK-12403][doc-zh]Translate 'How to use logging' page into Chinese

flinkbot edited a comment on pull request #16313: URL: https://github.com/apache/flink/pull/16313#issuecomment-869876553 ## CI report: * 7cf74d29a15da9f95d2c6dc87b4aaf2d35f9d81e UNKNOWN * 3f82bd6a6ba451071b692e90b2369ef618d2df08 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16828: [FLINK-23686][connector/kafka] Increase counter "commitsSucceeded" per commit instead of per partition

flinkbot edited a comment on pull request #16828: URL: https://github.com/apache/flink/pull/16828#issuecomment-898883840 ## CI report: * d19e2c494af0ede85778b1e3c503de0ee3eed90b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16829: [FLINK-23189][checkpoint] Count and fail the task in case of IOExceptions in CheckpointCoordinator

flinkbot edited a comment on pull request #16829: URL: https://github.com/apache/flink/pull/16829#issuecomment-898892925 ## CI report: * c8b5cab0d0bd1206ef622170ec3cd5b5fa7c3fa9 Azure:

[GitHub] [flink] RocMarshal commented on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

RocMarshal commented on pull request #16723: URL: https://github.com/apache/flink/pull/16723#issuecomment-898909346 Hi, @wuchong Could you help me to review this patch? Thank you very much. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot edited a comment on pull request #16817: [FLINK-23767][streaming] FLIP-180: Adjust StreamStatus and Idleness definition.

flinkbot edited a comment on pull request #16817: URL: https://github.com/apache/flink/pull/16817#issuecomment-898452176 ## CI report: * a928b42d37aea7e709503facf5d45717ab439947 UNKNOWN * 786da0bb5582146e87a74daf96540c9ce73af426 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16780: [FLINK-13092][docs-zh] Translate "deployment/resource-providers/standalone/kubernetes.md" page into Chinese

flinkbot edited a comment on pull request #16780: URL: https://github.com/apache/flink/pull/16780#issuecomment-896705916 ## CI report: * bb43d8daea78de87fa0d1a504cee8141fe09cec8 UNKNOWN * 2257f46bfb896943279f8800eaea1e26200df721 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

flinkbot edited a comment on pull request #16723: URL: https://github.com/apache/flink/pull/16723#issuecomment-893364145 ## CI report: * 937fccd9a39524af05bd570c3ee53986016823b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16313: [FLINK-12403][doc-zh]Translate 'How to use logging' page into Chinese

flinkbot edited a comment on pull request #16313: URL: https://github.com/apache/flink/pull/16313#issuecomment-869876553 ## CI report: * 7cf74d29a15da9f95d2c6dc87b4aaf2d35f9d81e UNKNOWN * 3f82bd6a6ba451071b692e90b2369ef618d2df08 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16828: [FLINK-23686][connector/kafka] Increase counter "commitsSucceeded" per commit instead of per partition

flinkbot edited a comment on pull request #16828: URL: https://github.com/apache/flink/pull/16828#issuecomment-898883840 ## CI report: * d19e2c494af0ede85778b1e3c503de0ee3eed90b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16821: [FLINK-23358][core] Refactor CoreOptions parent first patterns to List options

flinkbot edited a comment on pull request #16821: URL: https://github.com/apache/flink/pull/16821#issuecomment-898859870 ## CI report: * 0d243d7d843ca55c80d85ab48f12236203d86113 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16827: [FLINK-23771][runtime][checkpoint] Fix the issue of getAllReceivedFuture if all channels are finished

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

[GitHub] [flink] flinkbot edited a comment on pull request #16780: [FLINK-13092][docs-zh] Translate "deployment/resource-providers/standalone/kubernetes.md" page into Chinese

flinkbot edited a comment on pull request #16780: URL: https://github.com/apache/flink/pull/16780#issuecomment-896705916 ## CI report: * bb43d8daea78de87fa0d1a504cee8141fe09cec8 UNKNOWN * 2257f46bfb896943279f8800eaea1e26200df721 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16313: [FLINK-12403][doc-zh]Translate 'How to use logging' page into Chinese

flinkbot edited a comment on pull request #16313: URL: https://github.com/apache/flink/pull/16313#issuecomment-869876553 ## CI report: * 7cf74d29a15da9f95d2c6dc87b4aaf2d35f9d81e UNKNOWN * 3f82bd6a6ba451071b692e90b2369ef618d2df08 UNKNOWN *

[GitHub] [flink] AHeise merged pull request #16770: [FLINK-23652][datastream] FLIP-179: Add common connector metrics

AHeise merged pull request #16770: URL: https://github.com/apache/flink/pull/16770 -- 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] hapihu commented on a change in pull request #16780: [FLINK-13092][docs-zh] Translate "deployment/resource-providers/standalone/kubernetes.md" page into Chinese

hapihu commented on a change in pull request #16780: URL: https://github.com/apache/flink/pull/16780#discussion_r688937699 ## File path: docs/content.zh/docs/deployment/resource-providers/standalone/kubernetes.md ## @@ -25,61 +25,59 @@ specific language governing permissions

[GitHub] [flink] flinkbot edited a comment on pull request #16770: [FLINK-23652][datastream] FLIP-179: Add common connector metrics

flinkbot edited a comment on pull request #16770: URL: https://github.com/apache/flink/pull/16770#issuecomment-896050027 ## CI report: * ce61eedf5930a24fff2feeb5881c910253b8de3b UNKNOWN * 1924e887787a072b5db1c759424fdd9552885660 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * f11f93a01d1d0e769d04eb0b66a34914526096cc UNKNOWN * e3d4e303be22e2ba4e01249b7c2cd3ab5105e330 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

rkhachatryan commented on a change in pull request #16773: URL: https://github.com/apache/flink/pull/16773#discussion_r688935790 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/event/TestEventQueueImpl.java ## @@ -0,0 +1,79 @@ +/* + *

[GitHub] [flink] rkhachatryan commented on a change in pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

rkhachatryan commented on a change in pull request #16773: URL: https://github.com/apache/flink/pull/16773#discussion_r688935539 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/testutils/CommonTestUtils.java ## @@ -182,8 +182,10 @@ public static void

[GitHub] [flink] flinkbot edited a comment on pull request #16823: [hotfix][docs]improve PushGatewayReporter config:deleteOnShutdown de…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * f11f93a01d1d0e769d04eb0b66a34914526096cc UNKNOWN * e3d4e303be22e2ba4e01249b7c2cd3ab5105e330 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

flinkbot edited a comment on pull request #16687: URL: https://github.com/apache/flink/pull/16687#issuecomment-891705871 ## CI report: * be63c96684e4e874f288db5bdb4ee17e78419940 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

rkhachatryan commented on a change in pull request #16773: URL: https://github.com/apache/flink/pull/16773#discussion_r688934442 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/PartiallyFinishedSourcesITCase.java ## @@ -0,0 +1,100 @@ +/* +

[GitHub] [flink] rkhachatryan commented on a change in pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

rkhachatryan commented on a change in pull request #16773: URL: https://github.com/apache/flink/pull/16773#discussion_r688934442 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/PartiallyFinishedSourcesITCase.java ## @@ -0,0 +1,100 @@ +/* +

[GitHub] [flink] rkhachatryan commented on a change in pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

rkhachatryan commented on a change in pull request #16773: URL: https://github.com/apache/flink/pull/16773#discussion_r688933981 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/command/TestCommandQueue.java ## @@ -0,0 +1,52 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #16829: [FLINK-23189][checkpoint] Count and fail the task in case of IOExceptions in CheckpointCoordinator

flinkbot edited a comment on pull request #16829: URL: https://github.com/apache/flink/pull/16829#issuecomment-898892925 ## CI report: * c8b5cab0d0bd1206ef622170ec3cd5b5fa7c3fa9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16826: [hotfix][docs] Fix typo in datastream api

flinkbot edited a comment on pull request #16826: URL: https://github.com/apache/flink/pull/16826#issuecomment-898881601 ## CI report: * dab9f25a06f6db42dfcaa4fc23c24cf9aa34e4c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16825: [FLINK-23770][runtime][checkpoint] Retrieve the state with both uidHash and generated ID on checking finished state consistency

flinkbot edited a comment on pull request #16825: URL: https://github.com/apache/flink/pull/16825#issuecomment-898872020 ## CI report: * da755cb1681130e773f6b57fb925f85854d159d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

flinkbot edited a comment on pull request #16773: URL: https://github.com/apache/flink/pull/16773#issuecomment-896196766 ## CI report: * f11f93a01d1d0e769d04eb0b66a34914526096cc UNKNOWN * e3d4e303be22e2ba4e01249b7c2cd3ab5105e330 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

flinkbot edited a comment on pull request #16687: URL: https://github.com/apache/flink/pull/16687#issuecomment-891705871 ## CI report: * be63c96684e4e874f288db5bdb4ee17e78419940 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

rkhachatryan commented on a change in pull request #16773: URL: https://github.com/apache/flink/pull/16773#discussion_r688929533 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/event/TestEventQueue.java ## @@ -0,0 +1,46 @@ +/* + * Licensed

[GitHub] [flink] rkhachatryan commented on a change in pull request #16773: [FLINK-21090][tests] Add IT case for stop-with-savepoint

rkhachatryan commented on a change in pull request #16773: URL: https://github.com/apache/flink/pull/16773#discussion_r688929533 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/event/TestEventQueue.java ## @@ -0,0 +1,46 @@ +/* + * Licensed

[GitHub] [flink] flinkbot commented on pull request #16829: [FLINK-23189][checkpoint] Count and fail the task in case of IOExceptions in CheckpointCoordinator

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

[GitHub] [flink] Thesharing commented on a change in pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

Thesharing commented on a change in pull request #16687: URL: https://github.com/apache/flink/pull/16687#discussion_r688926551 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -214,87 +260,116 @@

[GitHub] [flink] AHeise closed pull request #16433: FLIP-180: Adjust StreamStatus and Idleness definition (POC)

AHeise closed pull request #16433: URL: https://github.com/apache/flink/pull/16433 -- 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] AHeise commented on pull request #16433: FLIP-180: Adjust StreamStatus and Idleness definition (POC)

AHeise commented on pull request #16433: URL: https://github.com/apache/flink/pull/16433#issuecomment-898890613 Closing POC (attached to FLIP) and continuing on #16817. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot edited a comment on pull request #16821: [FLINK-23358][core] Refactor CoreOptions parent first patterns to List options

flinkbot edited a comment on pull request #16821: URL: https://github.com/apache/flink/pull/16821#issuecomment-898859870 ## CI report: * 0d243d7d843ca55c80d85ab48f12236203d86113 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16828: [FLINK-23686][connector/kafka] Increase counter "commitsSucceeded" per commit instead of per partition

flinkbot edited a comment on pull request #16828: URL: https://github.com/apache/flink/pull/16828#issuecomment-898883840 ## CI report: * d19e2c494af0ede85778b1e3c503de0ee3eed90b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16824: avoid multiple authentications

flinkbot edited a comment on pull request #16824: URL: https://github.com/apache/flink/pull/16824#issuecomment-898866000 ## CI report: * aefe5ca137f0aa03db0ef4a406aa1e68d9d64f4f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16817: [FLINK-23767][streaming] FLIP-180: Adjust StreamStatus and Idleness definition.

flinkbot edited a comment on pull request #16817: URL: https://github.com/apache/flink/pull/16817#issuecomment-898452176 ## CI report: * a928b42d37aea7e709503facf5d45717ab439947 UNKNOWN * 8bd74477e5d245ad8e2c480bcb85f9c040743406 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16776: [FLINK-16201][table] Support JSON_VALUE

flinkbot edited a comment on pull request #16776: URL: https://github.com/apache/flink/pull/16776#issuecomment-896566536 ## CI report: * 506f2e1401344e8dce63545bb6a793bcf45549b4 UNKNOWN * 876c61083b3a3bb9d42b0512a027f76d2c30a1ef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

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

[GitHub] [flink] flinkbot commented on pull request #16829: [FLINK-23189][checkpoint] Count and fail the task in case of IOExceptions in CheckpointCoordinator

flinkbot commented on pull request #16829: URL: https://github.com/apache/flink/pull/16829#issuecomment-898886743 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] pnowojski commented on pull request #16637: [FLINK-23189][checkpoint]Count and fail the task when the disk is error on JobManager

pnowojski commented on pull request #16637: URL: https://github.com/apache/flink/pull/16637#issuecomment-898886723 Superseded by https://github.com/apache/flink/pull/16829 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] pnowojski closed pull request #16637: [FLINK-23189][checkpoint]Count and fail the task when the disk is error on JobManager

pnowojski closed pull request #16637: URL: https://github.com/apache/flink/pull/16637 -- 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] pnowojski commented on a change in pull request #16637: [FLINK-23189][checkpoint]Count and fail the task when the disk is error on JobManager

pnowojski commented on a change in pull request #16637: URL: https://github.com/apache/flink/pull/16637#discussion_r688922304 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java ## @@ -626,6 +627,194 @@ public void

[GitHub] [flink] pnowojski opened a new pull request #16829: [FLINK-23189][checkpoint] Count and fail the task in case of IOExceptions in CheckpointCoordinator

pnowojski opened a new pull request #16829: URL: https://github.com/apache/flink/pull/16829 This PR supersedes https://github.com/apache/flink/pull/16637. It's adding a couple of fixes on top of the original one. ## What is the purpose of the change This pull request make

[GitHub] [flink] flinkbot edited a comment on pull request #16827: [FLINK-23771][runtime][checkpoint] Fix the issue of getAllReceivedFuture if all channels are finished

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

[GitHub] [flink] flinkbot commented on pull request #16828: [FLINK-23686][connector/kafka] Increase counter "commitsSucceeded" per commit instead of per partition

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

[GitHub] [flink] flinkbot edited a comment on pull request #16821: [FLINK-23358][core] Refactor CoreOptions parent first patterns to List options

flinkbot edited a comment on pull request #16821: URL: https://github.com/apache/flink/pull/16821#issuecomment-898859870 ## CI report: * 0d243d7d843ca55c80d85ab48f12236203d86113 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16817: [FLINK-23767][streaming] FLIP-180: Adjust StreamStatus and Idleness definition.

flinkbot edited a comment on pull request #16817: URL: https://github.com/apache/flink/pull/16817#issuecomment-898452176 ## CI report: * a928b42d37aea7e709503facf5d45717ab439947 UNKNOWN * 8bd74477e5d245ad8e2c480bcb85f9c040743406 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16826: [hotfix][docs] Fix typo in datastream api

flinkbot edited a comment on pull request #16826: URL: https://github.com/apache/flink/pull/16826#issuecomment-898881601 ## CI report: * dab9f25a06f6db42dfcaa4fc23c24cf9aa34e4c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16770: [FLINK-23652][datastream] FLIP-179: Add common connector metrics

flinkbot edited a comment on pull request #16770: URL: https://github.com/apache/flink/pull/16770#issuecomment-896050027 ## CI report: * ce61eedf5930a24fff2feeb5881c910253b8de3b UNKNOWN * 1924e887787a072b5db1c759424fdd9552885660 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

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

[jira] [Commented] (FLINK-23770) FLIP-147: Unable to recover after source fully finished

[ https://issues.apache.org/jira/browse/FLINK-23770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399163#comment-17399163 ] Yun Gao commented on FLINK-23770: - Sorry the current StateAssignmentOperation seems to have the same

[GitHub] [flink] horacehylee commented on pull request #16821: [FLINK-23358][core] Refactor CoreOptions parent first patterns to List options

horacehylee commented on pull request #16821: URL: https://github.com/apache/flink/pull/16821#issuecomment-898883515 @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] RocMarshal removed a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

RocMarshal removed a comment on pull request #16723: URL: https://github.com/apache/flink/pull/16723#issuecomment-898860085 @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

[GitHub] [flink] flinkbot commented on pull request #16826: [hotfix][docs] Fix typo in datastream api

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

[GitHub] [flink] flinkbot commented on pull request #16827: [FLINK-23771][runtime][checkpoint] Fix the issue of getAllReceivedFuture if all channels are finished

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

[GitHub] [flink] flinkbot edited a comment on pull request #16821: [FLINK-23358][core] Refactor CoreOptions parent first patterns to List options

flinkbot edited a comment on pull request #16821: URL: https://github.com/apache/flink/pull/16821#issuecomment-898859870 ## CI report: * 0d243d7d843ca55c80d85ab48f12236203d86113 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16822: [FLINK-23759][runtime][checkpoint] Ignore the restored checkpoints when reporting latest completed id with abortion message

flinkbot edited a comment on pull request #16822: URL: https://github.com/apache/flink/pull/16822#issuecomment-898859883 ## CI report: * 3049e0b3134673e9245bd5d27e9dbeb8a641baf0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16817: [FLINK-23767][streaming] FLIP-180: Adjust StreamStatus and Idleness definition.

flinkbot edited a comment on pull request #16817: URL: https://github.com/apache/flink/pull/16817#issuecomment-898452176 ## CI report: * a928b42d37aea7e709503facf5d45717ab439947 UNKNOWN * 8bd74477e5d245ad8e2c480bcb85f9c040743406 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16784: [FLINK-23430][runtime][checkpoint] Allows taking snapshots for operator coordinators which all corresponding tasks finished

flinkbot edited a comment on pull request #16784: URL: https://github.com/apache/flink/pull/16784#issuecomment-896788454 ## CI report: * 04900c4ecb5bbe923198c7985dd07c0ae7832f40 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16770: [FLINK-23652][datastream] FLIP-179: Add common connector metrics

flinkbot edited a comment on pull request #16770: URL: https://github.com/apache/flink/pull/16770#issuecomment-896050027 ## CI report: * ce61eedf5930a24fff2feeb5881c910253b8de3b UNKNOWN * 1924e887787a072b5db1c759424fdd9552885660 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16745: [FLINK-22246]when use HiveCatalog create table , can't set Table owne…

flinkbot edited a comment on pull request #16745: URL: https://github.com/apache/flink/pull/16745#issuecomment-894632163 ## CI report: * ec30ee61c2adc94b71eede27342a6e4a42a23e56 Azure:

[jira] [Commented] (FLINK-23770) FLIP-147: Unable to recover after source fully finished

[ https://issues.apache.org/jira/browse/FLINK-23770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17399160#comment-17399160 ] Yun Gao commented on FLINK-23770: - Hi [~pnowojski] the code is in

  1   2   >