[GitHub] [flink-table-store] LadyForest commented on a change in pull request #25: [FLINK-26208] Introduce TableStoreFactory

2022-02-28 Thread GitBox
LadyForest commented on a change in pull request #25: URL: https://github.com/apache/flink-table-store/pull/25#discussion_r816525533 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactoryOptions.java ## @@ -0,0 +1,32 @@

[GitHub] [flink] wangyang0918 commented on pull request #18891: [FLINK-25243][k8s] Increase the k8s transactional operation max retries in the integration tests

2022-02-28 Thread GitBox
wangyang0918 commented on pull request #18891: URL: https://github.com/apache/flink/pull/18891#issuecomment-1055125369 cc @gaoyunhaii Would you like to have a look on this simple change? -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[jira] [Updated] (FLINK-26416) Release Testing:

2022-02-28 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-26416: Description: With the introduction of Sink V2, the operator model of the sink changed slightly th

[GitHub] [flink] flinkbot edited a comment on pull request #18840: [FLINK-25528][state-processor-api] state processor api do not support increment checkpoint

2022-02-28 Thread GitBox
flinkbot edited a comment on pull request #18840: URL: https://github.com/apache/flink/pull/18840#issuecomment-1044222572 ## CI report: * 23a67ad924dce87513c4fb7809fc24ca2b35f2de Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-26416) Release Testing:

2022-02-28 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-26416: --- Summary: Release Testing: Key: FLINK-26416 URL: https://issues.apache.org/jira/browse/FLINK-26416 Project: Flink Issue Type: Improvement Components:

[jira] [Comment Edited] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

2022-02-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499374#comment-17499374 ] Martijn Visser edited comment on FLINK-26360 at 3/1/22, 7:48 AM: -

[GitHub] [flink] liufangqi commented on a change in pull request #18840: [FLINK-25528][state-processor-api] state processor api do not support increment checkpoint

2022-02-28 Thread GitBox
liufangqi commented on a change in pull request #18840: URL: https://github.com/apache/flink/pull/18840#discussion_r816519952 ## File path: flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/output/SnapshotUtilsTest.java ## @@ -50,13 +53,24 @@

[jira] [Commented] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

2022-02-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499374#comment-17499374 ] Martijn Visser commented on FLINK-26360: Thanks for opening the ticket [~luoyuxi

[GitHub] [flink] flinkbot edited a comment on pull request #18840: [FLINK-25528][state-processor-api] state processor api do not support increment checkpoint

2022-02-28 Thread GitBox
flinkbot edited a comment on pull request #18840: URL: https://github.com/apache/flink/pull/18840#issuecomment-1044222572 ## CI report: * 23a67ad924dce87513c4fb7809fc24ca2b35f2de Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26296) Add missing documentation

2022-02-28 Thread Joe Moser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Moser updated FLINK-26296: -- Component/s: Documentation > Add missing documentation > - > >

[jira] [Commented] (FLINK-26400) Release Testing: Explicit shutdown signalling from TaskManager to JobManager

2022-02-28 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499370#comment-17499370 ] Zhu Zhu commented on FLINK-26400: - I'd like to take this ticket if no one else already p

[GitHub] [flink-table-store] JingsongLi merged pull request #26: [hotfix] Set authority as thread name for FailingAtomicRenameFileSystem to support multi-thread testing

2022-02-28 Thread GitBox
JingsongLi merged pull request #26: URL: https://github.com/apache/flink-table-store/pull/26 -- 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: issue

[GitHub] [flink] flinkbot edited a comment on pull request #18852: [FLINK-26049][checkpoint] Improve logic after checkpoint trigger fails

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

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #25: [FLINK-26208] Introduce TableStoreFactory

2022-02-28 Thread GitBox
JingsongLi commented on a change in pull request #25: URL: https://github.com/apache/flink-table-store/pull/25#discussion_r816508016 ## File path: flink-table-store-connector/pom.xml ## @@ -39,6 +39,13 @@ under the License. provided + +

[GitHub] [flink] flinkbot edited a comment on pull request #18936: [hotfix] Fix doc about temporal functions

2022-02-28 Thread GitBox
flinkbot edited a comment on pull request #18936: URL: https://github.com/apache/flink/pull/18936#issuecomment-1055104384 ## CI report: * 8983567c26c34c8ef4e77bd0453aa50a5c1220d1 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18936: [hotfix] Fix doc about temporal functions

2022-02-28 Thread GitBox
flinkbot commented on pull request #18936: URL: https://github.com/apache/flink/pull/18936#issuecomment-1055104384 ## CI report: * 8983567c26c34c8ef4e77bd0453aa50a5c1220d1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink-table-store] tsreaper opened a new pull request #26: [hotfix] Set authority as thread name for FailingAtomicRenameFileSystem to support multi-thread testing

2022-02-28 Thread GitBox
tsreaper opened a new pull request #26: URL: https://github.com/apache/flink-table-store/pull/26 Currently `FailingAtomicRenameFileSystem` uses a static method to reset the failing counter and set failing possibility. This may cause conflicts when there are multiple testing threads running

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #25: [FLINK-26208] Introduce TableStoreFactory

2022-02-28 Thread GitBox
JingsongLi commented on a change in pull request #25: URL: https://github.com/apache/flink-table-store/pull/25#discussion_r816504715 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -0,0 +1,205 @@ +/* +

[GitHub] [flink] yittg opened a new pull request #18936: [hotfix] Fix doc about temporal functions

2022-02-28 Thread GitBox
yittg opened a new pull request #18936: URL: https://github.com/apache/flink/pull/18936 ## What is the purpose of the change Looks like it's a typo, fix me if i'm wrong, it's confused. ## Brief change log *(for example:)* - *The TaskInfo is stored in the

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #25: [FLINK-26208] Introduce TableStoreFactory

2022-02-28 Thread GitBox
JingsongLi commented on a change in pull request #25: URL: https://github.com/apache/flink-table-store/pull/25#discussion_r816495766 ## File path: flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/TableStoreFactory.java ## @@ -0,0 +1,205 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #18776: [FLINK-26151][streaming]Avoid inprogressfileRecoverable not be clean up after restoring the bucket

2022-02-28 Thread GitBox
flinkbot edited a comment on pull request #18776: URL: https://github.com/apache/flink/pull/18776#issuecomment-1040098864 ## CI report: * 0f86d63379ee403df5bf196f9f11b5188fed70a9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26406) Significant differences of Fault Tolerance between English and Chinese version

2022-02-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499361#comment-17499361 ] Yun Tang commented on FLINK-26406: -- The deprecated state backends do not mean they cann

[jira] [Updated] (FLINK-26406) Significant differences of Fault Tolerance between English and Chinese version

2022-02-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-26406: - Priority: Major (was: Blocker) > Significant differences of Fault Tolerance between English and Chinese

[jira] [Commented] (FLINK-26394) CheckpointCoordinator.isTriggering can not be reset if a checkpoint expires while the checkpointCoordinator task is queuing in the SourceCoordinator executor.

2022-02-28 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499358#comment-17499358 ] Yun Tang commented on FLINK-26394: -- [~pltbkd], do you have any test case to reproduce t

[GitHub] [flink] flinkbot edited a comment on pull request #18920: [FLINK-26361][hive] add variables when create LogicFilter to fix "une…

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

[jira] [Updated] (FLINK-26387) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26387: Fix Version/s: 1.15.0 > KafkaSourceLegacyITCase.testBrokerFailure hang on azure >

[GitHub] [flink] flinkbot edited a comment on pull request #18934: [Hotfix][doc] Fix typo in java code demo of ES stream connector page for release-1.14

2022-02-28 Thread GitBox
flinkbot edited a comment on pull request #18934: URL: https://github.com/apache/flink/pull/18934#issuecomment-1055015788 ## CI report: * 9dc64e7d3b6137dcffe799bbc6badf8dcb21fdc9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18920: [FLINK-26361][hive] add variables when create LogicFilter to fix "une…

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

[jira] [Updated] (FLINK-26387) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26387: Priority: Blocker (was: Major) > KafkaSourceLegacyITCase.testBrokerFailure hang on azure > --

[jira] [Comment Edited] (FLINK-26191) Incorrect license in Elasticsearch connectors

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499313#comment-17499313 ] Yun Gao edited comment on FLINK-26191 at 3/1/22, 6:56 AM: -- Hi [

[GitHub] [flink] gaoyunhaii commented on pull request #18805: [FLINK-26173][streaming] Recover GlobalCommittables with Sink V1 GlobalCommittable serializer

2022-02-28 Thread GitBox
gaoyunhaii commented on pull request #18805: URL: https://github.com/apache/flink/pull/18805#issuecomment-1055085939 Thanks @fapaul for the PR! I'll have 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 URL

[GitHub] [flink] XComp commented on a change in pull request #18910: [FLINK-26296] Add missing documentation for JobResultStore and repeatable resource cleanup strategy

2022-02-28 Thread GitBox
XComp commented on a change in pull request #18910: URL: https://github.com/apache/flink/pull/18910#discussion_r816492422 ## File path: docs/content.zh/docs/deployment/overview.md ## @@ -152,7 +152,12 @@ When deploying Flink, there are often multiple options available for each

[jira] [Updated] (FLINK-26405) Add validation check of num of JM replica

2022-02-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26405: --- Labels: pull-request-available (was: ) > Add validation check of num of JM replica > --

[GitHub] [flink] flinkbot edited a comment on pull request #18935: [FLINK-26347][rpc] Using system classloader in deserialization of Rem…

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

[GitHub] [flink] flinkbot commented on pull request #18935: [FLINK-26347][rpc] Using system classloader in deserialization of Rem…

2022-02-28 Thread GitBox
flinkbot commented on pull request #18935: URL: https://github.com/apache/flink/pull/18935#issuecomment-1055078593 ## CI report: * d5ac33b72f6446d08a3593663720f425a0321d39 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-26415) Improve view usage in hive dialect

2022-02-28 Thread luoyuxia (Jira)
luoyuxia created FLINK-26415: Summary: Improve view usage in hive dialect Key: FLINK-26415 URL: https://issues.apache.org/jira/browse/FLINK-26415 Project: Flink Issue Type: Sub-task R

[jira] [Updated] (FLINK-26347) Should use Flink system Classloader (AppClassloader) when deserializing RPC message

2022-02-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26347: --- Labels: pull-request-available (was: ) > Should use Flink system Classloader (AppClassloade

[jira] [Resolved] (FLINK-26289) Adaptive Scheduler: Exception history can not be queried by the REST API

2022-02-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-26289. --- Resolution: Fixed {{master}}: [5c4d2632e991696e0cb7e016a34ce045a06faf83|https://github.com/

[jira] [Updated] (FLINK-26289) Adaptive Scheduler: Exception history can not be queried by the REST API

2022-02-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26289: -- Affects Version/s: 1.15.0 > Adaptive Scheduler: Exception history can not be queried by the RE

[GitHub] [flink] KarmaGYZ opened a new pull request #18935: [FLINK-26347][rpc] Using system classloader in deserialization of Rem…

2022-02-28 Thread GitBox
KarmaGYZ opened a new pull request #18935: URL: https://github.com/apache/flink/pull/18935 …oteRpcInvocation ## What is the purpose of the change To fix the issue recorded in FLINK-26347, we proposed to use the system classloader in the deserialization of RemoteRpcInvocation.

[GitHub] [flink] XComp merged pull request #18866: [FLINK-26289][runtime] AdaptiveScheduler: Allow exception history to …

2022-02-28 Thread GitBox
XComp merged pull request #18866: URL: https://github.com/apache/flink/pull/18866 -- 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.

[GitHub] [flink] XComp commented on pull request #18866: [FLINK-26289][runtime] AdaptiveScheduler: Allow exception history to …

2022-02-28 Thread GitBox
XComp commented on pull request #18866: URL: https://github.com/apache/flink/pull/18866#issuecomment-1055076328 Thanks for the contributions and reviews. The CI run succeeded. I'm gonna merge it. -- This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Updated] (FLINK-26405) Add validation check of num of JM replica

2022-02-28 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26405: -- Description: When HA is enabled, the replicas of JM can be 1 or more,  When HA is not set, the replic

[jira] [Commented] (FLINK-26401) improve the compatibility for hive catalogView

2022-02-28 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499351#comment-17499351 ] zoucao commented on FLINK-26401: Hi [~luoyuxia], I just pick 'date' at random, If we jus

[jira] [Created] (FLINK-26414) Hive dialect supports "Marco"

2022-02-28 Thread luoyuxia (Jira)
luoyuxia created FLINK-26414: Summary: Hive dialect supports "Marco" Key: FLINK-26414 URL: https://issues.apache.org/jira/browse/FLINK-26414 Project: Flink Issue Type: Sub-task Report

[jira] [Created] (FLINK-26413) Hive dialect support "LOAD DATA INPATH"

2022-02-28 Thread luoyuxia (Jira)
luoyuxia created FLINK-26413: Summary: Hive dialect support "LOAD DATA INPATH" Key: FLINK-26413 URL: https://issues.apache.org/jira/browse/FLINK-26413 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26412) Hive dialect supports "CREATE TEMPORARY FUNCTION USING xxx.jar"

2022-02-28 Thread luoyuxia (Jira)
luoyuxia created FLINK-26412: Summary: Hive dialect supports "CREATE TEMPORARY FUNCTION USING xxx.jar" Key: FLINK-26412 URL: https://issues.apache.org/jira/browse/FLINK-26412 Project: Flink Issu

[jira] [Commented] (FLINK-26405) Add validation check of num of JM replica

2022-02-28 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499348#comment-17499348 ] Yang Wang commented on FLINK-26405: --- Of cause, thanks for creating this ticket. > Add

[jira] [Assigned] (FLINK-26405) Add validation check of num of JM replica

2022-02-28 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-26405: - Assignee: Biao Geng > Add validation check of num of JM replica > -

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-02-28 Thread Lyn Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499347#comment-17499347 ] Lyn Zhang commented on FLINK-25695: --- Hi [~wenlong.lwl] Actually we used FsStateBackend

[jira] [Updated] (FLINK-26408) retract a non-existent record in RetractableTopNFunction

2022-02-28 Thread Hengyu Dai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hengyu Dai updated FLINK-26408: --- Description: RetractableTopNFunction will throw a RuntimeException when # the sorted Map {color:#07

[GitHub] [flink] flinkbot edited a comment on pull request #18928: [FLINK-25545][flink-clients][JUnit5 Migration] Module: flink-clients.

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

[jira] [Comment Edited] (FLINK-26408) retract a non-existent record in RetractableTopNFunction

2022-02-28 Thread Hengyu Dai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499315#comment-17499315 ] Hengyu Dai edited comment on FLINK-26408 at 3/1/22, 5:48 AM: -

[GitHub] [flink] flinkbot edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

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

[GitHub] [flink] flinkbot edited a comment on pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

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

[jira] [Updated] (FLINK-26408) retract a non-existent record in RetractableTopNFunction

2022-02-28 Thread Hengyu Dai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hengyu Dai updated FLINK-26408: --- Description: RetractableTopNFunction will throw a RuntimeException when # the sorted Map {color:#07

[GitHub] [flink] flinkbot edited a comment on pull request #18920: [FLINK-26361][hive] add variables when create LogicFilter to fix "une…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18928: [FLINK-25545][flink-clients][JUnit5 Migration] Module: flink-clients.

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

[GitHub] [flink] MrWhiteSike commented on a change in pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

2022-02-28 Thread GitBox
MrWhiteSike commented on a change in pull request #18655: URL: https://github.com/apache/flink/pull/18655#discussion_r816456481 ## File path: docs/content.zh/docs/connectors/table/filesystem.md ## @@ -190,209 +194,217 @@ CREATE TABLE MyUserTableWithFilepath ( ) ``` + + ##

[GitHub] [flink] flinkbot edited a comment on pull request #18928: [FLINK-25545][flink-clients][JUnit5 Migration] Module: flink-clients.

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

[GitHub] [flink] RocMarshal commented on pull request #18928: [FLINK-25545][flink-clients][JUnit5 Migration] Module: flink-clients.

2022-02-28 Thread GitBox
RocMarshal commented on pull request #18928: URL: https://github.com/apache/flink/pull/18928#issuecomment-1055029965 @flinkbot run azure -- 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 speci

[GitHub] [flink] RocMarshal removed a comment on pull request #18928: [FLINK-25545][flink-clients][JUnit5 Migration] Module: flink-clients.

2022-02-28 Thread GitBox
RocMarshal removed a comment on pull request #18928: URL: https://github.com/apache/flink/pull/18928#issuecomment-1054457481 @flinkbot run azure -- 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 t

[GitHub] [flink] RocMarshal commented on pull request #18646: [FLINK-25797][docs-zh] Translate datastream/formats/parquet.md page into Chinese.

2022-02-28 Thread GitBox
RocMarshal commented on pull request #18646: URL: https://github.com/apache/flink/pull/18646#issuecomment-1055022446 Hi, @wangzhiwubigdata Would you mind checking the conflicts ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] RocMarshal commented on a change in pull request #18655: [FLINK-25799] [docs] Translate table/filesystem.md page into Chinese.

2022-02-28 Thread GitBox
RocMarshal commented on a change in pull request #18655: URL: https://github.com/apache/flink/pull/18655#discussion_r816448300 ## File path: docs/content.zh/docs/connectors/table/filesystem.md ## @@ -190,209 +194,217 @@ CREATE TABLE MyUserTableWithFilepath ( ) ``` + + ## S

[GitHub] [flink] flinkbot edited a comment on pull request #18934: [Hotfix][doc] Fix typo in java code demo of ES stream connector page for release-1.14

2022-02-28 Thread GitBox
flinkbot edited a comment on pull request #18934: URL: https://github.com/apache/flink/pull/18934#issuecomment-1055015788 ## CI report: * 9dc64e7d3b6137dcffe799bbc6badf8dcb21fdc9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18934: [Hotfix][doc] Fix typo in java code demo of ES stream connector page for release-1.14

2022-02-28 Thread GitBox
flinkbot commented on pull request #18934: URL: https://github.com/apache/flink/pull/18934#issuecomment-1055015788 ## CI report: * 9dc64e7d3b6137dcffe799bbc6badf8dcb21fdc9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-26181) Support manual savepoint triggering in the operator

2022-02-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499331#comment-17499331 ] Gyula Fora commented on FLINK-26181: I think Matyas will start a discuss thread on t

[GitHub] [flink] RocMarshal opened a new pull request #18934: [Hotfix][doc] Fix typo in java code demo of ES stream connector page for release-1.14

2022-02-28 Thread GitBox
RocMarshal opened a new pull request #18934: URL: https://github.com/apache/flink/pull/18934 ## What is the purpose of the change Fix typo in java code demo of ES stream connector page for release-1.14 ## Brief change log Fix typo in java code demo of

[jira] [Updated] (FLINK-26408) retract a non-existent record in RetractableTopNFunction

2022-02-28 Thread Hengyu Dai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hengyu Dai updated FLINK-26408: --- Priority: Blocker (was: Major) > retract a non-existent record in RetractableTopNFunction > --

[jira] [Created] (FLINK-26411) Hive dialect supports CLUSTERED BY/ SORTED BY table

2022-02-28 Thread luoyuxia (Jira)
luoyuxia created FLINK-26411: Summary: Hive dialect supports CLUSTERED BY/ SORTED BY table Key: FLINK-26411 URL: https://issues.apache.org/jira/browse/FLINK-26411 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-26409) Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest

2022-02-28 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-26409: - Summary: Remove meaningless Kafka connector test case KafkaConsumerTestBase.runBrokerFailureTest Key: FLINK-26409 URL: https://issues.apache.org/jira/browse/FLINK-26409

[jira] [Created] (FLINK-26410) support hive transform

2022-02-28 Thread luoyuxia (Jira)
luoyuxia created FLINK-26410: Summary: support hive transform Key: FLINK-26410 URL: https://issues.apache.org/jira/browse/FLINK-26410 Project: Flink Issue Type: Sub-task Components: Con

[jira] [Commented] (FLINK-26401) improve the compatibility for hive catalogView

2022-02-28 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499319#comment-17499319 ] luoyuxia commented on FLINK-26401: -- [~zoucao]Thanks for reporting it. IIUC, as the *dat

[jira] [Comment Edited] (FLINK-26401) improve the compatibility for hive catalogView

2022-02-28 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499319#comment-17499319 ] luoyuxia edited comment on FLINK-26401 at 3/1/22, 4:14 AM: --- [~

[jira] [Comment Edited] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-02-28 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499317#comment-17499317 ] Wenlong Lyu edited comment on FLINK-25695 at 3/1/22, 4:12 AM:

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some cases

2022-02-28 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499317#comment-17499317 ] Wenlong Lyu commented on FLINK-25695: - hi, [~wenlong.lwl] thanks for sharing your in

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

2022-02-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26208: --- Labels: pull-request-available (was: ) > Introduce implementation of ManagedTableFactory >

[GitHub] [flink-table-store] LadyForest opened a new pull request #25: [FLINK-26208] Introduce TableStoreFactory

2022-02-28 Thread GitBox
LadyForest opened a new pull request #25: URL: https://github.com/apache/flink-table-store/pull/25 # What is the purpose of the change This PR aims to introduce the implementation of `ManagedTableFactory`, which supports using SQL to interact with table-store, the more details can be

[jira] [Commented] (FLINK-26408) retract a non-existent record in RetractableTopNFunction

2022-02-28 Thread Hengyu Dai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499315#comment-17499315 ] Hengyu Dai commented on FLINK-26408: Hi, [~lzljs3620320], I find you have some resea

[jira] [Closed] (FLINK-25789) Translate the formats/hadoop page into Chinese.

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25789. --- Fix Version/s: 1.15.0 Assignee: RocMarshal Resolution: Fixed > Translate the formats/hadoop

[GitHub] [flink] flinkbot edited a comment on pull request #18825: [FLINK-26126][kafka] fix numRecordsOut metric error

2022-02-28 Thread GitBox
flinkbot edited a comment on pull request #18825: URL: https://github.com/apache/flink/pull/18825#issuecomment-1043598537 ## CI report: * 3d0d69f8ecfb2a8d52236bf71e287caf3aebcfc8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25789) Translate the formats/hadoop page into Chinese.

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499314#comment-17499314 ] Yun Gao commented on FLINK-25789: - Merge on master via 1cdb6591e5bb73f182e9c2414b1d13fd3

[GitHub] [flink] gaoyunhaii closed pull request #18480: [FLINK-25789][docs-zh] Translate the formats/hadoop page into Chinese.

2022-02-28 Thread GitBox
gaoyunhaii closed pull request #18480: URL: https://github.com/apache/flink/pull/18480 -- 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-unsu

[jira] [Updated] (FLINK-26408) retract a non-existent record in RetractableTopNFunction

2022-02-28 Thread Hengyu Dai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hengyu Dai updated FLINK-26408: --- Affects Version/s: 1.12.2 > retract a non-existent record in RetractableTopNFunction >

[jira] [Updated] (FLINK-26408) retract a non-existent record in RetractableTopNFunction

2022-02-28 Thread Hengyu Dai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hengyu Dai updated FLINK-26408: --- Description: RetractableTopNFunction will throw a RuntimeException when # the sorted Map {color:#07

[jira] [Updated] (FLINK-26408) retract a non-existent record in RetractableTopNFunction

2022-02-28 Thread Hengyu Dai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hengyu Dai updated FLINK-26408: --- Description: RetractableTopNFunction will throw a RuntimeException when # the sorted Map {color:#07

[jira] [Created] (FLINK-26408) retract a non-existent record in RetractableTopNFunction

2022-02-28 Thread Hengyu Dai (Jira)
Hengyu Dai created FLINK-26408: -- Summary: retract a non-existent record in RetractableTopNFunction Key: FLINK-26408 URL: https://issues.apache.org/jira/browse/FLINK-26408 Project: Flink Issue T

[jira] [Commented] (FLINK-26051) one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode

2022-02-28 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499312#comment-17499312 ] xuyang commented on FLINK-26051: Hi, thanks to report this bug! Would you like to fix th

[jira] [Commented] (FLINK-26191) Incorrect license in Elasticsearch connectors

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499313#comment-17499313 ] Yun Gao commented on FLINK-26191: - Hi [~chesnay] [~jark] do we have updates on this issu

[jira] [Commented] (FLINK-26387) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499307#comment-17499307 ] Yun Gao commented on FLINK-26387: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-26387) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499306#comment-17499306 ] Yun Gao commented on FLINK-26387: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Closed] (FLINK-26276) Introduce ITCase for table store source and sink

2022-02-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26276. Resolution: Fixed master: a472c23e9e6aa0900360f3bc12b7e3e325bec318 > Introduce ITCase for table s

[GitHub] [flink-table-store] JingsongLi merged pull request #23: [FLINK-26276] Introduce ITCase for table store source and sink

2022-02-28 Thread GitBox
JingsongLi merged pull request #23: URL: https://github.com/apache/flink-table-store/pull/23 -- 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: issue

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

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499304#comment-17499304 ] Yun Gao commented on FLINK-26314: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-26393) KafkaITCase.testBrokerFailure fails due to a topic isn't cleaned up properly

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499303#comment-17499303 ] Yun Gao commented on FLINK-26393: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-26321) KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails on azure

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499301#comment-17499301 ] Yun Gao commented on FLINK-26321: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-26393) KafkaITCase.testBrokerFailure fails due to a topic isn't cleaned up properly

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499300#comment-17499300 ] Yun Gao commented on FLINK-26393: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-26393) KafkaITCase.testBrokerFailure fails due to a topic isn't cleaned up properly

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499299#comment-17499299 ] Yun Gao commented on FLINK-26393: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Updated] (FLINK-26393) KafkaITCase.testBrokerFailure fails due to a topic isn't cleaned up properly

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-26393: Priority: Blocker (was: Critical) > KafkaITCase.testBrokerFailure fails due to a topic isn't cleaned up p

[jira] [Commented] (FLINK-26393) KafkaITCase.testBrokerFailure fails due to a topic isn't cleaned up properly

2022-02-28 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17499298#comment-17499298 ] Yun Gao commented on FLINK-26393: - https://dev.azure.com/apache-flink/apache-flink/_buil

  1   2   3   4   5   6   >