[GitHub] [flink-benchmarks] pnowojski merged pull request #12: [hotfix] Fix Readme instructions that are easy to break

pnowojski merged pull request #12: URL: https://github.com/apache/flink-benchmarks/pull/12 -- 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] [Created] (FLINK-22007) PartitionReleaseInBatchJobBenchmarkExecutor seems to be failing

Piotr Nowojski created FLINK-22007: -- Summary: PartitionReleaseInBatchJobBenchmarkExecutor seems to be failing Key: FLINK-22007 URL: https://issues.apache.org/jira/browse/FLINK-22007 Project: Flink

[GitHub] [flink-benchmarks] pnowojski commented on pull request #12: [hotfix] Fix Readme instructions that are easy to break

pnowojski commented on pull request #12: URL: https://github.com/apache/flink-benchmarks/pull/12#issuecomment-809122082 Build failure looks unrelated: https://issues.apache.org/jira/browse/FLINK-22007 -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] twalthr commented on pull request #15406: [FLINK-21998][hive] Copy more code from hive and move them to a dedicated package

twalthr commented on pull request #15406: URL: https://github.com/apache/flink/pull/15406#issuecomment-809120847 @lirui-apache could you give the community more context about this change in the JIRA issue? I think most people in the Flink community would immediately reject copying more cod

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

gaoyunhaii commented on a change in pull request #15259: URL: https://github.com/apache/flink/pull/15259#discussion_r602998872 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -94,11 +94,17 @@ */

[GitHub] [flink] XComp commented on pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

XComp commented on pull request #15020: URL: https://github.com/apache/flink/pull/15020#issuecomment-809117295 Ok, thanks @SteNicholas . I'll give it another pass when you're done. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot commented on pull request #15406: [FLINK-21998][hive] Copy more code from hive and move them to a dedicated package

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

[GitHub] [flink] flinkbot edited a comment on pull request #15405: [Flink-21976] Move Flink ML pipeline API and library code to a separate repository named flink-ml

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

[jira] [Updated] (FLINK-16641) Announce sender's backlog to solve the deadlock issue without exclusive buffers

[ https://issues.apache.org/jira/browse/FLINK-16641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16641: Fix Version/s: (was: 1.13.0) 1.14.0 > Announce sender's backlog to solve th

[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 * de78d0128017c7ad13d93cd5ba30f94ec516c5f1 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16012: Fix Version/s: (was: 1.13.0) 1.14.0 > Reduce the default number of exclusiv

[jira] [Updated] (FLINK-18762) Make network buffers per incoming/outgoing channel can be configured separately

[ https://issues.apache.org/jira/browse/FLINK-18762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-18762: Fix Version/s: (was: 1.13.0) 1.14.0 > Make network buffers per incoming/out

[jira] [Updated] (FLINK-16428) Fine-grained network buffer management for backpressure

[ https://issues.apache.org/jira/browse/FLINK-16428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-16428: Fix Version/s: (was: 1.13.0) 1.14.0 > Fine-grained network buffer managemen

[jira] [Commented] (FLINK-16428) Fine-grained network buffer management for backpressure

[ https://issues.apache.org/jira/browse/FLINK-16428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310448#comment-17310448 ] Yingjie Cao commented on FLINK-16428: - Though the PR is ready, I guess we do not hav

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

[GitHub] [flink] flinkbot edited a comment on pull request #13025: [FLINK-18762][network] Make network buffers per incoming/outgoing channel can be configured separately

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

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

[ https://issues.apache.org/jira/browse/FLINK-22006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-22006: -- Labels: k8s-ha (was: ) > Could not run more than 20 jobs in a native K8s session with K8s HA enabled

[jira] [Updated] (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:all-tabpanel ] Yang Wang updated FLINK-22006: -- Description: Currently, if we start a native K8s session cluster when K8s HA enabled, we could not ru

[jira] [Updated] (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:all-tabpanel ] Yang Wang updated FLINK-22006: -- Summary: Could not run more than 20 jobs in a native K8s session when K8s HA enabled (was: Could not

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

Jiayi-Liao commented on a change in pull request #15016: URL: https://github.com/apache/flink/pull/15016#discussion_r603040907 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlStateTestBase.java ## @@ -471,6 +473,26 @@ public void testRestoreTtl

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

[ https://issues.apache.org/jira/browse/FLINK-22006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-22006: -- Component/s: Runtime / Coordination > Could not run more than 20 jobs in a native K8s session with K8s

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

Yang Wang created FLINK-22006: - Summary: Could not run more than 20 jobs in a native K8s session with K8s HA enabled Key: FLINK-22006 URL: https://issues.apache.org/jira/browse/FLINK-22006 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-22006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-22006: -- Attachment: image-2021-03-24-18-08-42-116.png > Could not run more than 20 jobs in a native K8s sessio

[GitHub] [flink] flinkbot commented on pull request #15406: [FLINK-21998][hive] Copy more code from hive and move them to a dedicated package

flinkbot commented on pull request #15406: URL: https://github.com/apache/flink/pull/15406#issuecomment-809105749 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Assigned] (FLINK-21942) KubernetesLeaderRetrievalDriver not closed after terminated which lead to connection leak

[ https://issues.apache.org/jira/browse/FLINK-21942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-21942: - Assignee: Yang Wang > KubernetesLeaderRetrievalDriver not closed after terminated which lead to

[jira] [Updated] (FLINK-21998) Copy more code from hive and move them to a dedicated package

[ https://issues.apache.org/jira/browse/FLINK-21998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21998: --- Labels: pull-request-available (was: ) > Copy more code from hive and move them to a dedica

[GitHub] [flink] lirui-apache opened a new pull request #15406: [FLINK-21998][hive] Copy more code from hive and move them to a dedicated package

lirui-apache opened a new pull request #15406: URL: https://github.com/apache/flink/pull/15406 ## What is the purpose of the change Copy more code from hive and move them to a dedicated package ## Brief change log - Move the copied hive classes to package

[jira] [Commented] (FLINK-21942) KubernetesLeaderRetrievalDriver not closed after terminated which lead to connection leak

[ https://issues.apache.org/jira/browse/FLINK-21942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310438#comment-17310438 ] Yang Wang commented on FLINK-21942: --- I will attach a PR for this issue. It will solve

[GitHub] [flink] flinkbot commented on pull request #15405: [Flink-21976] Move Flink ML pipeline API and library code to a separate repository named flink-ml

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

[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 * 19964baf25121c6f0a4f85d75ffcc568d98dcdaa Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15253: [FLINK-21808][hive] Support DQL/DML in HiveParser

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

[GitHub] [flink] flinkbot edited a comment on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

flinkbot edited a comment on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-797177953 ## CI report: * d3f59e302b9860d49ce79252aeb8bd1decaeeabf UNKNOWN * 6fc6cc9a2e6c26e9e8fa62b481237231394078eb Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #13025: [FLINK-18762][network] Make network buffers per incoming/outgoing channel can be configured separately

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

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

Myasuka commented on a change in pull request #15016: URL: https://github.com/apache/flink/pull/15016#discussion_r603034801 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlStateTestBase.java ## @@ -471,6 +473,26 @@ public void testRestoreTtlAnd

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

Myasuka commented on a change in pull request #15016: URL: https://github.com/apache/flink/pull/15016#discussion_r603034801 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlStateTestBase.java ## @@ -471,6 +473,26 @@ public void testRestoreTtlAnd

[GitHub] [flink] flinkbot commented on pull request #15405: [Flink-21976] Move Flink ML pipeline API and library code to a separate repository named flink-ml

flinkbot commented on pull request #15405: URL: https://github.com/apache/flink/pull/15405#issuecomment-809095000 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] lindong28 opened a new pull request #15405: [Flink-21976 ] Move Flink ML pipeline API and library code to a separate repository named flink-ml

lindong28 opened a new pull request #15405: URL: https://github.com/apache/flink/pull/15405 ## What is the purpose of the change Remove ML pipeline API and library code from Flink so that we can later add them to https://github.com/apache/flink-ml. ## Brief change log -

[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 * 19964baf25121c6f0a4f85d75ffcc568d98dcdaa Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15253: [FLINK-21808][hive] Support DQL/DML in HiveParser

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

[GitHub] [flink] flinkbot edited a comment on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

flinkbot edited a comment on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-797177953 ## CI report: * d3f59e302b9860d49ce79252aeb8bd1decaeeabf UNKNOWN * 6fc6cc9a2e6c26e9e8fa62b481237231394078eb Azure: [FAILURE](https://dev.azure.com/apache-fl

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

[jira] [Commented] (FLINK-21906) Support computed column syntax for Hive DDL dialect

[ https://issues.apache.org/jira/browse/FLINK-21906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310429#comment-17310429 ] Jark Wu commented on FLINK-21906: - Thanks [~hackergin], I assigned this issue to you. >

[jira] [Assigned] (FLINK-21906) Support computed column syntax for Hive DDL dialect

[ https://issues.apache.org/jira/browse/FLINK-21906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21906: --- Assignee: jinfeng > Support computed column syntax for Hive DDL dialect > -

[GitHub] [flink] SteNicholas commented on pull request #15020: [FLINK-21445][kubernetes] Application mode does not set the configuration when building PackagedProgram

SteNicholas commented on pull request #15020: URL: https://github.com/apache/flink/pull/15020#issuecomment-809072744 @tillrohrmann , I will update this pull request through following the comments above. -- This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Closed] (FLINK-21989) Add a SupportsSourceWatermark ability interface

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

[GitHub] [flink] twalthr closed pull request #15388: [FLINK-21989][table] Add a SupportsSourceWatermark ability interface

twalthr closed pull request #15388: URL: https://github.com/apache/flink/pull/15388 -- 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 #14839: [FLINK-21353][state] Add DFS-based StateChangelog

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

[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_r603014108 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/TemporalRowTimeJoinOperator.java #

[jira] [Commented] (FLINK-21906) Support computed column syntax for Hive DDL dialect

[ https://issues.apache.org/jira/browse/FLINK-21906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310411#comment-17310411 ] jinfeng commented on FLINK-21906: - I learned the code in FLIP-152, what we need to do is

[jira] [Commented] (FLINK-21981) Increase the priority of the parameter in flink-conf

[ https://issues.apache.org/jira/browse/FLINK-21981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310410#comment-17310410 ] Xintong Song commented on FLINK-21981: -- Hi [~Bo Cui], I noticed you have filed sev

[GitHub] [flink] flinkbot edited a comment on pull request #15404: [hotfix][docs] Remove redundant import

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

[GitHub] [flink] flinkbot edited a comment on pull request #15200: [FLINK-21355] Send changes to the state changelog

flinkbot edited a comment on pull request #15200: URL: https://github.com/apache/flink/pull/15200#issuecomment-798902665 ## CI report: * 5e1342d9916f5c4356c622a40bc27bcbdacde9d7 UNKNOWN * 683a1724ca1074a01a0cbaf986afa4a85537b478 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[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 * e7f59e2e2811c0718a453572e90a4ad2a900

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

[jira] [Closed] (FLINK-22005) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1)

[ https://issues.apache.org/jira/browse/FLINK-22005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-22005. - Fix Version/s: 1.13.0 Release Note: fix in the master c375f4cfd394c10b54110eac446873055b716b89

[jira] [Commented] (FLINK-22005) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1)

[ https://issues.apache.org/jira/browse/FLINK-22005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310399#comment-17310399 ] Guowei Ma commented on FLINK-22005: --- thanks [~Leonard Xu]. I find that this does not a

[GitHub] [flink] wuchong commented on a change in pull request #15400: [FLINK-20557][sql-client] Support STATEMENT SET in SQL CLI

wuchong commented on a change in pull request #15400: URL: https://github.com/apache/flink/pull/15400#discussion_r603002125 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java ## @@ -299,15 +307,23 @@ private void callOpera

[jira] [Commented] (FLINK-22005) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1)

[ https://issues.apache.org/jira/browse/FLINK-22005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310391#comment-17310391 ] Leonard Xu commented on FLINK-22005: [~maguowei] Could you rebase to latest master,

[jira] [Commented] (FLINK-21981) Increase the priority of the parameter in flink-conf

[ https://issues.apache.org/jira/browse/FLINK-21981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310388#comment-17310388 ] Bo Cui commented on FLINK-21981: [~Paul Lin] yes, the current plan is like `export ...`,

[jira] [Commented] (FLINK-21990) SourceStreamTask will always hang if the CheckpointedFunction#snapshotState throws an exception.

[ https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310387#comment-17310387 ] Kezhu Wang commented on FLINK-21990: A {{disableChaining}} in between failed source

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process when testing pyflink

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310383#comment-17310383 ] Guowei Ma commented on FLINK-18356: --- https://dev.azure.com/apache-flink/apache-flink/_

[GitHub] [flink] flinkbot edited a comment on pull request #15403: [hotfix] fix typo, assign processedData to currentProcessedData rather than currentPersistedData.

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

[GitHub] [flink] flinkbot commented on pull request #15404: [hotfix][docs] Remove redundant import

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

[GitHub] [flink] flinkbot edited a comment on pull request #15402: [FLINK-21985][table-api] Support Explain Query/Modifcation syntax in Calcite Parser

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

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process when testing pyflink

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310380#comment-17310380 ] Guowei Ma commented on FLINK-18356: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-21103) E2e tests time out on azure

[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310377#comment-17310377 ] Guowei Ma commented on FLINK-21103: --- https://dev.azure.com/apache-flink/apache-flink/_

[GitHub] [flink] YikSanChan commented on pull request #15360: [FLINK-21938][docs] Add how to unit test python udfs

YikSanChan commented on pull request #15360: URL: https://github.com/apache/flink/pull/15360#issuecomment-809048667 @rmetzger Hi Robert, is there anything I need to do here? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Commented] (FLINK-21954) Test failures occur due to the test not waiting for the ExecutionGraph to be created

[ https://issues.apache.org/jira/browse/FLINK-21954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310374#comment-17310374 ] Guowei Ma commented on FLINK-21954: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-21659) Running HA per-job cluster (rocks, incremental) end-to-end test fails

[ https://issues.apache.org/jira/browse/FLINK-21659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310373#comment-17310373 ] Guowei Ma commented on FLINK-21659: --- https://dev.azure.com/apache-flink/apache-flink/_

[GitHub] [flink] flinkbot commented on pull request #15404: [hotfix][docs] Remove redundant import

flinkbot commented on pull request #15404: URL: https://github.com/apache/flink/pull/15404#issuecomment-809047367 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Commented] (FLINK-21990) SourceStreamTask will always hang if the CheckpointedFunction#snapshotState throws an exception.

[ https://issues.apache.org/jira/browse/FLINK-21990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310372#comment-17310372 ] Kezhu Wang commented on FLINK-21990: Ideally, this should be fixed in [1.12.2|https

[GitHub] [flink] YikSanChan opened a new pull request #15404: [hotfix][docs] Remove redundant import

YikSanChan opened a new pull request #15404: URL: https://github.com/apache/flink/pull/15404 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[jira] [Commented] (FLINK-21981) Increase the priority of the parameter in flink-conf

[ https://issues.apache.org/jira/browse/FLINK-21981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310371#comment-17310371 ] Paul Lin commented on FLINK-21981: -- [~Bo Cui] Just to confirm, did you try exporting `H

[jira] [Commented] (FLINK-21103) E2e tests time out on azure

[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310370#comment-17310370 ] Guowei Ma commented on FLINK-21103: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22005) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1)

[ https://issues.apache.org/jira/browse/FLINK-22005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310368#comment-17310368 ] Guowei Ma commented on FLINK-22005: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22005) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1)

[ https://issues.apache.org/jira/browse/FLINK-22005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310366#comment-17310366 ] Guowei Ma commented on FLINK-22005: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Comment Edited] (FLINK-21103) E2e tests time out on azure

[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307542#comment-17307542 ] Guowei Ma edited comment on FLINK-21103 at 3/29/21, 3:47 AM: -

[GitHub] [flink] fsk119 commented on a change in pull request #15402: [FLINK-21985][table-api] Support Explain Query/Modifcation syntax in Calcite Parser

fsk119 commented on a change in pull request #15402: URL: https://github.com/apache/flink/pull/15402#discussion_r602994006 ## File path: flink-table/flink-sql-parser-hive/src/main/codegen/includes/parserImpls.ftl ## @@ -1605,3 +1605,17 @@ SqlShowModules SqlShowModules() :

[jira] [Comment Edited] (FLINK-21103) E2e tests time out on azure

[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307542#comment-17307542 ] Guowei Ma edited comment on FLINK-21103 at 3/29/21, 3:45 AM: -

[GitHub] [flink] flinkbot commented on pull request #15403: [hotfix] fix typo, assign processedData to currentProcessedData rather than currentPersistedData.

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

[jira] [Comment Edited] (FLINK-21103) E2e tests time out on azure

[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307542#comment-17307542 ] Guowei Ma edited comment on FLINK-21103 at 3/29/21, 3:45 AM: -

[GitHub] [flink] flinkbot commented on pull request #15402: [FLINK-21985][table-api] Support Explain Query/Modifcation syntax in Calcite Parser

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

[GitHub] [flink] flinkbot edited a comment on pull request #15401: [FLINK-21969][python] Invoke finish bundle method before emitting the max timestamp watermark in PythonTimestampsAndWatermarksOperato

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

[jira] [Commented] (FLINK-22005) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1)

[ https://issues.apache.org/jira/browse/FLINK-22005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310365#comment-17310365 ] Guowei Ma commented on FLINK-22005: --- https://dev.azure.com/apache-flink/apache-flink/_

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

[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 * 7717d7719f6b448084ff27365c2b718d2c05

[jira] [Commented] (FLINK-21981) Increase the priority of the parameter in flink-conf

[ https://issues.apache.org/jira/browse/FLINK-21981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310364#comment-17310364 ] Xintong Song commented on FLINK-21981: -- {quote}and HADOOP_CONF_DIR=default hdfs-sit

[jira] [Created] (FLINK-22005) SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1)

Guowei Ma created FLINK-22005: - Summary: SQL Client end-to-end test (Old planner) Elasticsearch (v7.5.1) Key: FLINK-22005 URL: https://issues.apache.org/jira/browse/FLINK-22005 Project: Flink I

[jira] [Commented] (FLINK-21982) jobs should use client org.apache.hadoop.config on yarn

[ https://issues.apache.org/jira/browse/FLINK-21982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310358#comment-17310358 ] Bo Cui commented on FLINK-21982: when new configuration, configuration will load core-si

[jira] [Comment Edited] (FLINK-21981) Increase the priority of the parameter in flink-conf

[ https://issues.apache.org/jira/browse/FLINK-21981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310355#comment-17310355 ] Bo Cui edited comment on FLINK-21981 at 3/29/21, 3:33 AM: -- the

[jira] [Commented] (FLINK-21981) Increase the priority of the parameter in flink-conf

[ https://issues.apache.org/jira/browse/FLINK-21981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310355#comment-17310355 ] Bo Cui commented on FLINK-21981: the client side has 2 hdfs-silt (default hdfs-site and

[jira] [Commented] (FLINK-21982) jobs should use client org.apache.hadoop.config on yarn

[ https://issues.apache.org/jira/browse/FLINK-21982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310354#comment-17310354 ] Bo Cui commented on FLINK-21982: thx [~xintongsong] FLINK-16005 only solves part of my

[GitHub] [flink] flinkbot commented on pull request #15403: [hotfix] fix typo, assign processedData to currentProcessedData rather than currentPersistedData.

flinkbot commented on pull request #15403: URL: https://github.com/apache/flink/pull/15403#issuecomment-809039318 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[GitHub] [flink] flinkbot commented on pull request #15402: [FLINK-21985][table-api] Support Explain Query/Modifcation syntax in Calcite Parser

flinkbot commented on pull request #15402: URL: https://github.com/apache/flink/pull/15402#issuecomment-809039335 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pro

[jira] [Commented] (FLINK-21640) Job fails to be submitted in tenant scenario

[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17310353#comment-17310353 ] Xintong Song commented on FLINK-21640: -- [~Bo Cui], [~fly_in_gis], Obviously, diffe

[GitHub] [flink] est08zw opened a new pull request #15403: [hotfix] fix typo, assign processedData to currentProcessedData rather than currentPersistedData.

est08zw opened a new pull request #15403: URL: https://github.com/apache/flink/pull/15403 ## What is the purpose of the change fix typo, assign processedData to currentProcessedData rather than currentPersistedData. ## Brief change log fix typo, assign processed

[GitHub] [flink] chaozwn closed pull request #15390: [FLINK-21985][table-api] Support Explain Query/Modifcation syntax in Calcite Parser

chaozwn closed pull request #15390: URL: https://github.com/apache/flink/pull/15390 -- 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] [Created] (FLINK-22004) Translate Flink Roadmap to Chinese.

Yuan Mei created FLINK-22004: Summary: Translate Flink Roadmap to Chinese. Key: FLINK-22004 URL: https://issues.apache.org/jira/browse/FLINK-22004 Project: Flink Issue Type: Task Compon

[GitHub] [flink] chaozwn opened a new pull request #15402: [FLINK-21985][table-api] Support Explain Query/Modifcation syntax in Calcite Parser

chaozwn opened a new pull request #15402: URL: https://github.com/apache/flink/pull/15402 …Calcite Parser ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid

[jira] [Comment Edited] (FLINK-21103) E2e tests time out on azure

[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307542#comment-17307542 ] Guowei Ma edited comment on FLINK-21103 at 3/29/21, 3:18 AM: -

  1   2   3   4   >