I've finished the restructuring over the weekend.
@Ryan: I haven't organized FLIPs by topic, but it's possible to do that,
either via labels or by adding a sort of "Topic/Component" field to the
page properties and filtering on that.
If someone wants to do that go ahead, I don't wanna see anoth
+1 (binding)
Thanks for the clarification Martijn. I'd suggest considering adding a note
in the FLIP document (since the proposed repository name for this connector
is "flink-connector-redis") or changing the repository name to
"flink-connector-redis-streams".
Best Regards,
Yu
On Thu, 15 Sept 2
Yuxin Tan created FLINK-29329:
-
Summary: Checkpoint can not be triggered if encountering OOM
Key: FLINK-29329
URL: https://issues.apache.org/jira/browse/FLINK-29329
Project: Flink
Issue Type: Bug
Jason created FLINK-29328:
-
Summary: 【flink在使用状态过期设置时出现问题】
Key: FLINK-29328
URL: https://issues.apache.org/jira/browse/FLINK-29328
Project: Flink
Issue Type: Bug
Components: API / DataStrea
+1 to add `finish()` method to `TableFunction` only.
Can we use `endInput` just like `BoundedOneInput`?
Best,
Jingsong
On Fri, Sep 16, 2022 at 11:54 PM Lincoln Lee wrote:
>
> Hi Dawid, Piotr,
>Agree with you that add finish() method to `TableFunction` only. Other
> `UserDefinedFunction`s (`
Hi Konstantin and Martijn,
Sincere apologies for the late reply.
Being the newest data structure, Streams is still catching up with others.
But it obviously has its own unique usages which makes it the most suitable
Redis data structures for Flink especially as a *Source*.
We are always consider
