[GitHub] [flink] twalthr closed pull request #16213: [FLINK-22788][table-planner-blink] Support equalisers for many fields

twalthr closed pull request #16213: URL: https://github.com/apache/flink/pull/16213 -- 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] MikuSugar commented on pull request #16235: [hotfix][docs] ' Chinese document' Format repair

MikuSugar commented on pull request #16235: URL: https://github.com/apache/flink/pull/16235#issuecomment-865649594 @Airblader 我已经重新提交了，麻烦你看一下，谢谢～（I have resubmitted it. Please have a look at it. Thanks ） -- This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] flinkbot commented on pull request #16235: [hotfix][docs] ' Chinese document' Format repair

flinkbot commented on pull request #16235: URL: https://github.com/apache/flink/pull/16235#issuecomment-865649391 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] MikuSugar commented on pull request #16235: [hotfix][docs] 'ALTER.md' Format repair

MikuSugar commented on pull request #16235: URL: https://github.com/apache/flink/pull/16235#issuecomment-865648498 之前有一次提交，因为合并操作有错误，所以重新提交（There was a previous submission, because there was an error in the merge operation, so it was submitted again）https://github.com/apache/flink/pull/161

[GitHub] [flink] MikuSugar opened a new pull request #16235: [hotfix][docs] 'ALTER.md' Format repair

MikuSugar opened a new pull request #16235: URL: https://github.com/apache/flink/pull/16235 ## What is the purpose of the change - Fix document format ## Brief change log - 'Alter 语句' Chinese document format repair ## Verifying this change This change is a

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

lirui-apache commented on a change in pull request #16182: URL: https://github.com/apache/flink/pull/16182#discussion_r655924860 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HivePartitionFetcherContextBase.java ## @@ -

[GitHub] [flink] lirui-apache commented on pull request #16221: [FLINK-22881] Tasks are blocked while broadcasting stream status

lirui-apache commented on pull request #16221: URL: https://github.com/apache/flink/pull/16221#issuecomment-865645345 Thanks @dawidwys for the clarifications. I'm not really familiar with the watermark and idleness detection code. So I'll leave this for other folks to have a look. -- Th

[GitHub] [flink] flinkbot commented on pull request #16233: [FLINK-22085][tests] Add debug code to expose the sink status for KafkaSourceLegacyITCase

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #16221: [FLINK-22881] Tasks are blocked while broadcasting stream status

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

[jira] [Closed] (FLINK-23029) Extend PluginLoader to allow closing of backing ClassLoader

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

[GitHub] [flink] zentol merged pull request #16191: [FLINK-23029] Extend PluginLoader to allow closing ClassLoader

zentol merged pull request #16191: URL: https://github.com/apache/flink/pull/16191 -- 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] MikuSugar closed pull request #16119: [hotfix][docs] 'ALTER.md' Format repair

MikuSugar closed pull request #16119: URL: https://github.com/apache/flink/pull/16119 -- 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, plea

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

[ https://issues.apache.org/jira/browse/FLINK-22886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367044#comment-17367044 ] Yue Ma commented on FLINK-22886: [https://github.com/apache/flink/pull/16234]   This com

[GitHub] [flink] beyond1920 commented on pull request #16219: [FLINK-22781][table-planner-blink] Fix bug in emit behavior of GroupWindowAggregate to skip emit window result if input stream of GroupWin

beyond1920 commented on pull request #16219: URL: https://github.com/apache/flink/pull/16219#issuecomment-865641200 ci fails caused by [FLINK-23079](https://issues.apache.org/jira/browse/FLINK-23079) -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Comment Edited] (FLINK-23079) HiveTableSinkITCase fails

[ https://issues.apache.org/jira/browse/FLINK-23079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367042#comment-17367042 ] JING ZHANG edited comment on FLINK-23079 at 6/22/21, 6:38 AM:

[GitHub] [flink] flinkbot commented on pull request #16234: [FLINK-22886][state] Fix thread leak and add unit test in RocksIncrem…

flinkbot commented on pull request #16234: URL: https://github.com/apache/flink/pull/16234#issuecomment-865640692 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] [Created] (FLINK-23080) Add finish method to the SinkFunction

Dawid Wysakowicz created FLINK-23080: Summary: Add finish method to the SinkFunction Key: FLINK-23080 URL: https://issues.apache.org/jira/browse/FLINK-23080 Project: Flink Issue Type: Sub

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

MikuSugar commented on pull request #16119: URL: https://github.com/apache/flink/pull/16119#issuecomment-865640435 @Airblader 对不起，我似乎弄错了，我将关闭这个提交并重新发起（Sorry, I seem to have made a mistake. I will close this submission and restart it） -- This is an automated message from the Apache Git Se

[jira] [Commented] (FLINK-23079) HiveTableSinkITCase fails

[ https://issues.apache.org/jira/browse/FLINK-23079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367042#comment-17367042 ] JING ZHANG commented on FLINK-23079: [https://dev.azure.com/apache-flink/apache-flin

[jira] [Updated] (FLINK-23079) HiveTableSinkITCase fails

[ https://issues.apache.org/jira/browse/FLINK-23079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23079: --- Description: There are 4 tests in HiveTableSinkITCase fails: testBatchAppend, testPartStreamingMrW

[GitHub] [flink] mayuehappy opened a new pull request #16234: [FLINK-22886][state] Fix thread leak and add unit test in RocksIncrem…

mayuehappy opened a new pull request #16234: URL: https://github.com/apache/flink/pull/16234 …entalSnapshotStrategy ## What is the purpose of the change fix the thread leak in RocksDBStateUploader and add unit test ## Brief change log - Add close() functio

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

[ https://issues.apache.org/jira/browse/FLINK-19830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367041#comment-17367041 ] Timo Walther commented on FLINK-19830: -- Thanks [~Leonard Xu]. > Properly implement

[jira] [Created] (FLINK-23079) HiveTableSinkITCase fails

JING ZHANG created FLINK-23079: -- Summary: HiveTableSinkITCase fails Key: FLINK-23079 URL: https://issues.apache.org/jira/browse/FLINK-23079 Project: Flink Issue Type: Bug Components: C

[GitHub] [flink-benchmarks] zentol opened a new pull request #16: [hotfix] Remove SchedulerBenchmark#teardown

zentol opened a new pull request #16: URL: https://github.com/apache/flink-benchmarks/pull/16 It should be unnecessary to shut down the executor because as far as I can tell it isn't used. -- This is an automated message from the Apache Git Service. To respond to the message, please log

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

[ https://issues.apache.org/jira/browse/FLINK-23075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367040#comment-17367040 ] Dian Fu commented on FLINK-23075: - [~Zakelly] Thanks a lot for taking this. Have assigne

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

[ https://issues.apache.org/jira/browse/FLINK-23075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-23075: --- Assignee: Zakelly Lan > Python API for enabling ChangelogStateBackend > ---

[jira] [Closed] (FLINK-23040) Consider ConfigOption fallback keys in FactoryUtil

[ https://issues.apache.org/jira/browse/FLINK-23040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-23040. Resolution: Fixed Fixed for formats in 1.14.0: 3fdcb40c09cc1b8656d3b6059ef1a6def7c65d3c > Conside

[GitHub] [flink] twalthr closed pull request #16226: [FLINK-23040][table-common] Consider ConfigOption fallback keys of formats in FactoryUtil

twalthr closed pull request #16226: URL: https://github.com/apache/flink/pull/16226 -- 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] [Commented] (FLINK-23011) FLIP-27 sources are generating non-deterministic results when using event time

[ https://issues.apache.org/jira/browse/FLINK-23011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367037#comment-17367037 ] Dawid Wysakowicz commented on FLINK-23011: -- After some investigation of FLINK-2

[GitHub] [flink-benchmarks] pnowojski merged pull request #15: [FLINK-23078] Fix import

pnowojski merged pull request #15: URL: https://github.com/apache/flink-benchmarks/pull/15 -- 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] [Updated] (FLINK-23078) Scheduler Benchmarks not compiling

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

[GitHub] [flink-benchmarks] zentol opened a new pull request #15: [FLINK-23078] Fix import

zentol opened a new pull request #15: URL: https://github.com/apache/flink-benchmarks/pull/15 -- 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 servi

[jira] [Comment Edited] (FLINK-23078) Scheduler Benchmarks not compiling

[ https://issues.apache.org/jira/browse/FLINK-23078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367034#comment-17367034 ] Piotr Nowojski edited comment on FLINK-23078 at 6/22/21, 6:23 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-22890: Assignee: Dawid Wysakowicz > Few tests fail in HiveTableSinkITCase >

[jira] [Commented] (FLINK-23078) Scheduler Benchmarks not compiling

[ https://issues.apache.org/jira/browse/FLINK-23078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367034#comment-17367034 ] Piotr Nowojski commented on FLINK-23078: I'm fixing the benchmark build, but it

[GitHub] [flink] dawidwys commented on pull request #16221: [FLINK-22881] Tasks are blocked while broadcasting stream status

dawidwys commented on pull request #16221: URL: https://github.com/apache/flink/pull/16221#issuecomment-865631300 @lirui-apache The idea was that if we enable `TABLE_EXEC_SOURCE_IDLE_TIMEOUT` the `WatermarkAssignerOperator` takes control over its `StreamStatus` and it does not respect the

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

[ https://issues.apache.org/jira/browse/FLINK-23075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367032#comment-17367032 ] Zakelly Lan commented on FLINK-23075: - [~dian.fu] Sure, please assign it to me. Than

[jira] [Created] (FLINK-23078) Scheduler Benchmarks not compiling

Piotr Nowojski created FLINK-23078: -- Summary: Scheduler Benchmarks not compiling Key: FLINK-23078 URL: https://issues.apache.org/jira/browse/FLINK-23078 Project: Flink Issue Type: Bug

[jira] [Assigned] (FLINK-23078) Scheduler Benchmarks not compiling

[ https://issues.apache.org/jira/browse/FLINK-23078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-23078: Assignee: Chesnay Schepler > Scheduler Benchmarks not compiling > ---

[jira] [Comment Edited] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367027#comment-17367027 ] Yun Gao edited comment on FLINK-22085 at 6/22/21, 6:13 AM: --- Hi

[jira] [Comment Edited] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367027#comment-17367027 ] Yun Gao edited comment on FLINK-22085 at 6/22/21, 6:11 AM: --- Hi

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367027#comment-17367027 ] Yun Gao commented on FLINK-22085: - Hi [~lindong] thanks for the explanation and it indee

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

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #16221: [FLINK-22881] Tasks are blocked while broadcasting stream status

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

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

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

[GitHub] [flink] flinkbot commented on pull request #16233: [FLINK-22085][tests] Add debug code to expose the sink status for KafkaSourceLegacyITCase

flinkbot commented on pull request #16233: URL: https://github.com/apache/flink/pull/16233#issuecomment-865623841 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] gaoyunhaii opened a new pull request #16233: [FLINK-22085][tests] Add debug code to expose the sink status for KafkaSourceLegacyITCase

gaoyunhaii opened a new pull request #16233: URL: https://github.com/apache/flink/pull/16233 ## What is the purpose of the change This PR tries to expose the status of the sink for KafkaSourceLegacyITCase to help future debug the unstable cases. ## Brief change log - 9a

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

[ https://issues.apache.org/jira/browse/FLINK-23058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 5:47 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 5:47 AM:

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

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 r

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

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

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

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

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

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

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

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 sp

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

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 Gi

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

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 pro

[GitHub] [flink] xintongsong opened a new pull request #16232: [FLINK-22312][1.12] Fix test instabilities due to expected hear…

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 co

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

[ https://issues.apache.org/jira/browse/FLINK-23075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367014#comment-17367014 ] Dian Fu commented on FLINK-23075: - [~Zakelly] Thanks for creating this ticket. Will you

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

[ 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

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

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

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

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

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

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

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

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

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 to

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

[ 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

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 r

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

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

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

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

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

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

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

flinkbot edited a comment on pull request #16023: URL: https://github.com/apache/flink/pull/16023#issuecomment-850460112 ## CI report: * 39e31f7d9263880a031cd2fe8cc561dfaa10b0ab 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 #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

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

[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17367002#comment-17367002 ] Rui Li commented on FLINK-22735: [~frank wang] {{DEFAULT_RETRY_MILLIS}} is just meant to

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

[ https://issues.apache.org/jira/browse/FLINK-22735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366999#comment-17366999 ] Rui Li commented on FLINK-22735: Hi [~dwysakowicz], I think this was the same issue as F

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

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 4:11 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-23074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366965#comment-17366965 ] Ada Wong edited comment on FLINK-23074 at 6/22/21, 4:09 AM:

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

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 pro

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

[ https://issues.apache.org/jira/browse/FLINK-22881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ 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 t

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

[ 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: auto-depriorit

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

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 Se

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

[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366997#comment-17366997 ] Rui Li commented on FLINK-22890: bq. I'll check it. Do you know if the same problem occu

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

[ 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: * pipeline.o

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

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: https://issues.apache.org/jira/browse

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

[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366992#comment-17366992 ] Xintong Song commented on FLINK-23052: -- https://dev.azure.com/apache-flink/apache-f

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

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

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

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

[ 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 > YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLog

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

[ 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: https://dev.azure.com/apache-flink/apache-flink

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

[ 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 > YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibite

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

[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366986#comment-17366986 ] Xintong Song commented on FLINK-22890: -- https://dev.azure.com/apache-flink/apache-f

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

[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366985#comment-17366985 ] Xintong Song commented on FLINK-22890: -- https://dev.azure.com/apache-flink/apache-f

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

[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366984#comment-17366984 ] Xintong Song commented on FLINK-22890: -- https://dev.azure.com/apache-flink/apache-f

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

[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366983#comment-17366983 ] Xintong Song commented on FLINK-22890: -- https://dev.azure.com/apache-flink/apache-f

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

[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366982#comment-17366982 ] Xintong Song commented on FLINK-22890: -- https://dev.azure.com/apache-flink/apache-f

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

[ https://issues.apache.org/jira/browse/FLINK-23052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366980#comment-17366980 ] Xintong Song commented on FLINK-23052: -- https://dev.azure.com/apache-flink/apache-f

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

[ https://issues.apache.org/jira/browse/FLINK-22890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17366979#comment-17366979 ] Xintong Song commented on FLINK-22890: -- https://dev.azure.com/apache-flink/apache-f

  1   2   3   4   5   6   7   >