[jira] [Updated] (FLINK-21008) Residual HA related Kubernetes ConfigMaps and ZooKeeper nodes when cluster entrypoint received SIGTERM in shutdown

[ https://issues.apache.org/jira/browse/FLINK-21008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21008: -- Fix Version/s: 1.13.0 > Residual HA related Kubernetes ConfigMaps and ZooKeeper nodes when

[jira] [Updated] (FLINK-21008) Residual HA related Kubernetes ConfigMaps and ZooKeeper nodes when cluster entrypoint received SIGTERM in shutdown

[ https://issues.apache.org/jira/browse/FLINK-21008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21008: -- Affects Version/s: 1.13.0 > Residual HA related Kubernetes ConfigMaps and ZooKeeper nodes

[jira] [Commented] (FLINK-21817) New Kafka Source might break subtask and split assignment upon rescale

[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307079#comment-17307079 ] Kezhu Wang commented on FLINK-21817: +1 for gradual procedure. {quote} But we may even skip this for

[jira] [Created] (FLINK-21930) There are some error for hive_read_writer.md

hehuiyuan created FLINK-21930: - Summary: There are some error for hive_read_writer.md Key: FLINK-21930 URL: https://issues.apache.org/jira/browse/FLINK-21930 Project: Flink Issue Type: Wish

[jira] [Assigned] (FLINK-21910) Wrong Checks whether the service has been started.

[ https://issues.apache.org/jira/browse/FLINK-21910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-21910: - Assignee: pengkangjing > Wrong Checks whether the service has been started. >

[jira] [Commented] (FLINK-21045) Improve Usability of Pluggable Modules

[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307074#comment-17307074 ] Jane Chan commented on FLINK-21045: --- Thanks to all of you :D > Improve Usability of Pluggable Modules

[GitHub] [flink] hehuiyuan commented on pull request #15292: [DOC]fix hive dim doc replace o to order

hehuiyuan commented on pull request #15292: URL: https://github.com/apache/flink/pull/15292#issuecomment-804913386 > Thanks @hehuiyuan for fixing the doc. It looks good to me, but you need a jira ticket to associate with your PR. Hi @lirui-apache ,okay i do it. I have

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

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

[jira] [Closed] (FLINK-21550) ZooKeeperHaServicesTest.testSimpleClose fail

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

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

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

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

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

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

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

[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: * 295036f53219c05b7ed3b662a95034dddb56f3b7 Azure:

[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: * f2ef7bcb3464042674dae2b28e739663bbc97e13 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: * 78ff7bb296b43538274bedfc40f459914e7abd00 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: * 225c8fe92a5db0965de7934f945bd56a86966ad9 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 #15117: [FLINK-21655] [table-planner-blink] Fix incorrect simplification for coalesce call on a groupingsets' result

flinkbot edited a comment on pull request #15117: URL: https://github.com/apache/flink/pull/15117#issuecomment-792736135 ## CI report: * 79d036eb98a74f28c87ada0e2be3b6947f94a965 Azure:

[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: * 064626fee15d7580f840e76941c2b2f7ca47e436 Azure:

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

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

[jira] [Closed] (FLINK-21879) ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime fails on AZP

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

[GitHub] [flink] fsk119 commented on a change in pull request #15340: [FLINK-21669][table-api] Support "table.dml-sync" option to execute statement in sync mode

fsk119 commented on a change in pull request #15340: URL: https://github.com/apache/flink/pull/15340#discussion_r599563910 ## File path: flink-table/flink-sql-client/src/test/resources/sql/select.q ## @@ -50,8 +50,38 @@ java.lang.IllegalArgumentException: testing elements of

[GitHub] [flink] tillrohrmann closed pull request #15334: [FLINK-21550][tests] Harden ZooKeeperHaServicesTest.testSimpleClose

tillrohrmann closed pull request #15334: URL: https://github.com/apache/flink/pull/15334 -- 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] tillrohrmann closed pull request #15329: [FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime

tillrohrmann closed pull request #15329: URL: https://github.com/apache/flink/pull/15329 -- 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] fsk119 commented on a change in pull request #15340: [FLINK-21669][table-api] Support "table.dml-sync" option to execute statement in sync mode

fsk119 commented on a change in pull request #15340: URL: https://github.com/apache/flink/pull/15340#discussion_r599563910 ## File path: flink-table/flink-sql-client/src/test/resources/sql/select.q ## @@ -50,8 +50,38 @@ java.lang.IllegalArgumentException: testing elements of

[jira] [Updated] (FLINK-21872) Create a utility to create DataStream API's DataType and Schema

[ https://issues.apache.org/jira/browse/FLINK-21872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21872: --- Labels: pull-request-available (was: ) > Create a utility to create DataStream API's

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

twalthr opened a new pull request #15345: URL: https://github.com/apache/flink/pull/15345 ## What is the purpose of the change Adds a utility that extracts all information required from DataStream API's type information in order to create a table schema. The planner can use this

[GitHub] [flink] fsk119 commented on a change in pull request #15340: [FLINK-21669][table-api] Support "table.dml-sync" option to execute statement in sync mode

fsk119 commented on a change in pull request #15340: URL: https://github.com/apache/flink/pull/15340#discussion_r599563080 ## File path: flink-table/flink-sql-client/src/test/resources/sql/select.q ## @@ -50,8 +50,38 @@ java.lang.IllegalArgumentException: testing elements of

[GitHub] [flink] tillrohrmann commented on pull request #15329: [FLINK-21879][tests] Harden ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime

tillrohrmann commented on pull request #15329: URL: https://github.com/apache/flink/pull/15329#issuecomment-804898686 Thanks for the review @xintongsong. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[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: * f2ef7bcb3464042674dae2b28e739663bbc97e13 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15340: [FLINK-21669][table-api] Support "table.dml-sync" option to execute statement in sync mode

flinkbot edited a comment on pull request #15340: URL: https://github.com/apache/flink/pull/15340#issuecomment-804732503 ## CI report: * bd59806ebbb919d248ed5a7d024313f035431726 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: * c4dbb1db588af03b9686dc2c56f57eaab8cb981c 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: * 225c8fe92a5db0965de7934f945bd56a86966ad9 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 * 3f76d53948e105fa4bb08b78fa0284dcaacb80fd 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:

[GitHub] [flink] wsry commented on pull request #15336: [FLINK-20547][network] Fix inconsistent availability issue of LocalBufferPool

wsry commented on pull request #15336: URL: https://github.com/apache/flink/pull/15336#issuecomment-804896523 @pnowojski Thanks for the review and comments. I have updated the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-21550) ZooKeeperHaServicesTest.testSimpleClose fail

[ https://issues.apache.org/jira/browse/FLINK-21550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21550: -- Fix Version/s: 1.12.3 1.13.0 1.11.4 >

[GitHub] [flink] tillrohrmann commented on pull request #15334: [FLINK-21550][tests] Harden ZooKeeperHaServicesTest.testSimpleClose

tillrohrmann commented on pull request #15334: URL: https://github.com/apache/flink/pull/15334#issuecomment-804896144 Thanks for the review @zentol. The failing test is unrelated. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] wsry commented on a change in pull request #15336: [FLINK-20547][network] Fix inconsistent availability issue of LocalBufferPool

wsry commented on a change in pull request #15336: URL: https://github.com/apache/flink/pull/15336#discussion_r599558320 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java ## @@ -515,6 +518,27 @@ public void

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

flinkbot commented on pull request #15342: URL: https://github.com/apache/flink/pull/15342#issuecomment-804895675 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 commented on pull request #15343: [FLINK-21387][tests] Remove test timeout from DispatcherTest.testNonBlockingJobSubmission and .testInvalidCallDuringInitialization

flinkbot commented on pull request #15343: URL: https://github.com/apache/flink/pull/15343#issuecomment-804895644 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 commented on pull request #15344: [FLINK-21564][tests] Don't call condition or throw exception after condition met for CommonTestUtils.waitUntil

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

[jira] [Commented] (FLINK-21821) Clean up Task/StreamTask cancellation and remove unnecessary concurrency

[ https://issues.apache.org/jira/browse/FLINK-21821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307050#comment-17307050 ] Kezhu Wang commented on FLINK-21821: I am going to close this ticket as there is no more concern

[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=17307049#comment-17307049 ] Till Rohrmann commented on FLINK-21929: --- Another instance:

[jira] [Updated] (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:all-tabpanel ] Till Rohrmann updated FLINK-21929: -- Fix Version/s: 1.13.0 > flink-statebackend-rocksdb crashes with Error occurred in starting

[jira] [Updated] (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:all-tabpanel ] Till Rohrmann updated FLINK-21929: -- Priority: Critical (was: Major) > flink-statebackend-rocksdb crashes with Error occurred in

[GitHub] [flink] rmetzger commented on pull request #15108: [FLINK-21306] Ensure fatal errors always stop the JVM process

rmetzger commented on pull request #15108: URL: https://github.com/apache/flink/pull/15108#issuecomment-804893144 Thanks a lot for your review & sorry for the sloppy mistakes. I could have caught most of the issues myself. -- This is an automated message from the Apache Git Service. To

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

[ https://issues.apache.org/jira/browse/FLINK-21348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21348: --- Labels: pull-request-available (was: ) > Add tests for StateWithExecutionGraph >

[GitHub] [flink] kezhuw commented on pull request #15241: [FLINK-11408][datastream] Fix NPE and lost timer during window merging for ContinuousProcessingTimeTrigger

kezhuw commented on pull request #15241: URL: https://github.com/apache/flink/pull/15241#issuecomment-804891628 @flinkbot attention @kl0u @aljoscha @dawidwys -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] rmetzger commented on a change in pull request #15108: [FLINK-21306] Ensure fatal errors always stop the JVM process

rmetzger commented on a change in pull request #15108: URL: https://github.com/apache/flink/pull/15108#discussion_r599552923 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/util/FlinkSecurityManagerITCase.java ## @@ -0,0 +1,143 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-21564) CommonTestUtils.waitUntilCondition could fail with condition meets before

[ https://issues.apache.org/jira/browse/FLINK-21564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21564: --- Labels: pull-request-available (was: ) > CommonTestUtils.waitUntilCondition could fail

[jira] [Closed] (FLINK-21868) Support StreamExecLookupJoin json serialization/deserialization

[ https://issues.apache.org/jira/browse/FLINK-21868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21868. -- Resolution: Fixed Fixed in 1.13.0: 31df1f31cd8d13f6b22875dfad93cc115393b09f > Support

[jira] [Commented] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times

[ https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307040#comment-17307040 ] Kezhu Wang commented on FLINK-21467: I also think it is part of FLIP-147 [~pnowojski]. I believed

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

kezhuw opened a new pull request #15344: URL: https://github.com/apache/flink/pull/15344 ## What is the purpose of the change Improve `CommonTestUtils.waitUntil` to provide strong guarantee that there will be no condition call or exception after condition met. ## Brief change log

[GitHub] [flink] tillrohrmann opened a new pull request #15343: [FLINK-21387][tests] Remove test timeout from DispatcherTest.testNonBlockingJobSubmission and .testInvalidCallDuringInitialization

tillrohrmann opened a new pull request #15343: URL: https://github.com/apache/flink/pull/15343 The 5s test timeout for the DispatcherTest.testNonBlockingJobSubmission and .testInvalidCallDuringInitialization failed on the CI infrastructure. Therefore, this commit removes these timeouts in

[jira] [Updated] (FLINK-21387) DispatcherTest.testInvalidCallDuringInitialization times out on azp

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

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

rmetzger opened a new pull request #15342: URL: https://github.com/apache/flink/pull/15342 ## What is the purpose of the change Add more tests for StateWithExecutionGraph -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] godfreyhe closed pull request #15318: [FLINK-21868][table-planner-blink]Support StreamExecLookupJoin json serialization/deserialization

godfreyhe closed pull request #15318: URL: https://github.com/apache/flink/pull/15318 -- 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] lirui-apache commented on pull request #15292: [DOC]fix hive dim doc replace o to order

lirui-apache commented on pull request #15292: URL: https://github.com/apache/flink/pull/15292#issuecomment-804881403 Thanks @hehuiyuan for fixing the doc. It looks good to me, but you need a jira ticket to associate with your PR. -- This is an automated message from the Apache Git

[GitHub] [flink] lirui-apache commented on pull request #15274: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist

lirui-apache commented on pull request #15274: URL: https://github.com/apache/flink/pull/15274#issuecomment-804877633 Thanks for updating. The change LGTM. Please also add a test case for it in `HiveCatalogFactoryTest`. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] fsk119 commented on a change in pull request #15340: [FLINK-21669][table-api] Support "table.dml-sync" option to execute statement in sync mode

fsk119 commented on a change in pull request #15340: URL: https://github.com/apache/flink/pull/15340#discussion_r599536931 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala ## @@ -447,6 +447,50 @@ class

[jira] [Closed] (FLINK-21136) Reactive Mode: Adjust timeout behavior in adaptive scheduler

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

[GitHub] [flink] leonardBang commented on pull request #15303: [FLINK-21713][table-api/table-planner] Correct function CURRENT_TIMESTAMP/CURRENT_TIME/CURRENT_DATE/NOW/LOCALTIME/LOCALTIMESTAMP

leonardBang commented on pull request #15303: URL: https://github.com/apache/flink/pull/15303#issuecomment-804875262 Hello, @twalthr Could you have a more look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] rmetzger closed pull request #15159: [FLINK-21136] Adjust timeouts for reactive mode

rmetzger closed pull request #15159: URL: https://github.com/apache/flink/pull/15159 -- 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: * f2ef7bcb3464042674dae2b28e739663bbc97e13 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: * 17c83742085f3561ef2c3924d55d3e9cb99a80cc 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: * 225c8fe92a5db0965de7934f945bd56a86966ad9 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 * 3f76d53948e105fa4bb08b78fa0284dcaacb80fd Azure:

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

Tartarus0zm commented on pull request #15341: URL: https://github.com/apache/flink/pull/15341#issuecomment-804870850 @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] [Created] (FLINK-21929) flink-statebackend-rocksdb crashes with Error occurred in starting fork

Robert Metzger created FLINK-21929: -- Summary: flink-statebackend-rocksdb crashes with Error occurred in starting fork Key: FLINK-21929 URL: https://issues.apache.org/jira/browse/FLINK-21929 Project:

[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: * f2ef7bcb3464042674dae2b28e739663bbc97e13 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: * 61bac18cf324bf4b282471ec37cc6ea05a41ad05 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 * 3f76d53948e105fa4bb08b78fa0284dcaacb80fd Azure:

[jira] [Closed] (FLINK-14973) OSS filesystem does not relocate many dependencies

[ https://issues.apache.org/jira/browse/FLINK-14973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14973. -- Fix Version/s: 1.10.0 Resolution: Fixed > OSS filesystem does not relocate many

[jira] [Reopened] (FLINK-14973) OSS filesystem does not relocate many dependencies

[ https://issues.apache.org/jira/browse/FLINK-14973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-14973: > OSS filesystem does not relocate many dependencies >

[jira] [Commented] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times

[ https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306999#comment-17306999 ] Piotr Nowojski commented on FLINK-21467: Thanks for the explanation [~kezhuw]. For me this will

[jira] [Closed] (FLINK-21621) Support TIMESTAMP_LTZ arithmetic

[ https://issues.apache.org/jira/browse/FLINK-21621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21621. --- Fix Version/s: 1.13.0 Resolution: Fixed Fixed in master: 049f0e9050047044d20daf94cadfa1304c0465ca >

[GitHub] [flink] wuchong closed pull request #15133: [FLINK-21621] [table-planner] Support TIMESTAMP_LTZ arithmetic

wuchong closed pull request #15133: URL: https://github.com/apache/flink/pull/15133 -- 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 #15262: [FLINK-21745][tests] Sets the parallelism in tests to comply to the AdaptiveScheduler requirements

rmetzger commented on pull request #15262: URL: https://github.com/apache/flink/pull/15262#issuecomment-804844906 From this Ci run, it seems that there are still some instabilities: https://dev.azure.com/mapohl/flink/_build/results?buildId=356=results -- This is an automated message

[GitHub] [flink] wuchong commented on a change in pull request #15340: [FLINK-21669][table-api] Support "table.dml-sync" option to execute statement in sync mode

wuchong commented on a change in pull request #15340: URL: https://github.com/apache/flink/pull/15340#discussion_r599484931 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala ## @@ -447,6 +447,50 @@ class

[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: * b43a5ad088cc22393b7a37eedb0f439238cadeec 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: * 0578fc5c92aad3329227e213631cc30854618aec 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 * e05800fbad4314fbfd7e98169cb2df6b8ab91832 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15320: [FLINK-21903][docs-zh] Translate "Importing Flink into an IDE" page into Chinese

flinkbot edited a comment on pull request #15320: URL: https://github.com/apache/flink/pull/15320#issuecomment-803994203 ## CI report: * 3856b3507f621f6d54baebf18b4a40fe3c85b656 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: * 0578fc5c92aad3329227e213631cc30854618aec Azure:

[jira] [Commented] (FLINK-21817) New Kafka Source might break subtask and split assignment upon rescale

[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306985#comment-17306985 ] Stephan Ewen commented on FLINK-21817: -- Thanks for this discussion and the analysis of the

[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: * 9c04151c7d132aa6e6be59a7f97cf3bcef6597bc Azure:

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

dianfu commented on a change in pull request #15337: URL: https://github.com/apache/flink/pull/15337#discussion_r599471761 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/ManagedMemoryUtils.java ## @@ -155,4 +157,20 @@ public static

[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_r599464165 ## File path: flink-core/src/main/java/org/apache/flink/api/common/operators/CollectionExecutor.java ## @@ -110,7 +111,7 @@ public JobExecutionResult

[jira] [Assigned] (FLINK-21927) ExpressionReducer compile fail when running long term

[ https://issues.apache.org/jira/browse/FLINK-21927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-21927: Assignee: MaChengLong > ExpressionReducer compile fail when running long term >

[jira] [Commented] (FLINK-21927) ExpressionReducer compile fail when running long term

[ https://issues.apache.org/jira/browse/FLINK-21927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306971#comment-17306971 ] Timo Walther commented on FLINK-21927: -- [~xmarker] thanks for working on this. I will assign this

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

xintongsong commented on a change in pull request #15337: URL: https://github.com/apache/flink/pull/15337#discussion_r599461642 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/ManagedMemoryUtils.java ## @@ -155,4 +157,20 @@ public static

[GitHub] [flink] xintongsong 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

xintongsong commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r599453245 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ## @@ -513,6 +513,28 @@

[GitHub] [flink] pnowojski commented on a change in pull request #15336: [FLINK-20547][network] Fix inconsistent availability issue of LocalBufferPool

pnowojski commented on a change in pull request #15336: URL: https://github.com/apache/flink/pull/15336#discussion_r599455125 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java ## @@ -435,6 +435,7 @@ private boolean

[GitHub] [flink] flinkbot edited a comment on pull request #15319: [FLINK-21751] Eagerly issue release calls from RM if JM disconnects for terminal job

flinkbot edited a comment on pull request #15319: URL: https://github.com/apache/flink/pull/15319#issuecomment-803982383 ## CI report: * eb2822af636368eaa734582d260dc9d629d0ed78 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: * 7e24f4345e54fb86e29008e45ddefd52de86c2c1 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: * 9c04151c7d132aa6e6be59a7f97cf3bcef6597bc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15273: [FLINK-21800][core] Guard MemorySegment against concurrent frees.

flinkbot edited a comment on pull request #15273: URL: https://github.com/apache/flink/pull/15273#issuecomment-802508808 ## CI report: * d25b8d14546059db78a2ae8d391043604b729be8 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: * 225c8fe92a5db0965de7934f945bd56a86966ad9 Azure:

[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: * f2ef7bcb3464042674dae2b28e739663bbc97e13 Azure:

<    1   2   3   4   5   6   >