[GitHub] [flink] flinkbot edited a comment on pull request #16864: [FLINK-23556][tests] Make SQLClientSchemaRegistryITCase more stable

flinkbot edited a comment on pull request #16864: URL: https://github.com/apache/flink/pull/16864#issuecomment-900421523 ## CI report: * 8ab95712ad6ba7500517b9a1947b8321480df90e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

flinkbot commented on pull request #16865: URL: https://github.com/apache/flink/pull/16865#issuecomment-900450716 ## CI report: * 39b27723cdd77ec2b1c9d5d02f4e4d190fb06c32 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Created] (FLINK-23842) Add log messages for reader registrations and split requests.

Stephan Ewen created FLINK-23842: Summary: Add log messages for reader registrations and split requests. Key: FLINK-23842 URL: https://issues.apache.org/jira/browse/FLINK-23842 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #16849: [FLINK-23728][state-processor-api] State bootstrapping fails on new state backend factory stack

flinkbot edited a comment on pull request #16849: URL: https://github.com/apache/flink/pull/16849#issuecomment-899650193 ## CI report: * efcbbdd21997888ae1f79d925f28c832507f98a6 UNKNOWN * b3cb8bb33caba5e4d66d0daf74e7098470b102cd Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #16866: [FLINK-23841][doc]Modify incorrect English statements for page "execu…

flinkbot commented on pull request #16866: URL: https://github.com/apache/flink/pull/16866#issuecomment-900443458 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 pro

[GitHub] [flink] curcur edited a comment on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

curcur edited a comment on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900431151 Thanks @wsry for fixing up! But I have a small concern about this change. 1. It is necessary to recycle BufferBuilder in the BufferWritingResultPartition#close meth

[jira] [Commented] (FLINK-13636) Translate "Flink DataStream API Programming Guide" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400470#comment-17400470 ] wuguihu commented on FLINK-13636: - Hello, [~jark]  I have finished this ticket. Would yo

[jira] [Commented] (FLINK-23813) DeleteExecutor NPE

[ https://issues.apache.org/jira/browse/FLINK-23813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400471#comment-17400471 ] Roman Khachatryan commented on FLINK-23813: --- Sure [~xtsong].   [~Akihito Lia

[GitHub] [flink] curcur edited a comment on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

curcur edited a comment on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900431151 I have a concern about this change. 1. It is necessary to recycle BufferBuilder in the BufferWritingResultPartition#close method, but not sure why we add `closeBuff

[jira] [Commented] (FLINK-23841) [doc]Modify incorrect English statements for page 'execution_configuration'

[ https://issues.apache.org/jira/browse/FLINK-23841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400467#comment-17400467 ] wuguihu commented on FLINK-23841: - Hi,[~jark] Excuse me for taking up your time. I crea

[GitHub] [flink] curcur edited a comment on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

curcur edited a comment on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900431151 I have a concern about this change. 1. It is necessary to recycle BufferBuilder in the BufferWritingResultPartition#close method, but not sure why we add `closeBuff

[jira] [Updated] (FLINK-23841) [doc]Modify incorrect English statements for page 'execution_configuration'

[ https://issues.apache.org/jira/browse/FLINK-23841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23841: --- Labels: pull-request-available (was: ) > [doc]Modify incorrect English statements for page

[GitHub] [flink] hapihu opened a new pull request #16866: [FLINK-23841][doc]Modify incorrect English statements for page "execu…

hapihu opened a new pull request #16866: URL: https://github.com/apache/flink/pull/16866 https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/datastream/execution/execution_configuration/ docs/dev/datastream/execution/execution_configuration.md The English stat

[GitHub] [flink] curcur edited a comment on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

curcur edited a comment on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900431151 I have a concern about this change. 1. It is necessary to recycle BufferBuilder in the BufferWritingResultPartition#close method, but not sure why we add `closeBuff

[jira] [Commented] (FLINK-21926) Document Fine Grained Resource Management

[ https://issues.apache.org/jira/browse/FLINK-21926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400466#comment-17400466 ] Seth Wiesman commented on FLINK-21926: -- resolved in master: d2002c141f01082eae567a4

[jira] [Closed] (FLINK-21926) Document Fine Grained Resource Management

[ https://issues.apache.org/jira/browse/FLINK-21926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-21926. Resolution: Fixed > Document Fine Grained Resource Management > --

[GitHub] [flink] curcur edited a comment on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

curcur edited a comment on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900431151 I have a concern about this change. 1. It is necessary to recycle BufferBuilder in the BufferWritingResultPartition#close method, but not sure why we add have to `c

[GitHub] [flink] sjwiesman closed pull request #16561: [FLINK-21926][doc] Add docs for fine-grained resource management

sjwiesman closed pull request #16561: URL: https://github.com/apache/flink/pull/16561 -- 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: issues-unsub

[GitHub] [flink] curcur edited a comment on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

curcur edited a comment on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900431151 I have a concern about this change. 1. It is necessary to recycle BufferBuilder in the BufferWritingResultPartition#close method, but not sure why we add have to `c

[GitHub] [flink] curcur edited a comment on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

curcur edited a comment on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900431151 I have a concern about this change. 1. It is necessary to recycle BufferBuilder in the BufferWritingResultPartition#close method, but not sure why we add have to `c

[GitHub] [flink] curcur edited a comment on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

curcur edited a comment on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900431151 I have a concern about this change. 1. It is necessary to recycle BufferBuilder in the BufferWritingResultPartition#close method, but not sure why we add have to `c

[GitHub] [flink] curcur edited a comment on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

curcur edited a comment on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900431151 I have a concern about this change. Let's sync up offline. 1. It is necessary to recycle BufferBuilder in the BufferWritingResultPartition#close method, but not sure

[jira] [Commented] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400465#comment-17400465 ] Biao Geng commented on FLINK-23556: --- hi [~xtsong], thanks a lot for your support! I ha

[GitHub] [flink] curcur commented on pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

curcur commented on pull request #16844: URL: https://github.com/apache/flink/pull/16844#issuecomment-900431151 I have a concern about this change. Let's sync up offline. 1. It is necessary to recycle BufferBuilder in the BufferWritingResultPartition#close method, but not sure why we

[jira] [Closed] (FLINK-23330) Deprecate toAppendStream and toRetractStream

[ https://issues.apache.org/jira/browse/FLINK-23330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-23330. Release Note: The outdated variants of `StreamTableEnvironment.{fromDataStream|toAppendStream|toRe

[jira] [Created] (FLINK-23841) [doc]Modify incorrect English statements for page 'execution_configuration'

wuguihu created FLINK-23841: --- Summary: [doc]Modify incorrect English statements for page 'execution_configuration' Key: FLINK-23841 URL: https://issues.apache.org/jira/browse/FLINK-23841 Project: Flink

[GitHub] [flink] twalthr closed pull request #16855: [FLINK-23330][table-api-java-bridge] Deprecate old fromDataStream, toAppendStream, toRetractStream

twalthr closed pull request #16855: URL: https://github.com/apache/flink/pull/16855 -- 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: issues-unsubsc

[GitHub] [flink] flinkbot commented on pull request #16864: [FLINK-23556][tests] Schemaregistry it fix

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

[GitHub] [flink] flinkbot edited a comment on pull request #16860: [FLINK-22198][connector/kafka] Redirect KafkaContainer output to log4j and print debug log if test hangs

flinkbot edited a comment on pull request #16860: URL: https://github.com/apache/flink/pull/16860#issuecomment-900154319 ## CI report: * d6bfdd97c618e764305515917075f97a38ebcd32 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16863: [FLINK-23116][docs] Minor documentation fixes & improvements

flinkbot edited a comment on pull request #16863: URL: https://github.com/apache/flink/pull/16863#issuecomment-900273865 ## CI report: * a5bd3397a4604d860028a1a11650d2393c503c56 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16849: [FLINK-23728][state-processor-api] State bootstrapping fails on new state backend factory stack

flinkbot edited a comment on pull request #16849: URL: https://github.com/apache/flink/pull/16849#issuecomment-899650193 ## CI report: * efcbbdd21997888ae1f79d925f28c832507f98a6 UNKNOWN * b3cb8bb33caba5e4d66d0daf74e7098470b102cd Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] sjwiesman commented on a change in pull request #16849: [FLINK-23728][state-processor-api] Support new state backend factory stack in State Processor API

sjwiesman commented on a change in pull request #16849: URL: https://github.com/apache/flink/pull/16849#discussion_r690508152 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/BootstrapTransformation.java ## @@ -215,12 +217,23 @@

[jira] [Updated] (FLINK-23734) Migrate ComponentFactory to the new Factory stack

[ https://issues.apache.org/jira/browse/FLINK-23734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-23734: - Issue Type: Technical Debt (was: Improvement) > Migrate ComponentFactory to the new Factory sta

[GitHub] [flink] flinkbot commented on pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

flinkbot commented on pull request #16865: URL: https://github.com/apache/flink/pull/16865#issuecomment-900419116 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 pro

[jira] [Updated] (FLINK-23720) Migrate ModuleFactory to the new factory stack

[ https://issues.apache.org/jira/browse/FLINK-23720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-23720: - Issue Type: Technical Debt (was: Improvement) > Migrate ModuleFactory to the new factory stack

[jira] [Updated] (FLINK-23720) Migrate ModuleFactory to the new factory stack

[ https://issues.apache.org/jira/browse/FLINK-23720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-23720: - Issue Type: Improvement (was: Technical Debt) > Migrate ModuleFactory to the new factory stack

[jira] [Commented] (FLINK-23111) Update Angular to version 12

[ https://issues.apache.org/jira/browse/FLINK-23111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400461#comment-17400461 ] Timo Walther commented on FLINK-23111: -- Additional fix in 1.14.0: 12f853d7aedc6a3e

[jira] [Updated] (FLINK-23836) [doc-zh]Translate "/dev/datastream/execution/execution_configuration.md" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23836: --- Labels: pull-request-available (was: ) > [doc-zh]Translate "/dev/datastream/execution/execu

[GitHub] [flink] hapihu opened a new pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

hapihu opened a new pull request #16865: URL: https://github.com/apache/flink/pull/16865 Translate "/dev/datastream/execution/execution_configuration.md" into Chinese -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [flink] twalthr closed pull request #16854: [FLINK-23111][runtime-web] Fix missing table component's nzFrontPagin…

twalthr closed pull request #16854: URL: https://github.com/apache/flink/pull/16854 -- 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: issues-unsubsc

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690502228 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ## @@

[jira] [Closed] (FLINK-23734) Migrate ComponentFactory to the new Factory stack

[ https://issues.apache.org/jira/browse/FLINK-23734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-23734. Fix Version/s: 1.14.0 Resolution: Fixed Fixed in 1.14.0: commit 8d28e71572e56bc7ffb76f446e

[GitHub] [flink] flinkbot commented on pull request #16864: [FLINK-23556][tests] Schemaregistry it fix

flinkbot commented on pull request #16864: URL: https://github.com/apache/flink/pull/16864#issuecomment-900412401 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 pro

[GitHub] [flink] twalthr closed pull request #16788: [FLINK-23734][table] Migrate ComponentFactory to the new Factory stack

twalthr closed pull request #16788: URL: https://github.com/apache/flink/pull/16788 -- 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: issues-unsubsc

[jira] [Updated] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23556: --- Labels: pull-request-available stale-blocker test-stability (was: stale-blocker test-stabil

[GitHub] [flink] bgeng777 opened a new pull request #16864: [FLINK-23556] [tests] Schemaregistry it fix

bgeng777 opened a new pull request #16864: URL: https://github.com/apache/flink/pull/16864 ## What is the purpose of the change This PR aims at improving the pass rate of SQLClientSchemaRegistryITCase(an unstable e2e test case). ## Brief change log - Remov

[jira] [Commented] (FLINK-23797) SavepointITCase.testStopSavepointWithBoundedInput fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400458#comment-17400458 ] Till Rohrmann commented on FLINK-23797: --- I couldn't find a problem caused by my re

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690492786 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690491144 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690488773 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] flinkbot edited a comment on pull request #16861: [FLINK-23808][checkpoint] Bypass operators when advanceToEndOfEventTime for both legacy and new source tasks

flinkbot edited a comment on pull request #16861: URL: https://github.com/apache/flink/pull/16861#issuecomment-900179085 ## CI report: * 0ac54c32d4214c83cc2a6c39795b97c931575235 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16849: [FLINK-23728][state-processor-api] Support new state backend factory stack in State Processor API

flinkbot edited a comment on pull request #16849: URL: https://github.com/apache/flink/pull/16849#issuecomment-899650193 ## CI report: * efcbbdd21997888ae1f79d925f28c832507f98a6 UNKNOWN * b3cb8bb33caba5e4d66d0daf74e7098470b102cd Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690486505 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] flinkbot edited a comment on pull request #16842: [FLINK-23806][runtime] Avoid StackOverflowException when a large scale job failed to acquire enough slots in time

flinkbot edited a comment on pull request #16842: URL: https://github.com/apache/flink/pull/16842#issuecomment-899394864 ## CI report: * bd4e67d7d9ceef1a570de51c79d71fc577ef45bb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690486505 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[jira] [Updated] (FLINK-23840) Confusing message from MemCheckpointStreamFactory#checkSize

[ https://issues.apache.org/jira/browse/FLINK-23840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-23840: --- Parent: FLINK-23668 Issue Type: Sub-task (was: Technical Debt) > Confusing message

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690485132 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690484382 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchemaBuilder.java ###

[GitHub] [flink] AHeise commented on a change in pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise commented on a change in pull request #16783: URL: https://github.com/apache/flink/pull/16783#discussion_r690483562 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/sink/KafkaRecordSerializationSchema.java ##

[jira] [Created] (FLINK-23840) Confusing message from MemCheckpointStreamFactory#checkSize

David Anderson created FLINK-23840: -- Summary: Confusing message from MemCheckpointStreamFactory#checkSize Key: FLINK-23840 URL: https://issues.apache.org/jira/browse/FLINK-23840 Project: Flink

[jira] [Updated] (FLINK-23668) Check Log Pollution for 1.14 release

[ https://issues.apache.org/jira/browse/FLINK-23668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23668: -- Priority: Critical (was: Major) > Check Log Pollution for 1.14 release >

[jira] [Created] (FLINK-23839) Unclear severity of Kafka transaction recommit warning in logs

Nico Kruber created FLINK-23839: --- Summary: Unclear severity of Kafka transaction recommit warning in logs Key: FLINK-23839 URL: https://issues.apache.org/jira/browse/FLINK-23839 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #16849: [FLINK-23728][state-processor-api] Support new state backend factory stack in State Processor API

flinkbot edited a comment on pull request #16849: URL: https://github.com/apache/flink/pull/16849#issuecomment-899650193 ## CI report: * efcbbdd21997888ae1f79d925f28c832507f98a6 UNKNOWN * b3cb8bb33caba5e4d66d0daf74e7098470b102cd Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

flinkbot edited a comment on pull request #16783: URL: https://github.com/apache/flink/pull/16783#issuecomment-896788403 ## CI report: * 08907e8f8a63de1b8d239abfba08b81c6b3c3076 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * d79db15ab05c86dcd82fe88dc7247fd413f5c0bf UNKNOWN * bbae6a1d070ad629349bcab8579ce442e2d91d42 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] rkhachatryan commented on a change in pull request #16849: [FLINK-23728][state-processor-api] Support new state backend factory stack in State Processor API

rkhachatryan commented on a change in pull request #16849: URL: https://github.com/apache/flink/pull/16849#discussion_r690447886 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/BootstrapTransformation.java ## @@ -215,12 +217,23

[GitHub] [flink] rkhachatryan commented on a change in pull request #16849: [FLINK-23728][state-processor-api] Support new state backend factory stack in State Processor API

rkhachatryan commented on a change in pull request #16849: URL: https://github.com/apache/flink/pull/16849#discussion_r690447886 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/BootstrapTransformation.java ## @@ -215,12 +217,23

[GitHub] [flink] flinkbot edited a comment on pull request #16860: [FLINK-22198][connector/kafka] Redirect KafkaContainer output to log4j and print debug log if test hangs

flinkbot edited a comment on pull request #16860: URL: https://github.com/apache/flink/pull/16860#issuecomment-900154319 ## CI report: * b6b9a6c734c897d7a3704486fc74e5d31bae7e73 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #16859: [FLINK-23719] [connectors/hbase] Support switch WAL in Flink SQL DDL options for HBase sink

flinkbot edited a comment on pull request #16859: URL: https://github.com/apache/flink/pull/16859#issuecomment-900154234 ## CI report: * 8350ecf3387549adadc84d318de6a85a66d2a32b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16815: [FLINK-23705][connectors/kinesis] Unregistering metric reporting for closed shards

flinkbot edited a comment on pull request #16815: URL: https://github.com/apache/flink/pull/16815#issuecomment-898382012 ## CI report: * 194397942a2539e9bc507c57aa58e66270097e93 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

flinkbot edited a comment on pull request #16783: URL: https://github.com/apache/flink/pull/16783#issuecomment-896788403 ## CI report: * 08907e8f8a63de1b8d239abfba08b81c6b3c3076 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #16752: [FLINK-23462] [docs-zh] Translate the abfs documentation to chinese

flinkbot edited a comment on pull request #16752: URL: https://github.com/apache/flink/pull/16752#issuecomment-894811682 ## CI report: * 79c04bc2127a41944dde0a3983ceb65d3608c490 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * d79db15ab05c86dcd82fe88dc7247fd413f5c0bf UNKNOWN * bbae6a1d070ad629349bcab8579ce442e2d91d42 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-22211) DataStream.collect() logs warnings if job is not initialized yet

[ https://issues.apache.org/jira/browse/FLINK-22211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400414#comment-17400414 ] Stephan Ewen commented on FLINK-22211: -- Fixed in release-1.12 via b477fafe481da3dd6

[GitHub] [flink] flinkbot edited a comment on pull request #16857: [FLINK-23362][tests] Remove timeouts

flinkbot edited a comment on pull request #16857: URL: https://github.com/apache/flink/pull/16857#issuecomment-900113447 ## CI report: * 32c5155ff1000418975afe32fbc300308859c957 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16815: [FLINK-23705][connectors/kinesis] Unregistering metric reporting for closed shards

flinkbot edited a comment on pull request #16815: URL: https://github.com/apache/flink/pull/16815#issuecomment-898382012 ## CI report: * 194397942a2539e9bc507c57aa58e66270097e93 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

flinkbot edited a comment on pull request #16783: URL: https://github.com/apache/flink/pull/16783#issuecomment-896788403 ## CI report: * 08907e8f8a63de1b8d239abfba08b81c6b3c3076 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16788: [FLINK-23734][table] Migrate ComponentFactory to the new Factory stack

flinkbot edited a comment on pull request #16788: URL: https://github.com/apache/flink/pull/16788#issuecomment-897412587 ## CI report: * bba33f114b52d3e86ce059b36027642494c00cce UNKNOWN * f734792406c3ff469abeb8e939bcb66605c447d3 Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] akalash commented on a change in pull request #16844: [FLINK-23724][network] Fix the network buffer leak when ResultPartition is released

akalash commented on a change in pull request #16844: URL: https://github.com/apache/flink/pull/16844#discussion_r690361139 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -972,24 +972,28 @@ private void releaseResources() {

[GitHub] [flink] flinkbot edited a comment on pull request #16863: [FLINK-23116][docs] Minor documentation fixes & improvements

flinkbot edited a comment on pull request #16863: URL: https://github.com/apache/flink/pull/16863#issuecomment-900273865 ## CI report: * a5bd3397a4604d860028a1a11650d2393c503c56 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16857: [FLINK-23362][tests] Remove timeouts

flinkbot edited a comment on pull request #16857: URL: https://github.com/apache/flink/pull/16857#issuecomment-900113447 ## CI report: * 32c5155ff1000418975afe32fbc300308859c957 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16858: [FLINK-16202][table] Support JSON_QUERY

flinkbot edited a comment on pull request #16858: URL: https://github.com/apache/flink/pull/16858#issuecomment-900113536 ## CI report: * 0018a655c7de010f3af718b987bdd4c96aa9b00a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16852: [FLINK-13636][docs-zh]Translate the "Flink DataStream API Programming Guide" page into Chinese

flinkbot edited a comment on pull request #16852: URL: https://github.com/apache/flink/pull/16852#issuecomment-900037795 ## CI report: * 6d75f9c16eee843ff01b7b3462f82fcc0b134ee2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16788: [FLINK-23734][table] Migrate ComponentFactory to the new Factory stack

flinkbot edited a comment on pull request #16788: URL: https://github.com/apache/flink/pull/16788#issuecomment-897412587 ## CI report: * bba33f114b52d3e86ce059b36027642494c00cce UNKNOWN * f734792406c3ff469abeb8e939bcb66605c447d3 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

flinkbot edited a comment on pull request #16783: URL: https://github.com/apache/flink/pull/16783#issuecomment-896788403 ## CI report: * a3823b920beb6983243355d46b0a629e698e5dee Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r690366650 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java ## @@

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r690366650 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java ## @@

[GitHub] [flink] Airblader commented on pull request #16788: [FLINK-23734][table] Migrate ComponentFactory to the new Factory stack

Airblader commented on pull request #16788: URL: https://github.com/apache/flink/pull/16788#issuecomment-900286382 @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 specifi

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400378#comment-17400378 ] Jark Wu commented on FLINK-22198: - The blocked stack of this issue is the same with FLIN

[jira] [Commented] (FLINK-22387) UpsertKafkaTableITCase hangs when setting up kafka

[ https://issues.apache.org/jira/browse/FLINK-22387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400380#comment-17400380 ] Jark Wu commented on FLINK-22387: - Seems related to FLINK-22198. > UpsertKafkaTableITC

[GitHub] [flink] flinkbot edited a comment on pull request #16858: [FLINK-16202][table] Support JSON_QUERY

flinkbot edited a comment on pull request #16858: URL: https://github.com/apache/flink/pull/16858#issuecomment-900113536 ## CI report: * 0018a655c7de010f3af718b987bdd4c96aa9b00a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16863: [FLINK-23116][docs] Minor documentation fixes & improvements

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

[GitHub] [flink] flinkbot edited a comment on pull request #16857: [FLINK-23362][tests] Remove timeouts

flinkbot edited a comment on pull request #16857: URL: https://github.com/apache/flink/pull/16857#issuecomment-900113447 ## CI report: * 32c5155ff1000418975afe32fbc300308859c957 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] twalthr closed pull request #16830: [hotfix][kinesis][docs] Configuring access

twalthr closed pull request #16830: URL: https://github.com/apache/flink/pull/16830 -- 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: issues-unsubsc

[GitHub] [flink] flinkbot edited a comment on pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

flinkbot edited a comment on pull request #16783: URL: https://github.com/apache/flink/pull/16783#issuecomment-896788403 ## CI report: * ba09ad39dc16a9b6adcf4aaa7dc7bb3ad39e6da7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * d79db15ab05c86dcd82fe88dc7247fd413f5c0bf UNKNOWN * bbae6a1d070ad629349bcab8579ce442e2d91d42 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] infoverload commented on pull request #16683: [hotfix][docs]improve PushGatewayReporter config description

infoverload commented on pull request #16683: URL: https://github.com/apache/flink/pull/16683#issuecomment-900264628 Thanks a lot for your contribution. Could you add a brief description of the change and use the template provided? Can you also link it to a JIRA ticket? -- Thi

[GitHub] [flink] flinkbot edited a comment on pull request #16851: [FLINK-23776][streaming] Fix emission of timestamp-less records in Sources.

flinkbot edited a comment on pull request #16851: URL: https://github.com/apache/flink/pull/16851#issuecomment-899772155 ## CI report: * 11392b6d7107d00ba49f39b8675c4a98ab2cebb1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

<    1   2   3   4   5   >