Han Yin created FLINK-36622:
---
Summary: Remove the dependency of StateBenchmark on
RocksDBKeyedStateBackend APIs.
Key: FLINK-36622
URL: https://issues.apache.org/jira/browse/FLINK-36622
Project: Flink
Piotr Nowojski created FLINK-36621:
--
Summary: Build failure: StatefulSink not found
Key: FLINK-36621
URL: https://issues.apache.org/jira/browse/FLINK-36621
Project: Flink
Issue Type: Improve
Zhenqiu Huang created FLINK-36625:
-
Summary: Add helper classes for Lineage integration in connectors
Key: FLINK-36625
URL: https://issues.apache.org/jira/browse/FLINK-36625
Project: Flink
Is
Hello team,
I apologize for reaching out on the dev mailing list. I'm working on
implementing micro-batching with near real-time processing.
I've seen similar questions in the Flink Slack channel and user mailing list,
but there hasn't been much discussion or feedback. Here are the options I've
Hector Miuler Malpica Gallegos created FLINK-36627:
--
Summary: Failure to process a CSV file in Flink due to a character
encoding mismatch: the file is in ISO-8859 and the application expects UTF-8.
Key: FLINK-3662
Hello,
in Flink 19, AWS managed Flink
flink-connector-kafka:3.3.0-1.19
After i enable watermark alignment at KafkaSource, It starts throwing
uncaught WakeupException.
It happens:
* On every checkpoint unless i disable offset committing:
setProperty(KafkaSourceOptions.COMMIT_OFFSETS_ON_CHECKPOI
Piotr Nowojski created FLINK-36624:
--
Summary: Log JobID in SourceCoordinator
Key: FLINK-36624
URL: https://issues.apache.org/jira/browse/FLINK-36624
Project: Flink
Issue Type: Improvement
Thanks Danny for the input,
I figured out most of the steps require committer permissions, I will reach
out offline for the next steps so thanks in advance for the assistance also.
Best Regards
Ahmed Hamdy
On Mon, 14 Oct 2024 at 17:23, Danny Cranmer wrote:
> Hey Ahmed,
>
> +1 for the release a
The Apache Flink community is very happy to announce the release of Apache
Flink Kubernetes Operator 1.10.0
The Flink Kubernetes Operator allows users to manage their Apache Flink
applications and their lifecycle through native k8s tooling like kubectl.
Please check out the release blog post for
+1 for Ferenc as the release manager and the content.
On Mon, Oct 28, 2024 at 5:03 PM Ferenc Csaky
wrote:
> Hi,
>
> Based on this discussion I would like to suggest to move on with
> the originally planned release with the HBase connector 4.0, that
> will support 1.18, and 1.19.
>
> I volunteer
Roman Khachatryan created FLINK-36623:
-
Summary: Improve logging in DefaultStateTransitionManager
Key: FLINK-36623
URL: https://issues.apache.org/jira/browse/FLINK-36623
Project: Flink
Is
Eduardo Breijo created FLINK-36626:
--
Summary: Flink SQL JOINs behavior change from Flink 1.15 to Flink
1.18+
Key: FLINK-36626
URL: https://issues.apache.org/jira/browse/FLINK-36626
Project: Flink
zjjiang created FLINK-36620:
---
Summary: Add support for the flink-home parameter to be set in
both “--flink-home $FLINK_HOME” and “--flink-home=$FLINK_HOME” formats
Key: FLINK-36620
URL: https://issues.apache.org/jira/br
Hello devs,
I would like to initiate a discussion about the Flink TopNFunction. In our
experience, we encountered the following issue while implementing the
Top3Function.
During this process, if no input has a timestamp smaller than the RowData
currently held by the Top3Function, that operator wi
I also have some questions:
1. Whether all SQL commands such as DDL & DML & SELECT are supported.
2. How to determine JobID and return JobID & ClusterId from the application
cluster
3. How to dynamically download the JAR specified by the user when
submitting the sql script, and whether it is possi
Hi everyone,
As official docs said, `RowKind` semantics have been changed after encode:
-U -> -D, +D -> +I. In fact, we also have a demand to make it consistent in
many scenarios, such as those that require different processing of -U/-D
and +U/+I.
I have taken advantage of the difference between
Hi, Shengkai
Thanks for initializing this FLIP, supports application mode for SQL
Gateway is a great job. The FLIP design looks good to me.
I've read the FLIP-316 which mentions supporting deploying SQL job to
application clusters for interactive or non-interactive gateway mode.
But I noticed t
Weijie Guo created FLINK-36628:
--
Summary: OpenTelemetryTestBase.eventuallyConsumeJson failed on AZP
Key: FLINK-36628
URL: https://issues.apache.org/jira/browse/FLINK-36628
Project: Flink
Issue T
Hi Shengkai,
Thank you for the timely updates and replies:
1. I have been studying your POC code, introducing OperationExecutor in
SqlRunner is a great idea, which can maximize compatibility with SqlClient.
Especially some SQL statements cannot be executed directly in the Table
Environmen
Can you share more details on what do you mean by micro-batching? Can you
explain with an example to understand it better?
Thanks
Venkat
On Tue, Oct 29, 2024, 1:22 PM Anil Dasari
wrote:
> Hello team,
> I apologize for reaching out on the dev mailing list. I'm working on
> implementing micro-bat
Hi Venkat,Thanks for the reply.
Microbatching is a data processing technique where small batches of data are
collected and processed together at regular intervals.However, I'm aiming to
avoid traditional micro-batch processing by tagging records within a time
window as a batch, allowing for ne
21 matches
Mail list logo
