Thanks Santwana and Martijn for the testing!
> I've closed my blocker ticket; after force killing all my Flink Java
processes, it did work when I restarted it.
That would be great!
Best regards,
Weijie
Martijn Visser 于2024年7月9日周二 03:04写道：
> Hi all,
>
> I've closed my blocker ticket; after f
xuyang created FLINK-35792:
--
Summary: Sorting by proctime does not work in rank
Key: FLINK-35792
URL: https://issues.apache.org/jira/browse/FLINK-35792
Project: Flink
Issue Type: Bug
Compo
I think there are three questions to be anwsered, and here are my two cents.
1) How do we define the compatibility guarantees for cli interfaces?
I'd be +1 for reusing the existing @Public and @PublicEvolving annotations,
as suggested by Ferenc. Having multiple sets of rules in the same project
m
LvYanquan created FLINK-35791:
-
Summary: Add database and table infos to Kafka json output.
Key: FLINK-35791
URL: https://issues.apache.org/jira/browse/FLINK-35791
Project: Flink
Issue Type: Impr
Sergio Peña created FLINK-35790:
---
Summary: Update docs for new schema definition in CTAS and RTAS
Key: FLINK-35790
URL: https://issues.apache.org/jira/browse/FLINK-35790
Project: Flink
Issue Ty
Sergio Peña created FLINK-35789:
---
Summary: Allow WATERMARK & PRIMARY KEY in CREATE TABLE AS (CTAS)
Key: FLINK-35789
URL: https://issues.apache.org/jira/browse/FLINK-35789
Project: Flink
Issue T
Hi David,
Any updates on the Kafka Message Header support? I am also interested in
supporting headers with the Flink SQL Formats:
https://lists.apache.org/thread/spl88o63sjm2dv4l5no0ym632d2yt2o6
On Fri, Jun 14, 2024 at 6:10 AM David Radley
wrote:
> Hi everyone,
> I have talked with Chesnay and
Thank you all!
The voting is closed now.
I've posted results [1].
[1] https://lists.apache.org/thread/mx3qd5qgyjtqk66p6sv639g777lm0jc6
Thanks,
Alexey
On Wed, Jul 3, 2024 at 6:39 PM Yuepeng Pan wrote:
> +1 (non-binding)
>
> Best regards,
>
> Yuepeng Pan
>
>
>
>
>
> At 2024-07-03 01:46:13, "Serg
Hello everyone,
The vote [1] for FLIP-456 [2] is over. The number of required binding votes
(3) was reached (total: 5, binding: 3, non-binding: 2). No objections were
raised.
Binding:
- Martijn Visser
- Sergey Nuyanzin
- Timo Walther
Non-binding:
- Jim Hughes
- Yuepeng Pan
PRs
Hi all,
I've closed my blocker ticket; after force killing all my Flink Java
processes, it did work when I restarted it.
Thanks, Martijn
On Mon, Jul 8, 2024 at 6:13 PM Santwana Verma
wrote:
> Hi everyone,
>
> Thanks for creating the release candidate. I've successfully validated the
> release
Hi everyone,
Thanks for creating the release candidate. I've successfully validated the
release candidate locally with the DataStream API.
1. I created a DataStream API based job, which read and deserialized JSON
strings from an input Kafka topic using flink-connector-kafka, transformed
the data,
João Boto created FLINK-35788:
-
Summary: Deprecate old InputFormat and SinkFunction
Key: FLINK-35788
URL: https://issues.apache.org/jira/browse/FLINK-35788
Project: Flink
Issue Type: Sub-task
Hi Fabian,
Awesome, this project looks great! Thanks for sharing. It would work well
with KafkaSource and the DataStream API as you've mentioned. We have
something similar internally, but where we are encountering difficulty is
integrating it with the Flink SQL Kafka DynamicTable Source and Sinks.
Roman Khachatryan created FLINK-35787:
-
Summary: DefaultSlotStatusSyncer might bring down JVM (exit code
239 instead of a proper shutdown)
Key: FLINK-35787
URL: https://issues.apache.org/jira/browse/FLINK-3578
Hi Kevin,
I worked on a project [1] in the past that had a similar purpose. You
should be able to use a similar approach with the existing KafkaSource by
implementing your own KafkaRecordDeserializationSchema that hides the logic
of pulling the records from blob storage from the connector. You can
Roman Khachatryan created FLINK-35786:
-
Summary: NPE in BlobServer / shutdownHook
Key: FLINK-35786
URL: https://issues.apache.org/jira/browse/FLINK-35786
Project: Flink
Issue Type: Bug
Hi all,
Thanks for the responses.
Grace those are indeed both challenges, thanks for flagging them. Regarding
expiry, we could consider having a Mark and Sweep garbage collection
system. A service can consume the topics with large messages, and track
references. When there are no references left
Hi all,
I've found that no query works in the SQL Client for RC0. See
https://issues.apache.org/jira/browse/FLINK-35785
Best regards,
Martijn
On Fri, Jun 28, 2024 at 6:09 PM weijie guo
wrote:
> Hi everyone,
>
>
> The release candidate #0(i.e. RC0) for Apache Flink 1.20.0 has been
> created.
>
Martijn Visser created FLINK-35785:
--
Summary: Executing query in SQL client results in
"java.lang.ClassNotFoundException: org.apache.flink.core.execution.RestoreMode"
Key: FLINK-35785
URL: https://issues.apache.o
Zakelly Lan created FLINK-35784:
---
Summary: The cp file-merging directory not properly registered in
SharedStateRegistry
Key: FLINK-35784
URL: https://issues.apache.org/jira/browse/FLINK-35784
Project: F
layhuts created FLINK-35783:
---
Summary: Flink CDC Could not start the yaml Job
Key: FLINK-35783
URL: https://issues.apache.org/jira/browse/FLINK-35783
Project: Flink
Issue Type: Bug
Compon
Yi Cai created FLINK-35782:
--
Summary: Flink connector jdbc works wrong when using sql gateway
Key: FLINK-35782
URL: https://issues.apache.org/jira/browse/FLINK-35782
Project: Flink
Issue Type: Bug
Hey Ferenc,
Yes correct. My thoughts were based on finding tradeoff between
following fully deprecation process and leaner one for CLIs.
Since cli are not like APIs, I think users would be aware of
deprecation only when were remove the commands. That is they
try to run their jobs with upgrade an
Hi Kevin,
I just want to double check, were you planning to send this proposal to the
Kafka Dev mailing list? Because I don't see directly how this affects Flink
:)
Best regards,
Martijn
On Mon, Jul 8, 2024 at 8:05 AM Grace Grimwood wrote:
> Hi Kevin,
>
> Thanks for starting this thread.
>
>
24 matches
Mail list logo
