[jira] [Commented] (FLINK-24162) PartiallyFinishedSourcesITCase fails due to assertion error in DrainingValidator.validateOperatorLifecycle

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

[jira] [Created] (FLINK-24180) UnalignedCheckpointRescaleITCase fails due to direct OOM

2021-09-06 Thread Xintong Song (Jira)
Xintong Song created FLINK-24180: Summary: UnalignedCheckpointRescaleITCase fails due to direct OOM Key: FLINK-24180 URL: https://issues.apache.org/jira/browse/FLINK-24180 Project: Flink

[jira] [Created] (FLINK-24179) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee fails on azure

2021-09-06 Thread Xintong Song (Jira)
Xintong Song created FLINK-24179: Summary: KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee fails on azure Key: FLINK-24179 URL: https://issues.apache.org/jira/browse/FLINK-24179 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17152: [FLINK-24131][datastream/kafka] Reliably shutdown producer

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #17152: URL: https://github.com/apache/flink/pull/17152#issuecomment-913235346 ## CI report: * 640fa7cee84eccde4c60157cfbc3d18e2d3a618f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16740: [FLINK-23614][table-planner] The resulting scale of TRUNCATE(DECIMAL,…

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #16740: URL: https://github.com/apache/flink/pull/16740#issuecomment-894176423 ## CI report: * 9296b4edc8df450cdace492e137e58a1dba609c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16731: [FLINK-23612][table-runtime] Fix compile exception for ROUND function with some numeric input arguments

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #16731: URL: https://github.com/apache/flink/pull/16731#issuecomment-893977654 ## CI report: * aac3509302c236a01d2ea8f7b75167a227a2039b Azure:

[jira] [Commented] (FLINK-24137) Python tests fail with "Exception in thread read_grpc_client_inputs"

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

[jira] [Commented] (FLINK-23747) Testing Window TVF offset

2021-09-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410927#comment-17410927 ] Xintong Song commented on FLINK-23747: -- [~liliwei], Thanks a lot for the updates. Shall we consider

[GitHub] [flink] flinkbot commented on pull request #17170: [FLINK-24163][test] Increase the checkpoint timeout for PartiallyFinishedSourcesITCase

2021-09-06 Thread GitBox
flinkbot commented on pull request #17170: URL: https://github.com/apache/flink/pull/17170#issuecomment-914008319 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] [Updated] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

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

[GitHub] [flink] gaoyunhaii opened a new pull request #17170: [FLINK-24163][test] Increase the checkpoint timeout for PartiallyFinishedSourcesITCase

2021-09-06 Thread GitBox
gaoyunhaii opened a new pull request #17170: URL: https://github.com/apache/flink/pull/17170 ## What is the purpose of the change This PR increases the checkpoint timeout for PartiallyFinishedITCase since it seems that it might use more than 5s. ## Brief change log -

[jira] [Updated] (FLINK-24178) Flink on Kubernetes TaskManager

2021-09-06 Thread frey (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] frey updated FLINK-24178: - Attachment: image-2021-09-07-13-31-10-077.png image-2021-09-07-13-31-40-796.png

[GitHub] [flink] gaoyunhaii commented on pull request #17165: [FLINK-24160][tests] Use FS checkpoint storage in PartiallyFinishedSourcesITCase

2021-09-06 Thread GitBox
gaoyunhaii commented on pull request #17165: URL: https://github.com/apache/flink/pull/17165#issuecomment-914003513 Hi @rkhachatryan very thanks for opening the issue! The fix looks very good to me, and for one thing, perhaps we also change the default statebackend type for the other two

[GitHub] [flink] Aitozi commented on a change in pull request #17160: [FLINK-23961][kubernetes] Hint user about missing 'kubernetes.cluster…

2021-09-06 Thread GitBox
Aitozi commented on a change in pull request #17160: URL: https://github.com/apache/flink/pull/17160#discussion_r703186616 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java ## @@ -85,7 +85,15 @@ public

[jira] [Created] (FLINK-24178) flink on

2021-09-06 Thread frey (Jira)
frey created FLINK-24178: Summary: flink on Key: FLINK-24178 URL: https://issues.apache.org/jira/browse/FLINK-24178 Project: Flink Issue Type: Bug Reporter: frey -- This message

[jira] [Commented] (FLINK-23747) Testing Window TVF offset

2021-09-06 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410923#comment-17410923 ] liwei li commented on FLINK-23747: -- Hi [~xtsong], I have run many use cases of different time zone

[jira] [Closed] (FLINK-23834) Test StreamTableEnvironment batch mode manually

2021-09-06 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-23834. --- Resolution: Fixed > Test StreamTableEnvironment batch mode manually >

[jira] [Commented] (FLINK-23834) Test StreamTableEnvironment batch mode manually

2021-09-06 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410922#comment-17410922 ] Yun Gao commented on FLINK-23834: - Since there is no pending issues without issue, I'll first close this

[GitHub] [flink] flinkbot edited a comment on pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-904867960 ## CI report: * e2e83d6db7cc3b15e946862a510aca393096e942 UNKNOWN * df32ec43e5a4bec2d9f78f173fe9ff45cc454eb3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16940: [FLINK-23914][connector/testing-framework] Print debug log if multiple split data validation fails

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #16940: URL: https://github.com/apache/flink/pull/16940#issuecomment-903640018 ## CI report: * d2cb0d1ee59ef4b277011153531d5e31ebb2fffe Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16740: [FLINK-23614][table-planner] The resulting scale of TRUNCATE(DECIMAL,…

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #16740: URL: https://github.com/apache/flink/pull/16740#issuecomment-894176423 ## CI report: * 9296b4edc8df450cdace492e137e58a1dba609c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16731: [FLINK-23612][table-runtime] Fix compile exception for ROUND function with some numeric input arguments

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #16731: URL: https://github.com/apache/flink/pull/16731#issuecomment-893977654 ## CI report: * aac3509302c236a01d2ea8f7b75167a227a2039b Azure:

[GitHub] [flink] SteNicholas commented on pull request #17155: [FLINK-19883][table] Support 'IF EXISTS' in DDL for ALTER TABLE

2021-09-06 Thread GitBox
SteNicholas commented on pull request #17155: URL: https://github.com/apache/flink/pull/17155#issuecomment-913990898 @wuchong @Airblader , I have addressed the comments mentioned above. Please help to review again. -- This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-24159) document of entropy injection may mislead users

2021-09-06 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410920#comment-17410920 ] Feifan Wang commented on FLINK-24159: - Hi [~trohrmann], can you help confirm this problem ? >

[jira] [Comment Edited] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute ch

2021-09-06 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410864#comment-17410864 ] JING ZHANG edited comment on FLINK-24168 at 9/7/21, 4:55 AM: - [~Leonard Xu]

[GitHub] [flink] flinkbot edited a comment on pull request #17165: [FLINK-24160][tests] Use FS checkpoint storage in PartiallyFinishedSourcesITCase

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #17165: URL: https://github.com/apache/flink/pull/17165#issuecomment-913856367 ## CI report: * a8b35cf88f3531f7c363d731f377afa6600d01d8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17169: [FLINK-24177][runtime/network] Add epoll available check exception

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #17169: URL: https://github.com/apache/flink/pull/17169#issuecomment-913977825 ## CI report: * 45a6a284e4f37295ef77c7310e302e0751c05aca Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17121: [FLINK-24115][docs] Fix outdated SQL Temporal Join example

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #17121: URL: https://github.com/apache/flink/pull/17121#issuecomment-911635717 ## CI report: * a1b116b1a8beddb4e8d9ce594dd59d2fdc1d67c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16940: [FLINK-23914][connector/testing-framework] Print debug log if multiple split data validation fails

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #16940: URL: https://github.com/apache/flink/pull/16940#issuecomment-903640018 ## CI report: * d2cb0d1ee59ef4b277011153531d5e31ebb2fffe Azure:

[jira] [Commented] (FLINK-23821) Test loopback mode to allow Python UDF worker and client reuse the same Python VM

2021-09-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410918#comment-17410918 ] Xintong Song commented on FLINK-23821: -- Sounds great. Thanks > Test loopback mode to allow Python

[GitHub] [flink] wuchong commented on a change in pull request #17158: [FLINK-22198][connector/kafka] Disable log deletion on Kafka broker in Kafka table connector tests

2021-09-06 Thread GitBox
wuchong commented on a change in pull request #17158: URL: https://github.com/apache/flink/pull/17158#discussion_r703161746 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaTableITCase.java ## @@

[GitHub] [flink] flinkbot commented on pull request #17169: [FLINK-24177][runtime/network] Add epoll available check exception

2021-09-06 Thread GitBox
flinkbot commented on pull request #17169: URL: https://github.com/apache/flink/pull/17169#issuecomment-913977825 ## CI report: * 45a6a284e4f37295ef77c7310e302e0751c05aca UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17168: [hotfix][docs] Fix sentence by adding one word:

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #17168: URL: https://github.com/apache/flink/pull/17168#issuecomment-913969753 ## CI report: * a7312019be0d4e23c42801a85ce39d07abbf1362 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17121: [FLINK-24115][docs] Fix outdated SQL Temporal Join example

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #17121: URL: https://github.com/apache/flink/pull/17121#issuecomment-911635717 ## CI report: * a1b116b1a8beddb4e8d9ce594dd59d2fdc1d67c4 Azure:

[GitHub] [flink] flinkbot commented on pull request #17169: [FLINK-24177][runtime/network] Add epoll available check exception

2021-09-06 Thread GitBox
flinkbot commented on pull request #17169: URL: https://github.com/apache/flink/pull/17169#issuecomment-913971508 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] [Closed] (FLINK-24172) Table API join documentation for Java has missing end quote after table name

2021-09-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24172. --- Resolution: Fixed Fixed in master: c13b749782d0d72647ec6d73ce1eb22b57f2be7d > Table API join documentation

[jira] [Assigned] (FLINK-24172) Table API join documentation for Java has missing end quote after table name

2021-09-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24172: --- Assignee: Mans Singh > Table API join documentation for Java has missing end quote after table

[GitHub] [flink] wuchong merged pull request #17166: [FLINK-24172][tableapi][docs] - Fixed missing quote for join examples

2021-09-06 Thread GitBox
wuchong merged pull request #17166: URL: https://github.com/apache/flink/pull/17166 -- 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] [Updated] (FLINK-24177) Add epoll exception check

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

[GitHub] [flink] skyguard1 opened a new pull request #17169: [FLINK-24177][runtime/network] Add epoll available check exception

2021-09-06 Thread GitBox
skyguard1 opened a new pull request #17169: URL: https://github.com/apache/flink/pull/17169 ## What is the purpose of the change There is no exception check in `NettyServer` when using epoll, and exception check is required when using epoll, thanks ## Brief change log

[GitHub] [flink] RocMarshal commented on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

2021-09-06 Thread GitBox
RocMarshal commented on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-913970522 > @wuchong @twalthr Thank you for your suggestions. I'll simplify the related documentation in this PR. > Looking forward to the refactoring next. @wuchong @twalthr

[GitHub] [flink] flinkbot commented on pull request #17168: [hotfix][docs] Fix sentence by adding one word:

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

[GitHub] [flink] flinkbot edited a comment on pull request #17164: [FLINK-24162][tests] Check MAX_WATERMARK per attempt in FLIP-147 tests

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #17164: URL: https://github.com/apache/flink/pull/17164#issuecomment-913837309 ## CI report: * 17c454a4215a3b08ac3db28ce1ff498fb466f12a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-904867960 ## CI report: * e2e83d6db7cc3b15e946862a510aca393096e942 UNKNOWN * 42d8954d9c3710f14fbecddf9f665a08a704c472 Azure:

[jira] [Created] (FLINK-24177) Add epoll exception check

2021-09-06 Thread rufei xing (Jira)
rufei xing created FLINK-24177: -- Summary: Add epoll exception check Key: FLINK-24177 URL: https://issues.apache.org/jira/browse/FLINK-24177 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-24137) Python tests fail with "Exception in thread read_grpc_client_inputs"

2021-09-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410912#comment-17410912 ] Dian Fu commented on FLINK-24137: - I have added some logs and triggered the tests more than 50 times in

[jira] [Commented] (FLINK-23905) Reduce the load on JobManager when submitting large-scale job with a big user jar

2021-09-06 Thread huntercc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410911#comment-17410911 ] huntercc commented on FLINK-23905: -- Thanks for providing those practical doubts, Zhilong. `Flink on

[jira] [Updated] (FLINK-24176) Column alias in Flink-SQL is unsuccessful after converting Table to DataStream

2021-09-06 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24176: Component/s: Table SQL / API > Column alias in Flink-SQL is unsuccessful after converting Table to >

[GitHub] [flink] flinkbot commented on pull request #17168: [HOTFIX][docs] fix sentence by adding one word:

2021-09-06 Thread GitBox
flinkbot commented on pull request #17168: URL: https://github.com/apache/flink/pull/17168#issuecomment-913961822 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] JingGe opened a new pull request #17168: [HOTFIX][docs] fix sentence by adding one word:

2021-09-06 Thread GitBox
JingGe opened a new pull request #17168: URL: https://github.com/apache/flink/pull/17168 these records together do not consume too "much" memory. ## What is the purpose of the change This pull request improves the java doc by fixing the sentence. ## Brief change log

[jira] [Commented] (FLINK-24149) Make checkpoint relocatable

2021-09-06 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410904#comment-17410904 ] Feifan Wang commented on FLINK-24149: - [~yunta],thanks for reminding, this feature does invalidate

[GitHub] [flink] flinkbot edited a comment on pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #17064: URL: https://github.com/apache/flink/pull/17064#issuecomment-908893945 ## CI report: * 72f6cfe35351e1891f5ca8d60604b68a27fc1e5f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #16969: URL: https://github.com/apache/flink/pull/16969#issuecomment-904867960 ## CI report: * e2e83d6db7cc3b15e946862a510aca393096e942 UNKNOWN * 42d8954d9c3710f14fbecddf9f665a08a704c472 Azure:

[jira] [Commented] (FLINK-23807) Use metrics to detect restarts in MiniClusterTestEnvironment#triggerTaskManagerFailover

2021-09-06 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410903#comment-17410903 ] Liu commented on FLINK-23807: - I have met the same problem and it blocks my ITCase for pulsar. Hope it to be

[jira] [Commented] (FLINK-24086) Do not re-register SharedStateRegistry to reduce the recovery time of the job

2021-09-06 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410902#comment-17410902 ] ming li commented on FLINK-24086: - [~pnowojski], thanks for your reply, I will try to make changes on

[jira] [Commented] (FLINK-23821) Test loopback mode to allow Python UDF worker and client reuse the same Python VM

2021-09-06 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410901#comment-17410901 ] Liu commented on FLINK-23821: - [~xtsong] Sorry for late reply. I am doing this ticket and will complete it

[jira] [Created] (FLINK-24176) Column alias in Flink-SQL is unsuccessful after converting Table to DataStream

2021-09-06 Thread Wang Guanglei (Jira)
Wang Guanglei created FLINK-24176: - Summary: Column alias in Flink-SQL is unsuccessful after converting Table to DataStream Key: FLINK-24176 URL: https://issues.apache.org/jira/browse/FLINK-24176

[jira] [Commented] (FLINK-24174) MiniClusterTestEnvironment‘s triggerTaskManagerFailover may stuck in CommonTestUtils.waitForJobStatus()

2021-09-06 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410900#comment-17410900 ] Liu commented on FLINK-24174: - [~renqs]Thanks for your reply. Yes, it is the same question. I will close

[jira] [Closed] (FLINK-24174) MiniClusterTestEnvironment‘s triggerTaskManagerFailover may stuck in CommonTestUtils.waitForJobStatus()

2021-09-06 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu closed FLINK-24174. --- Resolution: Duplicate > MiniClusterTestEnvironment‘s triggerTaskManagerFailover may stuck in >

[jira] [Created] (FLINK-24175) KafkaITCase.testConcurrentProducerConsumerTopology times out

2021-09-06 Thread Xintong Song (Jira)
Xintong Song created FLINK-24175: Summary: KafkaITCase.testConcurrentProducerConsumerTopology times out Key: FLINK-24175 URL: https://issues.apache.org/jira/browse/FLINK-24175 Project: Flink

[jira] [Reopened] (FLINK-23905) Reduce the load on JobManager when submitting large-scale job with a big user jar

2021-09-06 Thread huntercc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huntercc reopened FLINK-23905: -- > Reduce the load on JobManager when submitting large-scale job with a big user > jar >

[GitHub] [flink] amazingJing commented on a change in pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

2021-09-06 Thread GitBox
amazingJing commented on a change in pull request #16969: URL: https://github.com/apache/flink/pull/16969#discussion_r703141262 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #17166: [FLINK-24172][tableapi][docs] - Fixed missing quote for join examples

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #17166: URL: https://github.com/apache/flink/pull/17166#issuecomment-913902033 ## CI report: * 6a6a4467fca8eecc55adad57f76a341388df829b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #17064: URL: https://github.com/apache/flink/pull/17064#issuecomment-908893945 ## CI report: * 72f6cfe35351e1891f5ca8d60604b68a27fc1e5f Azure:

[jira] [Commented] (FLINK-24174) MiniClusterTestEnvironment‘s triggerTaskManagerFailover may stuck in CommonTestUtils.waitForJobStatus()

2021-09-06 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410895#comment-17410895 ] Qingsheng Ren commented on FLINK-24174: --- Thanks [~Jiangang] for reporting this. I think the issue

[jira] [Commented] (FLINK-23749) Testing Window Join

2021-09-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410893#comment-17410893 ] Xintong Song commented on FLINK-23749: -- Hi [~q977734161], How are things going with the testings?

[jira] [Commented] (FLINK-24174) MiniClusterTestEnvironment‘s triggerTaskManagerFailover may stuck in CommonTestUtils.waitForJobStatus()

2021-09-06 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410891#comment-17410891 ] Liu commented on FLINK-24174: - Hello, [~renqs]. Can you have a look and confirm the problem? Thank you. >

[jira] [Commented] (FLINK-23747) Testing Window TVF offset

2021-09-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410892#comment-17410892 ] Xintong Song commented on FLINK-23747: -- Hi [~liliwei], How are things going with the testings? Do

[jira] [Created] (FLINK-24174) MiniClusterTestEnvironment‘s triggerTaskManagerFailover may stuck in CommonTestUtils.waitForJobStatus()

2021-09-06 Thread Liu (Jira)
Liu created FLINK-24174: --- Summary: MiniClusterTestEnvironment‘s triggerTaskManagerFailover may stuck in CommonTestUtils.waitForJobStatus() Key: FLINK-24174 URL: https://issues.apache.org/jira/browse/FLINK-24174

[jira] [Resolved] (FLINK-23983) JVM crash when running RocksDBStateBackend tests

2021-09-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-23983. -- Resolution: Fixed Merged master: 4f5978fd4f53428b6af85f487f3f2abbf2f590fd release-1.14:

[jira] [Updated] (FLINK-23983) JVM crash when running RocksDBStateBackend tests

2021-09-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23983: - Fix Version/s: 1.15.0 > JVM crash when running RocksDBStateBackend tests >

[jira] [Updated] (FLINK-23864) The document for Pulsar Source

2021-09-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23864: - Component/s: Documentation > The document for Pulsar Source > -- >

[jira] [Updated] (FLINK-23864) The document for Pulsar Source

2021-09-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23864: - Labels: documentation (was: documentation r) > The document for Pulsar Source >

[jira] [Updated] (FLINK-23582) Add documentation for session window

2021-09-06 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JING ZHANG updated FLINK-23582: --- Fix Version/s: (was: 1.14.0) 1.15.0 > Add documentation for session window >

[GitHub] [flink] Myasuka merged pull request #17112: [FLINK-23983][tests] Ensure to close and dispose created keyed-statebackend in StateBackendTestBase

2021-09-06 Thread GitBox
Myasuka merged pull request #17112: URL: https://github.com/apache/flink/pull/17112 -- 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] [Created] (FLINK-24173) BatchFileSystemITCaseBase.testProjectPushDown hangs on azure

2021-09-06 Thread Xintong Song (Jira)
Xintong Song created FLINK-24173: Summary: BatchFileSystemITCaseBase.testProjectPushDown hangs on azure Key: FLINK-24173 URL: https://issues.apache.org/jira/browse/FLINK-24173 Project: Flink

[jira] [Commented] (FLINK-24137) Python tests fail with "Exception in thread read_grpc_client_inputs"

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

[GitHub] [flink] flinkbot edited a comment on pull request #17167: [FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest

2021-09-06 Thread GitBox
flinkbot edited a comment on pull request #17167: URL: https://github.com/apache/flink/pull/17167#issuecomment-913931378 ## CI report: * 74c35f558ed6edb8073eb842403c9ee7e6c59788 Azure:

[jira] [Commented] (FLINK-24162) PartiallyFinishedSourcesITCase fails due to assertion error in DrainingValidator.validateOperatorLifecycle

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

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

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

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

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

[GitHub] [flink] crazyzhou commented on a change in pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

2021-09-06 Thread GitBox
crazyzhou commented on a change in pull request #17064: URL: https://github.com/apache/flink/pull/17064#discussion_r703127996 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReaderTest.java ## @@

[jira] [Commented] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

2021-09-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410876#comment-17410876 ] Xintong Song commented on FLINK-24163: -- Thanks [~gaoyunhaii]. I've assigned you to the ticket. >

[jira] [Assigned] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

2021-09-06 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-24163: Assignee: Yun Gao > PartiallyFinishedSourcesITCase fails due to timeout >

[jira] [Commented] (FLINK-24163) PartiallyFinishedSourcesITCase fails due to timeout

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

[jira] [Updated] (FLINK-24077) HBaseConnectorITCase.testTableSink

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

[jira] [Commented] (FLINK-24077) HBaseConnectorITCase.testTableSink

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

[jira] [Updated] (FLINK-24077) HBaseConnectorITCase.testTableSink

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

[GitHub] [flink] becketqin commented on a change in pull request #17064: [FLINK-24059][Connectors/Common] Allow SourceReaderTestBase.NUM_SPLITS to be overridden

2021-09-06 Thread GitBox
becketqin commented on a change in pull request #17064: URL: https://github.com/apache/flink/pull/17064#discussion_r703123222 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReaderTest.java ## @@

[jira] [Comment Edited] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

2021-09-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410870#comment-17410870 ] luoyuxia edited comment on FLINK-23857 at 9/7/21, 1:48 AM: --- [~lirui] I tried

[jira] [Comment Edited] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

2021-09-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410870#comment-17410870 ] luoyuxia edited comment on FLINK-23857 at 9/7/21, 1:47 AM: --- [~lirui] I tried

[jira] [Commented] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

2021-09-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410870#comment-17410870 ] luoyuxia commented on FLINK-23857: -- [~lirui] I tried with hive-2.3.2, hive-2.3.8,  hive-3.1.2. All of

[jira] [Updated] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

2021-09-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-23857: - Attachment: 7F086A05-FE73-47F2-BA6C-95371E89116C.png > insert overwirite table select * from t where 1

[GitHub] [flink] flinkbot commented on pull request #17167: [FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest

2021-09-06 Thread GitBox
flinkbot commented on pull request #17167: URL: https://github.com/apache/flink/pull/17167#issuecomment-913931378 ## CI report: * 74c35f558ed6edb8073eb842403c9ee7e6c59788 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Comment Edited] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute ch

2021-09-06 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410864#comment-17410864 ] JING ZHANG edited comment on FLINK-24168 at 9/7/21, 1:36 AM: - [~Leonard Xu]

[jira] [Comment Edited] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute ch

2021-09-06 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410864#comment-17410864 ] JING ZHANG edited comment on FLINK-24168 at 9/7/21, 1:33 AM: - [~Leonard Xu]

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

2021-09-06 Thread JING ZHANG (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410864#comment-17410864 ] JING ZHANG commented on FLINK-24168: [~Leonard Xu] [~twalthr] I try to fix the bug by updating the

[GitHub] [flink] flinkbot commented on pull request #17167: [FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest

2021-09-06 Thread GitBox
flinkbot commented on pull request #17167: URL: https://github.com/apache/flink/pull/17167#issuecomment-913915498 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] rkhachatryan opened a new pull request #17167: [FLINK-22889][tests] Increase timeouts in JdbcExactlyOnceSinkE2eTest

2021-09-06 Thread GitBox
rkhachatryan opened a new pull request #17167: URL: https://github.com/apache/flink/pull/17167 ...to tolerate occasional long XA PREPARE executions in MySQL -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-22889) JdbcExactlyOnceSinkE2eTest.testInsert hangs on azure

2021-09-06 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410856#comment-17410856 ] Roman Khachatryan commented on FLINK-22889: --- In the latest logs it's clearly seen that MySQL

  1   2   3   4   5   >