Does anyone encounter the non-heap memory increasing issue when using RocksDB
as state backend with memory controlling enabled? It has plagued us for long
time. Our flink jobs are deployed under Kubernetes, and they would be killed
because of OOM by the increasing non-heap memory by Kubernetes.
Hi everyone,
Thanks all for your comments!
As many of you have questions about the names for boolean options, I
suggest we make a naming rule for them. For now I could think of three
options:
Option 1: Use enumeration options if possible. But this may cause some name
collisions or confusion as
Hi Xintong,
I agree that decoupling from Kryo is a bigger topic, well beyond the scope of
this FLIP.
The reason I’d brought up Fury is that this increases my confidence that Flink
will want to decouple from Kryo sooner rather than later.
So I feel it would be worth investing in a (minor) name
Hi Zakelly,
Thanks for driving this! The organization of the configuration option
in the FLIP looks much cleaner and easier to understand. +1 to the
FLIP.
Just some questions from me.
1. I think the change to the ConfigOptions should be put in the
`Public Interface` section, instead of
Bonnie Varghese created FLINK-33958:
---
Summary: Implement restore tests for IntervalJoin node
Key: FLINK-33958
URL: https://issues.apache.org/jira/browse/FLINK-33958
Project: Flink
Issue
Prabhu Joseph created FLINK-33957:
-
Summary: Generic Log-Based Incremental Checkpoint fails when Task
Local Recovery is enabled
Key: FLINK-33957
URL: https://issues.apache.org/jira/browse/FLINK-33957
Thanks for the response, Zhanghao.
PersistenceServices sounds good to me.
Best,
Yangze Guo
On Wed, Dec 27, 2023 at 11:30 AM Zhanghao Chen
wrote:
>
> Thanks for driving this effort, Yangze! The proposal overall LGTM. Other from
> the throughput enhancement in the OLAP scenario, the separation
Hi David,
I believe this is because the testcontainers rely on the log4j
configuration settings. Github CI runs something like mvn clean
install -Dlog4j.configurationFile=tools/ci/log4j.properties
Best regards,
Martijn
On Fri, Dec 8, 2023 at 5:30 PM David Radley wrote:
>
> Hi,
> When I build
Martijn Visser created FLINK-33956:
--
Summary: Bump org.apache.zookeeper:zookeeper from 3.7.1 to 3.7.2
Key: FLINK-33956
URL: https://issues.apache.org/jira/browse/FLINK-33956
Project: Flink
Thanks Jing for driving this release.
+1 (non-binding)
*
Download artifacts and verify the signatures.
*
Verified the web PR
*
Verified the number of Python packages is 11
*
Started a local cluster and verified FLIP-291 to see the rescale results.
*
Verified the jar packages were
+1 for this :)
On Thu, Dec 7, 2023 at 6:05 AM wudi <676366...@qq.com.invalid> wrote:
>
>
> Hi all,
>
> As discussed in the previous email [1], about contributing the Flink Doris
> Connector to the Flink community.
>
>
> Apache Doris[2] is a high-performance, real-time analytical database based
Hi,
+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
Best regards,
Martijn
On Mon, Dec 11, 2023 at 12:11 AM Sergey Nuyanzin wrote:
>
> Hey everyone,
>
> The vote
Hi Sergey,
Is the next step that we need to generate a release of the
externalized code? Did someone already volunteer for that?
Best regards,
Martijn
On Mon, Dec 11, 2023 at 3:00 AM yuxia wrote:
>
> Thanks Sergey for the work. Happy to see we can externalize Hive connector
> finally.
>
>
Hi all,
I want to get some insights on how many users are still using Hadoop 2
vs how many users are using Hadoop 3. Flink currently requires a
minimum version of Hadoop 2.10.2 for certain features, but also
extensively uses Hadoop 3 (like for the file system implementations)
Hadoop 2 has a
Hi Oleksandr,
The FLIP talks about Curator, but outside of flink test utils, the
usage of Curator is only for test purposes. I don't think there's
anything preventing you right now from providing these additional
parameters as values in the flink-conf.yaml ?
Best regards,
Martijn
On Thu, Dec
Alek Łańduch created FLINK-33955:
Summary: UnsupportedFileSystemException when trying to save data
to Azure's abfss File System
Key: FLINK-33955
URL: https://issues.apache.org/jira/browse/FLINK-33955
The Apache Flink community is very happy to announce the release of Apache
Flink Pulsar Connector 4.1.0 which is
compatible with the Apache Flink 1.17.x and 1.18.x release series.
Apache Flink® is an open-source stream processing framework for distributed,
high-performing,
always-available,
+1 (binding)
Cheers,
Timo
> Am 28.12.2023 um 03:13 schrieb Yuepeng Pan :
>
> +1 (non-binding).
>
> Best,
> Yuepeng Pan.
>
>
>
>
> At 2023-12-28 09:19:37, "Lincoln Lee" wrote:
>> +1 (binding)
>>
>> Best,
>> Lincoln Lee
>>
>>
>> Martijn Visser 于2023年12月27日周三 23:16写道：
>>
>>> +1
18 matches
Mail list logo
