[GitHub] [flink] flinkbot edited a comment on pull request #18215: [FLINK-25392][table-planner]Support new StatementSet syntax in planner and parser

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

[GitHub] [flink] leonardBang commented on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

2022-01-12 Thread GitBox
leonardBang commented on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-1011784108 Thanks @eskabetxe and @MartijnVisser for the great work, LGTM. I also append two commits to improve our test and document. -- This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * 715383d5d8ec50ae6fd41db834d800bb65b99c80 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18215: [FLINK-25392][table-planner]Support new StatementSet syntax in planner and parser

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

[jira] [Commented] (FLINK-25559) SQL JOIN causes data loss

2022-01-12 Thread ZhuoYu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475100#comment-17475100 ] ZhuoYu Chen commented on FLINK-25559: - Hi [~Ashulin]    I am very interested in this

[GitHub] [flink] wenlong88 commented on a change in pull request #18215: [FLINK-25392][table-planner]Support new StatementSet syntax in planner and parser

2022-01-12 Thread GitBox
wenlong88 commented on a change in pull request #18215: URL: https://github.com/apache/flink/pull/18215#discussion_r783614658 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ## @@ -1738,6 +1765,28 @@ SqlNode SqlRichExplain() : } } +

[jira] [Commented] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-12 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475095#comment-17475095 ] dalongliu commented on FLINK-25635: --- cc [~luoyuxia]  > Using sql client create hive c

[jira] [Commented] (FLINK-25634) flink-read-onyarn-configuration

2022-01-12 Thread zlzhang0122 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475096#comment-17475096 ] zlzhang0122 commented on FLINK-25634: - I have encountered similar case and found tha

[jira] [Created] (FLINK-25635) Using sql client create hive catalog throw exception

2022-01-12 Thread dalongliu (Jira)
dalongliu created FLINK-25635: - Summary: Using sql client create hive catalog throw exception Key: FLINK-25635 URL: https://issues.apache.org/jira/browse/FLINK-25635 Project: Flink Issue Type: Ne

[GitHub] [flink] wangyang0918 commented on pull request #17819: [FLINK-15816][k8s] Prevent labels using kubernetes.cluster-id to exceed the limit of 63 characters

2022-01-12 Thread GitBox
wangyang0918 commented on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-1011771453 @alpreu Currently, the 45 characters pre-check could only work for native K8s HA/non-HA mode. But for standalone cluster with K8s HA enabled, we do not have the pre-check

[jira] [Assigned] (FLINK-25600) Support new statement set syntax in sql client and update docs

2022-01-12 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-25600: -- Assignee: Wenlong Lyu > Support new statement set syntax in sql client and update docs >

[jira] [Commented] (FLINK-25600) Support new statement set syntax in sql client and update docs

2022-01-12 Thread Wenlong Lyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475093#comment-17475093 ] Wenlong Lyu commented on FLINK-25600: - [~monster#12] thanks for offering help, I am

[GitHub] [flink] zjureel commented on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-01-12 Thread GitBox
zjureel commented on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1011768126 Thanks @xintongsong. Replace `ExecutorService#shutdownNow` with `Executor#awaitTermination` is not feasible, while the main target of `ExecutorService` is to clear the pending

[jira] [Commented] (FLINK-25484) TableRollingPolicy do not support inactivityInterval config which is supported in datastream api

2022-01-12 Thread LiChang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475088#comment-17475088 ] LiChang commented on FLINK-25484: - yes，I am doing on it  Fabian Paul   > TableRollingPo

[jira] [Updated] (FLINK-25484) TableRollingPolicy do not support inactivityInterval config which is supported in datastream api

2022-01-12 Thread LiChang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LiChang updated FLINK-25484: Attachment: image-2022-01-13-11-36-24-102.png > TableRollingPolicy do not support inactivityInterval confi

[jira] [Commented] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

2022-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475072#comment-17475072 ] Liu commented on FLINK-25566: - [~trohrmann] Thanks. I have updated the issue. Please have a

[GitHub] [flink] flinkbot edited a comment on pull request #18201: [FLINK-25167][API / DataStream]Expose StreamOperatorFactory in Connec…

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

[jira] [Updated] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

2022-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-25566: Description: When disk error, the related task will stuck for java.lang.NoClassDefFoundError. Our inner flink ver

[GitHub] [flink] flinkbot edited a comment on pull request #18201: [FLINK-25167][API / DataStream]Expose StreamOperatorFactory in Connec…

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

[jira] [Updated] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

2022-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-25566: Description: When disk error, the related task will stuck for java.lang.NoClassDefFoundError. Our inner flink ver

[GitHub] [flink-web] becketqin merged pull request #498: Make minor change to the 'Apache Flink ML 2.0.0 Release Announcement'

2022-01-12 Thread GitBox
becketqin merged pull request #498: URL: https://github.com/apache/flink-web/pull/498 -- 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-unsub

[GitHub] [flink-web] becketqin commented on pull request #498: Make minor change to the 'Apache Flink ML 2.0.0 Release Announcement'

2022-01-12 Thread GitBox
becketqin commented on pull request #498: URL: https://github.com/apache/flink-web/pull/498#issuecomment-1011723029 Thanks for the update. The changes looks good to me. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

2022-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-25566: Attachment: image-2022-01-13-10-56-10-668.png > Fail to cancel task if disk is bad for java.lang.NoClassDefFoundEr

[jira] [Updated] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

2022-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-25566: Attachment: image-2022-01-13-10-52-56-490.png > Fail to cancel task if disk is bad for java.lang.NoClassDefFoundEr

[jira] [Commented] (FLINK-24607) SourceCoordinator may miss to close SplitEnumerator when failover frequently

2022-01-12 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475066#comment-17475066 ] Jiangjie Qin commented on FLINK-24607: -- [~dmvk] I am not sure about the exact cause

[jira] [Updated] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

2022-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-25566: Description: When disk error, the related task will stuck for java.lang.NoClassDefFoundError. The total log is as

[jira] [Comment Edited] (FLINK-25631) Support enhanced `show tables` statement

2022-01-12 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475063#comment-17475063 ] Yubin Li edited comment on FLINK-25631 at 1/13/22, 2:46 AM:

[jira] [Updated] (FLINK-25566) Fail to cancel task if disk is bad for java.lang.NoClassDefFoundError

2022-01-12 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu updated FLINK-25566: Attachment: image-2022-01-13-10-45-02-495.png > Fail to cancel task if disk is bad for java.lang.NoClassDefFoundEr

[jira] [Commented] (FLINK-25631) Support enhanced `show tables` statement

2022-01-12 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475063#comment-17475063 ] Yubin Li commented on FLINK-25631: -- [~MartijnVisser] Thanks for your attention, the syn

[jira] [Updated] (FLINK-25634) flink-read-onyarn-configuration

2022-01-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 宇宙先生 updated FLINK-25634: - Description: in flink-src.code : !image-2022-01-13-10-14-18-918.png! Set the number of retries for failed YARN

[jira] [Comment Edited] (FLINK-25631) Support enhanced `show tables` statement

2022-01-12 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475051#comment-17475051 ] Yubin Li edited comment on FLINK-25631 at 1/13/22, 2:15 AM:

[jira] [Updated] (FLINK-25634) flink-read-onyarn-configuration

2022-01-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 宇宙先生 updated FLINK-25634: - Attachment: image-2022-01-13-10-14-18-918.png Description: in flink-src.code : !image-2022-01-13-10-14-18-

[jira] [Created] (FLINK-25634) flink-read-onyarn-configuration

2022-01-12 Thread Jira
宇宙先生 created FLINK-25634: Summary: flink-read-onyarn-configuration Key: FLINK-25634 URL: https://issues.apache.org/jira/browse/FLINK-25634 Project: Flink Issue Type: Bug Affects Versions: 1.11.2

[jira] [Comment Edited] (FLINK-25631) Support enhanced `show tables` statement

2022-01-12 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475051#comment-17475051 ] Yubin Li edited comment on FLINK-25631 at 1/13/22, 2:04 AM:

[jira] [Commented] (FLINK-25631) Support enhanced `show tables` statement

2022-01-12 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475051#comment-17475051 ] Yubin Li commented on FLINK-25631: -- [~monster#12] Thanks, it's very kind of you, but I

[jira] [Updated] (FLINK-25631) Support enhanced `show tables` statement

2022-01-12 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25631: - Description: Enhanced `show tables` statement like ` show tables from db1 like 't%' ` has been supporte

[jira] [Updated] (FLINK-25631) Support enhanced `show tables` statement

2022-01-12 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-25631: - Description: Enhanced `show tables` statement like ` show tables from db1 like 't%' ` has been supporte

[jira] [Commented] (FLINK-5129) make the BlobServer use a distributed file system

2022-01-12 Thread lupan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17475041#comment-17475041 ] lupan commented on FLINK-5129: -- OK. Thanks. I have submitted a new issue. https://issues.ap

[jira] [Updated] (FLINK-5129) make the BlobServer use a distributed file system

2022-01-12 Thread lupan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lupan updated FLINK-5129: - Attachment: image-2022-01-13-09-26-15-252.png > make the BlobServer use a distributed file system > -

[GitHub] [flink] nyingping commented on a change in pull request #17994: [FLINK-24456][Connectors / Kafka,Table SQL / Ecosystem] Support bound…

2022-01-12 Thread GitBox
nyingping commented on a change in pull request #17994: URL: https://github.com/apache/flink/pull/17994#discussion_r783555813 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java ## @@ -

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * a926ce5a76005fb6b1d272f6b3c120d49bded5a7 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] nyingping commented on a change in pull request #17994: [FLINK-24456][Connectors / Kafka,Table SQL / Ecosystem] Support bound…

2022-01-12 Thread GitBox
nyingping commented on a change in pull request #17994: URL: https://github.com/apache/flink/pull/17994#discussion_r783555813 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaConnectorOptions.java ## @@ -

[GitHub] [flink] galenwarren edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2022-01-12 Thread GitBox
galenwarren edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-1011205281 @xintongsong I just pushed commits with all the requested changes. I also rebased to address the conflict in `flink-core/src/main/java/org/apache/flink/core/fs/FileS

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN * 413eaca4204616c31360f74964551f3a63f9

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 3ccdd94768840aa728f0321e5a6481caacf5903d Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 3ccdd94768840aa728f0321e5a6481caacf5903d Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 3ccdd94768840aa728f0321e5a6481caacf5903d Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 3ccdd94768840aa728f0321e5a6481caacf5903d Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * a785fd4a6d88be5c685a08fd80d4671cd0aebdce Azure: [SUCCESS](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18165: [FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat…

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18165: URL: https://github.com/apache/flink/pull/18165#issuecomment-998902737 ## CI report: * 49ee432a0f04b1d560b2cea48b8ab8b40f3e5404 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * a785fd4a6d88be5c685a08fd80d4671cd0aebdce Azure: [PENDING](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * a785fd4a6d88be5c685a08fd80d4671cd0aebdce Azure: [PENDING](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 3ccdd94768840aa728f0321e5a6481caacf5903d Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] JingGe commented on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

2022-01-12 Thread GitBox
JingGe commented on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1011492869 @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 specific

[GitHub] [flink] flinkbot edited a comment on pull request #18290: [FLINK-25391][connectors][formats] Update existing table factories/format factories for catalog table options forwarding

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18290: URL: https://github.com/apache/flink/pull/18290#issuecomment-1006716199 ## CI report: * 8480af8298b5fa73b3a47dc97ebea031400e660a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18290: [FLINK-25391][connectors][formats] Update existing table factories/format factories for catalog table options forwarding

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

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * 5d9eca0f42ec07ed8577af689f2d90acba818a3a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * 5d9eca0f42ec07ed8577af689f2d90acba818a3a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * 5d9eca0f42ec07ed8577af689f2d90acba818a3a Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] metaswirl commented on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
metaswirl commented on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-1011470263 @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 specif

[jira] [Commented] (FLINK-25277) Introduce explicit shutdown signalling between TaskManager and JobManager

2022-01-12 Thread Niklas Semmler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474973#comment-17474973 ] Niklas Semmler commented on FLINK-25277: The [PR #18169 |https://github.com/apac

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [WIP][FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * 5d9eca0f42ec07ed8577af689f2d90acba818a3a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18343: [FLINK-25633] Set locale to en-US to avoid ambiguous decimal formattings

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18343: URL: https://github.com/apache/flink/pull/18343#issuecomment-1011258099 ## CI report: * 95cf3f884093ae61734d4bc0ed1d8214d821eb62 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [WIP][FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * 5d9eca0f42ec07ed8577af689f2d90acba818a3a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] JingGe commented on a change in pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-12 Thread GitBox
JingGe commented on a change in pull request #18302: URL: https://github.com/apache/flink/pull/18302#discussion_r783350027 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java ## @@ -0,0 +1,103 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [WIP][FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * 5d9eca0f42ec07ed8577af689f2d90acba818a3a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [WIP][FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * 5d9eca0f42ec07ed8577af689f2d90acba818a3a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18194: [FLINK-25436] Let Dispatcher only retain recovered jobs in BlobServer

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

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [WIP][FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * 5d9eca0f42ec07ed8577af689f2d90acba818a3a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18192: [FLINK-25406] Let FileSystemBlobStore sync output stream

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

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [WIP][FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * 5d9eca0f42ec07ed8577af689f2d90acba818a3a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [WIP][FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * 5d9eca0f42ec07ed8577af689f2d90acba818a3a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [WIP][FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * 5d9eca0f42ec07ed8577af689f2d90acba818a3a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [WIP][FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * 5d9eca0f42ec07ed8577af689f2d90acba818a3a Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #18191: [FLINK-25405] Let BlobServer/BlobCache check and delete corrupted blobs at start up

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18191: URL: https://github.com/apache/flink/pull/18191#issuecomment-1000337022 ## CI report: * 63201b3abe1c4c55383ca34130c6c49483c683ed Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18221: [FLINK-24803][table-planner] Fix cast BINARY/VARBINARY to STRING

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

[GitHub] [flink] flinkbot edited a comment on pull request #18333: [FLINK-25220][test] Write an architectural rule for all IT cases w.r.t. the MiniCluster

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18333: URL: https://github.com/apache/flink/pull/18333#issuecomment-1010381163 ## CI report: * 454378c5d0aecc36ae88a99f1e1d936405226a22 UNKNOWN * a785fd4a6d88be5c685a08fd80d4671cd0aebdce Azure: [FAILURE](https://dev.azure.com/apache-f

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

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * d5f7ce651d4ba90273a7b0f247e0e04594762cb9 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-818947931 ## CI report: * 27173ec5d2c2218e5b50ad86e88ee96aa712cba2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18341: URL: https://github.com/apache/flink/pull/18341#issuecomment-1011007519 ## CI report: * 6b5b590785bb896e24fe5f6fa2729fb5ce143f07 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18164: [FLINK-25404] Let blob.storage.directory default to /blobStorage

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18164: URL: https://github.com/apache/flink/pull/18164#issuecomment-998893805 ## CI report: * 12b9b89bc61dac49f6dcfb4af33402808a62be53 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 50f2652e65b6f315b68d8764da243e41b314ec79 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18165: [FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat…

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18165: URL: https://github.com/apache/flink/pull/18165#issuecomment-998902737 ## CI report: * 381e4a7a5c0102503dada63063ae1da80f44bff3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18165: [FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat…

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18165: URL: https://github.com/apache/flink/pull/18165#issuecomment-998902737 ## CI report: * 381e4a7a5c0102503dada63063ae1da80f44bff3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18286: [FLINK-25533] Forward preferred allocations into the DeclarativeSlotPoolBridge

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

[GitHub] [flink] flinkbot edited a comment on pull request #18201: [FLINK-25167][API / DataStream]Expose StreamOperatorFactory in Connec…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18165: [FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat…

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18165: URL: https://github.com/apache/flink/pull/18165#issuecomment-998902737 ## CI report: * 381e4a7a5c0102503dada63063ae1da80f44bff3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * a3ee27c14427a3e9ae4ae17adb4635aa4ab52e1e Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * a3ee27c14427a3e9ae4ae17adb4635aa4ab52e1e Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18165: [FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat…

2022-01-12 Thread GitBox
CrynetLogistics commented on a change in pull request #18165: URL: https://github.com/apache/flink/pull/18165#discussion_r783349826 ## File path: docs/content/docs/connectors/datastream/kinesis.md ## @@ -566,124 +583,124 @@ Retry and backoff parameters can be configured using

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 546d809fdb60cf252d4e34d39f5d5bf79bbf3a8d Azure: [CANCELED](https://dev.azure.com/apache-

[jira] [Closed] (FLINK-17505) Merge small files produced by StreamingFileSink

2022-01-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-17505. -- Resolution: Won't Fix This ticket has been superseded by https://issues.apache.org/jira/brows

[jira] [Resolved] (FLINK-20379) Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializationSchema

2022-01-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser resolved FLINK-20379. Resolution: Fixed This ticket was still open but the PR was merged. I've adjusted the fixV

[jira] [Updated] (FLINK-20379) Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializationSchema

2022-01-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-20379: --- Fix Version/s: 1.13.0 (was: 1.15.0) (was: 1.14.

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18165: [FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat…

2022-01-12 Thread GitBox
CrynetLogistics commented on a change in pull request #18165: URL: https://github.com/apache/flink/pull/18165#discussion_r783349826 ## File path: docs/content/docs/connectors/datastream/kinesis.md ## @@ -566,124 +583,124 @@ Retry and backoff parameters can be configured using

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 546d809fdb60cf252d4e34d39f5d5bf79bbf3a8d Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink-web] MartijnVisser commented on a change in pull request #497: Add Flink release 1.14.3

2022-01-12 Thread GitBox
MartijnVisser commented on a change in pull request #497: URL: https://github.com/apache/flink-web/pull/497#discussion_r783347479 ## File path: _posts/2022-01-17-release-1.14.3.md ## @@ -0,0 +1,413 @@ +--- +layout: post +title: "Apache Flink 1.14.3 Release Announcement" +date:

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [FLINK-24228][connectors/firehose] - Unified Async Sink for Kinesis Firehose

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 826fd84d3f61953a127829be78708c6d54de3244 UNKNOWN * 546d809fdb60cf252d4e34d39f5d5bf79bbf3a8d Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18165: [FLINK-24904][docs] Updated docs to reflect new KDS Sink and deprecat…

2022-01-12 Thread GitBox
CrynetLogistics commented on a change in pull request #18165: URL: https://github.com/apache/flink/pull/18165#discussion_r783344810 ## File path: docs/content/docs/connectors/datastream/kinesis.md ## @@ -566,124 +583,124 @@ Retry and backoff parameters can be configured using

[GitHub] [flink] flinkbot edited a comment on pull request #18342: [FLINK-25230][table-planner] Replace RelDataType with LogicalType serialization

2022-01-12 Thread GitBox
flinkbot edited a comment on pull request #18342: URL: https://github.com/apache/flink/pull/18342#issuecomment-1011078837 ## CI report: * 6dd2a1098d6003158a39d1fa7684a2fc4d1b74c2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

<    1   2   3   4   5   6   7   >