[GitHub] [flink] dianfu opened a new pull request #15349: [FLINK-21937][python] Support batch mode in Python DataStream API for basic operations

dianfu opened a new pull request #15349: URL: https://github.com/apache/flink/pull/15349 ## What is the purpose of the change *This pull request support batch mode in Python DataStream API for basic operations such as map, flatmap, filter, etc.* ## Verifying this

[GitHub] [flink] xintongsong closed pull request #15279: [hotfix][test] Fix misuse of env and properties

xintongsong closed pull request #15279: URL: https://github.com/apache/flink/pull/15279 -- 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. For queries about this service,

[GitHub] [flink] lindong28 commented on a change in pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

lindong28 commented on a change in pull request #15161: URL: https://github.com/apache/flink/pull/15161#discussion_r600109069 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java ## @@ -267,6 +270,12 @@ void

[GitHub] [flink] fsk119 commented on a change in pull request #15332: [FLINK-21701][sql-client] Extend the "RESET" syntax in the SQL Client

fsk119 commented on a change in pull request #15332: URL: https://github.com/apache/flink/pull/15332#discussion_r600097296 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java ## @@ -424,28 +424,14 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * 98c5f207e1d006b91be50df6ce1b3e8f45fc795b UNKNOWN * 3b6c434b676ee0d1aaad00e8ba1fa03c1ddc7f33 UNKNOWN *

[GitHub] [flink] kezhuw commented on a change in pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

kezhuw commented on a change in pull request #15331: URL: https://github.com/apache/flink/pull/15331#discussion_r600095822 ## File path: flink-core/src/main/java/org/apache/flink/api/common/operators/CollectionExecutor.java ## @@ -110,7 +111,7 @@ public JobExecutionResult

[jira] [Resolved] (FLINK-21628) Support Python UDAF in Tumbling Window

[ https://issues.apache.org/jira/browse/FLINK-21628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-21628. -- Resolution: Resolved Merged into master via 797b38299e5fd6ab5a6fdd6eb3e3de616e57040d >

[GitHub] [flink] HuangXingBo closed pull request #15212: [FLINK-21628][python] Support Python UDAF in Tumbling Window

HuangXingBo closed pull request #15212: URL: https://github.com/apache/flink/pull/15212 -- 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. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * 98c5f207e1d006b91be50df6ce1b3e8f45fc795b UNKNOWN * 3b6c434b676ee0d1aaad00e8ba1fa03c1ddc7f33 UNKNOWN *

[jira] [Created] (FLINK-21937) Support batch mode in Python DataStream API for basic operations

Dian Fu created FLINK-21937: --- Summary: Support batch mode in Python DataStream API for basic operations Key: FLINK-21937 URL: https://issues.apache.org/jira/browse/FLINK-21937 Project: Flink

[GitHub] [flink] wsry edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-805065015 @StephanEwen I have updated the PR. Is there any other concern? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Closed] (FLINK-21916) Allow OPERATOR and PYTHON ManagedMemoryUseCase to be used in the same operator

[ https://issues.apache.org/jira/browse/FLINK-21916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-21916. --- Resolution: Fixed Merged to master via 0e2560402e5f7c4d24cb9b3b05d79065bb97af6d > Allow OPERATOR and

[GitHub] [flink] dianfu closed pull request #15337: [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase for the same operator

dianfu closed pull request #15337: URL: https://github.com/apache/flink/pull/15337 -- 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. For queries about this service, please

[GitHub] [flink] dianfu commented on pull request #15337: [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase for the same operator

dianfu commented on pull request #15337: URL: https://github.com/apache/flink/pull/15337#issuecomment-805397275 It seems that the tests have failed because of network issues. Merging as it has passed in my personal azure pipeline:

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r600079683 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,265 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

flinkbot edited a comment on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805219989 ## CI report: * 9f5e232ca64f387a9e936d883f4278faf11a2f36 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

flinkbot edited a comment on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805219989 ## CI report: * 9f5e232ca64f387a9e936d883f4278faf11a2f36 Azure:

[jira] [Comment Edited] (FLINK-20945) flink hive insert heap out of memory

[ https://issues.apache.org/jira/browse/FLINK-20945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307480#comment-17307480 ] Aswin ram Sivaraman Venkataraman edited comment on FLINK-20945 at 3/24/21, 12:32 AM:

[jira] [Commented] (FLINK-20945) flink hive insert heap out of memory

[ https://issues.apache.org/jira/browse/FLINK-20945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307480#comment-17307480 ] Aswin ram Sivaraman Venkataraman commented on FLINK-20945: -- Can anybody please 

[GitHub] [flink] flinkbot edited a comment on pull request #15347: [FLINK-21933][kinesis] EFO consumer treats interrupts as retryable ex…

flinkbot edited a comment on pull request #15347: URL: https://github.com/apache/flink/pull/15347#issuecomment-805098241 ## CI report: * 86cef1cc8c4b61d5896b348acd566f2b28c7259a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

flinkbot edited a comment on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805219989 ## CI report: * 9f5e232ca64f387a9e936d883f4278faf11a2f36 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * 98c5f207e1d006b91be50df6ce1b3e8f45fc795b UNKNOWN * 3b6c434b676ee0d1aaad00e8ba1fa03c1ddc7f33 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15149: [FLINK-21294][python] Support state access API for the map/flat_map operation of Python ConnectedStreams

flinkbot edited a comment on pull request #15149: URL: https://github.com/apache/flink/pull/15149#issuecomment-796635889 ## CI report: * 44b79b3ce008d71fda142e56288d30ac19e2ad40 UNKNOWN * ec90293567a79dca2d23941aca6019f5f4c7d36e UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 33893b0eb17bbee5994cc5ff5c406be968b38808 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

flinkbot edited a comment on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805219989 ## CI report: * 9f5e232ca64f387a9e936d883f4278faf11a2f36 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

flinkbot edited a comment on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-792934307 ## CI report: * f2de7e07c66e6dda2b4caef75e2f1dfde9f0e5c3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

flinkbot edited a comment on pull request #15331: URL: https://github.com/apache/flink/pull/15331#issuecomment-804297575 ## CI report: * cbf4ab0e0683981a078a1b16e94d0406dc5ac8e9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15328: [FLINK-20533][datadog][release-1.12] Backport flink-metrics-datadog changes from master

flinkbot edited a comment on pull request #15328: URL: https://github.com/apache/flink/pull/15328#issuecomment-804259070 ## CI report: * c37a4c47c2417188b292f23c4d0c8a182096d117 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15313: [FLINK-19682] Actively timeout checkpoint barriers on the inputs

flinkbot edited a comment on pull request #15313: URL: https://github.com/apache/flink/pull/15313#issuecomment-803870812 ## CI report: * b402258a89847b62483a57e9fb193d9bbf3bc1ca Azure:

[jira] [Closed] (FLINK-21751) Improve handling of freed slots if final requirement message is in flight

[ https://issues.apache.org/jira/browse/FLINK-21751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21751. Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #15319: [FLINK-21751] Eagerly issue release calls from RM if JM disconnects for terminal job

zentol merged pull request #15319: URL: https://github.com/apache/flink/pull/15319 -- 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. For queries about this service, please

[jira] [Closed] (FLINK-21855) Document Metrics Limitations

[ https://issues.apache.org/jira/browse/FLINK-21855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21855. Resolution: Fixed master: 345f36d92a1ceffcc019af38ffc6b4c9b0b2d050 > Document Metrics

[GitHub] [flink] zentol merged pull request #15321: [FLINK-21855][docs] Document metrics limitations of reactive mode

zentol merged pull request #15321: URL: https://github.com/apache/flink/pull/15321 -- 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. For queries about this service, please

[GitHub] [flink] flinkbot edited a comment on pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

flinkbot edited a comment on pull request #15331: URL: https://github.com/apache/flink/pull/15331#issuecomment-804297575 ## CI report: * cbf4ab0e0683981a078a1b16e94d0406dc5ac8e9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15132: [FLINK-21698][table-planner] Disable problematic cast conversion between NUMERIC type and TIMESTAMP type

flinkbot edited a comment on pull request #15132: URL: https://github.com/apache/flink/pull/15132#issuecomment-795012449 ## CI report: * b01ec8679ce5ae6879c8dfd57e856bef9d0a8568 UNKNOWN * 85313c0327f765a8f74df155cd622e6477b6cbf9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15346: [FLINK-21896][table-planner-blink] Correct the different serialization result for json plan between jdk8 and jdk11

flinkbot edited a comment on pull request #15346: URL: https://github.com/apache/flink/pull/15346#issuecomment-804974540 ## CI report: * 146f8a23370ebc62c975dad121beaef04639071d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15339: [FLINK-21448] Randomize ITTests for delegating state backend

flinkbot edited a comment on pull request #15339: URL: https://github.com/apache/flink/pull/15339#issuecomment-804687609 ## CI report: * 974d39cf0e8ef0b67b8c5fdc72a9c58268e34056 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15157: [FLINK-21661][kinesis] Fix fetch interval for polling consumer

flinkbot edited a comment on pull request #15157: URL: https://github.com/apache/flink/pull/15157#issuecomment-796895603 ## CI report: * 91e0db5569dbdc877fa77ac7a981385e96a6aa16 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15313: [FLINK-19682] Actively timeout checkpoint barriers on the inputs

flinkbot edited a comment on pull request #15313: URL: https://github.com/apache/flink/pull/15313#issuecomment-803870812 ## CI report: * 52ed30948beb1f7aa81df22e7e5cc2355cdb72e0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

flinkbot edited a comment on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805219989 ## CI report: * 9f5e232ca64f387a9e936d883f4278faf11a2f36 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * c69a962e9416d22a9fce5a5e1068d1055134fede Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15212: [FLINK-21628][python] Support Python UDAF in Tumbling Window

flinkbot edited a comment on pull request #15212: URL: https://github.com/apache/flink/pull/15212#issuecomment-799172540 ## CI report: * 373cc1febbc6d9990b409228122e72b48f7e4c84 Azure:

[jira] [Closed] (FLINK-21913) Update DynamicTableFactory.Context to use ResolvedCatalogTable

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

[GitHub] [flink] twalthr closed pull request #15316: [FLINK-21913][table][connectors] Update DynamicTableFactory.Context to use ResolvedCatalogTable

twalthr closed pull request #15316: URL: https://github.com/apache/flink/pull/15316 -- 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. For queries about this service,

[GitHub] [flink] rmetzger commented on a change in pull request #15321: [FLINK-21855][docs] Document metrics limitations of reactive mode

rmetzger commented on a change in pull request #15321: URL: https://github.com/apache/flink/pull/15321#discussion_r599911357 ## File path: docs/content/docs/deployment/elastic_scaling.md ## @@ -104,6 +104,7 @@ Since Reactive Mode is a new, experimental feature, not all

[GitHub] [flink] flinkbot commented on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

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

[jira] [Updated] (FLINK-21884) Reduce TaskManager failure detection time

[ https://issues.apache.org/jira/browse/FLINK-21884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21884: --- Description: In Flink 1.13 (and older versions), TaskManager failures stall the processing

[GitHub] [flink] flinkbot edited a comment on pull request #15345: [FLINK-21872][table-api-java] Add utility for DataStream API's DataType, Schema, and projection

flinkbot edited a comment on pull request #15345: URL: https://github.com/apache/flink/pull/15345#issuecomment-804913315 ## CI report: * 1ffbd428b857c1b0d0e7929b3862f43ff61b204b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15221: [FLINK-17012][streaming] 'RUNNING' state split into 'RUNNING' and 'RE…

flinkbot edited a comment on pull request #15221: URL: https://github.com/apache/flink/pull/15221#issuecomment-799620682 ## CI report: * c0ce9a800b7f7378c256af64b88b663f4c5a674f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15132: [FLINK-21698][table-planner] Disable problematic cast conversion between NUMERIC type and TIMESTAMP type

flinkbot edited a comment on pull request #15132: URL: https://github.com/apache/flink/pull/15132#issuecomment-795012449 ## CI report: * b01ec8679ce5ae6879c8dfd57e856bef9d0a8568 UNKNOWN * 42e41863d5bb3797a6aca4f261ca034b2cc339c2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 56e557bf2c9421b5407068097c551ec46e7f98e7 Azure:

[jira] [Commented] (FLINK-21749) unable to use scala Shell

[ https://issues.apache.org/jira/browse/FLINK-21749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307391#comment-17307391 ] Chesnay Schepler commented on FLINK-21749: -- In my last comment I gave you 2 alternatives; you

[jira] [Commented] (FLINK-21936) Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-21936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307388#comment-17307388 ] Arvid Heise commented on FLINK-21936: - A completely different approach would be possible with

[jira] [Commented] (FLINK-21936) Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-21936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307386#comment-17307386 ] Arvid Heise commented on FLINK-21936: - Alternatively or additionally, we might want to add the keyed

[jira] [Commented] (FLINK-21936) Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-21936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307383#comment-17307383 ] Arvid Heise commented on FLINK-21936: - As a first step, we might want to provide users an explicit

[jira] [Created] (FLINK-21936) Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints

Arvid Heise created FLINK-21936: --- Summary: Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints Key: FLINK-21936 URL: https://issues.apache.org/jira/browse/FLINK-21936

[GitHub] [flink] austince commented on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

austince commented on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805188173 Some brief notes were discussed in https://github.com/flink-ci/flink-mirror/pull/7 -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot commented on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

flinkbot commented on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805186324 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] austince commented on pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

austince commented on pull request #15348: URL: https://github.com/apache/flink/pull/15348#issuecomment-805185746 @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

[jira] [Updated] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive"

[ https://issues.apache.org/jira/browse/FLINK-21844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21844: --- Labels: pull-request-available (was: ) > Do not auto-configure maxParallelism when setting

[GitHub] [flink] austince opened a new pull request #15348: [FLINK-21844][runtime] Do not auto-configure maxParallelism in REACTIVE scheduling mode

austince opened a new pull request #15348: URL: https://github.com/apache/flink/pull/15348 ## What is the purpose of the change To maintain compatibility between reactive and default scheduling modes, the `maxParallelism` of operators must be set consistently. Currently, there are

[GitHub] [flink] flinkbot edited a comment on pull request #15252: [FLINK-20654][tests] Forcing network action logger on TRACE for Unaligned Checkpoint ITCases.

flinkbot edited a comment on pull request #15252: URL: https://github.com/apache/flink/pull/15252#issuecomment-801056952 ## CI report: * e435009b2d17bb27a7227c7f3e33ecf19c86e504 Azure:

[jira] [Closed] (FLINK-21348) Add tests for StateWithExecutionGraph

[ https://issues.apache.org/jira/browse/FLINK-21348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-21348. -- Resolution: Fixed Resolved in

[GitHub] [flink] rmetzger closed pull request #15342: [FLINK-21348] Add tests for AdaptiveScheduler's StateWithExecutionGraph

rmetzger closed pull request #15342: URL: https://github.com/apache/flink/pull/15342 -- 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. For queries about this service,

[GitHub] [flink] rmetzger commented on pull request #15342: [FLINK-21348] Add tests for AdaptiveScheduler's StateWithExecutionGraph

rmetzger commented on pull request #15342: URL: https://github.com/apache/flink/pull/15342#issuecomment-805173808 Thanks a lot for your review. I'll merge this soon ;) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] flinkbot edited a comment on pull request #15344: [FLINK-21564][tests] Don't call condition or throw exception after condition met for CommonTestUtils.waitUntil

flinkbot edited a comment on pull request #15344: URL: https://github.com/apache/flink/pull/15344#issuecomment-804913184 ## CI report: * b8201f39b54a708defd6c87cbaf5cb8dafcf3420 Azure:

[GitHub] [flink] StephanEwen commented on a change in pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

StephanEwen commented on a change in pull request #15161: URL: https://github.com/apache/flink/pull/15161#discussion_r599670918 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContext.java ## @@ -267,6 +270,12 @@ void

[GitHub] [flink] flinkbot edited a comment on pull request #15316: [FLINK-21913][table][connectors] Update DynamicTableFactory.Context to use ResolvedCatalogTable

flinkbot edited a comment on pull request #15316: URL: https://github.com/apache/flink/pull/15316#issuecomment-803958416 ## CI report: * af9d39a31862cd85ee3e99f2172c4d14c3370672 Azure:

[jira] [Created] (FLINK-21935) Remove "state.backend.async" option.

Stephan Ewen created FLINK-21935: Summary: Remove "state.backend.async" option. Key: FLINK-21935 URL: https://issues.apache.org/jira/browse/FLINK-21935 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 40d4d0444fccadfa50d8ba466a113d2728fa9f4d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

flinkbot edited a comment on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-792934307 ## CI report: * c4e1fdecf51e7bd175ad6b182c820da389335f0d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15316: [FLINK-21913][table][connectors] Update DynamicTableFactory.Context to use ResolvedCatalogTable

flinkbot edited a comment on pull request #15316: URL: https://github.com/apache/flink/pull/15316#issuecomment-803958416 ## CI report: * af9d39a31862cd85ee3e99f2172c4d14c3370672 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15343: [FLINK-21387][tests] Remove test timeout from DispatcherTest.testNonBlockingJobSubmission and .testInvalidCallDuringInitialization

flinkbot edited a comment on pull request #15343: URL: https://github.com/apache/flink/pull/15343#issuecomment-804913079 ## CI report: * 4363083a299184f05c617cc669fde80b7479fee2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * 98c5f207e1d006b91be50df6ce1b3e8f45fc795b UNKNOWN * 51a2bfa471abde93d6fa0d040de43f210febc3e1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 40d4d0444fccadfa50d8ba466a113d2728fa9f4d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15149: [FLINK-21294][python] Support state access API for the map/flat_map operation of Python ConnectedStreams

flinkbot edited a comment on pull request #15149: URL: https://github.com/apache/flink/pull/15149#issuecomment-796635889 ## CI report: * 44b79b3ce008d71fda142e56288d30ac19e2ad40 UNKNOWN * ec90293567a79dca2d23941aca6019f5f4c7d36e UNKNOWN *

[jira] [Commented] (FLINK-21929) flink-statebackend-rocksdb crashes with Error occurred in starting fork

[ https://issues.apache.org/jira/browse/FLINK-21929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307326#comment-17307326 ] Robert Metzger commented on FLINK-21929:

[jira] [Commented] (FLINK-21929) flink-statebackend-rocksdb crashes with Error occurred in starting fork

[ https://issues.apache.org/jira/browse/FLINK-21929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307325#comment-17307325 ] Robert Metzger commented on FLINK-21929:

[GitHub] [flink] flinkbot edited a comment on pull request #15347: [FLINK-21933][kinesis] EFO consumer treats interrupts as retryable ex…

flinkbot edited a comment on pull request #15347: URL: https://github.com/apache/flink/pull/15347#issuecomment-805098241 ## CI report: * 86cef1cc8c4b61d5896b348acd566f2b28c7259a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15336: [FLINK-20547][network] Fix inconsistent availability issue of LocalBufferPool

flinkbot edited a comment on pull request #15336: URL: https://github.com/apache/flink/pull/15336#issuecomment-804609978 ## CI report: * 16d82400a7fa31064b1dece314f9d33b9b72afa0 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #15319: [FLINK-21751] Eagerly issue release calls from RM if JM disconnects for terminal job

tillrohrmann commented on a change in pull request #15319: URL: https://github.com/apache/flink/pull/15319#discussion_r599819020 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -1079,6 +1080,20 @@ private void

[jira] [Closed] (FLINK-21382) Standalone K8s documentation does not explain usage of standby JobManagers

[ https://issues.apache.org/jira/browse/FLINK-21382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-21382. - Resolution: Fixed Fixed via 1.13.0: d67c4d9559ae766bb08e411617a278e7f1f6d294 1.12.3:

[GitHub] [flink] flinkbot edited a comment on pull request #15108: [FLINK-21306] Ensure fatal errors always stop the JVM process

flinkbot edited a comment on pull request #15108: URL: https://github.com/apache/flink/pull/15108#issuecomment-792338349 ## CI report: * a83651245f10022c2b0c47e1bd7c4f4938f7753c Azure:

[GitHub] [flink] flinkbot commented on pull request #15347: [FLINK-21933][kinesis] EFO consumer treats interrupts as retryable ex…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * 98c5f207e1d006b91be50df6ce1b3e8f45fc795b UNKNOWN * 51a2bfa471abde93d6fa0d040de43f210febc3e1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15149: [FLINK-21294][python] Support state access API for the map/flat_map operation of Python ConnectedStreams

flinkbot edited a comment on pull request #15149: URL: https://github.com/apache/flink/pull/15149#issuecomment-796635889 ## CI report: * 44b79b3ce008d71fda142e56288d30ac19e2ad40 UNKNOWN * ec90293567a79dca2d23941aca6019f5f4c7d36e UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

flinkbot edited a comment on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-792934307 ## CI report: * 9faba578819a9c7daa47e050dc3dfcdaf76af488 Azure:

[GitHub] [flink] tillrohrmann closed pull request #15248: [FLINK-21382][doc] Update documentation for standalone Flink on Kubernetes with standby JobManagers

tillrohrmann closed pull request #15248: URL: https://github.com/apache/flink/pull/15248 -- 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. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15341: [FLINK-21923][table-planner-blink] Fix SplitAggregateRule not support both filter, count/sum, avg

flinkbot edited a comment on pull request #15341: URL: https://github.com/apache/flink/pull/15341#issuecomment-804760572 ## CI report: * b9683c5a994a83652c156b06233c360d73ecfd7f UNKNOWN * 3e75ad74ec4e8f1d9e7d4f5dee58aad94148f1b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15342: [FLINK-21348] Add tests for AdaptiveScheduler's StateWithExecutionGraph

flinkbot edited a comment on pull request #15342: URL: https://github.com/apache/flink/pull/15342#issuecomment-804912941 ## CI report: * e326380c43dfcff1776ea50b945f8e80b78297e6 Azure:

[GitHub] [flink] flinkbot commented on pull request #15347: [FLINK-21933][kinesis] EFO consumer treats interrupts as retryable ex…

flinkbot commented on pull request #15347: URL: https://github.com/apache/flink/pull/15347#issuecomment-805083002 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 #15221: [FLINK-17012][streaming] 'RUNNING' state split into 'RUNNING' and 'RE…

flinkbot edited a comment on pull request #15221: URL: https://github.com/apache/flink/pull/15221#issuecomment-799620682 ## CI report: * d844d6cd4b4401534fa00012d46e2f762be68a06 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * 98c5f207e1d006b91be50df6ce1b3e8f45fc795b UNKNOWN * 51a2bfa471abde93d6fa0d040de43f210febc3e1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

flinkbot edited a comment on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-792934307 ## CI report: * 9faba578819a9c7daa47e050dc3dfcdaf76af488 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15132: [FLINK-21698][table-planner] Disable problematic cast conversion between NUMERIC type and TIMESTAMP type

flinkbot edited a comment on pull request #15132: URL: https://github.com/apache/flink/pull/15132#issuecomment-795012449 ## CI report: * b01ec8679ce5ae6879c8dfd57e856bef9d0a8568 UNKNOWN * a3847140a61ed2ecebd6d97dda9bfbbdbbd4451d Azure:

[jira] [Updated] (FLINK-21933) [kinesis][efo] EFO consumer treats interrupts as retryable exceptions

[ https://issues.apache.org/jira/browse/FLINK-21933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21933: --- Labels: pull-request-available (was: ) > [kinesis][efo] EFO consumer treats interrupts as

[GitHub] [flink] dannycranmer opened a new pull request #15347: [FLINK-21933][kinesis] EFO consumer treats interrupts as retryable ex…

dannycranmer opened a new pull request #15347: URL: https://github.com/apache/flink/pull/15347 ## What is the purpose of the change Gracefully handle Interrupted exceptions in Kinesis EFO source consumer. ## Brief change log - Update error handling to treat Interrupted

[GitHub] [flink] StephanEwen commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

StephanEwen commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r599773493 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,265 @@ +/* + * Licensed to

[GitHub] [flink] wsry commented on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-805065015 @StephanEwen I have updated the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #15342: [FLINK-21348] Add tests for AdaptiveScheduler's StateWithExecutionGraph

flinkbot edited a comment on pull request #15342: URL: https://github.com/apache/flink/pull/15342#issuecomment-804912941 ## CI report: * e326380c43dfcff1776ea50b945f8e80b78297e6 Azure:

<    1   2   3   4   5   6   >