[jira] [Commented] (FLINK-26137) Create webhook REST api test

2022-03-07 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502781#comment-17502781 ] Nicholas Jiang commented on FLINK-26137: [~gyfora], I'm working for this ticket. Could you

[jira] [Updated] (FLINK-26208) Introduce implementation of ManagedTableFactory

2022-03-07 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26208: -- Description: Introduce impl for

[GitHub] [flink] flinkbot edited a comment on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state.

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1061472524 ## CI report: * b4fe404fd3eb4563d6e476c83c4d29c947752571 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state.

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1061472524 ## CI report: * b4fe404fd3eb4563d6e476c83c4d29c947752571 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18958: [FLINK-15854][hive] Use the new type inference for Hive UDTF

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18958: URL: https://github.com/apache/flink/pull/18958#issuecomment-1056725576 ## CI report: * d34eb21ae0bda39ec119ef18a9782fbaad2310bc Azure:

[jira] [Updated] (FLINK-26534) shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism

2022-03-07 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26534: Description: FLINK-20370 fix the wrong result when sink primary key is not the same with query

[jira] [Updated] (FLINK-26534) shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism

2022-03-07 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-26534: Description: FLINK-20370 fix the wrong result when sink primary key is not the same with query

[GitHub] [flink] flinkbot edited a comment on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state.

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1061472524 ## CI report: * b4fe404fd3eb4563d6e476c83c4d29c947752571 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state.

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1061472524 ## CI report: * b4fe404fd3eb4563d6e476c83c4d29c947752571 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state.

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1061472524 ## CI report: * b4fe404fd3eb4563d6e476c83c4d29c947752571 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * 2aa1d90060e534a17aa8f169d71cb0830178c183 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state.

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1061472524 ## CI report: * b4fe404fd3eb4563d6e476c83c4d29c947752571 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19005: [FLINK-26531][kafka] KafkaWriterITCase.testMetadataPublisher failed on azure

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #19005: URL: https://github.com/apache/flink/pull/19005#issuecomment-1061480820 ## CI report: * a259c21a8693b3bc8b6732f3f5a9372dc846a658 Azure:

[jira] [Resolved] (FLINK-21352) FLIP-158: Generalized incremental checkpoints

2022-03-07 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-21352. --- Resolution: Fixed > FLIP-158: Generalized incremental checkpoints >

[jira] [Updated] (FLINK-25867) [ZH] Add ChangelogBackend documentation

2022-03-07 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25867: -- Parent: FLINK-25842 Issue Type: Sub-task (was: Improvement) > [ZH] Add

[jira] [Updated] (FLINK-25867) [ZH] Add ChangelogBackend documentation

2022-03-07 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25867: -- Parent: (was: FLINK-21352) Issue Type: Improvement (was: Sub-task) >

[GitHub] [flink] flinkbot commented on pull request #19005: [FLINK-26531][kafka] KafkaWriterITCase.testMetadataPublisher failed on azure

2022-03-07 Thread GitBox
flinkbot commented on pull request #19005: URL: https://github.com/apache/flink/pull/19005#issuecomment-1061480820 ## CI report: * a259c21a8693b3bc8b6732f3f5a9372dc846a658 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flin

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1046819200 ## CI report: * 8dda8fdb80894c83abcaa8774f30e6f8388f2c68 Azure:

[jira] [Updated] (FLINK-26531) KafkaWriterITCase.testMetadataPublisher failed on azure

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

[GitHub] [flink] JingsongLi opened a new pull request #19005: [FLINK-26531][kafka] KafkaWriterITCase.testMetadataPublisher failed on azure

2022-03-07 Thread GitBox
JingsongLi opened a new pull request #19005: URL: https://github.com/apache/flink/pull/19005 ## What is the purpose of the change Fix unstable case: `KafkaWriterITCase.testMetadataPublisher` ## Brief change log After the sink v2 refactoring, `precommit` is divided into

[jira] [Updated] (FLINK-26527) ClassCastException in TemporaryClassLoaderContext

2022-03-07 Thread shizhengchao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhengchao updated FLINK-26527: - Description: When I try to run sql using flink's classloader, I get the following exception:

[GitHub] [flink] flinkbot edited a comment on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flin

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1046819200 ## CI report: * 480fcced44131cc57105d254b1d7cbad7004fdce Azure:

[jira] [Updated] (FLINK-26527) ClassCastException in TemporaryClassLoaderContext

2022-03-07 Thread shizhengchao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shizhengchao updated FLINK-26527: - Description: When I try to run sql using flink's classloader, I get the following exception:

[GitHub] [flink] flinkbot edited a comment on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when unnecessary.

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1061472524 ## CI report: * b4fe404fd3eb4563d6e476c83c4d29c947752571 Azure:

[GitHub] [flink] shizhengchao commented on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flink1.

2022-03-07 Thread GitBox
shizhengchao commented on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1061474367 > done -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Commented] (FLINK-26490) Adjust the MaxParallelism or remove the MaxParallelism check when unnecessary.

2022-03-07 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502768#comment-17502768 ] 刘方奇 commented on FLINK-26490: - [https://github.com/apache/flink/pull/19004] [~yunta] Hi, I did a prototype

[GitHub] [flink] shizhengchao removed a comment on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since

2022-03-07 Thread GitBox
shizhengchao removed a comment on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1061471664 -- 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] [Assigned] (FLINK-26531) KafkaWriterITCase.testMetadataPublisher failed on azure

2022-03-07 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26531: Assignee: Jingsong Lee > KafkaWriterITCase.testMetadataPublisher failed on azure >

[GitHub] [flink] flinkbot commented on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when unnecessary.

2022-03-07 Thread GitBox
flinkbot commented on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1061472524 ## CI report: * b4fe404fd3eb4563d6e476c83c4d29c947752571 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-26534) shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism

2022-03-07 Thread lincoln lee (Jira)
lincoln lee created FLINK-26534: --- Summary: shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism Key: FLINK-26534 URL:

[GitHub] [flink] shizhengchao commented on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flink1.

2022-03-07 Thread GitBox
shizhengchao commented on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1061471664 use CRLF or LF? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Updated] (FLINK-26490) Adjust the MaxParallelism or remove the MaxParallelism check when unnecessary.

2022-03-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26490: --- Labels: pull-request-available (was: ) > Adjust the MaxParallelism or remove the

[GitHub] [flink] liufangqi opened a new pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when unnecessary.

2022-03-07 Thread GitBox
liufangqi opened a new pull request #19004: URL: https://github.com/apache/flink/pull/19004 ## What is the purpose of the change Since Flink introduce key group and MaxParallelism, Flink can rescale with less cost. But when we want to update the job parallelism bigger

[jira] [Comment Edited] (FLINK-25684) Support enhanced show databases syntax

2022-03-07 Thread Moses (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477583#comment-17477583 ] Moses edited comment on FLINK-25684 at 3/8/22, 6:59 AM: Hi [~lzljs3620320] ,

[GitHub] [flink] ZhangChaoming removed a comment on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-03-07 Thread GitBox
ZhangChaoming removed a comment on pull request #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1038939945 @wuchong Hi, Could you please help give a review ? Thanks very much ! -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Closed] (FLINK-26508) Webhook should only validate on /validate endpoint end log errors for others

2022-03-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26508. -- Resolution: Fixed merged: b75c05807e43129016741277f16ca78634f1e423 > Webhook should only validate on

[jira] [Closed] (FLINK-26472) Introduce Savepoint object in JobStatus

2022-03-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26472. -- Resolution: Duplicate I am closing this as this is already part of the manual savepoint trigger work

[jira] [Assigned] (FLINK-26137) Create webhook REST api test

2022-03-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26137: -- Assignee: (was: Nicholas Jiang) > Create webhook REST api test >

[jira] [Commented] (FLINK-26531) KafkaWriterITCase.testMetadataPublisher failed on azure

2022-03-07 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502758#comment-17502758 ] Jingsong Lee commented on FLINK-26531: -- Thanks for reporting. I will take a look~ >

[GitHub] [flink] shizhengchao commented on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flink1.

2022-03-07 Thread GitBox
shizhengchao commented on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1061466075 > I tried it, but after running, all files are changed files -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Assigned] (FLINK-26137) Create webhook REST api test

2022-03-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26137: -- Assignee: Nicholas Jiang > Create webhook REST api test > > >

[jira] [Created] (FLINK-26533) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee failed on azure due to delete topic timeout

2022-03-07 Thread Yun Gao (Jira)
Yun Gao created FLINK-26533: --- Summary: KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee failed on azure due to delete topic timeout Key: FLINK-26533 URL: https://issues.apache.org/jira/browse/FLINK-26533

[jira] [Commented] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots ha

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502757#comment-17502757 ] Yun Gao commented on FLINK-24960: - 1.14:

[jira] [Updated] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hang

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24960: Affects Version/s: 1.14.3 >

[jira] [Updated] (FLINK-26501) Quickstarts Scala nightly end-to-end test failed on azure due to checkponts failed and logs contains exceptions

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26501: Affects Version/s: 1.15.0 > Quickstarts Scala nightly end-to-end test failed on azure due to checkponts

[jira] [Commented] (FLINK-26501) Quickstarts Scala nightly end-to-end test failed on azure due to checkponts failed and logs contains exceptions

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502756#comment-17502756 ] Yun Gao commented on FLINK-26501: - 1.15:

[jira] [Closed] (FLINK-26423) Integrate log store to StoreSink

2022-03-07 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26423. Resolution: Fixed master: 7f91a853e70bb558fd2e2aa619c83558b9bccaa7 > Integrate log store to

[jira] [Updated] (FLINK-26526) Record hasNull and allNull instead of nullCount in FieldStats

2022-03-07 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-26526: Summary: Record hasNull and allNull instead of nullCount in FieldStats (was: Record hasNull and

[GitHub] [flink-table-store] JingsongLi merged pull request #28: [FLINK-26423] Integrate log store to StoreSink

2022-03-07 Thread GitBox
JingsongLi merged pull request #28: URL: https://github.com/apache/flink-table-store/pull/28 -- 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. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-25819) NetworkBufferPoolTest.testIsAvailableOrNotAfterRequestAndRecycleMultiSegments fails on AZP

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502752#comment-17502752 ] Yun Gao commented on FLINK-25819: -

[jira] [Created] (FLINK-26532) SinkMetricsITCase.testMetrics failed on azure

2022-03-07 Thread Yun Gao (Jira)
Yun Gao created FLINK-26532: --- Summary: SinkMetricsITCase.testMetrics failed on azure Key: FLINK-26532 URL: https://issues.apache.org/jira/browse/FLINK-26532 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * fb78d6887a37ac8c242333159011831bab65dcb4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * fb78d6887a37ac8c242333159011831bab65dcb4 Azure:

[jira] [Commented] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502750#comment-17502750 ] Yun Gao commented on FLINK-24538: -

[jira] [Updated] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24538: Priority: Critical (was: Major) > ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten

[jira] [Updated] (FLINK-24538) ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails with NPE

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24538: Affects Version/s: 1.15.0 > ZooKeeperLeaderElectionTest.testLeaderShouldBeCorrectedWhenOverwritten fails

[jira] [Commented] (FLINK-26531) KafkaWriterITCase.testMetadataPublisher failed on azure

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502749#comment-17502749 ] Yun Gao commented on FLINK-26531: -

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502748#comment-17502748 ] Yun Gao commented on FLINK-25771: -

[jira] [Updated] (FLINK-26531) KafkaWriterITCase.testMetadataPublisher failed on azure

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26531: Priority: Critical (was: Major) > KafkaWriterITCase.testMetadataPublisher failed on azure >

[jira] [Commented] (FLINK-26531) KafkaWriterITCase.testMetadataPublisher failed on azure

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502746#comment-17502746 ] Yun Gao commented on FLINK-26531: - Hi [~lzljs3620320]  could you have a look at this test~? >

[jira] [Updated] (FLINK-26531) KafkaWriterITCase.testMetadataPublisher failed on azure

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26531: Fix Version/s: 1.15.0 > KafkaWriterITCase.testMetadataPublisher failed on azure >

[jira] [Created] (FLINK-26531) KafkaWriterITCase.testMetadataPublisher failed on azure

2022-03-07 Thread Yun Gao (Jira)
Yun Gao created FLINK-26531: --- Summary: KafkaWriterITCase.testMetadataPublisher failed on azure Key: FLINK-26531 URL: https://issues.apache.org/jira/browse/FLINK-26531 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-26507) Last state upgrade mode should allow reconciliation regardless of job and deployment status

2022-03-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26507: -- Assignee: Gyula Fora > Last state upgrade mode should allow reconciliation regardless of job

[jira] [Assigned] (FLINK-26521) Reconsider setting generationAwareEventProcessing = true

2022-03-07 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26521: -- Assignee: Gyula Fora > Reconsider setting generationAwareEventProcessing = true >

[GitHub] [flink] schumiyi removed a comment on pull request #18914: [FLINK-26259][table-planner]Partial insert and partition insert canno…

2022-03-07 Thread GitBox
schumiyi removed a comment on pull request #18914: URL: https://github.com/apache/flink/pull/18914#issuecomment-1050529549 @wuchong @JingsongLi Would you like to review this pr? Thanks for your time. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] schumiyi commented on pull request #18914: [FLINK-26259][table-planner]Partial insert and partition insert canno…

2022-03-07 Thread GitBox
schumiyi commented on pull request #18914: URL: https://github.com/apache/flink/pull/18914#issuecomment-1061444884 @twalthr Appreciate if you can help take a look. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Closed] (FLINK-26314) StreamingCompactingFileSinkITCase.testFileSink failed on azure

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26314. --- Fix Version/s: 1.15.0 Resolution: Fixed > StreamingCompactingFileSinkITCase.testFileSink failed on

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[jira] [Commented] (FLINK-26314) StreamingCompactingFileSinkITCase.testFileSink failed on azure

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502739#comment-17502739 ] Yun Gao commented on FLINK-26314: - I'll first close this issue since the two root-cause issues are all

[jira] [Closed] (FLINK-26440) CompactorOperatorStateHandler can not work with unaligned checkpoint

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-26440. --- Resolution: Fixed > CompactorOperatorStateHandler can not work with unaligned checkpoint >

[jira] [Commented] (FLINK-26440) CompactorOperatorStateHandler can not work with unaligned checkpoint

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502738#comment-17502738 ] Yun Gao commented on FLINK-26440: - Fix on master via 13b203fef748bdbe9b1d14ba01f23ca6c6b24b7e. >

[GitHub] [flink] gaoyunhaii closed pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

2022-03-07 Thread GitBox
gaoyunhaii closed pull request #18955: URL: https://github.com/apache/flink/pull/18955 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[jira] [Updated] (FLINK-26440) CompactorOperatorStateHandler can not work with unaligned checkpoint

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26440: Affects Version/s: 1.15.0 > CompactorOperatorStateHandler can not work with unaligned checkpoint >

[jira] [Updated] (FLINK-26440) CompactorOperatorStateHandler can not work with unaligned checkpoint

2022-03-07 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26440: Fix Version/s: 1.15.0 > CompactorOperatorStateHandler can not work with unaligned checkpoint >

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[GitHub] [flink-ml] mumuhhh edited a comment on pull request #68: [FLINK-26404] support non-local file systems

2022-03-07 Thread GitBox
mumuhhh edited a comment on pull request #68: URL: https://github.com/apache/flink-ml/pull/68#issuecomment-1061426210 `mvn checkstyle:check` sorry, I found it was the import problem; Idea optimizes import and replaces import -- This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18989: [FLINK-26306][state/changelog] Randomly offset materialization

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18989: URL: https://github.com/apache/flink/pull/18989#issuecomment-1060121028 ## CI report: * 1da5d40f751ebb3d9bc2382fb7ef5ab52c69bf4f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[GitHub] [flink-ml] mumuhhh commented on pull request #68: [FLINK-26404] support non-local file systems

2022-03-07 Thread GitBox
mumuhhh commented on pull request #68: URL: https://github.com/apache/flink-ml/pull/68#issuecomment-1061426210 sorry, I found it was the import problem; Idea optimizes import and replaces import -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-07 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure:

[jira] [Commented] (FLINK-24349) Support customized Calalogs via JDBC

2022-03-07 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502720#comment-17502720 ] RocMarshal commented on FLINK-24349:  [~martijnvisser] [~Bo Cui]  Is there any progress ? May I help

[GitHub] [flink] syhily commented on a change in pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

2022-03-07 Thread GitBox
syhily commented on a change in pull request #18838: URL: https://github.com/apache/flink/pull/18838#discussion_r821323308 ## File path: flink-connectors/flink-connector-pulsar/archunit-violations/stored.rules ## @@ -0,0 +1,4 @@ +# +#Thu Mar 03 12:42:13 CST 2022 +Tests\

[jira] [Created] (FLINK-26530) Refactor the FileStoreITCase and StoreSink

2022-03-07 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-26530: Summary: Refactor the FileStoreITCase and StoreSink Key: FLINK-26530 URL: https://issues.apache.org/jira/browse/FLINK-26530 Project: Flink Issue Type:

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #28: [FLINK-26423] Integrate log store to StoreSink

2022-03-07 Thread GitBox
JingsongLi commented on a change in pull request #28: URL: https://github.com/apache/flink-table-store/pull/28#discussion_r821318987 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/sink/LogStoreSinkITCase.java ## @@ -0,0 +1,168

[jira] [Commented] (FLINK-26461) Throw CannotPlanException in TableFunction

2022-03-07 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502711#comment-17502711 ] lincoln lee commented on FLINK-26461: - [~SpongebobZ] Very likely that some changes since 1.14.2 have

[jira] [Commented] (FLINK-26521) Reconsider setting generationAwareEventProcessing = true

2022-03-07 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17502710#comment-17502710 ] Thomas Weise commented on FLINK-26521: -- It would be great to eliminate the redundant

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #28: [FLINK-26423] Integrate log store to StoreSink

2022-03-07 Thread GitBox
JingsongLi commented on a change in pull request #28: URL: https://github.com/apache/flink-table-store/pull/28#discussion_r821313001 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/sink/LogStoreSinkITCase.java ## @@ -0,0 +1,168

[GitHub] [flink-ml] weibozhao commented on a change in pull request #67: [FLINK-26383] Create model stream sink demo

2022-03-07 Thread GitBox
weibozhao commented on a change in pull request #67: URL: https://github.com/apache/flink-ml/pull/67#discussion_r821309252 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/OnlineModelSaveLoadTest.java ## @@ -0,0 +1,178 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-26529) PyFlink 'tuple' object has no attribute '_values'

2022-03-07 Thread James Schulte (Jira)
James Schulte created FLINK-26529: - Summary: PyFlink 'tuple' object has no attribute '_values' Key: FLINK-26529 URL: https://issues.apache.org/jira/browse/FLINK-26529 Project: Flink Issue

[jira] [Assigned] (FLINK-26495) Dynamic table options does not work for view

2022-03-07 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-26495: -- Assignee: Jane Chan > Dynamic table options does not work for view >

  1   2   3   4   5   6   >