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

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18989: URL: https://github.com/apache/flink/pull/18989#issuecomment-1060121028 ## CI report: * 73d6764f05ac68f1f665f9783de182d8e3255495 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26453) execution.allow-client-job-configurations not checked for executeAsync

2022-03-06 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502116#comment-17502116 ] Fabian Paul commented on FLINK-26453: - Merged in master: 47c599cc95b305c5ae6db5a50f1

[jira] [Resolved] (FLINK-26453) execution.allow-client-job-configurations not checked for executeAsync

2022-03-06 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-26453. - Resolution: Fixed > execution.allow-client-job-configurations not checked for executeAsync > ---

[jira] [Closed] (FLINK-26453) execution.allow-client-job-configurations not checked for executeAsync

2022-03-06 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-26453. --- > execution.allow-client-job-configurations not checked for executeAsync > -

[GitHub] [flink] fapaul merged pull request #18972: [FLINK-26453][clients] Prevent program configurations also when execu…

2022-03-06 Thread GitBox
fapaul merged pull request #18972: URL: https://github.com/apache/flink/pull/18972 -- 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: issues-unsubscr

[jira] [Commented] (FLINK-26424) RequestTimeoutException

2022-03-06 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502111#comment-17502111 ] Till Rohrmann commented on FLINK-26424: --- I think the idea would be that you can de

[GitHub] [flink] flinkbot edited a comment on pull request #18991: [FLINK-26279][runtime] Add mailbox delay and throughput metrics

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18991: URL: https://github.com/apache/flink/pull/18991#issuecomment-1060268498 ## CI report: * 5b9dea466c3984b5e0afef3502cf2f4addc829e6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18991: [FLINK-26279][runtime] Add mailbox delay and throughput metrics

2022-03-06 Thread GitBox
flinkbot commented on pull request #18991: URL: https://github.com/apache/flink/pull/18991#issuecomment-1060268498 ## CI report: * 5b9dea466c3984b5e0afef3502cf2f4addc829e6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2022-03-06 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502109#comment-17502109 ] 刘方奇 commented on FLINK-26490: - [~mayuehappy] [~yunta] THX for your reply. In my opinion, re

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 763f2347ba146a4c8153f7ad5243d08af8bc8178 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26279) Provide mailbox delay metric

2022-03-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26279: --- Labels: pull-request-available (was: ) > Provide mailbox delay metric > ---

[GitHub] [flink] smattheis opened a new pull request #18991: [FLINK-26279][runtime] Add mailbox delay and throughput metrics

2022-03-06 Thread GitBox
smattheis opened a new pull request #18991: URL: https://github.com/apache/flink/pull/18991 ## What is the purpose of the change * Add mailbox delay/latency metric backed by a DescriptiveStatisticsHistogram and throughput metric backed by a MeterView. ## Brief change log

[GitHub] [flink] flinkbot edited a comment on pull request #18990: [FLINK-26504][python] Fix the incorrect type error in unbounded Python UDAF

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18990: URL: https://github.com/apache/flink/pull/18990#issuecomment-1060259607 ## CI report: * f8c839ffc97863294ca44f34ab6801c219ecbb97 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and use lateTrigger.

2022-03-06 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502108#comment-17502108 ] Yao Zhang commented on FLINK-26498: --- Hi [~jark] , I would like to fix this issue. Per

[GitHub] [flink] Myasuka commented on a change in pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-06 Thread GitBox
Myasuka commented on a change in pull request #18976: URL: https://github.com/apache/flink/pull/18976#discussion_r820419673 ## File path: flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/FsStateChangelogStorage.java ## @@ -72,14 +73,19 @@ public FsStateCha

[GitHub] [flink] flinkbot commented on pull request #18990: [FLINK-26504][python] Fix the incorrect type error in unbounded Python UDAF

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

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

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * 0675e590348283e696d1352d588e3cadfddd421b Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-26506) Support StreamExecutionEnvironment.registerCachedFile in Python DataStream API

2022-03-06 Thread Dian Fu (Jira)
Dian Fu created FLINK-26506: --- Summary: Support StreamExecutionEnvironment.registerCachedFile in Python DataStream API Key: FLINK-26506 URL: https://issues.apache.org/jira/browse/FLINK-26506 Project: Flink

[jira] [Updated] (FLINK-26504) Fix the incorrect type error in unbounded Python UDAF

2022-03-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26504: --- Labels: pull-request-available (was: ) > Fix the incorrect type error in unbounded Python U

[GitHub] [flink] HuangXingBo opened a new pull request #18990: [FLINK-26504][python] Fix the incorrect type error in unbounded Python UDAF

2022-03-06 Thread GitBox
HuangXingBo opened a new pull request #18990: URL: https://github.com/apache/flink/pull/18990 ## What is the purpose of the change *This pull request will fix the incorrect type error in unbounded Python UDAF* ## Brief change log - *Fix the incorrect type error in unb

[jira] [Commented] (FLINK-26281) Test Elasticsearch connector End2End

2022-03-06 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502106#comment-17502106 ] Yangze Guo commented on FLINK-26281: I found two behavior changes atm: - In 1.14, we

[GitHub] [flink] flinkbot edited a comment on pull request #18986: [FLINK-26496][flink-yarn-test] [JUnit5 Migration] Module: flink-yarn-test

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18986: URL: https://github.com/apache/flink/pull/18986#issuecomment-1059778170 ## CI report: * ff14b5113f506c8a62b840e7401ddb4828e31fce Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Comment Edited] (FLINK-26270) Flink SQL write data to kafka by CSV format , decimal type was converted to scientific notation

2022-03-06 Thread fengjk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502103#comment-17502103 ] fengjk edited comment on FLINK-26270 at 3/7/22, 6:58 AM: - The cu

[jira] [Comment Edited] (FLINK-26270) Flink SQL write data to kafka by CSV format , decimal type was converted to scientific notation

2022-03-06 Thread fengjk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502103#comment-17502103 ] fengjk edited comment on FLINK-26270 at 3/7/22, 6:57 AM: - The cu

[jira] [Commented] (FLINK-26270) Flink SQL write data to kafka by CSV format , decimal type was converted to scientific notation

2022-03-06 Thread fengjk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502103#comment-17502103 ] fengjk commented on FLINK-26270: The current fix is repackaged by modifying the source c

[GitHub] [flink] flinkbot edited a comment on pull request #18986: [FLINK-26496][flink-yarn-test] [JUnit5 Migration] Module: flink-yarn-test

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18986: URL: https://github.com/apache/flink/pull/18986#issuecomment-1059778170 ## CI report: * 9bc31adf772a329b3fadce1e5c11f93b676c4bd9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26270) Flink SQL write data to kafka by CSV format , decimal type was converted to scientific notation

2022-03-06 Thread fengjk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fengjk updated FLINK-26270: --- Attachment: image-2022-03-07-14-56-00-328.png > Flink SQL write data to kafka by CSV format , decimal type w

[jira] [Commented] (FLINK-24372) Deprecate Elasticsearch Sinkfunctions

2022-03-06 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502102#comment-17502102 ] Yangze Guo commented on FLINK-24372: Hmm...It seems the failure handler has been rem

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

2022-03-06 Thread Spongebob (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502100#comment-17502100 ] Spongebob commented on FLINK-26461: --- Hi  lincoln, I found this problem just occur in t

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

2022-03-06 Thread GitBox
gaoyunhaii commented on pull request #18955: URL: https://github.com/apache/flink/pull/18955#issuecomment-1060247930 Thanks @pltbkd for the updates! I do not have other comments except for the above one -- This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] gaoyunhaii commented on a change in pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

2022-03-06 Thread GitBox
gaoyunhaii commented on a change in pull request #18955: URL: https://github.com/apache/flink/pull/18955#discussion_r820421136 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/operator/CompactorOperatorStateHandler.java

[jira] [Commented] (FLINK-26330) Test Adaptive Batch Scheduler manually

2022-03-06 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502097#comment-17502097 ] Lijie Wang commented on FLINK-26330: I have discussed with [~zhuzh]  offline. We bel

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #33: [FLINK-26346] Add statistics collecting to sst files

2022-03-06 Thread GitBox
tsreaper commented on a change in pull request #33: URL: https://github.com/apache/flink-table-store/pull/33#discussion_r820416338 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/OrcFileStatsExtractor.java ## @@ -0,0 +1,183 @@ +/* + *

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #33: [FLINK-26346] Add statistics collecting to sst files

2022-03-06 Thread GitBox
tsreaper commented on a change in pull request #33: URL: https://github.com/apache/flink-table-store/pull/33#discussion_r820412865 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/sst/SstFileWriter.java ## @@ -161,49 +170,93 @@ pro

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

2022-03-06 Thread GitBox
mumuhhh commented on a change in pull request #68: URL: https://github.com/apache/flink-ml/pull/68#discussion_r820409320 ## File path: flink-ml-core/pom.xml ## @@ -31,6 +31,10 @@ under the License. flink-ml-core_${scala.binary.version} Flink ML : Core + +2.4.1 Re

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 414adf3bf2aa1467db7e089b10e18b4e9e349b56 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * 0fba3f1ec339f6e5f032b5e9ce4362af256fb278 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * 0fba3f1ec339f6e5f032b5e9ce4362af256fb278 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * 0fba3f1ec339f6e5f032b5e9ce4362af256fb278 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * 0fba3f1ec339f6e5f032b5e9ce4362af256fb278 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

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

2022-03-06 Thread GitBox
LadyForest commented on a change in pull request #28: URL: https://github.com/apache/flink-table-store/pull/28#discussion_r820369220 ## File path: flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/sink/CommittableSerializerTest.java ## @@ -18,21

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * 0fba3f1ec339f6e5f032b5e9ce4362af256fb278 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18986: [FLINK-26496][flink-yarn-test] [JUnit5 Migration] Module: flink-yarn-test

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18986: URL: https://github.com/apache/flink/pull/18986#issuecomment-1059778170 ## CI report: * 9bc31adf772a329b3fadce1e5c11f93b676c4bd9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * 9256843f24defd169d04c7347ac2457a33aa7dc1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] pltbkd commented on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-03-06 Thread GitBox
pltbkd commented on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1060167382 > @pltbkd Could you please add a ITcase to reproduce this problem? > > BTW, you can tag this PR as `draft` if you think this PR is still under development. Thanks f

[jira] [Updated] (FLINK-26505) Support non equality condition in Hive dialect

2022-03-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26505: - Description: It'll throw exception "java.lang.IndexOutOfBoundsException: Index: 0, Size: 0" with the fo

[jira] [Updated] (FLINK-26505) Support non equality condition in Hive dialect

2022-03-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26505: - Description: It'll throw exception "java.lang.IndexOutOfBoundsException: Index: 0, Size: 0" with the fo

[GitHub] [flink] flinkbot edited a comment on pull request #18986: [FLINK-26496][flink-yarn-test] [JUnit5 Migration] Module: flink-yarn-test

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18986: URL: https://github.com/apache/flink/pull/18986#issuecomment-1059778170 ## CI report: * 9bc31adf772a329b3fadce1e5c11f93b676c4bd9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26505) Support non equality condition in Hive dialect

2022-03-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26505: - Description: It'll throw exception with the following sql which can be executed in hive: {code:java} sel

[jira] [Updated] (FLINK-26505) Support non equality condition in Hive dialect

2022-03-06 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26505: - Description: It'll throw exception with the following sql which can be executed in hive: {code:java} sel

[GitHub] [flink] flinkbot edited a comment on pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18955: URL: https://github.com/apache/flink/pull/18955#issuecomment-1056126485 ## CI report: * 8eb23d59267a9fd4fe6c481591be3f8795fe564e Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18955: URL: https://github.com/apache/flink/pull/18955#issuecomment-1056126485 ## CI report: * 19fcc0e5728e9dd843c77f3f81c83e79d32cc84d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-26505) Support non equality condition in Hive dialect

2022-03-06 Thread luoyuxia (Jira)
luoyuxia created FLINK-26505: Summary: Support non equality condition in Hive dialect Key: FLINK-26505 URL: https://issues.apache.org/jira/browse/FLINK-26505 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-26456) StreamExecutionEnvironmentTests::test_add_python_file failed with ModuleNotFoundError

2022-03-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-26456: Assignee: Huang Xingbo > StreamExecutionEnvironmentTests::test_add_python_file failed wit

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

2022-03-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502069#comment-17502069 ] Yun Tang commented on FLINK-26490: -- I think it might be possible, how will you modify i

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #68: [FLINK-26404] support non-local file systems

2022-03-06 Thread GitBox
yunfengzhou-hub commented on a change in pull request #68: URL: https://github.com/apache/flink-ml/pull/68#discussion_r820343180 ## File path: flink-ml-core/src/test/java/org/apache/flink/ml/util/ReadWriteUtilsTest.java ## @@ -0,0 +1,92 @@ +package org.apache.flink.ml.util; +

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * 9256843f24defd169d04c7347ac2457a33aa7dc1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18956: [FLINK-26394] CheckpointCoordinator.isTriggering can not be reset in a particular case.

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18956: URL: https://github.com/apache/flink/pull/18956#issuecomment-1056194247 ## CI report: * 9256843f24defd169d04c7347ac2457a33aa7dc1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-03-06 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502066#comment-17502066 ] Yue Ma commented on FLINK-26490: I think it's valid, there is no need to check the MaxPa

[jira] [Created] (FLINK-26504) Fix the incorrect type error in unbounded Python UDAF

2022-03-06 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-26504: Summary: Fix the incorrect type error in unbounded Python UDAF Key: FLINK-26504 URL: https://issues.apache.org/jira/browse/FLINK-26504 Project: Flink Issue T

[GitHub] [flink] flinkbot edited a comment on pull request #17933: [FLINK-24948][jdbc] Fix bug that special character in column names breaks JDBC statement parsing

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #17933: URL: https://github.com/apache/flink/pull/17933#issuecomment-980508183 ## CI report: * 882b3f42c1e7cbef777580da1b7b1f2a9bf00481 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Resolved] (FLINK-20633) test_configuration.test_add_all test failed in py35

2022-03-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-20633. -- Fix Version/s: 1.13.7 1.14.5 Resolution: Fixed Merged into master vi

[GitHub] [flink] flinkbot edited a comment on pull request #17933: [FLINK-24948][jdbc] Fix bug that special character in column names breaks JDBC statement parsing

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #17933: URL: https://github.com/apache/flink/pull/17933#issuecomment-980508183 ## CI report: * 882b3f42c1e7cbef777580da1b7b1f2a9bf00481 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] HuangXingBo closed pull request #18954: [FLINK-20633][python] Add retry times to download avro

2022-03-06 Thread GitBox
HuangXingBo closed pull request #18954: URL: https://github.com/apache/flink/pull/18954 -- 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: issues-uns

[jira] [Resolved] (FLINK-26464) Introduce new metrics to represent full checkpoint size

2022-03-06 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-26464. -- Resolution: Fixed Merged in master: b2f4c0ea259027ed3f6a04595202cf2589e2495a > Introduce new metrics

[GitHub] [flink] Myasuka merged pull request #18969: [FLINK-26464][metrics] Make the meaning of lastCheckpointSize stay as before

2022-03-06 Thread GitBox
Myasuka merged pull request #18969: URL: https://github.com/apache/flink/pull/18969 -- 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: issues-unsubsc

[jira] [Comment Edited] (FLINK-24372) Deprecate Elasticsearch Sinkfunctions

2022-03-06 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502061#comment-17502061 ] Yangze Guo edited comment on FLINK-24372 at 3/7/22, 2:44 AM: -

[jira] [Commented] (FLINK-24372) Deprecate Elasticsearch Sinkfunctions

2022-03-06 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502061#comment-17502061 ] Yangze Guo commented on FLINK-24372: [~fpaul] Thanks for the explanation. Agree that

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

2022-03-06 Thread GitBox
JingsongLi commented on pull request #28: URL: https://github.com/apache/flink-table-store/pull/28#issuecomment-1060130770 Rebased -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18955: URL: https://github.com/apache/flink/pull/18955#issuecomment-1056126485 ## CI report: * 19fcc0e5728e9dd843c77f3f81c83e79d32cc84d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18955: URL: https://github.com/apache/flink/pull/18955#issuecomment-1056126485 ## CI report: * 19fcc0e5728e9dd843c77f3f81c83e79d32cc84d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-03-06 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26495: -- Component/s: Table SQL / Planner (was: Table SQL / API) > Dynamic table options d

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

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18989: URL: https://github.com/apache/flink/pull/18989#issuecomment-1060121028 ## CI report: * 73d6764f05ac68f1f665f9783de182d8e3255495 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 059cec3236ae33559d23aa1aa7ada32b35e2ccad Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-03-06 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502057#comment-17502057 ] Jane Chan edited comment on FLINK-26495 at 3/7/22, 2:19 AM:

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

2022-03-06 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502057#comment-17502057 ] Jane Chan commented on FLINK-26495: --- FLINK-25609 made {{CatalogSourceTable#toRel}} thr

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

2022-03-06 Thread GitBox
flinkbot commented on pull request #18989: URL: https://github.com/apache/flink/pull/18989#issuecomment-1060121028 ## CI report: * 73d6764f05ac68f1f665f9783de182d8e3255495 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 059cec3236ae33559d23aa1aa7ada32b35e2ccad Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26306) Triggered checkpoints can be delayed by discarding shared state

2022-03-06 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26306: --- Labels: pull-request-available (was: ) > Triggered checkpoints can be delayed by discarding

[GitHub] [flink] rkhachatryan opened a new pull request #18989: [FLINK-26306][state/changelog] Randomly offset materialization

2022-03-06 Thread GitBox
rkhachatryan opened a new pull request #18989: URL: https://github.com/apache/flink/pull/18989 ## What is the purpose of the change Currently, all tasks perform materialization rougly at the same time. This creates a spike in state deletion requests from JM to DFS. That can dela

[jira] [Commented] (FLINK-26381) Wrong document order of Chinese version

2022-03-06 Thread Yao Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502055#comment-17502055 ] Yao Zhang commented on FLINK-26381: --- The page weight values of Chinese version are dif

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 9f3c4d1ba885027bc2c6a4f19da76f78dd16d97a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * 9f3c4d1ba885027bc2c6a4f19da76f78dd16d97a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

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

2022-03-06 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26495: -- Description: The dynamic table options (aka. table hints) syntax {code:java} table_identifier /*+ OPTI

[GitHub] [flink] pltbkd commented on a change in pull request #18955: [FLINK-26440] CompactorOperatorStateHandler can not work with unaligned checkpoint.

2022-03-06 Thread GitBox
pltbkd commented on a change in pull request #18955: URL: https://github.com/apache/flink/pull/18955#discussion_r820330879 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/compactor/operator/CompactorOperatorStateHandler.java

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

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * 5d06c38e5fc474692377aae682086bbd034df9cc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * 5d06c38e5fc474692377aae682086bbd034df9cc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

2022-03-06 Thread GitBox
imaffe edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1058724107 CI Record: SUCCESS: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32496&view=results FAILUE: https://dev.azure.com/apache-flink/apache-fli

[GitHub] [flink] flinkbot edited a comment on pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18987: URL: https://github.com/apache/flink/pull/18987#issuecomment-1059995435 ## CI report: * 57c71a75978908600ab22a8f361c327cc32e7003 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18931: URL: https://github.com/apache/flink/pull/18931#issuecomment-1054455643 ## CI report: * 89a9ed31249c43781961b5a89c4214e7227ef9e1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18949: [FLINK-25235][tests] re-enable zookeeper test

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18949: URL: https://github.com/apache/flink/pull/18949#issuecomment-1055620167 ## CI report: * 193175d59ea80d8652f28e15d6b89ee1888535ef Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18988: [FLINK-26502][runtime] align behavior of multiple component leader election on close

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18988: URL: https://github.com/apache/flink/pull/18988#issuecomment-1060027177 ## CI report: * faab63921b886a142c1d6385f8c7e19e8a516b70 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18987: URL: https://github.com/apache/flink/pull/18987#issuecomment-1059995435 ## CI report: * cef5578df1ea2bdcf451a776dacf2027746073e9 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Created] (FLINK-26503) Multi-network deployments may lead to hard-to-debug issues

2022-03-06 Thread Niklas Semmler (Jira)
Niklas Semmler created FLINK-26503: -- Summary: Multi-network deployments may lead to hard-to-debug issues Key: FLINK-26503 URL: https://issues.apache.org/jira/browse/FLINK-26503 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18931: URL: https://github.com/apache/flink/pull/18931#issuecomment-1054455643 ## CI report: * d25343904e861b82e50d44daca95ef0d9c13f77c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18931: [FLINK-26396][state/changelog] Fail upload if last attempt times out

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18931: URL: https://github.com/apache/flink/pull/18931#issuecomment-1054455643 ## CI report: * d25343904e861b82e50d44daca95ef0d9c13f77c Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18949: [FLINK-25235][tests] re-enable zookeeper test

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18949: URL: https://github.com/apache/flink/pull/18949#issuecomment-1055620167 ## CI report: * 0388e4297d9b74d848b085beec4829b90020131e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18949: [FLINK-25235][tests] re-enable zookeeper test

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18949: URL: https://github.com/apache/flink/pull/18949#issuecomment-1055620167 ## CI report: * 0388e4297d9b74d848b085beec4829b90020131e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18987: URL: https://github.com/apache/flink/pull/18987#issuecomment-1059995435 ## CI report: * cef5578df1ea2bdcf451a776dacf2027746073e9 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-06 Thread GitBox
flinkbot edited a comment on pull request #18987: URL: https://github.com/apache/flink/pull/18987#issuecomment-1059995435 ## CI report: * 9663f6e72285163ac4df3e7ffab83ab9a73b8e5e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

  1   2   >