[jira] [Commented] (FLINK-23058) flink-elasticsearch-6 not work

2021-06-21 Thread yandufeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367024#comment-17367024 ] yandufeng commented on FLINK-23058: --- it works, i forget to add elasticsearch's package

[jira] [Closed] (FLINK-23058) flink-elasticsearch-6 not work

2021-06-21 Thread yandufeng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yandufeng closed FLINK-23058. - Resolution: Fixed > flink-elasticsearch-6 not work > -- > >

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-06-21 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 5:47 AM: Could we add a

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-06-21 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 5:47 AM: Could we add a

[GitHub] [flink] flinkbot commented on pull request #16232: [FLINK-22312][1.12] Fix test instabilities due to expected hear…

2021-06-21 Thread GitBox
flinkbot commented on pull request #16232: URL: https://github.com/apache/flink/pull/16232#issuecomment-865614922 ## CI report: * adcd1f9569cb897af0c08e60c639fc4cc2119bec UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16191: [FLINK-23029] Extend PluginLoader to allow closing ClassLoader

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16191: URL: https://github.com/apache/flink/pull/16191#issuecomment-863822678 ## CI report: * 8349827a782e23ae82592e79362a8397c4e2dd61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16179: [TESTING] Try to reproduce FLINK-22891

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16179: URL: https://github.com/apache/flink/pull/16179#issuecomment-863055916 ## CI report: * 5e6edf0fefc889f472de3ea26e566538a62ec9da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * da303c24e513b0678794526c6351003b6e76cb6d UNKNOWN *

[GitHub] [flink] chaplinthink commented on pull request #16198: [hotfix] Improve tuple equal code logic

2021-06-21 Thread GitBox
chaplinthink commented on pull request #16198: URL: https://github.com/apache/flink/pull/16198#issuecomment-865613902 cc @rmetzger @zentol -- 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] chaplinthink removed a comment on pull request #16198: [hotfix] Improve tuple equal code logic

2021-06-21 Thread GitBox
chaplinthink removed a comment on pull request #16198: URL: https://github.com/apache/flink/pull/16198#issuecomment-864673718 @lirui-apache Could you give this pull request a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot commented on pull request #16232: [FLINK-22312][1.12] Fix test instabilities due to expected hear…

2021-06-21 Thread GitBox
flinkbot commented on pull request #16232: URL: https://github.com/apache/flink/pull/16232#issuecomment-865592040 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] xintongsong opened a new pull request #16232: [FLINK-22312][1.12] Fix test instabilities due to expected hear…

2021-06-21 Thread GitBox
xintongsong opened a new pull request #16232: URL: https://github.com/apache/flink/pull/16232 Port FLINK-22312 to the 1.12 branch. -- 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

[jira] [Commented] (FLINK-23075) Python API for enabling ChangelogStateBackend

2021-06-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367014#comment-17367014 ] Dian Fu commented on FLINK-23075: - [~Zakelly] Thanks for creating this ticket. Will you take this issue?

[jira] [Updated] (FLINK-23075) Python API for enabling ChangelogStateBackend

2021-06-21 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23075: Fix Version/s: 1.14.0 > Python API for enabling ChangelogStateBackend >

[GitHub] [flink] flinkbot edited a comment on pull request #16231: [FLINK-22420] Improve UnalignedCheckpointITCase cluster stability

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16231: URL: https://github.com/apache/flink/pull/16231#issuecomment-865538511 ## CI report: * ebe0397b7383ad7d60bcbdbfd1b4868d6ca8e302 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16223: [BP-1.12][FLINK-22698][connectors/rabbitmq] Add deliveryTimeout to RabbitMQ source

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16223: URL: https://github.com/apache/flink/pull/16223#issuecomment-865133074 ## CI report: * f22e650fe0d06bfebd17645b68092f8637f8cc75 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16215: [FLINK-23023][table-planner-blink] Support offset in window TVF.

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16215: URL: https://github.com/apache/flink/pull/16215#issuecomment-864821802 ## CI report: * cdd12bf76f67e61cef92ecf99efb1ffd76fa3eb2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * da303c24e513b0678794526c6351003b6e76cb6d UNKNOWN *

[GitHub] [flink] Airblader commented on pull request #16119: [hotfix][docs] 'ALTER.md' Format repair

2021-06-21 Thread GitBox
Airblader commented on pull request #16119: URL: https://github.com/apache/flink/pull/16119#issuecomment-865561235 @MikuSugar Can you rebase this PR to the current master so we can get the CI to pass once? Thanks! -- This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-23076) DispatcherTest.testWaitingForJobMasterLeadership fails on azure

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23076: - Component/s: Runtime / Coordination > DispatcherTest.testWaitingForJobMasterLeadership fails on

[GitHub] [flink] flinkbot commented on pull request #16231: [FLINK-22420] Improve UnalignedCheckpointITCase cluster stability

2021-06-21 Thread GitBox
flinkbot commented on pull request #16231: URL: https://github.com/apache/flink/pull/16231#issuecomment-865538511 ## CI report: * ebe0397b7383ad7d60bcbdbfd1b4868d6ca8e302 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16228: [FLINK-23073][formats / CSV] Fix space handling in Row CSV timestamp parser

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16228: URL: https://github.com/apache/flink/pull/16228#issuecomment-865270132 ## CI report: * d134e0f49d9ebd0bcf8d5df4e442e4ccb23f7fa1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16215: [FLINK-23023][table-planner-blink] Support offset in window TVF.

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16215: URL: https://github.com/apache/flink/pull/16215#issuecomment-864821802 ## CI report: * cdd12bf76f67e61cef92ecf99efb1ffd76fa3eb2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * da303c24e513b0678794526c6351003b6e76cb6d UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16023: [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout parameter to RabbitMQ source

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-850460112 ## CI report: * 39e31f7d9263880a031cd2fe8cc561dfaa10b0ab Azure:

[GitHub] [flink] zicat commented on a change in pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

2021-06-21 Thread GitBox
zicat commented on a change in pull request #16163: URL: https://github.com/apache/flink/pull/16163#discussion_r655863226 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/BridgingFunctionGenUtil.scala ## @@ -147,7

[jira] [Commented] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

2021-06-21 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17367002#comment-17367002 ] Rui Li commented on FLINK-22735: [~frank wang] {{DEFAULT_RETRY_MILLIS}} is just meant to provide a

[jira] [Commented] (FLINK-22735) HiveTableSourceITCase.testStreamPartitionReadByCreateTime failed because of times out

2021-06-21 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366999#comment-17366999 ] Rui Li commented on FLINK-22735: Hi [~dwysakowicz], I think this was the same issue as FLINK-22890 and

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-06-21 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 4:11 AM: Could we add a

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-06-21 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 4:09 AM: Could we add a

[GitHub] [flink] flinkbot commented on pull request #16231: [FLINK-22420] Improve UnalignedCheckpointITCase cluster stability

2021-06-21 Thread GitBox
flinkbot commented on pull request #16231: URL: https://github.com/apache/flink/pull/16231#issuecomment-865510232 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] [Comment Edited] (FLINK-22881) Tasks are blocked while broadcasting stream status

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366998#comment-17366998 ] Xintong Song edited comment on FLINK-22881 at 6/22/21, 4:01 AM:

[jira] [Reopened] (FLINK-22881) Tasks are blocked while broadcasting stream status

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-22881: -- Reopening the ticket. Reverted in 8758b21b44d84412113df03255f2bad9d2fb6372 The commit has broken

[jira] [Updated] (FLINK-22420) UnalignedCheckpointITCase failed

2021-06-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22420: --- Labels: auto-deprioritized-major pull-request-available test-stability (was:

[GitHub] [flink] curcur opened a new pull request #16231: [FLINK-22420] Improve UnalignedCheckpointITCase cluster stability

2021-06-21 Thread GitBox
curcur opened a new pull request #16231: URL: https://github.com/apache/flink/pull/16231 As a follow-up of FLINK-22420, I increased both akka timeout as well as heartbeat timeout to improve UnalignedCheckpointITCase cluster stability -- This is an automated message from the Apache Git

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

2021-06-21 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366997#comment-17366997 ] Rui Li commented on FLINK-22890: bq. I'll check it. Do you know if the same problem occurs in 1.13 and

[jira] [Updated] (FLINK-23077) Running nexmark q5 with 1.13.1 of pipeline.object-reuse=true, the taskmanager will be killed and produce failover.

2021-06-21 Thread xiaojin.wy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaojin.wy updated FLINK-23077: --- Description: Running nexmark with flink 1.13.0, 1.13.1, q5 can`t success. *The conf is: *

[jira] [Created] (FLINK-23077) Running nexmark q5 with 1.13.1 of pipeline.object-reuse=true, the taskmanager will be killed and produce failover.

2021-06-21 Thread xiaojin.wy (Jira)
xiaojin.wy created FLINK-23077: -- Summary: Running nexmark q5 with 1.13.1 of pipeline.object-reuse=true, the taskmanager will be killed and produce failover. Key: FLINK-23077 URL:

[jira] [Commented] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366992#comment-17366992 ] Xintong Song commented on FLINK-23052: --

[jira] [Created] (FLINK-23076) DispatcherTest.testWaitingForJobMasterLeadership fails on azure

2021-06-21 Thread Xintong Song (Jira)
Xintong Song created FLINK-23076: Summary: DispatcherTest.testWaitingForJobMasterLeadership fails on azure Key: FLINK-23076 URL: https://issues.apache.org/jira/browse/FLINK-23076 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #16179: [TESTING] Try to reproduce FLINK-22891

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16179: URL: https://github.com/apache/flink/pull/16179#issuecomment-863055916 ## CI report: * 5e6edf0fefc889f472de3ea26e566538a62ec9da Azure:

[jira] [Updated] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22312: - Fix Version/s: 1.12.5 >

[jira] [Reopened] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-22312: -- Reopen to port the fix to 1.12. Instance on 1.12:

[jira] [Updated] (FLINK-22312) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents due to the heartbeat exception with Yarn RM

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22312: - Affects Version/s: 1.12.4 >

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366986#comment-17366986 ] Xintong Song commented on FLINK-22890: --

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366985#comment-17366985 ] Xintong Song commented on FLINK-22890: --

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366984#comment-17366984 ] Xintong Song commented on FLINK-22890: --

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366983#comment-17366983 ] Xintong Song commented on FLINK-22890: --

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366982#comment-17366982 ] Xintong Song commented on FLINK-22890: --

[jira] [Commented] (FLINK-23052) cron_snapshot_deployment_maven unstable on maven

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366980#comment-17366980 ] Xintong Song commented on FLINK-23052: --

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366979#comment-17366979 ] Xintong Song commented on FLINK-22890: --

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366978#comment-17366978 ] Xintong Song commented on FLINK-22890: --

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366976#comment-17366976 ] Xintong Song commented on FLINK-22890: --

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366975#comment-17366975 ] Xintong Song commented on FLINK-19863: --

[jira] [Commented] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

2021-06-21 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366973#comment-17366973 ] Yun Tang commented on FLINK-22974: -- Merged in master: 55eb22bbd6b5fa3aadbf3ca0ec39370a7ab22b58 > No

[jira] [Resolved] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

2021-06-21 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-22974. -- Resolution: Fixed > No execution checkpointing config desc in flink-conf.yaml >

[jira] [Updated] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

2021-06-21 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-22974: - Fix Version/s: 1.14.0 > No execution checkpointing config desc in flink-conf.yaml >

[jira] [Updated] (FLINK-22994) Improve the performance of nesting udf invoking

2021-06-21 Thread lynn1.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Summary: Improve the performance of nesting udf invoking (was: Improve the performance of

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366972#comment-17366972 ] Xintong Song commented on FLINK-22890: --

[GitHub] [flink] Myasuka merged pull request #16183: [FLINK-22974][dist] Add execution checkpointing related configs in flink-conf.yaml

2021-06-21 Thread GitBox
Myasuka merged pull request #16183: URL: https://github.com/apache/flink/pull/16183 -- 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-22890) Few tests fail in HiveTableSinkITCase

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366971#comment-17366971 ] Xintong Song commented on FLINK-22890: --

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

2021-06-21 Thread lynn1.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Description: h1. BackGround In some nesting udf invoking cases, Flink convert the udf result to

[jira] [Commented] (FLINK-22890) Few tests fail in HiveTableSinkITCase

2021-06-21 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366969#comment-17366969 ] Xintong Song commented on FLINK-22890: --

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

2021-06-21 Thread lynn1.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Description: h1. BackGround In some nesting udf invoking cases, Flink convert the udf result to

[jira] [Updated] (FLINK-22994) Improve the performance of invoking nesting udf

2021-06-21 Thread lynn1.zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lynn1.zhang updated FLINK-22994: Description: h1. BackGround In some nesting udf invoking cases, Flink convert the udf result to

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-06-21 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 3:19 AM: Could we add a

[GitHub] [flink] flinkbot edited a comment on pull request #16179: [TESTING] Try to reproduce FLINK-22891

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16179: URL: https://github.com/apache/flink/pull/16179#issuecomment-863055916 ## CI report: * 5e6edf0fefc889f472de3ea26e566538a62ec9da Azure:

[jira] [Created] (FLINK-23075) Python API for enabling ChangelogStateBackend

2021-06-21 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-23075: --- Summary: Python API for enabling ChangelogStateBackend Key: FLINK-23075 URL: https://issues.apache.org/jira/browse/FLINK-23075 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-06-21 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 3:09 AM: Could we add a

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-06-21 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366965#comment-17366965 ] Ada Wong commented on FLINK-23074: -- Could we add a parquet-hadoop in connector-hive pom. {code:xml}

[jira] [Commented] (FLINK-22886) Thread leak in RocksDBStateUploader

2021-06-21 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366959#comment-17366959 ] Yue Ma commented on FLINK-22886: [~roman_khachatryan] ok ,There is a little difference between 1.12 and

[jira] [Updated] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-06-21 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-23074: - Affects Version/s: 1.13.1 1.12.4 > There is a class conflict between

[jira] [Comment Edited] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-06-21 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366957#comment-17366957 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 3:02 AM: cc

[jira] [Assigned] (FLINK-23043) Wrong master address displayed when run application in native K8s with -Dkubernetes.rest-service.exposed.type=NodePort

2021-06-21 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-23043: - Assignee: Shang Yuanchun > Wrong master address displayed when run application in native K8s

[jira] [Commented] (FLINK-23043) Wrong master address displayed when run application in native K8s with -Dkubernetes.rest-service.exposed.type=NodePort

2021-06-21 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366958#comment-17366958 ] Yang Wang commented on FLINK-23043: --- I think this is a valid issue when running Flink client in a

[jira] [Resolved] (FLINK-22678) Hide ChangelogStateBackend From Users

2021-06-21 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-22678. -- Resolution: Fixed > Hide ChangelogStateBackend From Users > -- >

[jira] [Commented] (FLINK-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-06-21 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366957#comment-17366957 ] Ada Wong commented on FLINK-23074: -- cc [~lzljs3620320] > There is a class conflict between

[jira] [Commented] (FLINK-22678) Hide ChangelogStateBackend From Users

2021-06-21 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366956#comment-17366956 ] Yun Tang commented on FLINK-22678: -- Merged in master: 641c31e92fd8ff3702d2ac3510a63b0653802a2e > Hide

[GitHub] [flink] Myasuka merged pull request #16153: [FLINK-22678] Configurations and user APIs for ChangelogStateBackend

2021-06-21 Thread GitBox
Myasuka merged pull request #16153: URL: https://github.com/apache/flink/pull/16153 -- 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-23074) There is a class conflict between flink-connector-hive and flink-parquet

2021-06-21 Thread Ada Wong (Jira)
Ada Wong created FLINK-23074: Summary: There is a class conflict between flink-connector-hive and flink-parquet Key: FLINK-23074 URL: https://issues.apache.org/jira/browse/FLINK-23074 Project: Flink

[jira] [Commented] (FLINK-23057) flink-console.sh doesn't do variable expansion for FLINK_ENV_JAVA_OPTS like flink-daemon.sh

2021-06-21 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366954#comment-17366954 ] Yang Wang commented on FLINK-23057: --- I think the changes make sense to me. Would you like to provide a

[GitHub] [flink] RocMarshal commented on pull request #16070: [FLINK-23028][docs] Improve documentation for pages of SQL.

2021-06-21 Thread GitBox
RocMarshal commented on pull request #16070: URL: https://github.com/apache/flink/pull/16070#issuecomment-865487159 @Airblader Thank you for your suggestions. I did some checking based on your comments, but it seems that the problem described in JIRA has been fixed now. -- This is an

[GitHub] [flink] lirui-apache commented on pull request #16221: [FLINK-22890] Set idleness timeout for HiveTableSinkITCase

2021-06-21 Thread GitBox
lirui-apache commented on pull request #16221: URL: https://github.com/apache/flink/pull/16221#issuecomment-865486127 Hey @dawidwys , thanks for taking care of this. The documentation about `ExecutionConfigOptions::TABLE_EXEC_SOURCE_IDLE_TIMEOUT` says by default the idleness detect is not

[jira] [Updated] (FLINK-23010) HivePartitionFetcherContextBase::getComparablePartitionValueList can return partitions that don't exist

2021-06-21 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23010: --- Labels: pull-request-available (was: ) >

[GitHub] [flink] leonardBang commented on a change in pull request #16182: [FLINK-23010][hive] HivePartitionFetcherContextBase shouldn't list fo…

2021-06-21 Thread GitBox
leonardBang commented on a change in pull request #16182: URL: https://github.com/apache/flink/pull/16182#discussion_r655835230 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HivePartitionFetcherContextBase.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #16230: [hotfix][docs] Updated description of HOP and CUMULATE parameters

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16230: URL: https://github.com/apache/flink/pull/16230#issuecomment-865401009 ## CI report: * 3ddb5875ede037c6c79f18b3a2730944214d7943 Azure:

[jira] [Commented] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

2021-06-21 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366948#comment-17366948 ] Yang Wang commented on FLINK-21445: --- Thanks [~mapohl] for taking this ticket over. I would like to

[jira] [Commented] (FLINK-23051) Savepoint an application for source of cdc-kafka, then restart the application from the savepoint, offset not be recovered.

2021-06-21 Thread Carl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366943#comment-17366943 ] Carl commented on FLINK-23051: -- [~hiscat] thanks a lot! > Savepoint an application for source of

[jira] [Closed] (FLINK-23051) Savepoint an application for source of cdc-kafka, then restart the application from the savepoint, offset not be recovered.

2021-06-21 Thread Carl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Carl closed FLINK-23051. Fix Version/s: (was: 1.14.0) Resolution: Not A Bug -s appear in the wrong place > Savepoint an

[jira] [Commented] (FLINK-23051) Savepoint an application for source of cdc-kafka, then restart the application from the savepoint, offset not be recovered.

2021-06-21 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366941#comment-17366941 ] 谢波 commented on FLINK-23051: ... oh. This -s option appears to be in the wrong place. you can place the -s

[jira] [Updated] (FLINK-22792) Limit size of already processed files in File Source SplitEnumerator

2021-06-21 Thread Tianxin Zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tianxin Zhao updated FLINK-22792: - Description: File Source makes use of {{ContinuousFileSplitEnumerator}} to discover files in

[jira] [Updated] (FLINK-22792) Limit size of already processed files in File Source SplitEnumerator

2021-06-21 Thread Tianxin Zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tianxin Zhao updated FLINK-22792: - Description: File Source makes use of {{ContinuousFileSplitEnumerator}} to discover files in

[GitHub] [flink] leonardBang commented on pull request #16228: [FLINK-23073][formats / CSV] Fix space handling in Row CSV timestamp parser

2021-06-21 Thread GitBox
leonardBang commented on pull request #16228: URL: https://github.com/apache/flink/pull/16228#issuecomment-865465048 @sjwiesman Thanks for the contribution, Could you also add `trim()` for `RuntimeConverter` in `CsvRowDeserializationSchema` ? and it will be great if we can add a test to

[jira] [Commented] (FLINK-22887) Backlog based optimizations for RebalancePartitioner and RescalePartitioner

2021-06-21 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366931#comment-17366931 ] Jiayi Liao commented on FLINK-22887: [~pnowojski][~akalashnikov] Thanks for the feedback. My idea

[jira] [Commented] (FLINK-19830) Properly implements processing-time temporal table join

2021-06-21 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17366923#comment-17366923 ] Leonard Xu commented on FLINK-19830: [~twalthr] I checked that the old temporal function work well,

[GitHub] [flink] flinkbot edited a comment on pull request #16229: [FLINK-22464][tests] Fix OperatorCoordinator test which is stalling with AdaptiveScheduler

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16229: URL: https://github.com/apache/flink/pull/16229#issuecomment-865339185 ## CI report: * 2e843600b4202c779e5b68bea6a6b5b612cc1e6b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16230: [hotfix][docs] Updated description of HOP and CUMULATE parameters

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16230: URL: https://github.com/apache/flink/pull/16230#issuecomment-865401009 ## CI report: * 3ddb5875ede037c6c79f18b3a2730944214d7943 Azure:

[GitHub] [flink] flinkbot commented on pull request #16230: [hotfix][docs] Updated description of HOP and CUMULATE parameters

2021-06-21 Thread GitBox
flinkbot commented on pull request #16230: URL: https://github.com/apache/flink/pull/16230#issuecomment-865401009 ## CI report: * 3ddb5875ede037c6c79f18b3a2730944214d7943 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #16191: [FLINK-23029] Extend PluginLoader to allow closing ClassLoader

2021-06-21 Thread GitBox
flinkbot edited a comment on pull request #16191: URL: https://github.com/apache/flink/pull/16191#issuecomment-863822678 ## CI report: * ce0811d23c53c492e466a144fdd3de6fc1b1006e Azure:

[jira] [Updated] (FLINK-5601) Window operator does not checkpoint watermarks

2021-06-21 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5601: -- Labels: auto-deprioritized-critical auto-unassigned pull-request-available (was:

  1   2   3   4   5   6   7   >