Hi Devs,
Weijie Guo and I would like to initiate a discussion about FLIP-500:
Support Join Extension in DataStream V2 API [1].
In relational algebra, Join are used to co-group two datasets and combine
the data based on specific conditions. For stream computing systems, the
data of the two streams
Sergey Nuyanzin created FLINK-37006:
---
Summary: Apply changes from FLINK-36277 to AdaptiveJoin
Key: FLINK-37006
URL: https://issues.apache.org/jira/browse/FLINK-37006
Project: Flink
Issue Ty
Piotr Nowojski created FLINK-37005:
--
Summary: Make StreamExecDeduplicate ouput insert only where
possible
Key: FLINK-37005
URL: https://issues.apache.org/jira/browse/FLINK-37005
Project: Flink
Thanks Matthias for starting this discussion!
+1 for disabling CI for 1.18.*
Best,
Rui
On Fri, Jan 3, 2025 at 11:45 PM Robert Metzger wrote:
> Hey Matthias,
>
> it seems that there is no traction for creating another 1.18.x bugfix
> release, so *I'm +1 for disabling CI for 1.18.*
>
> On Wed, D
Hong Liang Teoh created FLINK-37004:
---
Summary: Implement Multithreaded SourceReader
Key: FLINK-37004
URL: https://issues.apache.org/jira/browse/FLINK-37004
Project: Flink
Issue Type: Improv
Hey Matthias,
it seems that there is no traction for creating another 1.18.x bugfix
release, so *I'm +1 for disabling CI for 1.18.*
On Wed, Dec 18, 2024 at 10:41 AM Matthias Pohl wrote:
> Hi everyone,
> with the release of 1.20.0 [1], 1.18 reached its EOL. The community has
> decided to do a fi
Hi Xu,Thanks for the response.I am currently using Spark Streaming to process
data from Kafka in microbatches, writing each microbatch's data to a dedicated
prefix in S3. Since Spark Streaming is lazy, it processes data only when a
microbatch is created or triggered, leaving resources idle unt
Hi, Anil
I don't understand what you mean by Global Watermark, are you trying to
have all Sources emit a special event with the same epoch at the same time?
Is there a specific user case for this question?
Happy new year!
Best,
Xu Huang
Anil Dasari 于2025年1月3日周五 14:02写道：
> Hello XU,Happy new
Zakelly Lan created FLINK-37003:
---
Summary: Implement async state version of Datastream Interval join
Key: FLINK-37003
URL: https://issues.apache.org/jira/browse/FLINK-37003
Project: Flink
Issue
Jacky Lau created FLINK-37002:
-
Summary: Migrate DecomposeGroupingSetsRule
Key: FLINK-37002
URL: https://issues.apache.org/jira/browse/FLINK-37002
Project: Flink
Issue Type: Sub-task
Co
Thanks Matthias very much for the sharing and suggestions.
The ideas make sense to me on the whole and I'd be willing to update it.
I just want to confirm a few questions before starting the next round of wiki
adjustments:
1 - About the Boundary Definition of Rescale Events
> A few ot
xuyang created FLINK-37001:
--
Summary: Remove all direct uses of
`TableEnvironmentInternal#registerTableSinkInternal` in table module
Key: FLINK-37001
URL: https://issues.apache.org/jira/browse/FLINK-37001
Pr
yux created FLINK-37000:
---
Summary: MySQL CDC could not handle date and time data prior to
unix epoch
Key: FLINK-37000
URL: https://issues.apache.org/jira/browse/FLINK-37000
Project: Flink
Issue Type:
林健昌 created FLINK-36999:
---
Summary: Null pointer exception when the source field type is
decimal and the value is null
Key: FLINK-36999
URL: https://issues.apache.org/jira/browse/FLINK-36999
Project: Flink
xuyang created FLINK-36998:
--
Summary: The RowKind of data about globalUpsertResult is different
in KeyedUpsertingSinkFunction while being inserted or be restored
Key: FLINK-36998
URL: https://issues.apache.org/jira/brows
15 matches
Mail list logo
