[GitHub] [flink] spoon-lz commented on a change in pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-11 Thread GitBox
spoon-lz commented on a change in pull request #18119: URL: https://github.com/apache/flink/pull/18119#discussion_r782661091 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -486,6 +487,26 @@ public static String

[jira] [Updated] (FLINK-25618) Data quality by apache flink

2022-01-11 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tanjialiang updated FLINK-25618: Description: This is discussing about how to support data quality through apache flink. For

[jira] [Created] (FLINK-25620) Upload artifacts to S3 failed on azure pipeline

2022-01-11 Thread Yun Gao (Jira)
Yun Gao created FLINK-25620: --- Summary: Upload artifacts to S3 failed on azure pipeline Key: FLINK-25620 URL: https://issues.apache.org/jira/browse/FLINK-25620 Project: Flink Issue Type: Bug

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

2022-01-11 Thread GitBox
xintongsong commented on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1010713720 Thanks for working on this, @zjureel & @KarmaGYZ. I'm still not entirely sure about exposing two executors (or two sets of scheduling interfaces) from the RPC

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

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

[jira] [Created] (FLINK-25625) Introduce FileFormat for table-store

2022-01-11 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-25625: Summary: Introduce FileFormat for table-store Key: FLINK-25625 URL: https://issues.apache.org/jira/browse/FLINK-25625 Project: Flink Issue Type: Sub-task

[GitHub] [flink-table-store] JingsongLi opened a new pull request #2: [FLINK-25625] Introduce FileFormat

2022-01-11 Thread GitBox
JingsongLi opened a new pull request #2: URL: https://github.com/apache/flink-table-store/pull/2 Introduce file format class which creates reader and writer factories for specific file format. -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-25615) FlinkKafkaProducer fail to correctly migrate pre Flink 1.9 state

2022-01-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474328#comment-17474328 ] Martijn Visser commented on FLINK-25615: Goedemorgen [~Matthias Schwalbe] :) Thanks for the

[GitHub] [flink] spoon-lz commented on a change in pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-11 Thread GitBox
spoon-lz commented on a change in pull request #18119: URL: https://github.com/apache/flink/pull/18119#discussion_r782661091 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java ## @@ -486,6 +487,26 @@ public static String

[GitHub] [flink] flinkbot edited a comment on pull request #17777: [FLINK-24886][core] TimeUtils supports the form of m.

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #1: URL: https://github.com/apache/flink/pull/1#issuecomment-966971402 ## CI report: * 405416d6b36b90cdfebc094af887eecd0a6707fb Azure:

[jira] [Created] (FLINK-25617) Support VectorAssembler in FlinkML

2022-01-11 Thread weibo zhao (Jira)
weibo zhao created FLINK-25617: -- Summary: Support VectorAssembler in FlinkML Key: FLINK-25617 URL: https://issues.apache.org/jira/browse/FLINK-25617 Project: Flink Issue Type: New Feature

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 40781260086d5780ad5c7eba1bed5e24e7a10464 Azure:

[GitHub] [flink] paul8263 opened a new pull request #18334: [BP-1.14][FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to a…

2022-01-11 Thread GitBox
paul8263 opened a new pull request #18334: URL: https://github.com/apache/flink/pull/18334 Unchanged backport of [#22821](https://github.com/apache/flink/pull/16108) on release-1.14 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

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

2022-01-11 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474230#comment-17474230 ] Liu commented on FLINK-25566: - Thanks, [~trohrmann]. Our flink version is 1.10.0. But I think the problem is

[GitHub] [flink-table-store] JingsongLi opened a new pull request #1: [FLINK-25619] Init flink-table-store repository

2022-01-11 Thread GitBox
JingsongLi opened a new pull request #1: URL: https://github.com/apache/flink-table-store/pull/1 Create: - README.md - NOTICE LICENSE CODE_OF_CONDUCT - .gitignore - maven tools - releasing tools - github build workflow - pom.xml -- This is an automated message from

[jira] [Updated] (FLINK-25619) Init flink-table-store repository

2022-01-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25619: --- Labels: pull-request-available (was: ) > Init flink-table-store repository >

[GitHub] [flink] flinkbot edited a comment on pull request #18326: [FLINK-25209][tests] Wait until the consuming topic is ready before polling records in KafkaContainerClient#readMessages

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18326: URL: https://github.com/apache/flink/pull/18326#issuecomment-1009773258 ## CI report: * cf2b79036082e166b7682ec9d420301a8a2e4b50 Azure:

[jira] [Commented] (FLINK-25374) Azure pipeline get stalled on scanning project

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

[jira] [Updated] (FLINK-25582) flink sql kafka source cannot special custom parallelism

2022-01-11 Thread venn wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] venn wu updated FLINK-25582: Description: when use flink sql api, all operator have same parallelism, but in some times we want

[jira] [Commented] (FLINK-24855) Source Coordinator Thread already exists. There should never be more than one thread driving the actions of a Source Coordinator.

2022-01-11 Thread WangMinChao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17473234#comment-17473234 ] WangMinChao commented on FLINK-24855: - Of cousrs, I am more than happy to follow your way go to find

[GitHub] [flink] flinkbot edited a comment on pull request #18308: [FLINK-25471][streaming-java] Wrong result if table transforms to Dat…

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18308: URL: https://github.com/apache/flink/pull/18308#issuecomment-1008462182 ## CI report: * 08443e0b37df7cae26379309ce99954a531b422f Azure:

[GitHub] [flink] liuyongvs commented on pull request #17777: [FLINK-24886][core] TimeUtils supports the form of m.

2022-01-11 Thread GitBox
liuyongvs commented on pull request #1: URL: https://github.com/apache/flink/pull/1#issuecomment-1010567298 hi @Thesharing , orignial commits are 4, i just reset the first commit and rebase code, then ci is running and you can see the log -- This is an automated message from the

[GitHub] [flink] jxjgssylsg commented on pull request #18313: Update match_recognize.md

2022-01-11 Thread GitBox
jxjgssylsg commented on pull request #18313: URL: https://github.com/apache/flink/pull/18313#issuecomment-1010672407 I have merged two pr according to the guidelines, please help to check -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #1: [FLINK-25619] Init flink-table-store repository

2022-01-11 Thread GitBox
JingsongLi commented on a change in pull request #1: URL: https://github.com/apache/flink-table-store/pull/1#discussion_r782755360 ## File path: pom.xml ## @@ -0,0 +1,697 @@ + + +http://maven.apache.org/POM/4.0.0; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; +

[GitHub] [flink-table-store] LadyForest commented on a change in pull request #1: [FLINK-25619] Init flink-table-store repository

2022-01-11 Thread GitBox
LadyForest commented on a change in pull request #1: URL: https://github.com/apache/flink-table-store/pull/1#discussion_r782745882 ## File path: README.md ## @@ -0,0 +1,19 @@ +# FLink Table Store + +Flink Table Store is a unified streaming and batch store for building dynamic

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

2022-01-11 Thread Yufei Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474282#comment-17474282 ] Yufei Zhang commented on FLINK-23944: - I'll try to investigate >

[GitHub] [flink] wsry commented on a change in pull request #17936: [FLINK-24954][network] Reset read buffer request timeout on buffer recycling for sort-shuffle

2022-01-11 Thread GitBox
wsry commented on a change in pull request #17936: URL: https://github.com/apache/flink/pull/17936#discussion_r782747038 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPoolTest.java ## @@ -98,6 +98,34 @@ public void

[jira] [Updated] (FLINK-25624) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee blocked on azure pipeline

2022-01-11 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25624: Labels: test-stability (was: ) > KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee blocked on azure

[jira] [Created] (FLINK-25624) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee blocked on azure pipeline

2022-01-11 Thread Yun Gao (Jira)
Yun Gao created FLINK-25624: --- Summary: KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee blocked on azure pipeline Key: FLINK-25624 URL: https://issues.apache.org/jira/browse/FLINK-25624 Project: Flink

[jira] [Commented] (FLINK-25095) Case when would be translated into different expression in Hive dialect and default dialect

2022-01-11 Thread Shuo Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474325#comment-17474325 ] Shuo Cheng commented on FLINK-25095: Similar issue: FLINK-20765 > Case when would be translated

[jira] [Commented] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job

2022-01-11 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474326#comment-17474326 ] Martijn Visser commented on FLINK-25070: [~wenlong.lwl] Does your FLIP also supersede

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #2: [FLINK-25625] Introduce FileFormat

2022-01-11 Thread GitBox
JingsongLi commented on a change in pull request #2: URL: https://github.com/apache/flink-table-store/pull/2#discussion_r782782673 ## File path: pom.xml ## @@ -444,7 +439,7 @@ under the License.

[jira] [Commented] (FLINK-25283) End-to-end application modules create oversized jars

2022-01-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17473237#comment-17473237 ] Dian Fu commented on FLINK-25283: - [~chesnay] Thanks. I'll take a look at this issue. > End-to-end

[GitHub] [flink] flinkbot edited a comment on pull request #18326: [FLINK-25209][tests] Wait until the consuming topic is ready before polling records in KafkaContainerClient#readMessages

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18326: URL: https://github.com/apache/flink/pull/18326#issuecomment-1009773258 ## CI report: * aa7137ca8f9c881acf698c641dc845ecbb2afcd2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * 3c8576341becb677e123b27eb9efbc280211b7a1 Azure:

[GitHub] [flink] flinkbot commented on pull request #18334: [BP-1.14][FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to a…

2022-01-11 Thread GitBox
flinkbot commented on pull request #18334: URL: https://github.com/apache/flink/pull/18334#issuecomment-1010589300 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #18334: [BP-1.14][FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to a…

2022-01-11 Thread GitBox
flinkbot commented on pull request #18334: URL: https://github.com/apache/flink/pull/18334#issuecomment-1010588736 ## CI report: * 96533113ed380aa0a8d5edc10ab61cc32620be0f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-25152) FLIP-188: Introduce Built-in Dynamic Table Storage

2022-01-11 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-25152: - Component/s: Table Store > FLIP-188: Introduce Built-in Dynamic Table Storage >

[GitHub] [flink] jxjgssylsg opened a new pull request #18335: [hotfix][Pattern Recognition][docs] Fixed an issue that the example o…

2022-01-11 Thread GitBox
jxjgssylsg opened a new pull request #18335: URL: https://github.com/apache/flink/pull/18335 …f “Time constraint” omits a comma. ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through

[jira] [Closed] (FLINK-25209) SQLClientSchemaRegistryITCase#testReading is broken

2022-01-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25209. Resolution: Fixed Fixed in master: 2d98608122574a9e56c00012be24824577ff47e6 The test has been

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

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

[jira] [Updated] (FLINK-25582) flink sql kafka source cannot special custom parallelism

2022-01-11 Thread venn wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] venn wu updated FLINK-25582: Description: when use flink sql api, all operator have same parallelism, but in some times we want

[GitHub] [flink] xintongsong commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2022-01-11 Thread GitBox
xintongsong commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r782663321 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/utils/BlobUtilsTest.java ## @@ -0,0 +1,125 @@ +/* + *

[jira] [Commented] (FLINK-25614) Let LocalWindowAggregate be chained with upstream

2022-01-11 Thread Q Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17473245#comment-17473245 ] Q Kang commented on FLINK-25614: The original intention of this change is to eliminate ser/deser between

[jira] [Updated] (FLINK-25152) FLIP-188: Introduce Built-in Dynamic Table Storage

2022-01-11 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-25152: - Fix Version/s: table-store-0.1.0 (was: 1.15.0) > FLIP-188: Introduce

[jira] [Commented] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

2022-01-11 Thread shouzuo meng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474266#comment-17474266 ] shouzuo meng commented on FLINK-25171: -- [~godfreyhe] Hi,the solution to this problem has been

[GitHub] [flink] flinkbot commented on pull request #18335: [hotfix][Pattern Recognition][docs] Fixed an issue that the example o…

2022-01-11 Thread GitBox
flinkbot commented on pull request #18335: URL: https://github.com/apache/flink/pull/18335#issuecomment-1010670800 ## CI report: * ee4eb2955410919042822b61fdf01bfbfed5067d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18335: [hotfix][Pattern Recognition][docs] Fixed an issue that the example o…

2022-01-11 Thread GitBox
flinkbot commented on pull request #18335: URL: https://github.com/apache/flink/pull/18335#issuecomment-1010671290 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #18308: [FLINK-25471][streaming-java] Wrong result if table transforms to Dat…

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18308: URL: https://github.com/apache/flink/pull/18308#issuecomment-1008462182 ## CI report: * 1192049c76b9c5648ebc13f422b48098ad442a14 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * f80e3635619ddb32f054090170799ee6cd49313a Azure:

[jira] [Commented] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

2022-01-11 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474304#comment-17474304 ] Lijie Wang commented on FLINK-25441: [~kevin.cyj] I would, I will prepare a fix according your

[GitHub] [flink-table-store] JingsongLi merged pull request #1: [FLINK-25619] Init flink-table-store repository

2022-01-11 Thread GitBox
JingsongLi merged pull request #1: URL: https://github.com/apache/flink-table-store/pull/1 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #17777: [FLINK-24886][core] TimeUtils supports the form of m.

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #1: URL: https://github.com/apache/flink/pull/1#issuecomment-966971402 ## CI report: * b00b49e806baf132df4f13124b98469cef9ebb91 Azure:

[jira] [Commented] (FLINK-25523) KafkaSourceITCase$KafkaSpecificTests.testTimestamp fails on AZP

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

[jira] [Assigned] (FLINK-25625) Introduce FileFormat for table-store

2022-01-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-25625: Assignee: Jingsong Lee > Introduce FileFormat for table-store >

[jira] [Closed] (FLINK-25619) Init flink-table-store repository

2022-01-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25619. Resolution: Fixed master: d0e4138a24ca35b944c0243f97d19c48b2501c59

[GitHub] [flink] xintongsong commented on a change in pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2022-01-11 Thread GitBox
xintongsong commented on a change in pull request #15599: URL: https://github.com/apache/flink/pull/15599#discussion_r782666723 ## File path: flink-filesystems/flink-gs-fs-hadoop/src/test/java/org/apache/flink/fs/gs/writer/GSRecoverableWriterTest.java ## @@ -0,0 +1,176 @@ +/*

[GitHub] [flink] flinkbot edited a comment on pull request #17777: [FLINK-24886][core] TimeUtils supports the form of m.

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #1: URL: https://github.com/apache/flink/pull/1#issuecomment-966971402 ## CI report: * 405416d6b36b90cdfebc094af887eecd0a6707fb Azure:

[jira] [Closed] (FLINK-25617) Support VectorAssembler in FlinkML

2022-01-11 Thread weibo zhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] weibo zhao closed FLINK-25617. -- Resolution: Duplicate > Support VectorAssembler in FlinkML > -- > >

[jira] [Resolved] (FLINK-25601) Update 'state.backend' in flink-conf.yaml

2022-01-11 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-25601. -- Resolution: Fixed merged in master: 41e96d2488e4caba17eef5172bb5ae493eb9c742 > Update

[jira] [Created] (FLINK-25618) Data quality by apache flink

2022-01-11 Thread tanjialiang (Jira)
tanjialiang created FLINK-25618: --- Summary: Data quality by apache flink Key: FLINK-25618 URL: https://issues.apache.org/jira/browse/FLINK-25618 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-25615) FlinkKafkaProducer fail to correctly migrate pre Flink 1.9 state

2022-01-11 Thread Matthias Schwalbe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474283#comment-17474283 ] Matthias Schwalbe commented on FLINK-25615: --- Goede morgen Martijn :),   The error remains in

[jira] [Created] (FLINK-25621) LegacyStatefulJobSavepointMigrationITCase failed on azure with exit code 127

2022-01-11 Thread Yun Gao (Jira)
Yun Gao created FLINK-25621: --- Summary: LegacyStatefulJobSavepointMigrationITCase failed on azure with exit code 127 Key: FLINK-25621 URL: https://issues.apache.org/jira/browse/FLINK-25621 Project: Flink

[jira] [Commented] (FLINK-22411) Checkpoint failed caused by Mkdirs failed to create file, the path for Flink state.checkpoints.dir in docker-compose can not work from Flink Operations Playground

2022-01-11 Thread Serge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474293#comment-17474293 ] Serge commented on FLINK-22411: --- That is really confusing.  Maybe u can try `chmod 777

[jira] [Created] (FLINK-25623) TPC-DS end-to-end test (Blink planner) failed on azure due to download file tpcds.idx failed.

2022-01-11 Thread Yun Gao (Jira)
Yun Gao created FLINK-25623: --- Summary: TPC-DS end-to-end test (Blink planner) failed on azure due to download file tpcds.idx failed. Key: FLINK-25623 URL: https://issues.apache.org/jira/browse/FLINK-25623

[jira] [Commented] (FLINK-6757) Investigate Apache Atlas integration

2022-01-11 Thread HideOnBush (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474316#comment-17474316 ] HideOnBush commented on FLINK-6757: --- I think this is very meaningful, especially in the construction of

[jira] [Commented] (FLINK-24801) "Post-job: Cache Maven local repo" failed on Azure

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

[GitHub] [flink] flinkbot edited a comment on pull request #18308: [FLINK-25471][streaming-java] Wrong result if table transforms to Dat…

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18308: URL: https://github.com/apache/flink/pull/18308#issuecomment-1008462182 ## CI report: * 08443e0b37df7cae26379309ce99954a531b422f Azure:

[jira] [Comment Edited] (FLINK-25614) Let LocalWindowAggregate be chained with upstream

2022-01-11 Thread Q Kang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17473245#comment-17473245 ] Q Kang edited comment on FLINK-25614 at 1/12/22, 2:23 AM: -- The original

[GitHub] [flink] flinkbot edited a comment on pull request #18306: [FLINK-25445] No need to create local recovery dirs when disabled loc…

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18306: URL: https://github.com/apache/flink/pull/18306#issuecomment-1008234006 ## CI report: * 7d972d43be4188ad9dad3d53e45f5710fdb8b754 Azure:

[GitHub] [flink] deadwind4 commented on pull request #18323: [FLINK-25601][state backends][config] Update the 'state.backend' option

2022-01-11 Thread GitBox
deadwind4 commented on pull request #18323: URL: https://github.com/apache/flink/pull/18323#issuecomment-1010640613 @Myasuka Thanks Yun Tang merge into master. Could I close this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] jxjgssylsg closed pull request #18307: Update match_recognize.md

2022-01-11 Thread GitBox
jxjgssylsg closed pull request #18307: URL: https://github.com/apache/flink/pull/18307 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] jxjgssylsg commented on pull request #18307: Update match_recognize.md

2022-01-11 Thread GitBox
jxjgssylsg commented on pull request #18307: URL: https://github.com/apache/flink/pull/18307#issuecomment-1010672860 I have merged two pr according to the guidelines, please help to check -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot edited a comment on pull request #18335: [hotfix][Pattern Recognition][docs] Fixed an issue that the example o…

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18335: URL: https://github.com/apache/flink/pull/18335#issuecomment-1010670800 ## CI report: * ee4eb2955410919042822b61fdf01bfbfed5067d Azure:

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #1: [FLINK-25619] Init flink-table-store repository

2022-01-11 Thread GitBox
JingsongLi commented on a change in pull request #1: URL: https://github.com/apache/flink-table-store/pull/1#discussion_r782760863 ## File path: pom.xml ## @@ -0,0 +1,697 @@ + + +http://maven.apache.org/POM/4.0.0; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; +

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #1: [FLINK-25619] Init flink-table-store repository

2022-01-11 Thread GitBox
JingsongLi commented on a change in pull request #1: URL: https://github.com/apache/flink-table-store/pull/1#discussion_r782760863 ## File path: pom.xml ## @@ -0,0 +1,697 @@ + + +http://maven.apache.org/POM/4.0.0; + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; +

[jira] [Updated] (FLINK-25625) Introduce FileFormat for table-store

2022-01-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25625: --- Labels: pull-request-available (was: ) > Introduce FileFormat for table-store >

[GitHub] [flink] cuibo01 commented on pull request #18304: [FLINK-25565][Formats][Parquet] write and read parquet int64 timestamp

2022-01-11 Thread GitBox
cuibo01 commented on pull request #18304: URL: https://github.com/apache/flink/pull/18304#issuecomment-1010552452 @MartijnVisser @tillrohrmann can you help me review this PR... thx -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #18326: [FLINK-25209][tests] Wait until the consuming topic is ready before polling records in KafkaContainerClient#readMessages

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18326: URL: https://github.com/apache/flink/pull/18326#issuecomment-1009773258 ## CI report: * aa7137ca8f9c881acf698c641dc845ecbb2afcd2 Azure:

[jira] [Created] (FLINK-25616) Support VectorAssembler in FlinkML

2022-01-11 Thread weibo zhao (Jira)
weibo zhao created FLINK-25616: -- Summary: Support VectorAssembler in FlinkML Key: FLINK-25616 URL: https://issues.apache.org/jira/browse/FLINK-25616 Project: Flink Issue Type: New Feature

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * 3c8576341becb677e123b27eb9efbc280211b7a1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 40781260086d5780ad5c7eba1bed5e24e7a10464 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18334: [BP-1.14][FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to a…

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18334: URL: https://github.com/apache/flink/pull/18334#issuecomment-1010588736 ## CI report: * 96533113ed380aa0a8d5edc10ab61cc32620be0f Azure:

[GitHub] [flink] paul8263 commented on pull request #16108: [FLINK-22821][core] Stabilize NetUtils#getAvailablePort in order to avoid wrongly allocating any used ports

2022-01-11 Thread GitBox
paul8263 commented on pull request #16108: URL: https://github.com/apache/flink/pull/16108#issuecomment-1010591513 Thank you @fapaul . I will do it. -- 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

[jira] [Created] (FLINK-25619) Init flink-table-store repository

2022-01-11 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-25619: Summary: Init flink-table-store repository Key: FLINK-25619 URL: https://issues.apache.org/jira/browse/FLINK-25619 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-25619) Init flink-table-store repository

2022-01-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-25619: Assignee: Jingsong Lee > Init flink-table-store repository >

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * f80e3635619ddb32f054090170799ee6cd49313a Azure:

[GitHub] [flink] JingsongLi merged pull request #18326: [FLINK-25209][tests] Wait until the consuming topic is ready before polling records in KafkaContainerClient#readMessages

2022-01-11 Thread GitBox
JingsongLi merged pull request #18326: URL: https://github.com/apache/flink/pull/18326 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-table-store] LadyForest commented on pull request #1: [FLINK-25619] Init flink-table-store repository

2022-01-11 Thread GitBox
LadyForest commented on pull request #1: URL: https://github.com/apache/flink-table-store/pull/1#issuecomment-1010710055 LGTM :) -- 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 #18268: [FLINK-14902][connector] Supports jdbc async lookup join

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * fe7d298f1ac142a2fa53241df09eaf93b44ec4be Azure:

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #2: [FLINK-25625] Introduce FileFormat

2022-01-11 Thread GitBox
JingsongLi commented on a change in pull request #2: URL: https://github.com/apache/flink-table-store/pull/2#discussion_r782782354 ## File path: pom.xml ## @@ -153,12 +154,6 @@ under the License. 1.3.9 - -

[jira] [Updated] (FLINK-25624) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee blocked on azure pipeline

2022-01-11 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25624: Affects Version/s: (was: 1.14.2) > KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee blocked on

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

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

[jira] [Commented] (FLINK-25582) flink sql kafka source cannot special custom parallelism

2022-01-11 Thread venn wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474331#comment-17474331 ] venn wu commented on FLINK-25582: - [~MartijnVisser]  thanks for reminding,  i have add the describe for

[GitHub] [flink] flinkbot edited a comment on pull request #18306: [FLINK-25445] No need to create local recovery dirs when disabled loc…

2022-01-11 Thread GitBox
flinkbot edited a comment on pull request #18306: URL: https://github.com/apache/flink/pull/18306#issuecomment-1008234006 ## CI report: * 7d972d43be4188ad9dad3d53e45f5710fdb8b754 Azure:

[jira] [Commented] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

2022-01-11 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474262#comment-17474262 ] Yingjie Cao commented on FLINK-25441: - [~wanglijie95] Would you prepare a fix for it? >

[jira] [Updated] (FLINK-25441) ProducerFailedException will cause task status switch from RUNNING to CANCELED, which will cause the job to hang.

2022-01-11 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-25441: Fix Version/s: 1.15.0 > ProducerFailedException will cause task status switch from RUNNING to >

[GitHub] [flink] jxjgssylsg closed pull request #18313: Update match_recognize.md

2022-01-11 Thread GitBox
jxjgssylsg closed pull request #18313: URL: https://github.com/apache/flink/pull/18313 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-25618) Data quality by apache flink

2022-01-11 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tanjialiang updated FLINK-25618: Description: This is discussing about how to support data quality through apache flink. For

[jira] [Updated] (FLINK-25152) FLIP-188: Introduce Built-in Dynamic Table Storage

2022-01-11 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25152: - Fix Version/s: 1.15.0 > FLIP-188: Introduce Built-in Dynamic Table Storage >

  1   2   3   4   5   6   7   8   >