[jira] [Created] (FLINK-29527) Make unknownFieldsIndices work for single ParquetReader

2022-10-06 Thread Sun Shun (Jira)
Sun Shun created FLINK-29527: Summary: Make unknownFieldsIndices work for single ParquetReader Key: FLINK-29527 URL: https://issues.apache.org/jira/browse/FLINK-29527 Project: Flink Issue Type: B

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.2.0, release candidate #2

2022-10-06 Thread Maximilian Michels
+1 (binding) because the source release looks good. I've verified the following: 1. Downloaded, compiled, and verified the signature of the source release staged at https://dist.apache.org/repos/dist/dev/flink/flink-kubernetes-operator-1.2.0-rc2/ 2. Verified licenses (Not a blocker: the LICENSE f

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.2.0, release candidate #2

2022-10-06 Thread Maximilian Michels
Turns out the issue with the Helm installation was that I was using cert-manager 1.9.1 instead of the recommended version 1.8.2. The operator now deploys cleanly in my local environment. On Thu, Oct 6, 2022 at 12:34 PM Maximilian Michels wrote: > +1 (binding) because the source release looks goo

[jira] [Created] (FLINK-29528) Check if core-default-shaded is still required

2022-10-06 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29528: Summary: Check if core-default-shaded is still required Key: FLINK-29528 URL: https://issues.apache.org/jira/browse/FLINK-29528 Project: Flink Issue

Re: [VOTE] Release flink-shaded 16.0, release candidate #1

2022-10-06 Thread Dawid Wysakowicz
+1 (binding) - Verified that checksums and GPG files match the released files - Checked that POM files point to the same version - Verified licenses - Verified web PR Best, Dawid On 29/09/2022 09:22, Martijn Visser wrote: Thanks for pushing this release Chesnay. +1 (binding) - Verified that

[jira] [Created] (FLINK-29529) Update flink version in flink-python-example of flink k8s operator

2022-10-06 Thread Biao Geng (Jira)
Biao Geng created FLINK-29529: - Summary: Update flink version in flink-python-example of flink k8s operator Key: FLINK-29529 URL: https://issues.apache.org/jira/browse/FLINK-29529 Project: Flink

[jira] [Created] (FLINK-29530) CommittableMessageTypeInfo#toString may force client to have S3 credentials

2022-10-06 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29530: Summary: CommittableMessageTypeInfo#toString may force client to have S3 credentials Key: FLINK-29530 URL: https://issues.apache.org/jira/browse/FLINK-29530 P

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.2.0, release candidate #2

2022-10-06 Thread Biao Geng
+1(non-binding) Thanks a lot for the great work. Successfully verified the following: - Checksums and gpg signatures of the tar files. - No binaries in source release - Build from source, build image from source without errors - Helm Repo works, Helm install works - Run HA/python example in applic

[RESULT][VOTE]FLIP-260: Support Job Dynamic Parameter With Flink Rest Api

2022-10-06 Thread Zheng Yu Chen
Hi everyone, FLIP-256 [1] has been accepted. There are 3 approving votes which are all binding [2] - Binding: Danny Cranmer- Binding: Gyula Fóra- Binding: Martijn Visser None against. Thanks again to everyone ! [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-256 +Support+Job+Dynam

Re: [RESULT][VOTE]FLIP-260: Support Job Dynamic Parameter With Flink Rest Api

2022-10-06 Thread Zheng Yu Chen
[1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-256%3A+Support+Job+Dynamic+Parameter+With+Flink+Rest+Api Zheng Yu Chen 于2022年10月7日周五 00:01写道: > Hi everyone, > > FLIP-256 [1] has been accepted. > > There are 3 approving votes which are all binding [2] > > - Binding: Danny Cranmer- Bin

Re: [DISCUSS] FLIP-246: Multi Cluster Kafka Source

2022-10-06 Thread Ryan van Huuksloot
Hi Mason, Thanks for the clarification! In regards to the addition to the OffsetInitializer of this API - this would be an awesome addition and I think this entire FLIP would be a great addition to the Flink. To provide more context as to why we need particular offsets, we use Hybrid Source to cu

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.2.0, release candidate #2

2022-10-06 Thread Márton Balassi
+1 (binding) Verified upgrade process from 1.1 with a running application On Thu, Oct 6, 2022 at 5:52 PM Biao Geng wrote: > +1(non-binding) > Thanks a lot for the great work. > > Successfully verified the following: > - Checksums and gpg signatures of the tar files. > - No binaries in source re

[jira] [Created] (FLINK-29531) Bump protoc and protobuf-java dependencies to 3.21.7

2022-10-06 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-29531: -- Summary: Bump protoc and protobuf-java dependencies to 3.21.7 Key: FLINK-29531 URL: https://issues.apache.org/jira/browse/FLINK-29531 Project: Flink Issu

Re: Support avro-confluent format for FileSystem SQL connector

2022-10-06 Thread liuxiangcao
Hi Martin, Thank you for the reply. I actually also noticed the reference of avro-confluent.subject in the avro-confluent format doc which is confusing. I tried using 'connector' = 'filesystem' and 'format' = 'avro-confluent' and it would fail with options validation when I tried to insert data

Re: Support avro-confluent format for FileSystem SQL connector

2022-10-06 Thread liuxiangcao
typo in my first sentence: I actually also noticed the reference of filesystem connector in the avro-confluent format doc which is confusing. On Thu, Oct 6, 2022 at 1:24 PM liuxiangcao wrote: > Hi Martin, > > Thank you for the reply. I actually also noticed the reference of > avro-confluent.subj

Re: Support avro-confluent format for FileSystem SQL connector

2022-10-06 Thread liuxiangcao
Actually I got the previous option validation issue resolved after adding 'avro-confluent.url' = 'https://confluent-schema-registry-url', 'avro-confluent.subject' = '' Now I'm one step closer to verifying whether avro-confluent format works with filesystem connector or not. Unfortuantely,

[jira] [Created] (FLINK-29532) Update Pulsar dependency to 2.10.1

2022-10-06 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-29532: -- Summary: Update Pulsar dependency to 2.10.1 Key: FLINK-29532 URL: https://issues.apache.org/jira/browse/FLINK-29532 Project: Flink Issue Type: Technical

Re: Support avro-confluent format for FileSystem SQL connector

2022-10-06 Thread liuxiangcao
In the meantime, I looked into the code of avro-confluent format and compared it with avro format. The *avro* format implemented *BulkWriterFormatFactory & BulkReaderFormatFactory* (see [1]) for file system connector and also *DeserializationFormatFactory & SerializationFormatFactory* for other c

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.2.0, release candidate #2

2022-10-06 Thread Thomas Weise
+1 (binding) Built from tag, manually tested upgrade mode change scenarios, upgraded existing environment On Thu, Oct 6, 2022 at 4:00 PM Márton Balassi wrote: > +1 (binding) > > Verified upgrade process from 1.1 with a running application > > On Thu, Oct 6, 2022 at 5:52 PM Biao Geng wrote: >

Re: Support avro-confluent format for FileSystem SQL connector

2022-10-06 Thread liuxiangcao
sorry I missed the references. [1] https://github.com/apache/flink/blob/fa161d3c5636370f5129320a9ca464e38f88fc6f/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroFileFormatFactory.java [2] https://github.com/apache/flink/blob/fa161d3c5636370f5129320a9ca464e38f88fc6f/flink-f

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.2.0, release candidate #2

2022-10-06 Thread Chenya Zhang
+1 non-binding Tested a few example applications and checking the operator log. Chenya On Thu, Oct 6, 2022 at 3:18 PM Thomas Weise wrote: > +1 (binding) > > Built from tag, manually tested upgrade mode change scenarios, upgraded > existing environment > > > On Thu, Oct 6, 2022 at 4:00 PM Márto

[jira] [Created] (FLINK-29533) Add proper table style to Flink website

2022-10-06 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-29533: - Summary: Add proper table style to Flink website Key: FLINK-29533 URL: https://issues.apache.org/jira/browse/FLINK-29533 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-265 Deprecate and remove Scala API support

2022-10-06 Thread Zheng Yu Chen
Hi Martjin, Thanks for compiling the FLIP. I think the removal of Scala in the later version 2.0 will help us to align with the JDK version in a more timely manner. Scala may be difficult to maintain due to too much syntactic sugar during maintenance (only represents a personal opinion). Flink dev

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.2.0, release candidate #2

2022-10-06 Thread Gyula Fóra
Thank you everyone for testing, I am closing this vote. Will post the results as a separate email. Gyula On Fri, Oct 7, 2022 at 5:38 AM Chenya Zhang wrote: > +1 non-binding > > Tested a few example applications and checking the operator log. > > Chenya > > On Thu, Oct 6, 2022 at 3:18 PM Thomas

[RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.2.0, release candidate #2

2022-10-06 Thread Gyula Fóra
Hi Devs! I'm happy to announce that we have unanimously approved this release. There are 8 approving votes, 4 of which are binding: * Gyula Fora (binding) * Marton Balassi (binding) * Thomas Weise (binding) * Maximilian Michels (binding) * Biao Geng (non-binding) * Jim Busche (non-binding) * Ma