Re: [DISCUSS] FLIP-260: Expose Finish Method For UserDefinedFunction

2022-09-21 Thread Lincoln Lee
Hi everyone, Thanks for all your feedback! I started a vote for this FLIP [1], please vote there or ask additional questions here[2]. [1] https://lists.apache.org/thread/nr9wwf98fkw1tk7ycgbcfjjo5g4x8pmz [2] https://lists.apache.org/thread/m9hj60p3mntyctkbxrksm8l4d0s4q9dw Best, Lincoln Lee Piot

[VOTE] FLIP-260: Expose Finish Method For TableFunction

2022-09-21 Thread Lincoln Lee
Hi everyone, Thanks for all your feedback for FLIP-260[1] in the discussion thread[2], I'd like to start a vote for it. The vote will be open for at least 72 hours. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-260%3A+Expose+Finish+Method+For+TableFunction [2] https://lists.apache.o

Re: [DISCUSS][FLINK-29372] Add a suffix to keys that violate YAML spec

2022-09-21 Thread Yun Tang
+1 This is the prerequisite to help us to introduce a standard YAML parser, which has been discussed in different tickets [1] [2]. [1] https://issues.apache.org/jira/browse/FLINK-23620 [2] https://issues.apache.org/jira/browse/FLINK-29366 Best Yun Tang From: Ya

[jira] [Created] (FLINK-29385) AddColumn in flink table store should check the duplicate field names

2022-09-21 Thread Shammon (Jira)
Shammon created FLINK-29385: --- Summary: AddColumn in flink table store should check the duplicate field names Key: FLINK-29385 URL: https://issues.apache.org/jira/browse/FLINK-29385 Project: Flink

Re: [DISCUSS][FLINK-29372] Add a suffix to keys that violate YAML spec

2022-09-21 Thread Yang Wang
This will make it possible to replace the current rough implementation[1] with a common yaml parser. And then we could avoid some unexpected behaviors[2]. +1 [1]. https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/configuration/GlobalConfiguration.java#L179 [2].

Re: Kubernetes Operator 1.2.0 release

2022-09-21 Thread Zheng Yu Chen
+1 Thanks to drive it Gyula Fóra 于2022年9月19日周一 19:37写道: > Hi Devs! > > The originally planned (October 1) release date for 1.2.0 is fast > approaching and we are already slightly behind schedule. There are a couple > outstanding bug tickets with 2 known blockers at the moment that should be > fi

Re: [DISCUSS][FLINK-29372] Add a suffix to keys that violate YAML spec

2022-09-21 Thread Konstantin Knauf
Make sense to me. It is moving us in the right direction and makes it possible to drop these keys with Flink 2.0 if that ever happens :) Am Mi., 21. Sept. 2022 um 16:06 Uhr schrieb Chesnay Schepler < ches...@apache.org>: > Hi, > > we have a small number of options in Flink whose key is a prefix o

[jira] [Created] (FLINK-29384) snakeyaml version 1.30 in flink-kubernetes-operator-1.2-SNAPSHOT-shaded.jar has vulnerabilities

2022-09-21 Thread James Busche (Jira)
James Busche created FLINK-29384: Summary: snakeyaml version 1.30 in flink-kubernetes-operator-1.2-SNAPSHOT-shaded.jar has vulnerabilities Key: FLINK-29384 URL: https://issues.apache.org/jira/browse/FLINK-29384

[jira] [Created] (FLINK-29383) Add additionalPrinterColumns for some status fields

2022-09-21 Thread Xin Hao (Jira)
Xin Hao created FLINK-29383: --- Summary: Add additionalPrinterColumns for some status fields Key: FLINK-29383 URL: https://issues.apache.org/jira/browse/FLINK-29383 Project: Flink Issue Type: Improve

[DISCUSS][FLINK-29372] Add a suffix to keys that violate YAML spec

2022-09-21 Thread Chesnay Schepler
Hi, we have a small number of options in Flink whose key is a prefix of other keys. This violates the YAML spec; when you view the options as a tree only leaf nodes may have properties. While this is a minor issue from our side I think this can be quite annoying for users, since it means y

[jira] [Created] (FLINK-29382) Flink fails to start when created using quick guide for flink operator

2022-09-21 Thread Barisa (Jira)
Barisa created FLINK-29382: -- Summary: Flink fails to start when created using quick guide for flink operator Key: FLINK-29382 URL: https://issues.apache.org/jira/browse/FLINK-29382 Project: Flink I

[jira] [Created] (FLINK-29381) Key_Shared subscription isn't works in the latest Pulsar connector

2022-09-21 Thread Yufan Sheng (Jira)
Yufan Sheng created FLINK-29381: --- Summary: Key_Shared subscription isn't works in the latest Pulsar connector Key: FLINK-29381 URL: https://issues.apache.org/jira/browse/FLINK-29381 Project: Flink

[jira] [Created] (FLINK-29380) Two streams union, watermark error, not the minimum value

2022-09-21 Thread xiechenling (Jira)
xiechenling created FLINK-29380: --- Summary: Two streams union, watermark error, not the minimum value Key: FLINK-29380 URL: https://issues.apache.org/jira/browse/FLINK-29380 Project: Flink Issue

[jira] [Created] (FLINK-29379) Back ExecutionConfig and CheckpointConfig by Configuration

2022-09-21 Thread Timo Walther (Jira)
Timo Walther created FLINK-29379: Summary: Back ExecutionConfig and CheckpointConfig by Configuration Key: FLINK-29379 URL: https://issues.apache.org/jira/browse/FLINK-29379 Project: Flink Is

[jira] [Created] (FLINK-29378) Misleading logging in Execution for failed state trannsitions

2022-09-21 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29378: Summary: Misleading logging in Execution for failed state trannsitions Key: FLINK-29378 URL: https://issues.apache.org/jira/browse/FLINK-29378 Project: Flink

[jira] [Created] (FLINK-29377) Make RPC timeout extraction reusable

2022-09-21 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29377: Summary: Make RPC timeout extraction reusable Key: FLINK-29377 URL: https://issues.apache.org/jira/browse/FLINK-29377 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-29376) Deployment already exists error if Flink version is not set correctly

2022-09-21 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-29376: -- Summary: Deployment already exists error if Flink version is not set correctly Key: FLINK-29376 URL: https://issues.apache.org/jira/browse/FLINK-29376 Project: Flink

[jira] [Created] (FLINK-29375) Move getSelfGateway into RpcService

2022-09-21 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29375: Summary: Move getSelfGateway into RpcService Key: FLINK-29375 URL: https://issues.apache.org/jira/browse/FLINK-29375 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-29374) RpcConnectionTest may pass invalid rpc URL

2022-09-21 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29374: Summary: RpcConnectionTest may pass invalid rpc URL Key: FLINK-29374 URL: https://issues.apache.org/jira/browse/FLINK-29374 Project: Flink Issue Type

来自ji_longzhang的邮件

2022-09-21 Thread ji_longzhang
hi flink

[jira] [Created] (FLINK-29373) DataStream to table not support BigDecimalTypeInfo

2022-09-21 Thread hk__lrzy (Jira)
hk__lrzy created FLINK-29373: Summary: DataStream to table not support BigDecimalTypeInfo Key: FLINK-29373 URL: https://issues.apache.org/jira/browse/FLINK-29373 Project: Flink Issue Type: Bug