[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:

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-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

[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-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

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

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

[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)

[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

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-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

[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-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

[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-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-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-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-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

[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-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:

[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-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:

[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

[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:

[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

[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:

[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

[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:

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

[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

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.

[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

[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

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

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

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

2022-04-02 Thread Őrhidi Mátyás
Thanks Gyula for bringing this topic up! Although the suggestion would indeed simplify the configuration handling I have some concerns about opening the operator configuration for end users in certain cases. In a multitenant scenario for example, how could we protect against one user messing up

[jira] [Created] (FLINK-27002) Optimize batch multiple partitions inserting

2022-04-02 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-27002: Summary: Optimize batch multiple partitions inserting Key: FLINK-27002 URL: https://issues.apache.org/jira/browse/FLINK-27002 Project: Flink Issue Type:

回复: [GitHub] [flink] flinkbot edited a comment on pull request #15519: [FLINK-22120] Remove duplicate code in generated code for map get

2022-04-02 Thread 范 佳兴
退订 发件人: GitBox 发送时间: 2021年4月9日 16:28 收件人: iss...@flink.apache.org 主题: [GitHub] [flink] flinkbot edited a comment on pull request #15519: [FLINK-22120] Remove duplicate code in generated code for map get flinkbot edited a comment on pull request #15519: URL: