[GitHub] [flink] flinkbot edited a comment on pull request #15294: [FLINK-21945][streaming] Omit pointwise connections from checkpointing in unaligned checkpoints.

flinkbot edited a comment on pull request #15294: URL: https://github.com/apache/flink/pull/15294#issuecomment-803058203 ## CI report: * b22d2cdd4e457842b585e64089858a0ae8eb9a2b UNKNOWN * 6bff4c2e3485c8f0dd09b872652c6a7958836e7f UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15294: [FLINK-21945][streaming] Omit pointwise connections from checkpointing in unaligned checkpoints.

flinkbot edited a comment on pull request #15294: URL: https://github.com/apache/flink/pull/15294#issuecomment-803058203 ## CI report: * b22d2cdd4e457842b585e64089858a0ae8eb9a2b UNKNOWN * 6bff4c2e3485c8f0dd09b872652c6a7958836e7f UNKNOWN *

[jira] [Created] (FLINK-22020) Reflections ClassNotFound when trying to deserialize a json plan in deployment envrionment

Wenlong Lyu created FLINK-22020: --- Summary: Reflections ClassNotFound when trying to deserialize a json plan in deployment envrionment Key: FLINK-22020 URL: https://issues.apache.org/jira/browse/FLINK-22020

[jira] [Commented] (FLINK-21748) LocalExecutorITCase.testBatchQueryExecutionMultipleTimes[Planner: old] fails

[ https://issues.apache.org/jira/browse/FLINK-21748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311082#comment-17311082 ] Jark Wu commented on FLINK-21748: - Will take a look. >

[GitHub] [flink] wenlong88 opened a new pull request #15423: [FLINK-22020][table-planner-blink] Add org.reflections to include list of maven shade plugin

wenlong88 opened a new pull request #15423: URL: https://github.com/apache/flink/pull/15423 ## What is the purpose of the change this is a hotfix adding org.reflections:reflections to include list of maven shade plugin just like how we treat com.ibm.icu:icu4j ## Brief change

[GitHub] [flink] wuchong merged pull request #15208: [hotfix][docs] Added missing state descriptor (AggregatingStateDescriptor) to docs

wuchong merged pull request #15208: URL: https://github.com/apache/flink/pull/15208 -- 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] wsry commented on pull request #15259: [FLINK-20757][network] Optimize data broadcast for sort-merge blocking shuffle

wsry commented on pull request #15259: URL: https://github.com/apache/flink/pull/15259#issuecomment-809877286 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] wsry commented on pull request #15259: [FLINK-20757][network] Optimize data broadcast for sort-merge blocking shuffle

wsry commented on pull request #15259: URL: https://github.com/apache/flink/pull/15259#issuecomment-809877143 > Well, I just noticed that the CI fails on `SortMergeResultPartitionTest.testRelease`. > Please take a look. Thanks for the reminder, I have updated the PR. -- This

[GitHub] [flink] flinkbot edited a comment on pull request #15247: [FLINK-21833][Table SQL / Runtime] TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge RowDa

flinkbot edited a comment on pull request #15247: URL: https://github.com/apache/flink/pull/15247#issuecomment-800773807 ## CI report: * 277437178141c1c0b18a435ca30084c58b8b0906 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15366: [FLINK-12828][sql-client] Support -f option with a sql script as input

flinkbot edited a comment on pull request #15366: URL: https://github.com/apache/flink/pull/15366#issuecomment-806388017 ## CI report: * 347d38bc59e3ffa1d3854da26163c2170c2f6986 UNKNOWN * 22e28abf69c6b0e4736ed91b2eda832be6dc42d3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15400: [FLINK-20557][sql-client] Support STATEMENT SET in SQL CLI

flinkbot edited a comment on pull request #15400: URL: https://github.com/apache/flink/pull/15400#issuecomment-808939586 ## CI report: * 4bea1912f0d0ff6f5d37317c462e98d06daffda4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15259: [FLINK-20757][network] Optimize data broadcast for sort-merge blocking shuffle

flinkbot edited a comment on pull request #15259: URL: https://github.com/apache/flink/pull/15259#issuecomment-801679503 ## CI report: * Unknown: [CANCELED](TBD) * 3c259ceea05f7bdb8860f94c9db585b4310db2e5 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #15280: [FLINK-21714][table-api] Use TIMESTAMP_LTZ as return type for function PROCTIME()

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

[GitHub] [flink] flinkbot edited a comment on pull request #15415: [FLINK-21148][tests] Fixes instability in YARN's detached-mode ITCases

flinkbot edited a comment on pull request #15415: URL: https://github.com/apache/flink/pull/15415#issuecomment-809344230 ## CI report: * a7ef92d81b3610d66a89f110b965bc7f2b034853 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * 0b5aaf42f2861a38e26a80e25cf2324e7cf06bb7 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15294: [FLINK-21945][streaming] Omit pointwise connections from checkpointing in unaligned checkpoints.

flinkbot edited a comment on pull request #15294: URL: https://github.com/apache/flink/pull/15294#issuecomment-803058203 ## CI report: * b22d2cdd4e457842b585e64089858a0ae8eb9a2b UNKNOWN * 6bff4c2e3485c8f0dd09b872652c6a7958836e7f UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15314: [FLINK-21332][runtime] Optimize releasing result partitions in RegionPartitionReleaseStrategy

flinkbot edited a comment on pull request #15314: URL: https://github.com/apache/flink/pull/15314#issuecomment-803903444 ## CI report: * e50463182d1e1a09cb7d657d515fbbef60bdb668 UNKNOWN * cd29b7245f0c2db5c087355e6cc1f2e7d537d8e5 Azure:

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

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

[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-809764484 @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

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

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

[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-809784745 @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

[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-809810055 @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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * 0b5aaf42f2861a38e26a80e25cf2324e7cf06bb7 UNKNOWN *

[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: * 91ecb010b1cc27e680041e03e0012eeab8ae1ad1 UNKNOWN * a56563a6a480a6caa1645326a63abc445354bdcb UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * 0b5aaf42f2861a38e26a80e25cf2324e7cf06bb7 UNKNOWN *

[jira] [Updated] (FLINK-22020) Reflections ClassNotFound when trying to deserialize a json plan in deployment envrionment

[ https://issues.apache.org/jira/browse/FLINK-22020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22020: --- Labels: pull-request-available (was: ) > Reflections ClassNotFound when trying to

[GitHub] [flink] zicat commented on a change in pull request #15247: [FLINK-21833][Table SQL / Runtime] TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge Row

zicat commented on a change in pull request #15247: URL: https://github.com/apache/flink/pull/15247#discussion_r603744434 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/TemporalRowTimeJoinOperator.java

[jira] [Updated] (FLINK-22021) PushFilterIntoLegacyTableSourceScanRule fails to deal with INTERVAL types

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

[GitHub] [flink] flinkbot commented on pull request #15422: [hotfix][ui] Remove unrelated UI backpressure console logs

flinkbot commented on pull request #15422: URL: https://github.com/apache/flink/pull/15422#issuecomment-809740746 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 #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * 0b5aaf42f2861a38e26a80e25cf2324e7cf06bb7 UNKNOWN *

[GitHub] [flink] vthinkxie commented on a change in pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

vthinkxie commented on a change in pull request #15054: URL: https://github.com/apache/flink/pull/15054#discussion_r603726822 ## File path: flink-runtime-web/web-dashboard/src/app/share/customize/flame-graph/flame-graph.component.html ## @@ -0,0 +1,23 @@ + + + + + + {{

[GitHub] [flink] vthinkxie commented on a change in pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

vthinkxie commented on a change in pull request #15054: URL: https://github.com/apache/flink/pull/15054#discussion_r603726822 ## File path: flink-runtime-web/web-dashboard/src/app/share/customize/flame-graph/flame-graph.component.html ## @@ -0,0 +1,23 @@ + + + + + + {{

[jira] [Updated] (FLINK-22020) Reflections ClassNotFound when trying to deserialize a json plan in deployment envrionment

[ https://issues.apache.org/jira/browse/FLINK-22020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-22020: Description: after some investigation, I found that it is because we can don't include

[GitHub] [flink] wsry commented on a change in pull request #15259: [FLINK-20757][network] Optimize data broadcast for sort-merge blocking shuffle

wsry commented on a change in pull request #15259: URL: https://github.com/apache/flink/pull/15259#discussion_r603742889 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartitionTest.java ## @@ -246,6 +257,36 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #15247: [FLINK-21833][Table SQL / Runtime] TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge RowDa

flinkbot edited a comment on pull request #15247: URL: https://github.com/apache/flink/pull/15247#issuecomment-800773807 ## CI report: * 541ea59b3f5cc4d81da59b3a72effe533f7f041b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15280: [FLINK-21714][table-api] Use TIMESTAMP_LTZ as return type for function PROCTIME()

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

[GitHub] [flink] carp84 commented on pull request #15016: [FLINK-21413][state] Clean TtlMapState and TtlListState after all elements are expired

carp84 commented on pull request #15016: URL: https://github.com/apache/flink/pull/15016#issuecomment-809872667 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] carp84 commented on pull request #15016: [FLINK-21413][state] Clean TtlMapState and TtlListState after all elements are expired

carp84 commented on pull request #15016: URL: https://github.com/apache/flink/pull/15016#issuecomment-809872620 We need to get a green build to commit the change, let me trigger another pre-commit run, will merge it once the build passes. -- This is an automated message from the Apache

[GitHub] [flink] wuchong commented on a change in pull request #15412: [FLINK-21881][table-planner-blink] Support local global optimization for window aggregation in plan

wuchong commented on a change in pull request #15412: URL: https://github.com/apache/flink/pull/15412#discussion_r603754802 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecWindowAggregateBase.java

[jira] [Commented] (FLINK-22019) UnalignedCheckpointRescaleITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17310986#comment-17310986 ] Arvid Heise commented on FLINK-22019: - Since there are no logs, there is not much I can do now. I

[GitHub] [flink] afedulov edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

afedulov edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-809002850 @zentol regarding https://github.com/apache/flink/pull/15054#discussion_r602410226 > This code would be easier to test if it wouldn't specifically require a

[GitHub] [flink] afedulov edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

afedulov edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-809724180 Regarding https://github.com/apache/flink/pull/15054#discussion_r602410226 > >Which class/interface do you mean by "TM"? > TaskExecutorGateway This seems

[GitHub] [flink] flinkbot edited a comment on pull request #15412: [FLINK-21881][table-planner-blink] Support local global optimization for window aggregation in plan

flinkbot edited a comment on pull request #15412: URL: https://github.com/apache/flink/pull/15412#issuecomment-809220432 ## CI report: * fa838b58283d117a53d2ef0bde9f51c53586793d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15366: [FLINK-12828][sql-client] Support -f option with a sql script as input

flinkbot edited a comment on pull request #15366: URL: https://github.com/apache/flink/pull/15366#issuecomment-806388017 ## CI report: * 347d38bc59e3ffa1d3854da26163c2170c2f6986 UNKNOWN * 22e28abf69c6b0e4736ed91b2eda832be6dc42d3 Azure:

[GitHub] [flink] afedulov commented on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

afedulov commented on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-809752343 @zentol question: by the fact that timeouts are always passed, but are never explicitly addressed in the method calls, I assume that they are handled by the underlying RPC

[GitHub] [flink] afedulov commented on a change in pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

afedulov commented on a change in pull request #15054: URL: https://github.com/apache/flink/pull/15054#discussion_r603656650 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -497,6 +505,32 @@ private void

[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: * 91ecb010b1cc27e680041e03e0012eeab8ae1ad1 UNKNOWN * Unknown: [CANCELED](TBD) * a56563a6a480a6caa1645326a63abc445354bdcb UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15419: [FLINK-22018][Connectors/JDBC] Remove error log on retries in JdbcBatchingOutputFormat

flinkbot edited a comment on pull request #15419: URL: https://github.com/apache/flink/pull/15419#issuecomment-809453567 ## CI report: * bb88aa2af55280905d4067807b232a7d9c6ca4f5 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: * 91ecb010b1cc27e680041e03e0012eeab8ae1ad1 UNKNOWN * Unknown: [CANCELED](TBD) * a56563a6a480a6caa1645326a63abc445354bdcb UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15405: [Flink-21976] Remove Flink ML pipeline API and library code from the Flink repo

flinkbot edited a comment on pull request #15405: URL: https://github.com/apache/flink/pull/15405#issuecomment-809101943 ## CI report: * ebab717d3df103b1c3d2546735c039567f31f0f5 Azure:

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

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

[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-809835162 @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] [Resolved] (FLINK-21976) Move Flink ML pipeline API and library code to a separate repository named flink-ml

[ https://issues.apache.org/jira/browse/FLINK-21976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-21976. -- Assignee: Dong Lin Resolution: Done The flink-ml repo has been created and the code

[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: * 91ecb010b1cc27e680041e03e0012eeab8ae1ad1 UNKNOWN * a56563a6a480a6caa1645326a63abc445354bdcb UNKNOWN *

[jira] [Commented] (FLINK-22010) when flink executed union all opeators,exception occured

[ https://issues.apache.org/jira/browse/FLINK-22010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311083#comment-17311083 ] HunterHunter commented on FLINK-22010: -- Could not allocate 16777216 bytes, only 0 bytes are

[jira] [Updated] (FLINK-22020) Reflections ClassNotFound when trying to deserialize a json plan in deployment envrionment

[ https://issues.apache.org/jira/browse/FLINK-22020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-22020: Attachment: error_log.png > Reflections ClassNotFound when trying to deserialize a json plan in

[GitHub] [flink] Jiayi-Liao commented on pull request #15016: [FLINK-21413][state] Clean TtlMapState and TtlListState after all elements are expired

Jiayi-Liao commented on pull request #15016: URL: https://github.com/apache/flink/pull/15016#issuecomment-809859267 The error of CI should be unrelated. ``` Mar 29 07:53:23 Error: Could not find or load main class

[GitHub] [flink] KurtYoung merged pull request #15384: [FLINK-21590][conf][log4j] Avoid hive logs in the SQL client console

KurtYoung merged pull request #15384: URL: https://github.com/apache/flink/pull/15384 -- 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,

[jira] [Commented] (FLINK-22006) Could not run more than 20 jobs in a native K8s session when K8s HA enabled

[ https://issues.apache.org/jira/browse/FLINK-22006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17311097#comment-17311097 ] Yang Wang commented on FLINK-22006: --- Thanks for the confirmation. I will start to work on this by

[GitHub] [flink] zhuzhurk commented on a change in pull request #15259: [FLINK-20757][network] Optimize data broadcast for sort-merge blocking shuffle

zhuzhurk commented on a change in pull request #15259: URL: https://github.com/apache/flink/pull/15259#discussion_r603747563 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -362,7 +396,10 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #15016: [FLINK-21413][state] Clean TtlMapState and TtlListState after all elements are expired

flinkbot edited a comment on pull request #15016: URL: https://github.com/apache/flink/pull/15016#issuecomment-785640058 ## CI report: * b4862f8a8e8dab12ec9c0d71d8a31152cb212ebc Azure:

[jira] [Assigned] (FLINK-22021) PushFilterIntoLegacyTableSourceScanRule fails to deal with INTERVAL types

[ https://issues.apache.org/jira/browse/FLINK-22021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-22021: Assignee: Caizhi Weng > PushFilterIntoLegacyTableSourceScanRule fails to deal with

[GitHub] [flink] flinkbot commented on pull request #15424: [FLINK-22021][table-planner-blink] Fix exception when PushFilterIntoLegacyTableSourceScanRule is faced with INTERVAL types

flinkbot commented on pull request #15424: URL: https://github.com/apache/flink/pull/15424#issuecomment-809884356 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] lirui-apache commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

lirui-apache commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r603759600 ## File path: flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java ## @@ -108,6 +108,19 @@

[GitHub] [flink] zicat commented on a change in pull request #15247: [FLINK-21833][Table SQL / Runtime] TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge Row

zicat commented on a change in pull request #15247: URL: https://github.com/apache/flink/pull/15247#discussion_r603744434 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/TemporalRowTimeJoinOperator.java

[GitHub] [flink] afedulov opened a new pull request #15422: [hotfix][ui] Remove unrelated UI backpressure console logs

afedulov opened a new pull request #15422: URL: https://github.com/apache/flink/pull/15422 This seems to have been accidentally left over during the development. It unnecessarily pollutes the browser logs. -- This is an automated message from the Apache Git Service. To respond to the

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

austince commented on a change in pull request #15348: URL: https://github.com/apache/flink/pull/15348#discussion_r603646853 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointMetadataLoadingTest.java ## @@ -213,7 +214,7 @@ private static

[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: * 91ecb010b1cc27e680041e03e0012eeab8ae1ad1 UNKNOWN * b15ae8f14a5b8525bdbd040f1305d2029e497f56 Azure:

[GitHub] [flink] flinkbot commented on pull request #15422: [hotfix][ui] Remove unrelated UI backpressure console logs

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

[GitHub] [flink] afedulov commented on a change in pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

afedulov commented on a change in pull request #15054: URL: https://github.com/apache/flink/pull/15054#discussion_r603675376 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/messages/ThreadInfoSample.java ## @@ -0,0 +1,285 @@ +/* + * Licensed to the Apache

[GitHub] [flink] becketqin merged pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

becketqin merged pull request #15161: URL: https://github.com/apache/flink/pull/15161 -- 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] becketqin commented on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

becketqin commented on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-809801052 Merged to master. 8d2fa1bb81eff790bdc21a69d15a17aa074010ae -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot commented on pull request #15423: [FLINK-22020][table-planner-blink] Add org.reflections to include list of maven shade plugin

flinkbot commented on pull request #15423: URL: https://github.com/apache/flink/pull/15423#issuecomment-809863566 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] [Created] (FLINK-22021) PushFilterIntoLegacyTableSourceScanRule fails to deal with INTERVAL types

Caizhi Weng created FLINK-22021: --- Summary: PushFilterIntoLegacyTableSourceScanRule fails to deal with INTERVAL types Key: FLINK-22021 URL: https://issues.apache.org/jira/browse/FLINK-22021 Project:

[GitHub] [flink] KurtYoung commented on a change in pull request #15366: [FLINK-12828][sql-client] Support -f option with a sql script as input

KurtYoung commented on a change in pull request #15366: URL: https://github.com/apache/flink/pull/15366#discussion_r603735057 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java ## @@ -250,50 +253,78 @@ public void close()

[GitHub] [flink] flinkbot edited a comment on pull request #15294: [FLINK-21945][streaming] Omit pointwise connections from checkpointing in unaligned checkpoints.

flinkbot edited a comment on pull request #15294: URL: https://github.com/apache/flink/pull/15294#issuecomment-803058203 ## CI report: * b22d2cdd4e457842b585e64089858a0ae8eb9a2b UNKNOWN * 6bff4c2e3485c8f0dd09b872652c6a7958836e7f UNKNOWN *

[GitHub] [flink] afedulov commented on a change in pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

afedulov commented on a change in pull request #15054: URL: https://github.com/apache/flink/pull/15054#discussion_r603678032 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/ThreadInfoSampleService.java ## @@ -0,0 +1,107 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * 0b5aaf42f2861a38e26a80e25cf2324e7cf06bb7 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #15412: [FLINK-21881][table-planner-blink] Support local global optimization for window aggregation in plan

flinkbot edited a comment on pull request #15412: URL: https://github.com/apache/flink/pull/15412#issuecomment-809220432 ## CI report: * fa838b58283d117a53d2ef0bde9f51c53586793d Azure:

[GitHub] [flink] zicat commented on a change in pull request #15247: [FLINK-21833][Table SQL / Runtime] TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge Row

zicat commented on a change in pull request #15247: URL: https://github.com/apache/flink/pull/15247#discussion_r603744434 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/TemporalRowTimeJoinOperator.java

[GitHub] [flink] wsry commented on pull request #15259: [FLINK-20757][network] Optimize data broadcast for sort-merge blocking shuffle

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

[jira] [Closed] (FLINK-21590) Avoid hive logs in the SQL client console

[ https://issues.apache.org/jira/browse/FLINK-21590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21590. -- Assignee: Rui Li Resolution: Fixed fixed in: b3b8abbb98b68422693dbf59bb26ed82c8ac0fec > Avoid

[GitHub] [flink] fsk119 commented on a change in pull request #15366: [FLINK-12828][sql-client] Support -f option with a sql script as input

fsk119 commented on a change in pull request #15366: URL: https://github.com/apache/flink/pull/15366#discussion_r603749496 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java ## @@ -197,4 +219,14 @@ public void

[GitHub] [flink] fsk119 commented on a change in pull request #15366: [FLINK-12828][sql-client] Support -f option with a sql script as input

fsk119 commented on a change in pull request #15366: URL: https://github.com/apache/flink/pull/15366#discussion_r603749496 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java ## @@ -197,4 +219,14 @@ public void

[jira] [Assigned] (FLINK-22004) Translate Flink Roadmap to Chinese.

[ https://issues.apache.org/jira/browse/FLINK-22004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-22004: - Assignee: Yuan Mei Thanks for following this up [~ym], assigned to you. > Translate Flink Roadmap to

[jira] [Assigned] (FLINK-12828) Support -f option with a sql script file as input

[ https://issues.apache.org/jira/browse/FLINK-12828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-12828: -- Assignee: Shengkai Fang (was: Zhenghua Gao) > Support -f option with a sql script file as

[GitHub] [flink] KurtYoung closed pull request #8727: [FLINK-12828][sql-client] Support -f option with a sql script file as…

KurtYoung closed pull request #8727: URL: https://github.com/apache/flink/pull/8727 -- 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 #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

flinkbot edited a comment on pull request #15054: URL: https://github.com/apache/flink/pull/15054#issuecomment-788337524 ## CI report: * 26a28f2d83f56cb386e1365fd4df4fb8a2f2bf86 UNKNOWN * 0b5aaf42f2861a38e26a80e25cf2324e7cf06bb7 UNKNOWN *

[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: * 91ecb010b1cc27e680041e03e0012eeab8ae1ad1 UNKNOWN * Unknown: [CANCELED](TBD) * a56563a6a480a6caa1645326a63abc445354bdcb UNKNOWN *

[GitHub] [flink] vthinkxie commented on a change in pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

vthinkxie commented on a change in pull request #15054: URL: https://github.com/apache/flink/pull/15054#discussion_r603727674 ## File path: flink-runtime-web/web-dashboard/src/app/share/customize/flame-graph/flame-graph.component.ts ## @@ -0,0 +1,69 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #15400: [FLINK-20557][sql-client] Support STATEMENT SET in SQL CLI

flinkbot edited a comment on pull request #15400: URL: https://github.com/apache/flink/pull/15400#issuecomment-808939586 ## CI report: * 4bea1912f0d0ff6f5d37317c462e98d06daffda4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15412: [FLINK-21881][table-planner-blink] Support local global optimization for window aggregation in plan

flinkbot edited a comment on pull request #15412: URL: https://github.com/apache/flink/pull/15412#issuecomment-809220432 ## CI report: * fa838b58283d117a53d2ef0bde9f51c53586793d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15416: [FLINK-21842][python] Support user defined WindowAssigner, Trigger and ProcessWindowFunction on Python DataStream API

flinkbot edited a comment on pull request #15416: URL: https://github.com/apache/flink/pull/15416#issuecomment-809357174 ## CI report: * 542206aac31ccfc366b0a6a567d40cd256c3448d Azure:

[GitHub] [flink] flinkbot commented on pull request #15423: [FLINK-22020][table-planner-blink] Add org.reflections to include list of maven shade plugin

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

[GitHub] [flink] flinkbot edited a comment on pull request #15423: [FLINK-22020][table-planner-blink] Add org.reflections to include list of maven shade plugin

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

[GitHub] [flink] flinkbot edited a comment on pull request #15416: [FLINK-21842][python] Support user defined WindowAssigner, Trigger and ProcessWindowFunction on Python DataStream API

flinkbot edited a comment on pull request #15416: URL: https://github.com/apache/flink/pull/15416#issuecomment-809357174 ## CI report: * 542206aac31ccfc366b0a6a567d40cd256c3448d Azure:

[GitHub] [flink] afedulov commented on a change in pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

afedulov commented on a change in pull request #15054: URL: https://github.com/apache/flink/pull/15054#discussion_r603616776 ## File path: flink-core/src/main/java/org/apache/flink/configuration/WebOptions.java ## @@ -156,6 +156,48 @@

[GitHub] [flink] afedulov commented on a change in pull request #15054: [FLINK-13550][runtime][ui] Operator's Flame Graph

afedulov commented on a change in pull request #15054: URL: https://github.com/apache/flink/pull/15054#discussion_r603656650 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -497,6 +505,32 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #15422: [hotfix][ui] Remove unrelated UI backpressure console logs

flinkbot edited a comment on pull request #15422: URL: https://github.com/apache/flink/pull/15422#issuecomment-809751035 ## CI report: * e0a46f4f0452270002214cca49564200795820c2 Azure:

  1   2   3   4   5   6   7   >