[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: * 7e65da37a98808e08f40e145becbd27dd02ff0ca UNKNOWN * c64d39a819a775c96feb95e7dc2a908fa09b2c16 Azure:

[jira] [Commented] (FLINK-26554) Clean termination of FlinkDeployment

[ https://issues.apache.org/jira/browse/FLINK-26554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504957#comment-17504957 ] Gyula Fora commented on FLINK-26554: Based on the log you have sent the cluster was shut down before

[jira] [Closed] (FLINK-26571) Savepoint trigger/tracking improvements

[ https://issues.apache.org/jira/browse/FLINK-26571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26571. -- Resolution: Fixed merged: 33572a0052f6c046ac06f3fb7abea864cfb20c49 > Savepoint trigger/tracking

[GitHub] [flink] rkhachatryan commented on pull request #19051: [FLINK-26063][state/changelog] Compute keys of the removed PQ elements

rkhachatryan commented on pull request #19051: URL: https://github.com/apache/flink/pull/19051#issuecomment-1065190568 Test failures unrelated (Connection timed out when pulling dependencies). -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Closed] (FLINK-26574) Allow definining Operator configuration in Helm chart Values

[ https://issues.apache.org/jira/browse/FLINK-26574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26574. -- > Allow definining Operator configuration in Helm chart Values >

[jira] [Commented] (FLINK-26611) Generate documentation for OperatorConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-26611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504955#comment-17504955 ] Gyula Fora commented on FLINK-26611: This seems to be unnecesserily heavy, maybe it's better to

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 153f0d85a16e19beded6c6e4f1025189a4e61708 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19062: [FLINK-26592][state/changelog] Use mailbox in FsStateChangelogWriter instead of a lock

flinkbot edited a comment on pull request #19062: URL: https://github.com/apache/flink/pull/19062#issuecomment-1065178629 ## CI report: * bf5eb61e8156db51c58b7c65b2775403c0bf2d85 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18991: [FLINK-26279][runtime] Add mailbox delay and throughput metrics

flinkbot edited a comment on pull request #18991: URL: https://github.com/apache/flink/pull/18991#issuecomment-1060268498 ## CI report: * 195dd50ec12230bbc8c7a57e58b1dee43f16be33 Azure:

[GitHub] [flink] flinkbot commented on pull request #19062: [FLINK-26592][state/changelog] Use mailbox in FsStateChangelogWriter instead of a lock

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

[GitHub] [flink] flinkbot edited a comment on pull request #19061: [FLINK-26610] FileSink can not upgrade from 1.13 if the uid of the origin sink is not set

flinkbot edited a comment on pull request #19061: URL: https://github.com/apache/flink/pull/19061#issuecomment-1065059123 ## CI report: * 61fc095d87bd4344e71253d0d42891c3d1b983b2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 153f0d85a16e19beded6c6e4f1025189a4e61708 Azure:

[jira] [Resolved] (FLINK-26574) Allow definining Operator configuration in Helm chart Values

[ https://issues.apache.org/jira/browse/FLINK-26574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora resolved FLINK-26574. Resolution: Fixed merged: a027644a5cdda3f9dbcdd7643bd0bc933f7d2bcd > Allow definining Operator

[GitHub] [flink] rkhachatryan opened a new pull request #19062: [FLINK-26592][state/changelog] Use mailbox in FsStateChangelogWriter instead of a lock

rkhachatryan opened a new pull request #19062: URL: https://github.com/apache/flink/pull/19062 This is an alternative version of #19050 that solves the problem using `MailboxExecutor`. ## What is the purpose of the change ``` When a task thread tries to schedule an upload,

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 153f0d85a16e19beded6c6e4f1025189a4e61708 Azure:

[jira] [Created] (FLINK-26614) Upsert Kafka SQL Connector:Support startup mode of timestamp and specific offsets

Ning Ma created FLINK-26614: --- Summary: Upsert Kafka SQL Connector:Support startup mode of timestamp and specific offsets Key: FLINK-26614 URL: https://issues.apache.org/jira/browse/FLINK-26614 Project:

[jira] [Commented] (FLINK-26121) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504946#comment-17504946 ] Matthias Pohl commented on FLINK-26121: --- The connection loss can be observed in the

[jira] [Assigned] (FLINK-26611) Generate documentation for OperatorConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-26611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26611: -- Assignee: (was: Gyula Fora) > Generate documentation for OperatorConfigOptions >

[jira] [Assigned] (FLINK-26612) Create docs webpages like other Flink projects

[ https://issues.apache.org/jira/browse/FLINK-26612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26612: -- Assignee: Márton Balassi (was: Gyula Fora) > Create docs webpages like other Flink projects

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 153f0d85a16e19beded6c6e4f1025189a4e61708 Azure:

[GitHub] [flink] shizhengchao commented on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flink1.

shizhengchao commented on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1065158141 > Thanks for review. I'll fix it soon! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Comment Edited] (FLINK-26121) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504940#comment-17504940 ] Matthias Pohl edited comment on FLINK-26121 at 3/11/22, 2:20 PM: - I'm

[jira] [Comment Edited] (FLINK-26121) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504940#comment-17504940 ] Matthias Pohl edited comment on FLINK-26121 at 3/11/22, 2:20 PM: - I'm

[jira] [Closed] (FLINK-26596) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-26596. - Resolution: Duplicate >

[jira] [Reopened] (FLINK-26121) ZooKeeperLeaderRetrievalConnectionHandlingTest.testNewLeaderAfterReconnectTriggersListenerNotification failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reopened FLINK-26121: --- I'm reopening the issue because there was another build failure recently:

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 153f0d85a16e19beded6c6e4f1025189a4e61708 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19057: [FLINK-26589][connectors/kinesis][connectors/firehose] Updating KDS/K…

flinkbot edited a comment on pull request #19057: URL: https://github.com/apache/flink/pull/19057#issuecomment-1064980178 ## CI report: * 023b2355d96005f94c942628052e46898df0d637 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19060: [FLINK-26532][metrics][test] using the numRecordsSend counter to get the correct metric

flinkbot edited a comment on pull request #19060: URL: https://github.com/apache/flink/pull/19060#issuecomment-1065047082 ## CI report: * 870a443f569667a35b1f71c8228269d5563aed3c Azure:

[jira] [Assigned] (FLINK-26613) Stateful unified Sink V2 upgrades only work when operator uids are given

[ https://issues.apache.org/jira/browse/FLINK-26613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-26613: --- Assignee: Fabian Paul > Stateful unified Sink V2 upgrades only work when operator uids are

[jira] [Created] (FLINK-26613) Stateful unified Sink V2 upgrades only work when operator uids are given

Fabian Paul created FLINK-26613: --- Summary: Stateful unified Sink V2 upgrades only work when operator uids are given Key: FLINK-26613 URL: https://issues.apache.org/jira/browse/FLINK-26613 Project:

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504939#comment-17504939 ] Zichen Liu commented on FLINK-24229: Would you mind elaborating a little on why the changes

[jira] [Commented] (FLINK-26063) [Changelog] Incorrect key group logged for PQ.poll and remove

[ https://issues.apache.org/jira/browse/FLINK-26063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504937#comment-17504937 ] Roman Khachatryan commented on FLINK-26063: --- So far I've only been able to reproduce the issue

[jira] [Assigned] (FLINK-26611) Generate documentation for OperatorConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-26611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26611: -- Assignee: Gyula Fora > Generate documentation for OperatorConfigOptions >

[jira] [Assigned] (FLINK-26612) Create docs webpages like other Flink projects

[ https://issues.apache.org/jira/browse/FLINK-26612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26612: -- Assignee: Gyula Fora > Create docs webpages like other Flink projects >

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 6597e5cfd909d88d299a8f74ed5bd49e99e648fb Azure:

[GitHub] [flink] XComp commented on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

XComp commented on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1065147101 Force pushes included adding a missing space and renaming a test. Additionally, I rebased the branch -- This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-26605) JobManagerDeploymentStatus.READY does not correctly reflect the real Flink cluster status

[ https://issues.apache.org/jira/browse/FLINK-26605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504935#comment-17504935 ] Gyula Fora commented on FLINK-26605: I think this also raises the question whether once in a READY

[GitHub] [flink] XComp commented on a change in pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

XComp commented on a change in pull request #19047: URL: https://github.com/apache/flink/pull/19047#discussion_r824739740 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -428,6 +428,12 @@ private void

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19039: [FLINK-26582][table] Convert table modules assertions to AssertJ

slinkydeveloper commented on a change in pull request #19039: URL: https://github.com/apache/flink/pull/19039#discussion_r824739611 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/DataStreamJavaITCase.java ## @@

[GitHub] [flink] realdengziqi commented on pull request #18982: [FLINK-26334][datastream] Fix getWindowStartWithOffset in TimeWindow.java

realdengziqi commented on pull request #18982: URL: https://github.com/apache/flink/pull/18982#issuecomment-1065140341 @zjuwangg Thanks for the review, again! We checked the unit-test module, which located at `org.apache.flink.streaming.runtime.operators.windowing.TimeWindowTest`.

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 6597e5cfd909d88d299a8f74ed5bd49e99e648fb Azure:

[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: * 720a8dceb2ba69674b1361cbfcb46f027693008c 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: * 793d98ffc067bdb9db098e56ed282dd7d746660e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19059: [FLINK-25771][connectors][Cassandra][tests][flaky] Remove testRetrialAndDropTables and make drop tables atomic

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

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 6597e5cfd909d88d299a8f74ed5bd49e99e648fb 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: * 793d98ffc067bdb9db098e56ed282dd7d746660e Azure:

[GitHub] [flink] echauchot commented on a change in pull request #19059: [FLINK-25771][connectors][Cassandra][tests][flaky] Remove testRetrialAndDropTables and make drop tables atomic

echauchot commented on a change in pull request #19059: URL: https://github.com/apache/flink/pull/19059#discussion_r824724876 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 6597e5cfd909d88d299a8f74ed5bd49e99e648fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18982: [FLINK-26334][datastream] Fix getWindowStartWithOffset in TimeWindow.java

flinkbot edited a comment on pull request #18982: URL: https://github.com/apache/flink/pull/18982#issuecomment-1059437393 ## CI report: * dbb6ce5f77546baf2368fc2f23a30d956aa8b3a0 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: * 7e65da37a98808e08f40e145becbd27dd02ff0ca UNKNOWN * c64d39a819a775c96feb95e7dc2a908fa09b2c16 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: * bce43e7566a2f3a265ce04a86f03f64ee792 Azure:

[jira] [Comment Edited] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504922#comment-17504922 ] Yuri Gusev edited comment on FLINK-24229 at 3/11/22, 1:34 PM: -- Ok thank you

[jira] [Comment Edited] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504922#comment-17504922 ] Yuri Gusev edited comment on FLINK-24229 at 3/11/22, 1:34 PM: -- Ok thank you

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504922#comment-17504922 ] Yuri Gusev commented on FLINK-24229: Ok thank you [~martijnvisser] and [~CrynetLogistics] . There

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 6597e5cfd909d88d299a8f74ed5bd49e99e648fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19041: [FLINK-24538][runtime][tests] Fix race condition when offering information to leader event queue in TestingRetrievalBase

flinkbot edited a comment on pull request #19041: URL: https://github.com/apache/flink/pull/19041#issuecomment-1064048402 ## CI report: * 9991f4cf3b69c789aabac03193e0549a7bf8f32d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18982: [FLINK-26334][datastream] Fix getWindowStartWithOffset in TimeWindow.java

flinkbot edited a comment on pull request #18982: URL: https://github.com/apache/flink/pull/18982#issuecomment-1059437393 ## CI report: * dbb6ce5f77546baf2368fc2f23a30d956aa8b3a0 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: * 7e65da37a98808e08f40e145becbd27dd02ff0ca UNKNOWN * c64d39a819a775c96feb95e7dc2a908fa09b2c16 Azure:

[jira] [Commented] (FLINK-16956) Git fetch failed with exit code 128

[ https://issues.apache.org/jira/browse/FLINK-16956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504920#comment-17504920 ] Piotr Nowojski commented on FLINK-16956: Ok, thanks for the explanation. > Git fetch failed

[GitHub] [flink] pnowojski commented on a change in pull request #18991: [FLINK-26279][runtime] Add mailbox delay and throughput metrics

pnowojski commented on a change in pull request #18991: URL: https://github.com/apache/flink/pull/18991#discussion_r824689000 ## File path: docs/content.zh/docs/ops/metrics.md ## @@ -1443,6 +1443,11 @@ Note that the metrics are only available via reporters. The latency

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 6597e5cfd909d88d299a8f74ed5bd49e99e648fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19041: [FLINK-24538][runtime][tests] Fix race condition when offering information to leader event queue in TestingRetrievalBase

flinkbot edited a comment on pull request #19041: URL: https://github.com/apache/flink/pull/19041#issuecomment-1064048402 ## CI report: * 9991f4cf3b69c789aabac03193e0549a7bf8f32d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19040: [FLINK-26548][runtime] set the source parallelism correctly when using legacy file sources with AdaptiveBatcheScheduler

flinkbot edited a comment on pull request #19040: URL: https://github.com/apache/flink/pull/19040#issuecomment-1064026493 ## CI report: * 555dc6ab31ce27539cae8499161bd87ecee0b353 Azure:

[jira] [Created] (FLINK-26612) Create docs webpages like other Flink projects

Gyula Fora created FLINK-26612: -- Summary: Create docs webpages like other Flink projects Key: FLINK-26612 URL: https://issues.apache.org/jira/browse/FLINK-26612 Project: Flink Issue Type:

[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: * 7e65da37a98808e08f40e145becbd27dd02ff0ca UNKNOWN * c64d39a819a775c96feb95e7dc2a908fa09b2c16 Azure:

[jira] [Created] (FLINK-26611) Generate documentation for OperatorConfigOptions

Gyula Fora created FLINK-26611: -- Summary: Generate documentation for OperatorConfigOptions Key: FLINK-26611 URL: https://issues.apache.org/jira/browse/FLINK-26611 Project: Flink Issue Type:

[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=17504916#comment-17504916 ] Dawid Wysakowicz commented on FLINK-26274: -- I repeated the test on current master. It did work

[jira] [Closed] (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:all-tabpanel ] Dawid Wysakowicz closed FLINK-26274. Resolution: Done > Test local recovery works across TaskManager process restarts >

[GitHub] [flink] flinkbot edited a comment on pull request #19056: [FLINK-26028][Connector/pulsar] add sink documentation; change some source documentation

flinkbot edited a comment on pull request #19056: URL: https://github.com/apache/flink/pull/19056#issuecomment-1064910556 ## CI report: * dc7a98116e2eb27de5f4c5a385aa6f71d5b12b70 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 6597e5cfd909d88d299a8f74ed5bd49e99e648fb 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: * 7e65da37a98808e08f40e145becbd27dd02ff0ca UNKNOWN * c64d39a819a775c96feb95e7dc2a908fa09b2c16 Azure:

[GitHub] [flink] zentol commented on a change in pull request #19059: [FLINK-25771][connectors][Cassandra][tests][flaky] Remove testRetrialAndDropTables and make drop tables atomic

zentol commented on a change in pull request #19059: URL: https://github.com/apache/flink/pull/19059#discussion_r824696201 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #19058: [FLINK-26388][docs] Adds information about missed out artifacts in repeatable cleanup with a reference to the FLINK issue

flinkbot edited a comment on pull request #19058: URL: https://github.com/apache/flink/pull/19058#issuecomment-1065003076 ## CI report: * 2b98d684cfee71de772c4a893de3fdb44e52a3da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * 6597e5cfd909d88d299a8f74ed5bd49e99e648fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19035: [FLINK-26281][connectors/elasticsearch] setting default delivery guarantee to AT_LEAST_ONCE

flinkbot edited a comment on pull request #19035: URL: https://github.com/apache/flink/pull/19035#issuecomment-1063817920 ## CI report: * 10cb63b99fd9289856226edc362077c2b97a2438 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: * 7e65da37a98808e08f40e145becbd27dd02ff0ca UNKNOWN * c64d39a819a775c96feb95e7dc2a908fa09b2c16 Azure:

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504912#comment-17504912 ] Martijn Visser commented on FLINK-24229: Most of the committers are currently fixing bugs and

[GitHub] [flink] zentol commented on a change in pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

zentol commented on a change in pull request #19047: URL: https://github.com/apache/flink/pull/19047#discussion_r824693430 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -428,6 +428,12 @@ private void

[GitHub] [flink] maxCodeVector commented on a change in pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

maxCodeVector commented on a change in pull request #18854: URL: https://github.com/apache/flink/pull/18854#discussion_r824693213 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java ## @@ -130,15 +132,16 @@ public

[GitHub] [flink] zentol commented on a change in pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

zentol commented on a change in pull request #19047: URL: https://github.com/apache/flink/pull/19047#discussion_r824692532 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -428,6 +428,12 @@ private void

[GitHub] [flink] alpreu commented on pull request #19035: [FLINK-26281][connectors/elasticsearch] setting default delivery guarantee to AT_LEAST_ONCE

alpreu commented on pull request #19035: URL: https://github.com/apache/flink/pull/19035#issuecomment-1065090962 > Also I would like to clarify one thing now that at-least-once delivery is default it might happen that users run the pipeline without checkpointing and without buffer

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * dbef7fbb42fc3b4b7baff3132bd9749e10350b98 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19035: [FLINK-26281][connectors/elasticsearch] setting default delivery guarantee to AT_LEAST_ONCE

flinkbot edited a comment on pull request #19035: URL: https://github.com/apache/flink/pull/19035#issuecomment-1063817920 ## CI report: * 10cb63b99fd9289856226edc362077c2b97a2438 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: * 7e65da37a98808e08f40e145becbd27dd02ff0ca UNKNOWN * c64d39a819a775c96feb95e7dc2a908fa09b2c16 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #18991: [FLINK-26279][runtime] Add mailbox delay and throughput metrics

pnowojski commented on a change in pull request #18991: URL: https://github.com/apache/flink/pull/18991#discussion_r824687883 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.java ## @@ -175,6 +199,7 @@ public

[jira] [Commented] (FLINK-24229) [FLIP-171] DynamoDB implementation of Async Sink

[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504909#comment-17504909 ] Zichen Liu commented on FLINK-24229: Maybe [~arvid] ? > [FLIP-171] DynamoDB implementation of Async

[jira] [Assigned] (FLINK-26610) FileSink can not upgrade from 1.13 if the uid of the origin sink is not set.

[ https://issues.apache.org/jira/browse/FLINK-26610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul reassigned FLINK-26610: --- Assignee: Gen Luo > FileSink can not upgrade from 1.13 if the uid of the origin sink is

[GitHub] [flink] maxCodeVector commented on a change in pull request #18854: [FLINK-25648][Kubernetes] Avoid redundant to query Kubernetes deployment when creating task manager pods

maxCodeVector commented on a change in pull request #18854: URL: https://github.com/apache/flink/pull/18854#discussion_r824687133 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java ## @@ -130,15 +132,16 @@ public

[GitHub] [flink] MartijnVisser merged pull request #19055: [hotfix][table-planner] RawToBinaryCastRule can fail

MartijnVisser merged pull request #19055: URL: https://github.com/apache/flink/pull/19055 -- 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 #18991: [FLINK-26279][runtime] Add mailbox delay and throughput metrics

flinkbot edited a comment on pull request #18991: URL: https://github.com/apache/flink/pull/18991#issuecomment-1060268498 ## CI report: * 7a222b87cf1721247dbc1c432107514efb5613b1 Azure:

[GitHub] [flink] XComp commented on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

XComp commented on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1065084813 I added a test case to make the log message reproducible in a unit test. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[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: * 7e65da37a98808e08f40e145becbd27dd02ff0ca UNKNOWN * c64d39a819a775c96feb95e7dc2a908fa09b2c16 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19047: [FLINK-26583][runtime] Make the Flink cluster fail if the job ID is listed as globally-terminated and cleaned

flinkbot edited a comment on pull request #19047: URL: https://github.com/apache/flink/pull/19047#issuecomment-1064287012 ## CI report: * dbef7fbb42fc3b4b7baff3132bd9749e10350b98 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18991: [FLINK-26279][runtime] Add mailbox delay and throughput metrics

flinkbot edited a comment on pull request #18991: URL: https://github.com/apache/flink/pull/18991#issuecomment-1060268498 ## CI report: * 7a222b87cf1721247dbc1c432107514efb5613b1 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: * 7e65da37a98808e08f40e145becbd27dd02ff0ca UNKNOWN * c64d39a819a775c96feb95e7dc2a908fa09b2c16 Azure:

[jira] [Commented] (FLINK-16956) Git fetch failed with exit code 128

[ https://issues.apache.org/jira/browse/FLINK-16956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504908#comment-17504908 ] Chesnay Schepler commented on FLINK-16956: -- Note that the checkout already has a retry. > Git

[jira] [Commented] (FLINK-16956) Git fetch failed with exit code 128

[ https://issues.apache.org/jira/browse/FLINK-16956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504905#comment-17504905 ] Chesnay Schepler commented on FLINK-16956: -- No, because this error happens as part of the git

[jira] [Comment Edited] (FLINK-16956) Git fetch failed with exit code 128

[ https://issues.apache.org/jira/browse/FLINK-16956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504903#comment-17504903 ] Piotr Nowojski edited comment on FLINK-16956 at 3/11/22, 12:40 PM: ---

[jira] [Commented] (FLINK-16956) Git fetch failed with exit code 128

[ https://issues.apache.org/jira/browse/FLINK-16956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17504903#comment-17504903 ] Piotr Nowojski commented on FLINK-16956: [~chesnay] Couldn't we implement either a retry

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #307: [FLINK-26537][statefun] Allow disabling StatefulFunctionsConfigValida…

igalshilman commented on a change in pull request #307: URL: https://github.com/apache/flink-statefun/pull/307#discussion_r824676050 ## File path: statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsJob.java ## @@ -36,18

<    1   2   3   4   5   6   >