Re: [DISCUSS] Make Kubernetes Operator config "dynamic" and consider merging with flinkConfiguration

2022-04-02 Thread Gyula Fóra
That's a very good point Matyas, we cannot risk any interference with other jobs but I think we don't necessarily have to. First of all we should only allow users to overwrite selected configs. For deciding what to allow, we can separate the operator related configs into 2 main groups: *Group 1*:

Re: [VOTE] Apache Flink Kubernetes Operator Release 0.1.0, release candidate #3

2022-04-02 Thread Nicholas Jiang
+1 (non-binding) 1.Verified maven and helm chart versions for built from source 2.Verified helm chart points to correct docker image and deploys it by default 3.Verified helm installation and basic/checkpointing, stateful examples with upgrades and manual savepoints 4.Verified online documents inc

[jira] [Created] (FLINK-27003) Operator Helm chart improvements

2022-04-02 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-27003: -- Summary: Operator Helm chart improvements Key: FLINK-27003 URL: https://issues.apache.org/jira/browse/FLINK-27003 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27004) Use '.' instead of 'file..' in table properties of managed table

2022-04-02 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-27004: --- Summary: Use '.' instead of 'file..' in table properties of managed table Key: FLINK-27004 URL: https://issues.apache.org/jira/browse/FLINK-27004 Project: Flink

RE: Question about community collaboration options

2022-04-02 Thread Hao t Chang
Hi Martijn, Thanks for the meeting pointer. I am interested to join the next sync meeting on Tuesday. I am curious besides using the PR threads in github , how do you "ping" people to get attention ? On 4/1/22, 3:07 AM, "Martijn Visser" wrote: Hi Ted, This is a great question. Ther

[jira] [Created] (FLINK-27005) Bump CRD version to v1alpha2

2022-04-02 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-27005: -- Summary: Bump CRD version to v1alpha2 Key: FLINK-27005 URL: https://issues.apache.org/jira/browse/FLINK-27005 Project: Flink Issue Type: Improvement Co

Re: [DISCUSS] Make Kubernetes Operator config "dynamic" and consider merging with flinkConfiguration

2022-04-02 Thread Nicholas Jiang
Thanks Gyula for discussing this topic! I also prefer Proposal 2 which merges *flinkConfiguration* and *operatorConfiguration* for easily understanding to end Flink users. IMO, from an end-user perspective, the *flinkConfiguration* and *operatorConfiguration* are the configuration related to the

[jira] [Created] (FLINK-27006) Support SingleValueAggFunction for Char data type

2022-04-02 Thread luoyuxia (Jira)
luoyuxia created FLINK-27006: Summary: Support SingleValueAggFunction for Char data type Key: FLINK-27006 URL: https://issues.apache.org/jira/browse/FLINK-27006 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-27007) Should the MailboxDefaultAction interface be annotated with @FunctionalInterface?

2022-04-02 Thread Shubin Ruan (Jira)
Shubin Ruan created FLINK-27007: --- Summary: Should the MailboxDefaultAction interface be annotated with @FunctionalInterface? Key: FLINK-27007 URL: https://issues.apache.org/jira/browse/FLINK-27007 Proje

[jira] [Created] (FLINK-27008) Document the configurable parameters of the helm chart and their default values

2022-04-02 Thread Yang Wang (Jira)
Yang Wang created FLINK-27008: - Summary: Document the configurable parameters of the helm chart and their default values Key: FLINK-27008 URL: https://issues.apache.org/jira/browse/FLINK-27008 Project: Fl

[jira] [Created] (FLINK-27009) Support SQL job submission in flink kubernetes opeartor

2022-04-02 Thread Biao Geng (Jira)
Biao Geng created FLINK-27009: - Summary: Support SQL job submission in flink kubernetes opeartor Key: FLINK-27009 URL: https://issues.apache.org/jira/browse/FLINK-27009 Project: Flink Issue Type:

[jira] [Created] (FLINK-27010) Support setting sql client args via flink conf

2022-04-02 Thread Luning Wang (Jira)
Luning Wang created FLINK-27010: --- Summary: Support setting sql client args via flink conf Key: FLINK-27010 URL: https://issues.apache.org/jira/browse/FLINK-27010 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-27011) Add various types of state usage examples

2022-04-02 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-27011: Summary: Add various types of state usage examples Key: FLINK-27011 URL: https://issues.apache.org/jira/browse/FLINK-27011 Project: Flink Issue Type: New Fea

[jira] [Created] (FLINK-27012) Caching maven dependencies to speed up workflows for flink-kubernetes-operator

2022-04-02 Thread Yang Wang (Jira)
Yang Wang created FLINK-27012: - Summary: Caching maven dependencies to speed up workflows for flink-kubernetes-operator Key: FLINK-27012 URL: https://issues.apache.org/jira/browse/FLINK-27012 Project: Fli

[jira] [Created] (FLINK-27013) Hive dialect supports IS_DISTINCT_FROM

2022-04-02 Thread luoyuxia (Jira)
luoyuxia created FLINK-27013: Summary: Hive dialect supports IS_DISTINCT_FROM Key: FLINK-27013 URL: https://issues.apache.org/jira/browse/FLINK-27013 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27014) Hive dialect support select null literal in subquery

2022-04-02 Thread luoyuxia (Jira)
luoyuxia created FLINK-27014: Summary: Hive dialect support select null literal in subquery Key: FLINK-27014 URL: https://issues.apache.org/jira/browse/FLINK-27014 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-27015) Hive dialect supports cast timestamp to decimal implicitly while inserting

2022-04-02 Thread luoyuxia (Jira)
luoyuxia created FLINK-27015: Summary: Hive dialect supports cast timestamp to decimal implicitly while inserting Key: FLINK-27015 URL: https://issues.apache.org/jira/browse/FLINK-27015 Project: Flink

[jira] [Created] (FLINK-27016) Improve supporting for complex data type for Hive dialect

2022-04-02 Thread luoyuxia (Jira)
luoyuxia created FLINK-27016: Summary: Improve supporting for complex data type for Hive dialect Key: FLINK-27016 URL: https://issues.apache.org/jira/browse/FLINK-27016 Project: Flink Issue Type:

[jira] [Created] (FLINK-27017) Hive dialect supports divide by zero

2022-04-02 Thread luoyuxia (Jira)
luoyuxia created FLINK-27017: Summary: Hive dialect supports divide by zero Key: FLINK-27017 URL: https://issues.apache.org/jira/browse/FLINK-27017 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27018) timestamp missing end zero when outputing to kafka

2022-04-02 Thread jeff-zou (Jira)
jeff-zou created FLINK-27018: Summary: timestamp missing end zero when outputing to kafka Key: FLINK-27018 URL: https://issues.apache.org/jira/browse/FLINK-27018 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27019) use hive dialect in SqlClient would thrown an error based on 1.15 version

2022-04-02 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-27019: -- Summary: use hive dialect in SqlClient would thrown an error based on 1.15 version Key: FLINK-27019 URL: https://issues.apache.org/jira/browse/FLINK-27019 Project: Flink

[jira] [Created] (FLINK-27020) use hive dialect in SqlClient would thrown an error based on 1.15 version

2022-04-02 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-27020: -- Summary: use hive dialect in SqlClient would thrown an error based on 1.15 version Key: FLINK-27020 URL: https://issues.apache.org/jira/browse/FLINK-27020 Project: Flink

[jira] [Created] (FLINK-27021) CRD improvements for v1alpha2

2022-04-02 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-27021: -- Summary: CRD improvements for v1alpha2 Key: FLINK-27021 URL: https://issues.apache.org/jira/browse/FLINK-27021 Project: Flink Issue Type: Improvement C

[jira] [Created] (FLINK-27022) Expose taskSlots in TaskManager spec

2022-04-02 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-27022: -- Summary: Expose taskSlots in TaskManager spec Key: FLINK-27022 URL: https://issues.apache.org/jira/browse/FLINK-27022 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27023) Merge default flink and operator configuration settings for the operator

2022-04-02 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-27023: -- Summary: Merge default flink and operator configuration settings for the operator Key: FLINK-27023 URL: https://issues.apache.org/jira/browse/FLINK-27023 Project: Flink

Re: [DISCUSS] Make Kubernetes Operator config "dynamic" and consider merging with flinkConfiguration

2022-04-02 Thread Gyula Fóra
Hi all, Based on the feedback I have opened a ticket to start merging the config settings on the operator side: https://issues.apache.org/jira/browse/FLINK-27023 This won't allow dynamic configuration yet but it will simplify the operator configuration as a starting point. As a next step we can

[jira] [Created] (FLINK-27024) Cleanup surefire configuration

2022-04-02 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27024: Summary: Cleanup surefire configuration Key: FLINK-27024 URL: https://issues.apache.org/jira/browse/FLINK-27024 Project: Flink Issue Type: Technical

[RESULT] [VOTE] Apache Flink Kubernetes Operator Release 0.1.0, release candidate #3

2022-04-02 Thread Gyula Fóra
I'm happy to announce that we have unanimously approved this release. There are 8 approving votes, 4 of which are binding: * Marton Balassi (binding) * Yang Wang (non-binding) * Gyula Fora (binding) * Biao Geng (non-binding) * Thomas Weise (binding) * Xintong Song (binding) * Aitozi (non-binding)

Re: [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 0.1.0, release candidate #3

2022-04-02 Thread Márton Balassi
Thank you team, it was a pleasure to witness the community investing into this much requested topic and coming to an initial release so swiftly. On Sat, Apr 2, 2022 at 4:45 PM Gyula Fóra wrote: > I'm happy to announce that we have unanimously approved this release. > > There are 8 approving vote

Creating flink-kubernetes-operator project on Dockerhub

2022-04-02 Thread Gyula Fóra
Hi Devs, Does anyone know what is the process for creating a new dockerhub project under apache? I would like to create *apache**/flink-kubernetes-operator *and get push access to it. Thank you! Gyula

[jira] [Created] (FLINK-27025) Cannot read parquet file, after putting the jar in the right place with right permissions

2022-04-02 Thread Ziheng Wang (Jira)
Ziheng Wang created FLINK-27025: --- Summary: Cannot read parquet file, after putting the jar in the right place with right permissions Key: FLINK-27025 URL: https://issues.apache.org/jira/browse/FLINK-27025

[jira] [Created] (FLINK-27026) Upgrade checkstyle plugin

2022-04-02 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27026: Summary: Upgrade checkstyle plugin Key: FLINK-27026 URL: https://issues.apache.org/jira/browse/FLINK-27026 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-27027) Get rid of oddly named mvn-${sys mvn.forkNumber}.log files

2022-04-02 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27027: Summary: Get rid of oddly named mvn-${sys mvn.forkNumber}.log files Key: FLINK-27027 URL: https://issues.apache.org/jira/browse/FLINK-27027 Project: Flink

Re: [RESULT] [VOTE] Apache Flink Kubernetes Operator Release 0.1.0, release candidate #3

2022-04-02 Thread Aitozi
Nice to see it happens Cheers, Aitozi. Márton Balassi 于2022年4月2日周六 23:08写道: > Thank you team, it was a pleasure to witness the community investing into > this much requested topic and coming to an initial release so swiftly. > > On Sat, Apr 2, 2022 at 4:45 PM Gyula Fóra wrote: > > > I'm happy

[jira] [Created] (FLINK-27028) Support to upload jar and run jar in RestClusterClient

2022-04-02 Thread Aitozi (Jira)
Aitozi created FLINK-27028: -- Summary: Support to upload jar and run jar in RestClusterClient Key: FLINK-27028 URL: https://issues.apache.org/jira/browse/FLINK-27028 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-27029) DeploymentValidator should take default flink config into account during validation

2022-04-02 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-27029: -- Summary: DeploymentValidator should take default flink config into account during validation Key: FLINK-27029 URL: https://issues.apache.org/jira/browse/FLINK-27029 Proje