Hello Dale and Martijn, I've been looking into some schema registry
issues, and I thought I'd bring this back up.
I can *kind of* see the value in configuring the Flink job with
sufficient information that you can run and/or test without a schema
registry, but it really seems like the best way to
+1 (binding)
- Validated hashes
- Verified signature
- Verified that no binaries exist in the source archive
- Build the source with Maven
- Verified licenses
- Verified web PRs
On Fri, Nov 24, 2023 at 7:29 AM Jing Ge wrote:
>
> +1(not-binding)
>
> - verified signatures hash
> - verified hash
>
Hi Danny,
Thanks for driving this.
+1 (binding)
- Validated hashes
- Verified signature
- Verified that no binaries exist in the source archive
- Build the source with Maven
- Verified licenses
- Verified web PRs
On Mon, Nov 20, 2023 at 12:29 PM Jiabao Sun
wrote:
>
> Thanks Danny for driving t
Jiabao Sun created FLINK-33637:
--
Summary: [JUnit5 Migration] Introduce ArchTest rules to ban Junit
4 for table-planner
Key: FLINK-33637
URL: https://issues.apache.org/jira/browse/FLINK-33637
Project: Fli
Yubin Li created FLINK-33638:
Summary: Support variable-length data generation for
variable-length data types
Key: FLINK-33638
URL: https://issues.apache.org/jira/browse/FLINK-33638
Project: Flink
+1 (binding)
- Validated hashes
- Verified signature
- Verified that no binaries exist in the source archive
- Build the source with Maven
- Verified licenses
- Verified web PRs
On Fri, Nov 24, 2023 at 7:25 AM Jing Ge wrote:
>
> +1(not-binding)
>
> - verified signatures and hash
> - reviewed the
Hi all,
Offline discussed with Zhu Zhu and Leonard Xu and we have reached the
following three points of consensus:
1. Rename the interface method Context#getMaxSourceParallelism proposed by
the FLIP to Context#getParallelismInferenceUpperBound, to make the meaning
of the method clearer. See [1] fo
Sergey Nuyanzin created FLINK-33639:
---
Summary: Support zookeeper 3.9.0+
Key: FLINK-33639
URL: https://issues.apache.org/jira/browse/FLINK-33639
Project: Flink
Issue Type: Technical Debt
Matt Wang created FLINK-33640:
-
Summary: Support configuring FLINK_CONF_FILE through environment
variables
Key: FLINK-33640
URL: https://issues.apache.org/jira/browse/FLINK-33640
Project: Flink
Hi Peter!
Thank you for the analysis of the options.
I don't really have a strong opinion, but in general I am in favor of the
mix in style interfaces.
We follow the same approach for table sources / sinks as well.
Some other benefits I see in addition to what you mentioned:
- Easier to introdu
Hi Surendra!
The resource configuration in Flink is pretty well established and
covers setting both memory requests and limits (through the limit factor.)
Could you please elaborate why you think this change is a good addition?
I see a few downsides:
- It complicates memory configuration by add
Thanks Xia and Zhu Zhu for driving this work,
It will help unify the parallelism inference for all operators of batch job,
the updated FLIP looks good to me.
Best,
Leonard
> 2023年11月24日 下午5:53,Xia Sun 写道:
>
> Hi all,
> Offline discussed with Zhu Zhu and Leonard Xu and we have reached the
> f
Sergey Nuyanzin created FLINK-33641:
---
Summary: RankITCase.testMultipleUnaryTopNAfterAgg fails on AZP
Key: FLINK-33641
URL: https://issues.apache.org/jira/browse/FLINK-33641
Project: Flink
I
Thanks Danny for driving this.
+1 (binding)
- built from source code succeeded
- verified signatures
- verified hashsums
- checked the contents contains jar and pom files in apache repo
- checked the lowest supported flink version issue has been fixed
- checked Github release tag
- checked re
Sergey Nuyanzin created FLINK-33642:
---
Summary: Use docker image with jdk21 in CI
Key: FLINK-33642
URL: https://issues.apache.org/jira/browse/FLINK-33642
Project: Flink
Issue Type: Sub-task
Matt Wang created FLINK-33643:
-
Summary: Allow StreamExecutionEnvironment's executeAsync API to
use default JobName
Key: FLINK-33643
URL: https://issues.apache.org/jira/browse/FLINK-33643
Project: Flink
Thanks for reviving the efforts here Matthias! +1 for the transition
to GitHub Actions.
As for ASF Infra Jenkins, it works fine. Jenkins is extremely
feature-rich. Not sure about the spare capacity though. I know that
for Apache Beam, Google donated a bunch of servers to get additional
build capac
+1(binding)
And closing this vote thread, results will be announced in a separate email.
Best,
Dawid
On Wed, 22 Nov 2023 at 14:17, Martijn Visser
wrote:
> +1 (binding)
>
> On Wed, Nov 22, 2023 at 2:05 AM Lincoln Lee
> wrote:
> >
> > +1 (binding)
> >
> > Best,
> > Lincoln Lee
> >
> >
> > Serge
+1 (non-binding)
- Verified signatures
- Build the source with Maven
- start cluster bin/start-cluster.sh with java8, it works fine
- started SQL Client, used datagen source to verify several SQL
cases(FLINK-33010,FLINK-32456,FLINK-30966), result seems ok.
Best,
Lincoln Lee
Martijn Visser 于202
FLIP-393 [1] has been accepted and voted through this thread [2].
The proposal received 10 approving votes, 7 of which are binding, and
there is no disapproval.
Benchao Li (binding)
Martijn Visser (binding)
Gyula Fora (binding)
Timo Walther (binding)
Sergey Nuyanzin (binding)
Lincoln Lee (binding
Dawid Wysakowicz created FLINK-33644:
Summary: FLIP-393: Make QueryOperations SQL serializable
Key: FLINK-33644
URL: https://issues.apache.org/jira/browse/FLINK-33644
Project: Flink
Issue
+1 (binding)
- Validated hashes
- Verified signature
- Verified that no binaries exist in the source archive
- Build the source with Maven
- Verified licenses
- Verified web PRs
On Fri, Nov 24, 2023 at 12:38 PM Leonard Xu wrote:
>
> Thanks Danny for driving this.
>
>
> +1 (binding)
>
> - built f
Tony Garrard created FLINK-33645:
Summary: Env vars in config not added to Taskmanagers in
Standalone mode
Key: FLINK-33645
URL: https://issues.apache.org/jira/browse/FLINK-33645
Project: Flink
Hi everyone,
Please review and vote on release candidate #1 for version 3.0.2 of the
Apache Flink Kafka Connector, as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
Compared to the previous hotfix release, this release only additionally
Thanks everyone for responses
I've started preparation steps to make it happened by following steps [1]
One of the preliminary steps is publishing GPG key dist.apache.org
I don't have write access there and as it is also mentioned at wiki page
>Note: Only PMC members have write access to the rel
+1 (binding)
- Verified signature and hashes
- Verified mvn dependency:tree for a typical user job jar [1]. When using
Flink 1.18.0, flink-connector-base is no longer getting bundled, and all
Flink dependencies resolve as 1.18.0 / provided.
- Submitting user job jar to local Flink 1.18.0 cluster w
Hi Gyula,
Thank you for raising these valid concerns and sharing your perspective. I
agree that this new change will impact the existing pipelines.
I brought up this issue because in Kubernetes environments, resource
configuration is typically managed through Kubernetes objects like
container tem
I think a better and more Kubernetes canonical approach would be what is
outlined in this ticket:
https://issues.apache.org/jira/browse/FLINK-33548
The upside is that it will work for all operator supported Flink versions
and is much simpler to use than the pod template.
What do you think?
Gyul
Hi Gyula,
Yes, I agree with this approach.
Thanks
Surendra
On Sat, Nov 25, 2023, 12:28 AM Gyula Fóra wrote:
> I think a better and more Kubernetes canonical approach would be what is
> outlined in this ticket:
>
> https://issues.apache.org/jira/browse/FLINK-33548
>
> The upside is that it w
Hi
In that case we could also close your ticket and the one you linked and
refer to this one as the selected approach :)
Gyula
On Fri, 24 Nov 2023 at 20:19, Surendra Singh Lilhore <
surendralilh...@gmail.com> wrote:
> Hi Gyula,
>
>
> Yes, I agree with this approach.
>
>
> Thanks
> Surendra
>
>
Sergey Nuyanzin created FLINK-33646:
---
Summary: Cleanup the rest usage of deprecated
TableEnvironment#registerFunction and in docs
Key: FLINK-33646
URL: https://issues.apache.org/jira/browse/FLINK-33646
Bonnie Varghese created FLINK-33647:
---
Summary: Implement restore tests for LookupJoin node
Key: FLINK-33647
URL: https://issues.apache.org/jira/browse/FLINK-33647
Project: Flink
Issue Type:
Jing Ge created FLINK-33648:
---
Summary: table usfs doc in Chinese is out-of-date
Key: FLINK-33648
URL: https://issues.apache.org/jira/browse/FLINK-33648
Project: Flink
Issue Type: Improvement
+1 (non-binding)
- Validated checksum hash
- Verified signature
- Verified that no binaries exist in the source archive
- Build the source with Maven and jdk8
- Verified licenses
- Verified web PRs
Best,
Rui
On Sat, Nov 25, 2023 at 2:05 AM Tzu-Li (Gordon) Tai
wrote:
> +1 (binding)
>
> - Verifi
+1 (non-binding)
- Validated checksum hash
- Verified signature
- Verified that no binaries exist in the source archive
- Build the source with Maven and jdk8
- Verified licenses
- Verified web PRs, left a minor comment
Best,
Rui
On Fri, Nov 24, 2023 at 10:26 PM Martijn Visser
wrote:
> +1 (bin
Rui Fan created FLINK-33649:
---
Summary: Exponential Delay doc is missed
Key: FLINK-33649
URL: https://issues.apache.org/jira/browse/FLINK-33649
Project: Flink
Issue Type: Technical Debt
Co
36 matches
Mail list logo