Regarding the concern of the SlotManager, my two cents:
1. it is necessary for the SlotManager to host blocked slots, in 2 cases:
a. In standalone mode, a taskmanager may be temporarily added to
the blocklist. We do not want the TM to get disconnected and shut down.
So we need to keep its
Hi Chesnay,
Would you share your thoughts in the discussion thread if there are
still concerns?
Thanks,
Zhu
Chesnay Schepler 于2022年5月27日周五 14:54写道：
>
> -1 to put a lid on things for now, because I'm not quite done yet with
> the discussion.
>
> On 27/05/2022 05:25, Yangze Guo wrote:
> > +1
fanrui created FLINK-27822:
--
Summary: Translate the doc of checkpoint/savepoint guarantees
Key: FLINK-27822
URL: https://issues.apache.org/jira/browse/FLINK-27822
Project: Flink
Issue Type:
Hi Devs!
We have been performing extensive manual testing on the release.
We have found some very infrequent savepoint upgrade issues with Flink 1.15
deployments that we could not reliably reproduce so far. I have added a fix
that hopefully eliminates the root cause (
Hi Yang,
Oh, I’ve been using podman on Red Hat for testing:
podman version
Client: Podman Engine
Version: 4.0.2
API Version: 4.0.2
If I use Docker (version 20.10.13 for me right now) then it builds fine with
that COPY git line. Nice!
To use podman, I need to either comment
Hi, everyone.
Thanks for all the inputs.
If there is no more feedback, I think we can start the vote next monday.
Best,
Godfrey
Martijn Visser 于2022年5月25日周三 19:46写道：
>
> Hi Godfrey,
>
> Thanks for creating the FLIP. I have no comments.
>
> Best regards,
>
> Martijn
>
>
> On Tue, 17 May 2022 at
Thanks all for the valuable discussion. The new feature looks very
interesting.
According to the FLIP description: "*Currently we have JDBC, Hive and HBase
connector implemented lookup table source. All existing implementations
will be migrated to the current design and the migration will be
Hector Miuler Malpica Gallegos created FLINK-27821:
--
Summary: Cannot delete flinkdeployment when the pod and deployment
deleted manually
Key: FLINK-27821
URL:
Gyula Fora created FLINK-27820:
--
Summary: Handle Upgrade/Deployment errors gracefully
Key: FLINK-27820
URL: https://issues.apache.org/jira/browse/FLINK-27820
Project: Flink
Issue Type:
Hi Lincoln,
Delayed Dim Join is a frequently requested feature, it's exciting to see
this feature is on the road.
The FLIP looks good to me in general. I only left some minor comments.
1) support retry for sync lookup
I'm also fine with the idea proposed by Jingsong. But this doesn't conflict
Chesnay Schepler created FLINK-27819:
Summary: Generate better operationIds for OpenAPI spec
Key: FLINK-27819
URL: https://issues.apache.org/jira/browse/FLINK-27819
Project: Flink
Issue
Chesnay Schepler created FLINK-27818:
Summary: Model enums as references in OpenAPI spec
Key: FLINK-27818
URL: https://issues.apache.org/jira/browse/FLINK-27818
Project: Flink
Issue
godfrey he created FLINK-27817:
--
Summary: TaskManager metaspace OOM for session cluster
Key: FLINK-27817
URL: https://issues.apache.org/jira/browse/FLINK-27817
Project: Flink
Issue Type: New
jinshuangxian created FLINK-27816:
-
Summary: file source reader has Some requirements
Key: FLINK-27816
URL: https://issues.apache.org/jira/browse/FLINK-27816
Project: Flink
Issue Type:
godfrey he created FLINK-27815:
--
Summary: Improve the join reorder strategy for batch sql job
Key: FLINK-27815
URL: https://issues.apache.org/jira/browse/FLINK-27815
Project: Flink
Issue Type:
Caizhi Weng created FLINK-27814:
---
Summary: Add an abstraction layer for connectors to read and write
row data instead of key-values
Key: FLINK-27814
URL: https://issues.apache.org/jira/browse/FLINK-27814
Oleksandr created FLINK-27813:
-
Summary: java.lang.IllegalStateException: afte migration from
statefun 3.1.1 to 3.2.0
Key: FLINK-27813
URL: https://issues.apache.org/jira/browse/FLINK-27813
Project:
Matyas Orhidi created FLINK-27812:
-
Summary: Support Dynamic change of watched namespaces
Key: FLINK-27812
URL: https://issues.apache.org/jira/browse/FLINK-27812
Project: Flink
Issue Type:
Hi all,
I think the problem now is below:
1. AllCache and PartialCache interface on the non-uniform, one needs to
provide LookupProvider, the other needs to provide CacheBuilder.
2. AllCache definition is not flexible, for example, PartialCache can use
any custom storage, while the AllCache can
Chesnay Schepler created FLINK-27811:
Summary: Remove netty dependency in flink-test-utils
Key: FLINK-27811
URL: https://issues.apache.org/jira/browse/FLINK-27811
Project: Flink
Issue
Chesnay Schepler created FLINK-27810:
Summary: Elasticsearch e2e jars bundle way more than they should
Key: FLINK-27810
URL: https://issues.apache.org/jira/browse/FLINK-27810
Project: Flink
I had an offline discussion with Piotr and here is the summary. Please
correct me if I miss something, Piotr.
There are two things we would like to seek more opinions from the
community, so we can make progress on this FLIP.
1. The General pattern to add obligatory features to existing
Chesnay Schepler created FLINK-27809:
Summary: Clarify that cluster-id is mandatory for Kubernetes HA in
standalone mode
Key: FLINK-27809
URL: https://issues.apache.org/jira/browse/FLINK-27809
Chesnay Schepler created FLINK-27808:
Summary: Allow "kubernetes" as setting for HA_MODE
Key: FLINK-27808
URL: https://issues.apache.org/jira/browse/FLINK-27808
Project: Flink
Issue
-1 to put a lid on things for now, because I'm not quite done yet with
the discussion.
On 27/05/2022 05:25, Yangze Guo wrote:
+1 (binding)
Best,
Yangze Guo
On Thu, May 26, 2022 at 3:54 PM Yun Gao wrote:
Thanks Lijie and Zhu for driving the FLIP!
The blocked list functionality helps reduce
Thanks, Lincoln, the updated comments look good to me.
Best,
Jark
On Fri, 27 May 2022 at 14:21, Lincoln Lee wrote:
> Hi Jark & developers,
>
> I'm fine with this, and minor changes:
>
> "timeout from first invoke to final completion of asynchronous operation,
> may include multiple retries,
Hi Jark & developers,
I'm fine with this, and minor changes:
"timeout from first invoke to final completion of asynchronous operation,
may include multiple retries, and will be reset in case of failover"
The FLIP[1] was updated including two changes:
1. generic type naming, use OUT instead of T
27 matches
Mail list logo
