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

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

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

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23944: - Labels: test-stability (was: stale-blocker test-stability) >

[jira] [Commented] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-24038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407743#comment-17407743 ] Xintong Song commented on FLINK-24038: -- Alright, I'll take a look into option 2). >

[jira] [Assigned] (FLINK-24038) DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

[ https://issues.apache.org/jira/browse/FLINK-24038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-24038: Assignee: Xintong Song > DispatcherResourceManagerComponent fails to deregister

[GitHub] [flink] lometheus commented on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

lometheus commented on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-909794153 > @lometheus , I left one more comment, you can check it and then you can squash your commits to one for the final review and test. Wonderful idea ,I just fixed it with

[GitHub] [flink] flinkbot edited a comment on pull request #17025: [FLINK-24029][docs] Update doc example sql field in release-1.13.2 to dept_id

flinkbot edited a comment on pull request #17025: URL: https://github.com/apache/flink/pull/17025#issuecomment-907189639 ## CI report: * 20abcd8ee08baa3acb52d606bf1db76df6e9769e Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #17079: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer produce +U's when possible

JingsongLi commented on a change in pull request #17079: URL: https://github.com/apache/flink/pull/17079#discussion_r699774076 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/sink/SinkUpsertMaterializer.java ## @@ -96,36

[jira] [Commented] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I

[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407735#comment-17407735 ] Kurt Young commented on FLINK-24054: You opinions also make sense in some cases. That's exactly what

[GitHub] [flink] Aitozi commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699753195 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework

[GitHub] [flink] Aitozi commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699742772 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework

[GitHub] [flink] Aitozi commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699738100 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/util/ZooKeeperUtilsTest.java ## @@ -44,4 +58,27 @@ private void

[GitHub] [flink] Aitozi commented on a change in pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

Aitozi commented on a change in pull request #17053: URL: https://github.com/apache/flink/pull/17053#discussion_r699737483 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java ## @@ -226,9 +230,21 @@ public static CuratorFramework

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

flinkbot edited a comment on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008 ## CI report: * 43d4529418e7acc1aeed1effd0d3bca44543671f Azure:

[jira] [Updated] (FLINK-22798) Exception handling of transactional producer

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #17086: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting watermarks after source operator finishes [1.14]

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

[GitHub] [flink] flinkbot edited a comment on pull request #17087: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably. [1.14]

flinkbot edited a comment on pull request #17087: URL: https://github.com/apache/flink/pull/17087#issuecomment-909652544 ## CI report: * e0fbadda95ef6479db09fb6f23771f7c9b903a81 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17088: [FLINK-23817][docs] Add metric description to Kafka source. [1.14]

flinkbot edited a comment on pull request #17088: URL: https://github.com/apache/flink/pull/17088#issuecomment-909652631 ## CI report: * 073a325e226137c54f582b6924d39fbe12455b68 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source.

flinkbot edited a comment on pull request #17067: URL: https://github.com/apache/flink/pull/17067#issuecomment-908989247 ## CI report: * 2a4d75712d460c5bf001b999680c5a3cf6523977 UNKNOWN * fd0ab7b0f100ead3f3ca2ada7da972db617c35d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * 87aad8cc4b5e044225bf2ebf173402b810e82146 Azure:

[GitHub] [flink] flinkbot commented on pull request #17088: [FLINK-23817][docs] Add metric description to Kafka source. [1.14]

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

[GitHub] [flink] flinkbot commented on pull request #17087: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably. [1.14]

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

[GitHub] [flink] flinkbot edited a comment on pull request #17079: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer produce +U's when possible

flinkbot edited a comment on pull request #17079: URL: https://github.com/apache/flink/pull/17079#issuecomment-909337010 ## CI report: * a413c4c1bd4ae9251c5f5f8085afb66d7ffe2da2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17083: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

flinkbot edited a comment on pull request #17083: URL: https://github.com/apache/flink/pull/17083#issuecomment-909410631 ## CI report: * b088b23bfc4e26d0bd0e456380232e3414f6a022 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17067: [FLINK-23817][docs] Add metric description to Kafka source.

flinkbot edited a comment on pull request #17067: URL: https://github.com/apache/flink/pull/17067#issuecomment-908989247 ## CI report: * 2a4d75712d460c5bf001b999680c5a3cf6523977 UNKNOWN * fd0ab7b0f100ead3f3ca2ada7da972db617c35d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * 87aad8cc4b5e044225bf2ebf173402b810e82146 Azure:

[GitHub] [flink] flinkbot commented on pull request #17088: [FLINK-23817][docs] Add metric description to Kafka source. [1.14]

flinkbot commented on pull request #17088: URL: https://github.com/apache/flink/pull/17088#issuecomment-909623503 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] flinkbot edited a comment on pull request #17082: [FLINK-24087][connectors/kafka] Avoid importing table API class in DataStream API package

flinkbot edited a comment on pull request #17082: URL: https://github.com/apache/flink/pull/17082#issuecomment-909390587 ## CI report: * 85f02e21c22ae8a5e1e1ad6c545da555ff9dac31 Azure:

[GitHub] [flink] AHeise opened a new pull request #17088: [FLINK-23817][docs] Add metric description to Kafka source. [1.14]

AHeise opened a new pull request #17088: URL: https://github.com/apache/flink/pull/17088 Unchanged backport of #17067. -- 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

[GitHub] [flink] flinkbot commented on pull request #17087: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably. [1.14]

flinkbot commented on pull request #17087: URL: https://github.com/apache/flink/pull/17087#issuecomment-909618353 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] AHeise opened a new pull request #17087: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably. [1.14]

AHeise opened a new pull request #17087: URL: https://github.com/apache/flink/pull/17087 Unchanged backport of #17019. -- 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

[jira] [Commented] (FLINK-23664) Write documentation for new KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407643#comment-17407643 ] Arvid Heise commented on FLINK-23664: - Merged into 1.14 as

[jira] [Resolved] (FLINK-23664) Write documentation for new KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23664. - Resolution: Fixed > Write documentation for new KafkaSink >

[GitHub] [flink] AHeise merged pull request #17080: [FLINK-23664][docs] Add docs for KafkaSink [1.14]

AHeise merged pull request #17080: URL: https://github.com/apache/flink/pull/17080 -- 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 #17080: [FLINK-23664][docs] Add docs for KafkaSink [1.14]

AHeise commented on pull request #17080: URL: https://github.com/apache/flink/pull/17080#issuecomment-909609159 Build is green without `docs_404_check` which was green on a rebased run... merging. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-23664) Write documentation for new KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407642#comment-17407642 ] Arvid Heise commented on FLINK-23664: - Merged into master as

[GitHub] [flink] AHeise merged pull request #17058: [FLINK-23664][docs] Add docs for KafkaSink

AHeise merged pull request #17058: URL: https://github.com/apache/flink/pull/17058 -- 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 #17080: [FLINK-23664][docs] Add docs for KafkaSink [1.14]

flinkbot edited a comment on pull request #17080: URL: https://github.com/apache/flink/pull/17080#issuecomment-909337168 ## CI report: * 69c40e4d0033af49b04e1f469a6d59461c23172a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17081: [FLINK-23797][tests] Wait for all task running before savepoint for a…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17056: [FLINK-23748][tests] Testing window TVF session window

flinkbot edited a comment on pull request #17056: URL: https://github.com/apache/flink/pull/17056#issuecomment-908449260 ## CI report: * cd52e6e9e4ea1cca1007f86c0364f331c86888b0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16989: [FLINK-23611][yarn-tests] Refactors yarn tests and enable hadoop logs

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

[GitHub] [flink] flinkbot edited a comment on pull request #17080: [FLINK-23664][docs] Add docs for KafkaSink [1.14]

flinkbot edited a comment on pull request #17080: URL: https://github.com/apache/flink/pull/17080#issuecomment-909337168 ## CI report: * 69c40e4d0033af49b04e1f469a6d59461c23172a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * 4ae73b536a677dc2fe47c75e74004bedab309a9b Azure:

[GitHub] [flink] brachi-wernick commented on pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

brachi-wernick commented on pull request #16598: URL: https://github.com/apache/flink/pull/16598#issuecomment-909556618 @Airblader I'm ready from my side, anything else that should be addressed? -- This is an automated message from the Apache Git Service. To respond to the message,

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

[ https://issues.apache.org/jira/browse/FLINK-23864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407618#comment-17407618 ] Joe Moser commented on FLINK-23864: --- Hi [~syhily], how are you progressing with this one? Let me know

[GitHub] [flink] flinkbot edited a comment on pull request #17078: [FLINK-23468][test] Do not hide original exception if SSL is not available

flinkbot edited a comment on pull request #17078: URL: https://github.com/apache/flink/pull/17078#issuecomment-909306199 ## CI report: * 2871b6333b15ffcf00a3a480b8408155668aba0a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17086: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting watermarks after source operator finishes [1.14]

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

[GitHub] [flink] flinkbot edited a comment on pull request #17077: [FLINK-24085][docs] Add first class subject for page `versioned table` and `Timezone`

flinkbot edited a comment on pull request #17077: URL: https://github.com/apache/flink/pull/17077#issuecomment-909283338 ## CI report: * 87fe6f2b508bb6923b16345e95204bade06af980 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * e83ed6ab33d450ff7532b84c13e1a3a942d98fd6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * 4fd88f7afc644ef965221cbef881e11577d719a6 Azure:

[jira] [Commented] (FLINK-16428) Fine-grained network buffer management for backpressure

[ https://issues.apache.org/jira/browse/FLINK-16428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407609#comment-17407609 ] Joe Moser commented on FLINK-16428: --- [~kevin.cyj], i think it might make sense to also add somewhere

[jira] [Created] (FLINK-24090) Document ability to ignore in-flight data on recovery

Joe Moser created FLINK-24090: - Summary: Document ability to ignore in-flight data on recovery Key: FLINK-24090 URL: https://issues.apache.org/jira/browse/FLINK-24090 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #17085: [FLINK-24081][table-blink-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestamp

flinkbot edited a comment on pull request #17085: URL: https://github.com/apache/flink/pull/17085#issuecomment-909410759 ## CI report: * 6ce983467e3a4ac8b339f48023141666e427dffd Azure:

[GitHub] [flink] flinkbot commented on pull request #17086: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting watermarks after source operator finishes [1.14]

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

[GitHub] [flink] flinkbot edited a comment on pull request #17080: [FLINK-23664][docs] Add docs for KafkaSink [1.14]

flinkbot edited a comment on pull request #17080: URL: https://github.com/apache/flink/pull/17080#issuecomment-909337168 ## CI report: * 69c40e4d0033af49b04e1f469a6d59461c23172a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17070: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

flinkbot edited a comment on pull request #17070: URL: https://github.com/apache/flink/pull/17070#issuecomment-909190301 ## CI report: * 3700dfa72cd72d384bf6d69376321fb7ef9eaab9 UNKNOWN * a9123b9a11b2ae139a778853daf9f1216ea5fdd5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17058: [FLINK-23664][docs] Add docs for KafkaSink

flinkbot edited a comment on pull request #17058: URL: https://github.com/apache/flink/pull/17058#issuecomment-908449514 ## CI report: * 20a38a862a7439523c7175477ee8ff32f3fefdf8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * ea83c14a8c3f8f974703a12e4d3248026abf3ded Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

flinkbot edited a comment on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008 ## CI report: * a951a23faf7d9a6691519f8294c7c19a35dd7dd4 Azure:

[jira] [Commented] (FLINK-13414) Add support for Scala 2.13

[ https://issues.apache.org/jira/browse/FLINK-13414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407579#comment-17407579 ] Martijn Visser commented on FLINK-13414: Thanks for that [~etspaceman].  I hope that with

[GitHub] [flink] AHeise commented on pull request #17080: [FLINK-23664][docs] Add docs for KafkaSink [1.14]

AHeise commented on pull request #17080: URL: https://github.com/apache/flink/pull/17080#issuecomment-909476426 @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 specific

[GitHub] [flink] flinkbot commented on pull request #17086: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting watermarks after source operator finishes [1.14]

flinkbot commented on pull request #17086: URL: https://github.com/apache/flink/pull/17086#issuecomment-909462747 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] AHeise opened a new pull request #17086: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting watermarks after source operator finishes [1.14]

AHeise opened a new pull request #17086: URL: https://github.com/apache/flink/pull/17086 Unchanged backport of #17050. -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17080: [FLINK-23664][docs] Add docs for KafkaSink [1.14]

flinkbot edited a comment on pull request #17080: URL: https://github.com/apache/flink/pull/17080#issuecomment-909337168 ## CI report: * 69c40e4d0033af49b04e1f469a6d59461c23172a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

flinkbot edited a comment on pull request #17019: URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059 ## CI report: * fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN * ea83c14a8c3f8f974703a12e4d3248026abf3ded Azure:

[jira] [Commented] (FLINK-23351) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails due to "too few watermarks emitted" on azure

[ https://issues.apache.org/jira/browse/FLINK-23351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407557#comment-17407557 ] Arvid Heise commented on FLINK-23351: - Merged into master as

[GitHub] [flink] AHeise merged pull request #17050: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting wa…

AHeise merged pull request #17050: URL: https://github.com/apache/flink/pull/17050 -- 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 #17080: [FLINK-23664][docs] Add docs for KafkaSink [1.14]

AHeise commented on pull request #17080: URL: https://github.com/apache/flink/pull/17080#issuecomment-909457039 @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 specific

[jira] [Resolved] (FLINK-23764) add RuntimeContext to SourceReaderContext

[ https://issues.apache.org/jira/browse/FLINK-23764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23764. - Resolution: Won't Fix > add RuntimeContext to SourceReaderContext >

[jira] [Commented] (FLINK-23764) add RuntimeContext to SourceReaderContext

[ https://issues.apache.org/jira/browse/FLINK-23764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407553#comment-17407553 ] Arvid Heise commented on FLINK-23764: - I'll close this for now because FLINK-24051 got merged. >

[jira] [Commented] (FLINK-23850) Test Kafka table connector with new runtime provider

[ https://issues.apache.org/jira/browse/FLINK-23850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407548#comment-17407548 ] Arvid Heise commented on FLINK-23850: - Please note FLINK-24051 which makes consumer group.id

[GitHub] [flink] flinkbot edited a comment on pull request #17085: [FLINK-24081][table-blink-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestamp

flinkbot edited a comment on pull request #17085: URL: https://github.com/apache/flink/pull/17085#issuecomment-909410759 ## CI report: * 6ce983467e3a4ac8b339f48023141666e427dffd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17083: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

flinkbot edited a comment on pull request #17083: URL: https://github.com/apache/flink/pull/17083#issuecomment-909410631 ## CI report: * b088b23bfc4e26d0bd0e456380232e3414f6a022 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17075: [FLINK-24035][network][refactor] Move the blocking allocation of one floating buffer logic from the constructor of LocalBufferPool to

flinkbot edited a comment on pull request #17075: URL: https://github.com/apache/flink/pull/17075#issuecomment-909241018 ## CI report: * ccdf9bfaaa9e6d6eefb728b07ccf69df8233e93a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17074: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

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

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * d94a61c3ef01cccddc649a674e7967e2f9048343 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16192: [FLINK-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate

flinkbot edited a comment on pull request #16192: URL: https://github.com/apache/flink/pull/16192#issuecomment-863860019 ## CI report: * 832a44171672a679bb17556b94afa3381d30157c Azure:

[GitHub] [flink] akalash commented on a change in pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

akalash commented on a change in pull request #17024: URL: https://github.com/apache/flink/pull/17024#discussion_r699524505 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -330,9 +330,12 @@

[jira] [Commented] (FLINK-24089) AzureBlobStorageFSFactoryTest and AzureDataLakeStoreGen2FSFactoryTest fail using mvn test

[ https://issues.apache.org/jira/browse/FLINK-24089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407532#comment-17407532 ] Nicolaus Weidner commented on FLINK-24089: -- Added the stacktrace. Too much of a hurry before,

[jira] [Updated] (FLINK-24089) AzureBlobStorageFSFactoryTest and AzureDataLakeStoreGen2FSFactoryTest fail using mvn test

[ https://issues.apache.org/jira/browse/FLINK-24089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolaus Weidner updated FLINK-24089: - Description: Tests in

[jira] [Updated] (FLINK-24089) AzureBlobStorageFSFactoryTest and AzureDataLakeStoreGen2FSFactoryTest fail using mvn test

[ https://issues.apache.org/jira/browse/FLINK-24089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicolaus Weidner updated FLINK-24089: - Description: Tests in

[GitHub] [flink] AHeise commented on a change in pull request #17019: [FLINK-23854][connectors/Kafka] Ensure lingering Kafka transactions are aborted reliably.

AHeise commented on a change in pull request #17019: URL: https://github.com/apache/flink/pull/17019#discussion_r699524495 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java ## @@ -406,8 +406,14 @@

[jira] [Comment Edited] (FLINK-23960) StreamTaskTimerTest.checkScheduledTimestamps fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407526#comment-17407526 ] Anton Kalashnikov edited comment on FLINK-23960 at 8/31/21, 5:01 PM: -

[jira] [Commented] (FLINK-23960) StreamTaskTimerTest.checkScheduledTimestamps fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407526#comment-17407526 ] Anton Kalashnikov commented on FLINK-23960: --- The cause of this problem is

[GitHub] [flink] flinkbot commented on pull request #17085: [FLINK-24081][table-blink-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

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

[GitHub] [flink] flinkbot commented on pull request #17083: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

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

[GitHub] [flink] flinkbot edited a comment on pull request #17082: [FLINK-24087][connectors/kafka] Avoid importing table API class in DataStream API package

flinkbot edited a comment on pull request #17082: URL: https://github.com/apache/flink/pull/17082#issuecomment-909390587 ## CI report: * 85f02e21c22ae8a5e1e1ad6c545da555ff9dac31 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

flinkbot edited a comment on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008 ## CI report: * 680f8172bea8a9b7396604e8f0c5dcaf4efff5f9 Azure:

[jira] [Commented] (FLINK-24089) AzureBlobStorageFSFactoryTest and AzureDataLakeStoreGen2FSFactoryTest fail using mvn test

[ https://issues.apache.org/jira/browse/FLINK-24089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407521#comment-17407521 ] Chesnay Schepler commented on FLINK-24089: -- Can you provide us with the actual error you are

[jira] [Created] (FLINK-24089) AzureBlobStorageFSFactoryTest and AzureDataLakeStoreGen2FSFactoryTest fail using mvn test

Nicolaus Weidner created FLINK-24089: Summary: AzureBlobStorageFSFactoryTest and AzureDataLakeStoreGen2FSFactoryTest fail using mvn test Key: FLINK-24089 URL: https://issues.apache.org/jira/browse/FLINK-24089

[GitHub] [flink] flinkbot commented on pull request #17085: [FLINK-24081][table-blink-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

flinkbot commented on pull request #17085: URL: https://github.com/apache/flink/pull/17085#issuecomment-909394495 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] leonardBang opened a new pull request #17085: [FLINK-24081][table-blink-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

leonardBang opened a new pull request #17085: URL: https://github.com/apache/flink/pull/17085 ## What is the purpose of the change * Fix `StreamExecOverAggregate` and `StreamExecTemporalSort` operators didn't support LocalZonedTimestampType ## Brief change log - Use

[GitHub] [flink] leonardBang closed pull request #17084: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

leonardBang closed pull request #17084: URL: https://github.com/apache/flink/pull/17084 -- 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] leonardBang opened a new pull request #17084: [FLINK-24081][table-planner] Fix StreamExecOverAggregate and StreamExecTemporalSort operator didn't support LocalZonedTimestampType

leonardBang opened a new pull request #17084: URL: https://github.com/apache/flink/pull/17084 ## What is the purpose of the change * Fix `StreamExecOverAggregate` and `StreamExecTemporalSort` operators didn't support LocalZonedTimestampType ## Brief change log - Use

[GitHub] [flink] flinkbot edited a comment on pull request #17081: [FLINK-23797][tests] Wait for all task running before savepoint for a…

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

[GitHub] [flink] flinkbot commented on pull request #17082: [FLINK-24087][connectors/kafka] Avoid importing table API class in DataStream API package

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

[GitHub] [flink] flinkbot edited a comment on pull request #17073: [FLINK-24058][coordination][tests] Harden TaskSlotTableImplTest#runDeactivateSlotTimeoutTest

flinkbot edited a comment on pull request #17073: URL: https://github.com/apache/flink/pull/17073#issuecomment-909190473 ## CI report: * 64652a612587229163e00d740031f8b303308c86 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17069: [FLINK-24051][connectors/kafka] Make groupId optional when constructi…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17050: [FLINK-23351][tests] Harden FileReadingWatermarkITCase by counting wa…

flinkbot edited a comment on pull request #17050: URL: https://github.com/apache/flink/pull/17050#issuecomment-908295316 ## CI report: * a4c9501964a166055517eeead5bdebe58cb466a8 UNKNOWN * e86a51603227ec45834b586ecb1c208308c50e43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17056: [FLINK-23748][tests] Testing window TVF session window

flinkbot edited a comment on pull request #17056: URL: https://github.com/apache/flink/pull/17056#issuecomment-908449260 ## CI report: * e23989b2d576ae4b4bbb560b38b0028d71331756 Azure:

<    1   2   3   4   5   6   7   8   >