Hi Adam,
Thanks for reporting this issue. The bug you identified has been fixed in
the release-1.18 and master branches, which will be released in v1.18.2 and
v1.19.0. You can now use the `emitUpdateWithRetract` method with the
expected behavior. More details can be found here[1].
[1] https://is
tly, the Datagen connector generates data that doesn't match the
> schema definition
> when dealing with fixed-length and variable-length fields. It defaults to
> a unified length of 100
> and requires manual configuration by the user. This violates the
> correctness of schema constraints
Hi Yunhui,
If you need to access the documentation offline, you can clone the Flink
project locally and build the documentation following the instructions in
the readme file. Once built, you can view it by opening localhost:1313 in
your browser. However, if you prefer a PDF version, you may find t
Hi Elakiya,
Did you encounter a ParserException when executing the DDL? AFAIK, Flink
SQL does not support declaring a nested column (compound identifier) as
primary key at syntax level.
A possible workaround is to change the schema to not contain record type,
then you can change the DDL to the fo
Hi,
>From the attachment, I saw there are IntervalJoin and GroupWindowAggregate
operators. AFAIK the state retention for such operators is not controlled
by `table.exec.state.ttl`.
Could you share the operator-level state metrics to help identify the
issue?
Best,
Jane
On Sun, Jun 25, 2023 at 10:
Congratulations!
Best regards,
Jane
On Thu, Mar 30, 2023 at 1:38 PM Jiadong Lu wrote:
> Congratulations !!!
>
> Best,
> Jiadong Lu
>
> On 2023/3/27 17:23, Yu Li wrote:
> > Dear Flinkers,
> >
> >
> >
> As you may have noticed, we are pleased to announce that Flink Table Store
> has joined the A
Please refer to https://flink.apache.org/community/ and send the email to
user-unsubscr...@flink.apache.org
Best,
Jane
On Fri, Feb 24, 2023 at 3:17 PM zhangjunjie wrote:
> 退订
>
>
>
Hi Daniel,
Thanks for reporting this issue. According to the FLIP [1], this should be
a bug, and I've created a Jira ticket [2] to track this.
> We will introduce a declarative concept to `BuiltInFunctionDefinitions`
> and `FlinkSqlOperatorTable` that maintain a function name + version to
> insta
Congrats! Thanks Jingsong for driving this release, and thanks to all
contributors!
Best,
Jane
On Mon, Aug 29, 2022 at 11:35 AM Jingsong Li wrote:
> The Apache Flink community is very happy to announce the release of
> Apache Flink Table Store 0.2.0.
>
> Apache Flink Table Store is a unified st
