Re: Flink Table Task question

2022-09-01 Thread Sergey Nuyanzin
Hi Emma, not sure if I fully understand your question/case however there is a FLIP-195 [1] about improvement of naming I think you might be interested in taking a look at it [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-195%3A+Improve+the+name+and+structure+of+vertex+and+operator+nam

Re: [DISCUSS] Support 'DYNAMIC MetadataColumn' in flink table

2022-09-01 Thread Ran Tao
Hi, Jark & Timo. I'm glad to support this feature, and if you guys agree, I'll be ready to create a FLIP, and then you guys and other developers can review and check some specifics. Thanks. Jark Wu 于2022年8月30日周二 20:24写道: > Thank you Ran for the explanation. > > The column DEFAULT is a reasonabl

Re: [DISCUSS] Switch docker iamge base to Eclipse Temurin

2022-09-01 Thread Chesnay Schepler
Thanks Xingbo. Should've known that the Flink side relies on the distro name, sorry for the inconvenience. On 01/09/2022 06:55, Xingbo Huang wrote: Thanks Chesnay for driving this. I found a problem with image name change[1] and I have created a PR[2] to fix it. Best, Xingbo [1] https://issue

Re: [DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api

2022-09-01 Thread Teoh, Hong
That sounds good to me. Thanks for working in this Zheng Yu! Hong From: Zheng Yu Chen Sent: 01 September 2022 05:08:03 To: dev@flink.apache.org Subject: RE: [EXTERNAL][DISCUSS] FLIP-256 Support Job Dynamic Parameter With Flink Rest Api CAUTION: This emai

[jira] [Created] (FLINK-29166) 多流合并成一个的方案优化

2022-09-01 Thread zhangyang (Jira)
zhangyang created FLINK-29166: - Summary: 多流合并成一个的方案优化 Key: FLINK-29166 URL: https://issues.apache.org/jira/browse/FLINK-29166 Project: Flink Issue Type: Improvement Components: API / Da

[jira] [Created] (FLINK-29167) Time out-of-order optimization for merging multiple data streams into one data stream

2022-09-01 Thread zhangyang (Jira)
zhangyang created FLINK-29167: - Summary: Time out-of-order optimization for merging multiple data streams into one data stream Key: FLINK-29167 URL: https://issues.apache.org/jira/browse/FLINK-29167 Proj

[jira] [Created] (FLINK-29168) Add Transformer for NGram

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29168: - Summary: Add Transformer for NGram Key: FLINK-29168 URL: https://issues.apache.org/jira/browse/FLINK-29168 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-29169) Add Transformer and Estimator for UnivariateFeatureSelector

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29169: - Summary: Add Transformer and Estimator for UnivariateFeatureSelector Key: FLINK-29169 URL: https://issues.apache.org/jira/browse/FLINK-29169 Project: Flink

[jira] [Created] (FLINK-29170) Add Transformer and Estimator for VarianceThresholdSelector

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29170: - Summary: Add Transformer and Estimator for VarianceThresholdSelector Key: FLINK-29170 URL: https://issues.apache.org/jira/browse/FLINK-29170 Project: Flink

Re: [DISCUSS] FLIP-254 Guarantee binary compatibility for Public/-Evolving APIs between patch releases

2022-09-01 Thread Chesnay Schepler
I compared 1.15.0 and 1.15.2; we overall did a very good job with one outlier. Based on this I'd say we should also apply this FLIP to 1.15. Table connectors: Source-compatible change; relevant if you implement your own DataStream(Scan/Sink)Provider:   org.apache.flink.table.connector.sink.Dat

[jira] [Created] (FLINK-29171) Add docs of MaxAbs, FeatureHasher, Interaction, VectorSlicer, ElementwiseProduct and Binarizer.

2022-09-01 Thread weibo zhao (Jira)
weibo zhao created FLINK-29171: -- Summary: Add docs of MaxAbs, FeatureHasher, Interaction, VectorSlicer, ElementwiseProduct and Binarizer. Key: FLINK-29171 URL: https://issues.apache.org/jira/browse/FLINK-29171

Re: [DISCUSS] Switch docker iamge base to Eclipse Temurin

2022-09-01 Thread Chesnay Schepler
The e2e tests have passed successfully for the updated 1.14/1.15/master images. On 01/09/2022 11:05, Chesnay Schepler wrote: Thanks Xingbo. Should've known that the Flink side relies on the distro name, sorry for the inconvenience. On 01/09/2022 06:55, Xingbo Huang wrote: Thanks Chesnay for

[jira] [Created] (FLINK-29172) Add built-in string_split function.

2022-09-01 Thread Yongming Zhang (Jira)
Yongming Zhang created FLINK-29172: -- Summary: Add built-in string_split function. Key: FLINK-29172 URL: https://issues.apache.org/jira/browse/FLINK-29172 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-29173) Upgrade curator

2022-09-01 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-29173: - Summary: Upgrade curator Key: FLINK-29173 URL: https://issues.apache.org/jira/browse/FLINK-29173 Project: Flink Issue Type: Improvement Component

Re: [DISCUSS] Switch docker iamge base to Eclipse Temurin

2022-09-01 Thread Chesnay Schepler
Unless anyone objects I will announce the switch on Monday via the mailing lists / twitter and execute it on Wednesday. On 01/09/2022 14:27, Chesnay Schepler wrote: The e2e tests have passed successfully for the updated 1.14/1.15/master images. On 01/09/2022 11:05, Chesnay Schepler wrote: Tha

Re: [DISCUSS] Switch docker iamge base to Eclipse Temurin

2022-09-01 Thread Thomas Weise
+1, the change to Ubuntu (hopefully) also reduces the ripple effect for downstream customizers of the image. On Thu, Sep 1, 2022 at 10:00 AM Chesnay Schepler wrote: > Unless anyone objects I will announce the switch on Monday via the > mailing lists / twitter and execute it on Wednesday. > > On

[jira] [Created] (FLINK-29174) Add document for ML algorithms

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29174: - Summary: Add document for ML algorithms Key: FLINK-29174 URL: https://issues.apache.org/jira/browse/FLINK-29174 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29175) Add documents for AgglomerativeClustering, KbinsCretizer, ChisquaredTest, VectorIndexer, Tokenizer, RegexTokenizer, IDF

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29175: - Summary: Add documents for AgglomerativeClustering, KbinsCretizer, ChisquaredTest, VectorIndexer, Tokenizer, RegexTokenizer, IDF Key: FLINK-29175 URL: https://issues.apache.org/

[jira] [Created] (FLINK-29176) Add python source/test for ChiSqTest

2022-09-01 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-29176: - Summary: Add python source/test for ChiSqTest Key: FLINK-29176 URL: https://issues.apache.org/jira/browse/FLINK-29176 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-29177) Shade the org.apache.commons in flink-sql-connector-hive to avoid the class conflict

2022-09-01 Thread luoyuxia (Jira)
luoyuxia created FLINK-29177: Summary: Shade the org.apache.commons in flink-sql-connector-hive to avoid the class conflict Key: FLINK-29177 URL: https://issues.apache.org/jira/browse/FLINK-29177 Project:

[jira] [Created] (FLINK-29178) flink - on -yarn out-off-memory

2022-09-01 Thread zhangyang (Jira)
zhangyang created FLINK-29178: - Summary: flink - on -yarn out-off-memory Key: FLINK-29178 URL: https://issues.apache.org/jira/browse/FLINK-29178 Project: Flink Issue Type: Bug Component

[jira] [Created] (FLINK-29179) Translate "Temporal Table Function" page of "Streaming Concepts" into Chinese

2022-09-01 Thread ChunJi (Jira)
ChunJi created FLINK-29179: -- Summary: Translate "Temporal Table Function" page of "Streaming Concepts" into Chinese Key: FLINK-29179 URL: https://issues.apache.org/jira/browse/FLINK-29179 Project: Flink

[jira] [Created] (FLINK-29180) Show subtask metrics as default in vertex detail

2022-09-01 Thread Junhan Yang (Jira)
Junhan Yang created FLINK-29180: --- Summary: Show subtask metrics as default in vertex detail Key: FLINK-29180 URL: https://issues.apache.org/jira/browse/FLINK-29180 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-29181) log.system can be congiured by dynamic options

2022-09-01 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29181: Summary: log.system can be congiured by dynamic options Key: FLINK-29181 URL: https://issues.apache.org/jira/browse/FLINK-29181 Project: Flink Issue Type: Ne

[jira] [Created] (FLINK-29182) SumAggFunction redundant computations

2022-09-01 Thread jackylau (Jira)
jackylau created FLINK-29182: Summary: SumAggFunction redundant computations Key: FLINK-29182 URL: https://issues.apache.org/jira/browse/FLINK-29182 Project: Flink Issue Type: Bug Compo