+1 (binding)
- verified signatures: *OK*
- verified hashes: *OK*
- build source code with JDK11 and Maven 3.8.6: *OK*
- Started local cluster and verified web ui & logs: *OK*
- Run wordcount job: *OK*
Best,
Jark
On Thu, 13 Mar 2025 at 01:18, Ferenc Csaky
wrote:
> +1 (non-binding)
>
> - Verifie
Hi Ammu,
The SQL Gateway enables clients to specify which cluster to submit jobs to.
Here’s my understanding of the workflow:
1. The SQL client reads the configuration files (flink-conf.yaml or
config.yaml) located in $FLINK_HOME/conf. The default configuration
typically includes the rest.address
Looking forward to hearing the good news!
Best,
Shengkai
Gabor Somogyi 于2025年3月12日周三 22:24写道：
> Thanks for both the valuable input!
>
> Let me take a closer look at the suggestions, like the Catalog capabilities
> and possibility of embedding TypeInformation or
> StateDescriptor metadata direct
Hi All,
I would like to start a discussion of FLIP-514: Custom Evaluator plugin for
Flink Autoscaler [1].
Feel free to share your thoughts and suggestions to make this feature better.
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-514%3A+Custom+Evaluator+plugin+for+Flink+Autosc
+1 (binding)
On Wed, Mar 12, 2025 at 10:21 AM Yuepeng Pan wrote:
> +1 (non-binding).
>
> Best regards,
> Yuepeng Pan.
>
>
>
>
>
>
>
>
>
>
>
> At 2025-03-12 17:02:55, "Sergey Nuyanzin" wrote:
> >+1 (binding)
> >
> >On Tue, Mar 11, 2025, 12:38 Xuyang wrote:
> >
> >> +1(binding)
> >>
> >>
> >> --
+1 (non-binding)
- Verified signatures and checksums
- Checked GH release tag
- Built src with JDK21 and Maven 3.8.6
- Deployed TopSpeedWindowing example to standalone cluster
- Ran dummy datagen SELECT via SQL client on standalone cluster
- Checked web PR that has quite some comments from David,
qihuang created FLINK-37468:
---
Summary: Flink release-1.19 branch has instructions - Maven 3.8.6
(recommended or later)
Key: FLINK-37468
URL: https://issues.apache.org/jira/browse/FLINK-37468
Project: Flink
I'm trying the Pyflink - Kafka connection.
I'm using Python 3.11 on Pycharm, with the
flink-sql-connector-kafka-3.3.0-1.20.jar and apache-flink 1.20. I'm running
Kafka on Docker, and I've tested the producer who can correctly send
message to the topic
I'm trying with a simple code like:
```
from p
Diego Lobba created FLINK-37467:
---
Summary: FlinkSessionJob: possibility to use configmaps and
secrets in args parameter
Key: FLINK-37467
URL: https://issues.apache.org/jira/browse/FLINK-37467
Project: F
Timo Walther created FLINK-37466:
Summary: A helper function for DEFAULT in Table API
Key: FLINK-37466
URL: https://issues.apache.org/jira/browse/FLINK-37466
Project: Flink
Issue Type: Sub-ta
Thanks for both the valuable input!
Let me take a closer look at the suggestions, like the Catalog capabilities
and possibility of embedding TypeInformation or
StateDescriptor metadata directly into the raw state files...
BR,
G
On Wed, Mar 12, 2025 at 8:17 AM Shengkai Fang wrote:
> Thanks for
Hi Shengkai,
Thanks for responding. It works after setting rest.address. Now the docker file
looks like below:
services:
sql-gateway:
image: flink-1.20
ports:
- "8083:8083"
command: sql-gateway.sh start-foreground
-Dsql-gateway.endpoint.rest.address=localhost
depends_on:
Thanks for addressing the feedback Poorvank,
+1 (non-binding)
Best Regards
Ahmed Hamdy
On Tue, 11 Mar 2025 at 11:32, Doğuşcan Namal
wrote:
> Thanks for the FLIP Poorvank. We already had a discussion on the Google doc
> and thanks for addressing the comments.
>
> It looks good as is to me, +1(
+1 (non-binding).
Best regards,
Yuepeng Pan.
At 2025-03-12 17:02:55, "Sergey Nuyanzin" wrote:
>+1 (binding)
>
>On Tue, Mar 11, 2025, 12:38 Xuyang wrote:
>
>> +1(binding)
>>
>>
>> --
>>
>> Best！
>> Xuyang
>>
>>
>>
>>
>>
>> 在 2025-03-11 19:12:05，"Leonard Xu" 写道：
>> >+1(binding)
+1 (binding)
On Tue, Mar 11, 2025, 12:38 Xuyang wrote:
> +1(binding)
>
>
> --
>
> Best！
> Xuyang
>
>
>
>
>
> 在 2025-03-11 19:12:05，"Leonard Xu" 写道：
> >+1(binding)
> >
> >Best,
> >Leonard
> >
> >> 2025年3月11日 18:42，Timo Walther 写道：
> >>
> >> +1 (binding)
> >>
> >> Thanks for working on t
Xiao Huang created FLINK-37465:
--
Summary: [Docs] Update options for oceanbase connector
Key: FLINK-37465
URL: https://issues.apache.org/jira/browse/FLINK-37465
Project: Flink
Issue Type: Improve
Michas Szacillo created FLINK-37464:
---
Summary: Update ZK to v3.9.3 in Flink Kubernetes Operator for TLS
v1.3 support
Key: FLINK-37464
URL: https://issues.apache.org/jira/browse/FLINK-37464
Project:
Thanks for Zakelly's clarification.
1. State TTL for Value Columns
+1 to delay the discussion about this.
2. Metadata Table vs. Metadata Column
I’d like to share my perspective on the State Catalog proposal. While
introducing this capability is beneficial, there is a blocker: the current
StateB
18 matches
Mail list logo
