[GitHub] [flink] flinkbot edited a comment on pull request #16905: [FLINK-23884][checkpoint] Fix the concurrent problem between triggering savepoint with drain and task finishing

flinkbot edited a comment on pull request #16905: URL: https://github.com/apache/flink/pull/16905#issuecomment-902531195 ## CI report: * be085feee5def4ca765403459b835bd9e163eb79 UNKNOWN * 9519356e1758f2e163695d047e2785fc85731db2 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-23879) Benchmarks are not compiling

[ https://issues.apache.org/jira/browse/FLINK-23879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402542#comment-17402542 ] Arvid Heise commented on FLINK-23879: - Thanks for fixing [~chesnay]! Sorry for creat

[jira] [Commented] (FLINK-23883) Following bug fix and code improvement for FLIP-147

[ https://issues.apache.org/jira/browse/FLINK-23883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402539#comment-17402539 ] Yun Gao commented on FLINK-23883: - Discovered while testing > Following bug fix and cod

[GitHub] [flink] flinkbot edited a comment on pull request #16905: [FLINK-23884][checkpoint] Fix the concurrent problem between triggering savepoint with drain and task finishing

flinkbot edited a comment on pull request #16905: URL: https://github.com/apache/flink/pull/16905#issuecomment-902531195 ## CI report: * be085feee5def4ca765403459b835bd9e163eb79 UNKNOWN * 9519356e1758f2e163695d047e2785fc85731db2 Azure: [FAILURE](https://dev.azure.com/apache-fl

[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: * e47cc45fd35764b1b65c6a0dd41bf863b8dcee49 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16894: [FLINK-23871][Runtime/Coordination]Dispatcher should handle finishing…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

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

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

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402527#comment-17402527 ] Dong Lin commented on FLINK-22198: -- Hey [~fsk119], do you think it would be simpler to

[GitHub] [flink] flinkbot edited a comment on pull request #16908: [FLINK-23898][akka] Fix log level mapping

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

[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: * dd0cecc8a4fd0faa255bb3692ebd82a3c4e451f2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16894: [FLINK-23871][Runtime/Coordination]Dispatcher should handle finishing…

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

[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: * dd0cecc8a4fd0faa255bb3692ebd82a3c4e451f2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-23905) Reduce the load on JobManager when submitting large-scale job with a big user jar

huntercc created FLINK-23905: Summary: Reduce the load on JobManager when submitting large-scale job with a big user jar Key: FLINK-23905 URL: https://issues.apache.org/jira/browse/FLINK-23905 Project: Fl

[GitHub] [flink] flinkbot edited a comment on pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

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

[GitHub] [flink] flinkbot edited a comment on pull request #16894: [FLINK-23871][Runtime/Coordination]Dispatcher should handle finishing…

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

[GitHub] [flink] Aitozi commented on a change in pull request #16894: [FLINK-23871][Runtime/Coordination]Dispatcher should handle finishing…

Aitozi commented on a change in pull request #16894: URL: https://github.com/apache/flink/pull/16894#discussion_r693277592 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobAlreadyDoneException.java ## @@ -0,0 +1,35 @@ +/* + * Licensed to the Apac

[jira] [Updated] (FLINK-23072) Add benchmarks for SQL internal and external serializers

[ https://issues.apache.org/jira/browse/FLINK-23072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23072: --- Labels: stale-major starter (was: starter) I am the [Flink Jira Bot|https://github.com/apac

[jira] [Updated] (FLINK-21440) Translate Real Time Reporting with the Table API doc and correct a spelling mistake

[ https://issues.apache.org/jira/browse/FLINK-21440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21440: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-23441) Remove CheckpointOptions Argument away from Snapshotable#snapshot

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

[jira] [Updated] (FLINK-16504) Add a AWS DynamoDB sink

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

[jira] [Updated] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

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

[jira] [Updated] (FLINK-23399) Add a performance benchmark for statebackend rescaling

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

[jira] [Updated] (FLINK-22800) EXACTLY_ONCE KAFKA consumer (FLINK-6988) has not set isolation.level

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

[GitHub] [flink] flinkbot edited a comment on pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

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

[GitHub] [flink] flinkbot edited a comment on pull request #16915: [FLINK-9925][tests] Harden ClientTest by making handler shareable

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

rkhachatryan commented on a change in pull request #16885: URL: https://github.com/apache/flink/pull/16885#discussion_r693197096 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -762,17 +762,21 @@ private void doRun() {

[GitHub] [flink] flinkbot edited a comment on pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

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

[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: * dd0cecc8a4fd0faa255bb3692ebd82a3c4e451f2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16908: [FLINK-23898][akka] Fix log level mapping

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

[GitHub] [flink] flinkbot edited a comment on pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

rkhachatryan commented on a change in pull request #16885: URL: https://github.com/apache/flink/pull/16885#discussion_r693198045 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -881,12 +859,16 @@ private boolean a

[GitHub] [flink] rkhachatryan commented on a change in pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

rkhachatryan commented on a change in pull request #16885: URL: https://github.com/apache/flink/pull/16885#discussion_r693197096 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -762,17 +762,21 @@ private void doRun() {

[GitHub] [flink] flinkbot edited a comment on pull request #16908: [FLINK-23898][akka] Fix log level mapping

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

[jira] [Commented] (FLINK-23640) Create a KafkaRecordSerializationSchemas valueOnly helper

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

[jira] [Resolved] (FLINK-23640) Create a KafkaRecordSerializationSchemas valueOnly helper

[ https://issues.apache.org/jira/browse/FLINK-23640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23640. - Fix Version/s: 1.14.0 Resolution: Fixed > Create a KafkaRecordSerializationSchemas valueO

[GitHub] [flink] AHeise merged pull request #16783: [FLINK-23640][connectors/kafka] Add KafkaRecordSerializationSchemaBuilder to cover common serialization scenarios

AHeise merged pull request #16783: URL: https://github.com/apache/flink/pull/16783 -- 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-unsubscr

[jira] [Assigned] (FLINK-23801) Add FLIP-33 metrics to KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-23801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23801: --- Assignee: Qingsheng Ren > Add FLIP-33 metrics to KafkaSource >

[jira] [Resolved] (FLINK-23801) Add FLIP-33 metrics to KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-23801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23801. - Resolution: Fixed > Add FLIP-33 metrics to KafkaSource > -- > >

[jira] [Commented] (FLINK-23801) Add FLIP-33 metrics to KafkaSource

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

[jira] [Assigned] (FLINK-23773) KafkaPartitionSplitReader should remove empty splits from fetcher

[ https://issues.apache.org/jira/browse/FLINK-23773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23773: --- Assignee: Qingsheng Ren > KafkaPartitionSplitReader should remove empty splits from fetcher

[GitHub] [flink] AHeise merged pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

AHeise merged pull request #16838: URL: https://github.com/apache/flink/pull/16838 -- 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-unsubscr

[GitHub] [flink] flinkbot edited a comment on pull request #16914: [FLINK-22932][tests] Harden RocksDBStateBackendWindowITCase by using RpcUtils.INF_TIMEOUT for MiniCluster RPC timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #16913: [FLINK-23809][checkpoint] Respect the finished flag when extracting operator states due to skip in-flight data

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

[GitHub] [flink] flinkbot edited a comment on pull request #16894: [FLINK-23871][Runtime/Coordination]Dispatcher should handle finishing…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

flinkbot edited a comment on pull request #16838: URL: https://github.com/apache/flink/pull/16838#issuecomment-899337835 ## CI report: * 5dd51383b3c2448eaec88a74f93207da18eeb538 UNKNOWN * 7f4a778d5f6b2b1174ac8f7142fad2a743bf4069 Azure: [SUCCESS](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: * 283f1ffac9b3805fecba32edce3f5c8f8c9c3a20 UNKNOWN * caf989bc742156c5f128b0c13ea384d0d1730638 Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

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

[GitHub] [flink] flinkbot edited a comment on pull request #16915: [FLINK-9925][tests] Harden ClientTest by making handler shareable

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

[GitHub] [flink] flinkbot edited a comment on pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

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

[jira] [Commented] (FLINK-23866) KafkaTransactionLogITCase.testGetTransactionsToAbort fails with IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-23866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402371#comment-17402371 ] Fabian Paul commented on FLINK-23866: - Merged on master: 226858967eb341c37b44b2f6264

[jira] [Updated] (FLINK-23866) KafkaTransactionLogITCase.testGetTransactionsToAbort fails with IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-23866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-23866: Release Note: (was: Merged on master: 226858967eb341c37b44b2f62646798d42c383ff) > KafkaTransact

[jira] [Resolved] (FLINK-23866) KafkaTransactionLogITCase.testGetTransactionsToAbort fails with IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-23866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-23866. - Release Note: Merged on master: 226858967eb341c37b44b2f62646798d42c383ff Resolution: Fixed

[GitHub] [flink] AHeise merged pull request #16896: [FLINK-23866][connectors/kafka] Statically assign partitions when reading transaction log topic

AHeise merged pull request #16896: URL: https://github.com/apache/flink/pull/16896 -- 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-unsubscr

[GitHub] [flink] syhily commented on a change in pull request #16900: [FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing.

syhily commented on a change in pull request #16900: URL: https://github.com/apache/flink/pull/16900#discussion_r693138134 ## File path: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/runtime/mock/PulsarMockProvider.java ## @@

[GitHub] [flink] syhily commented on pull request #16900: [FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing.

syhily commented on pull request #16900: URL: https://github.com/apache/flink/pull/16900#issuecomment-902874170 > Before doing a full-fledged review, I'd like to understand the scope a bit better since the PR is rather big as well. > Do you want to contribute the test utilities to improv

[GitHub] [flink] AHeise commented on a change in pull request #16900: [FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing.

AHeise commented on a change in pull request #16900: URL: https://github.com/apache/flink/pull/16900#discussion_r693123793 ## File path: flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/runtime/mock/PulsarMockProvider.java ## @@

[GitHub] [flink] flinkbot commented on pull request #16915: [FLINK-9925][tests] Harden ClientTest by making handler shareable

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

[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: * f5026d9fa9cc1b14f972985e1f76181e9fcb6ff9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] akalash commented on a change in pull request #16885: [FLINK-23862][runtime] Cleanup StreamTask if cancelled after restore …

akalash commented on a change in pull request #16885: URL: https://github.com/apache/flink/pull/16885#discussion_r693122516 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -881,12 +859,16 @@ private boolean areChe

[GitHub] [flink] flinkbot commented on pull request #16915: [FLINK-9925][tests] Harden ClientTest by making handler shareable

flinkbot commented on pull request #16915: URL: https://github.com/apache/flink/pull/16915#issuecomment-902850530 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] 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: * f5026d9fa9cc1b14f972985e1f76181e9fcb6ff9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

flinkbot edited a comment on pull request #16838: URL: https://github.com/apache/flink/pull/16838#issuecomment-899337835 ## CI report: * 5dd51383b3c2448eaec88a74f93207da18eeb538 UNKNOWN * 7b11402e44f62ef803b912b0741c109e12b3513c Azure: [SUCCESS](https://dev.azure.com/apache-fl

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

[ https://issues.apache.org/jira/browse/FLINK-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9925: -- Labels: auto-deprioritized-critical pull-request-available test-stability (was: auto-depriorit

[GitHub] [flink] tillrohrmann opened a new pull request #16915: [FLINK-9925][tests] Harden ClientTest by making handler shareable

tillrohrmann opened a new pull request #16915: URL: https://github.com/apache/flink/pull/16915 This commit makes the handler that is used for the testConcurrentQueries shareable so that Netty won't fail if another pipeline is created. -- This is an automated message from the Apache Git S

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

[ https://issues.apache.org/jira/browse/FLINK-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9925: - Fix Version/s: 1.13.3 1.12.6 > ClientTest.testSimpleRequests fails on Travis >

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

[ https://issues.apache.org/jira/browse/FLINK-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402321#comment-17402321 ] Till Rohrmann commented on FLINK-9925: -- I think the problem is that the channel hand

[jira] [Commented] (FLINK-23721) Flink SQL state TTL has no effect when using non-incremental RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-23721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402322#comment-17402322 ] Yun Tang commented on FLINK-23721: -- [~lmagics] Whether enable incremental checkpoints h

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

[ https://issues.apache.org/jira/browse/FLINK-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9925: - Fix Version/s: 1.14.0 > ClientTest.testSimpleRequests fails on Travis > -

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

[ https://issues.apache.org/jira/browse/FLINK-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9925: Assignee: Till Rohrmann > ClientTest.testSimpleRequests fails on Travis >

[GitHub] [flink] flinkbot edited a comment on pull request #16912: [FLINK-23903][tests] Harden ZooKeeperLeaderRetrievalConnectionHandlingTest.testSuspendedConnectionDoesNotClearLeaderInformationIfClea

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

[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: * f5026d9fa9cc1b14f972985e1f76181e9fcb6ff9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

flinkbot edited a comment on pull request #16838: URL: https://github.com/apache/flink/pull/16838#issuecomment-899337835 ## CI report: * 5dd51383b3c2448eaec88a74f93207da18eeb538 UNKNOWN * 7b11402e44f62ef803b912b0741c109e12b3513c Azure: [SUCCESS](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: * 283f1ffac9b3805fecba32edce3f5c8f8c9c3a20 UNKNOWN * caf989bc742156c5f128b0c13ea384d0d1730638 Azure: [CANCELED](https://dev.azure.com/apache-f

[jira] [Updated] (FLINK-23886) An exception is thrown out when recover job timers from savepoint file

[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23886: --- Description: A user report the bug in the [mailist.  |http://mail-archives.apache.org/mod_mbox/flink

[jira] [Closed] (FLINK-23430) Take snapshots for operator coordinators which all corresponding tasks finished

[ https://issues.apache.org/jira/browse/FLINK-23430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-23430. --- Resolution: Fixed > Take snapshots for operator coordinators which all corresponding tasks > finished > ---

[jira] [Commented] (FLINK-23430) Take snapshots for operator coordinators which all corresponding tasks finished

[ https://issues.apache.org/jira/browse/FLINK-23430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402302#comment-17402302 ] Yun Gao commented on FLINK-23430: - Fix on master via e8ecf45efbcbc005129492d9f289bf7b277

[GitHub] [flink] gaoyunhaii closed pull request #16784: [FLINK-23430][runtime][checkpoint] Allows taking snapshots for operator coordinators which all corresponding tasks finished

gaoyunhaii closed pull request #16784: URL: https://github.com/apache/flink/pull/16784 -- 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-unsu

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

gaoyunhaii commented on pull request #16784: URL: https://github.com/apache/flink/pull/16784#issuecomment-902808830 Very thanks Roman @rkhachatryan for the review! I'll merge the code~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #16913: [FLINK-23809][checkpoint] Respect the finished flag when extracting operator states due to skip in-flight data

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

[GitHub] [flink] flinkbot edited a comment on pull request #16914: [FLINK-22932][tests] Harden RocksDBStateBackendWindowITCase by using RpcUtils.INF_TIMEOUT for MiniCluster RPC timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #16894: [FLINK-23871][Runtime/Coordination]Dispatcher should handle finishing…

flinkbot edited a comment on pull request #16894: URL: https://github.com/apache/flink/pull/16894#issuecomment-901800802 ## CI report: * 9c0242e54be44f5e9aeb3596a3df73c62d126518 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: * 283f1ffac9b3805fecba32edce3f5c8f8c9c3a20 UNKNOWN * caf989bc742156c5f128b0c13ea384d0d1730638 Azure: [PENDING](https://dev.azure.com/apache-fl

[jira] [Closed] (FLINK-22568) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails with Timeout

[ https://issues.apache.org/jira/browse/FLINK-22568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-22568. - Resolution: Duplicate Most likely caused by a flakey CI infrastructure. This problem should be

[jira] [Updated] (FLINK-22568) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails with Timeout

[ https://issues.apache.org/jira/browse/FLINK-22568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22568: -- Fix Version/s: (was: 1.14.0) > RescalingITCase.testSavepointRescalingInPartitionedOperator

[jira] [Commented] (FLINK-22568) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails with Timeout

[ https://issues.apache.org/jira/browse/FLINK-22568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402295#comment-17402295 ] Till Rohrmann commented on FLINK-22568: --- I think the problem is our CI infrastruct

[jira] [Assigned] (FLINK-22568) RescalingITCase.testSavepointRescalingInPartitionedOperatorStateList fails with Timeout

[ https://issues.apache.org/jira/browse/FLINK-22568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-22568: - Assignee: Till Rohrmann > RescalingITCase.testSavepointRescalingInPartitionedOperatorSt

[jira] [Closed] (FLINK-22571) SavepointITCase.testSavepointForJobWithIteration fails with Timeout

[ https://issues.apache.org/jira/browse/FLINK-22571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-22571. - Fix Version/s: (was: 1.14.0) Resolution: Duplicate Maybe a duplicate of FLINK-22932.

[jira] [Commented] (FLINK-22571) SavepointITCase.testSavepointForJobWithIteration fails with Timeout

[ https://issues.apache.org/jira/browse/FLINK-22571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402290#comment-17402290 ] Till Rohrmann commented on FLINK-22571: --- This problem looks very similar to FLINK-

[jira] [Assigned] (FLINK-22571) SavepointITCase.testSavepointForJobWithIteration fails with Timeout

[ https://issues.apache.org/jira/browse/FLINK-22571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-22571: - Assignee: Till Rohrmann > SavepointITCase.testSavepointForJobWithIteration fails with T

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

fapaul commented on pull request #16783: URL: https://github.com/apache/flink/pull/16783#issuecomment-902791696 @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 c

[jira] [Resolved] (FLINK-23838) Add FLIP-33 metrics to new KafkaSink

[ https://issues.apache.org/jira/browse/FLINK-23838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23838. - Resolution: Fixed Merged into master as 8e8a60a7afaba21272aaf2c2e12e1abfc2b12375..545fd7a9e306b

[GitHub] [flink] AHeise merged pull request #16875: [FLINK-23838][connectors/kafka] Implement FLIP-33 metrics for KafkaSink

AHeise merged pull request #16875: URL: https://github.com/apache/flink/pull/16875 -- 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-unsubscr

[GitHub] [flink] flinkbot commented on pull request #16914: [FLINK-22932][tests] Harden RocksDBStateBackendWindowITCase by using RpcUtils.INF_TIMEOUT for MiniCluster RPC timeout

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

[GitHub] [flink] flinkbot commented on pull request #16913: [FLINK-23809][checkpoint] Respect the finished flag when extracting operator states due to skip in-flight data

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

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

AHeise commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r693047920 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java ## @@ -15

[GitHub] [flink] flinkbot edited a comment on pull request #16910: [FLINK-23097][tests] Harden test_queryable_state_restart_tm.sh

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

[GitHub] [flink] flinkbot edited a comment on pull request #16894: [FLINK-23871][Runtime/Coordination]Dispatcher should handle finishing…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16875: [FLINK-23838][connectors/kafka] Implement FLIP-33 metrics for KafkaSink

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

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

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

  1   2   3   4   >