Yanquan Lv created FLINK-36843:
--
Summary: Remove deprecated method in flink-table-planner
Key: FLINK-36843
URL: https://issues.apache.org/jira/browse/FLINK-36843
Project: Flink
Issue Type: Impro
Hi Ryan.
Thanks for your input. I am not a k8s expert, but I know that Flink k8s
deployments supports to get Flink TaskManager with specified pod
template[1], which supports to specify image. @Junrui may provide more
detailed information about this topic.
If different taskmanager has different wo
Hi Danny… and community,
At this point would it make sense for me to begin putting a FLIP together with
more details and perhaps continue the conversation from there?
Thanks,
Sergio
> On Nov 30, 2024, at 7:29 AM, Sergio Chong Loo wrote:
>
> Hey Danny
>
> Thanks for digging deeper into this t
Max Feng created FLINK-36842:
Summary: FlinkPipelineComposer allows injecting
StreamExecutionEnvironment
Key: FLINK-36842
URL: https://issues.apache.org/jira/browse/FLINK-36842
Project: Flink
Is
Gustavo de Morais created FLINK-36841:
-
Summary: Incorrect error message for CURRENT_TIMESTAMP
Key: FLINK-36841
URL: https://issues.apache.org/jira/browse/FLINK-36841
Project: Flink
Issue
Gustavo de Morais created FLINK-36840:
-
Summary: Multiple time-related built-in functions cannot be called
Key: FLINK-36840
URL: https://issues.apache.org/jira/browse/FLINK-36840
Project: Flink
Ferenc Csaky created FLINK-36839:
Summary: Update Kudu version to 1.17.1
Key: FLINK-36839
URL: https://issues.apache.org/jira/browse/FLINK-36839
Project: Flink
Issue Type: Improvement
The Apache Flink community is very happy to announce the release of
Apache flink-connector-hbase 4.0.0.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data
streaming applications.
The release is available for download a
Hi Yanquan,
Thanks for your support. Yes and support for the new dialects.
It would be great to get open PRs merged to support new dialect if possible,
including:
https://github.com/apache/flink-connector-jdbc/pull/118 - this has been around
for a while with the submitter asking for a merge ?C t
Hi Shengkai,
Today we currently use application mode. It is an option and may be the
recommendation.
Specifically for Batch jobs, we have Machine Learning pipelines that are
ephemeral however they contain very different dependencies depending on the
workload.
>From my perspective, Batch jobs work
Hi Yanquan,
I have kicked off the release process for v3.1, will try to conclude soon
and announce.
Sorry for the delays, it is quite hard to process the release without PMC
permissions but Danny is kindly offering help when needed.
Best Regards
Ahmed Hamdy
On Tue, 3 Dec 2024 at 12:05, Yanquan L
Unsubscribe
> 2024年12月3日 21:11，ar...@apache.org 写道：
>
> This is an automated email from the ASF dual-hosted git repository.
>
> arvid pushed a commit to branch main
> in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
>
>
> The following commit(s) were added to refs/he
Zakelly Lan created FLINK-36838:
---
Summary: [state] Join background threads when ForSt state backend
quit
Key: FLINK-36838
URL: https://issues.apache.org/jira/browse/FLINK-36838
Project: Flink
Hi Ahmed,
I would like to kindly inquire about the current plan for release v3.1, are
there any other conclusions from offline communication?
> 2024年10月14日 17:21，Ahmed Hamdy 写道：
>
> Hi all,
> I want to kick off the discussion for elasticsearch connector release v3.1.
> Our latest release v3.0.1
Hi Roman!
> 1. Why do we give up on the idea of reporting child spans independently
> from the parent? I couldn't find much details in the Rejected Alternatives
> section
We are not giving up on it. But the issue is how to connect related spans if
they are reported independently, potentially on d
Hi Romand and Hongshun,
> 1. The scope of the variables added - is it only the last transformation?
> Do I understand correctly, that chaining does NOT affect this scoping?
> Could you please give a more detailed example how to do it? Currently, the
> example only shows source.
Setting the scope
Hi Roman!
> 1. Should it list the events that would be emitted in the first version?
> If not as part of the proposed change, then maybe as examples
I've added a brief list of events that will be added in the first version.
> 2. Interface Event - Scope
> It's scope is explicitly tied to a Class
Hi Max,That’s great to hear—thank you for the update. I look forward to
reviewing the code when it’s available.
Thanks,Anil
On Thursday, November 28, 2024 at 04:16:32 AM PST, Maximilian Michels
wrote:
Hi Anil,
Great. The Dynamic Iceberg Sink will address your feature request. We'll
s
xuyang created FLINK-36837:
--
Summary: Introduce new RowTimeDeduplicateFunction with Async State
API
Key: FLINK-36837
URL: https://issues.apache.org/jira/browse/FLINK-36837
Project: Flink
Issue Type
Hi David,
Thanks for organizing! Two points of order:
When I put up PRs, I am usually already working with a committer or putting
up some kind of draft. If you saw an assigned reviewer (or the PR marked
as a draft), would that help you step over the PR and focus on other ones?
(Or said differen
yuanfenghu created FLINK-36836:
--
Summary: Autoscaler Supports config the upper and lower limits of
target utilization.
Key: FLINK-36836
URL: https://issues.apache.org/jira/browse/FLINK-36836
Project: Fli
Hi.
Why needs different image for taskmanager? Do you mean different operators
require different resources?
As far as I know, JM supports to manage taskmanager with different
profiles. For example, a cluster may consists of two taskmanagers with
following profiles:
* TM1 contains 4 slots, every s
22 matches
Mail list logo
