pp created FLINK-19028:
--
Summary: Translate the "application_parameters.zh.md" into Chinese
Key: FLINK-19028
URL: https://issues.apache.org/jira/browse/FLINK-19028
Project: Flink
Issue Type: Improvemen
Thanks for the Reply Yun,
I see that when I publish the messages to SNS from map operator, in case of
any errors I find the checkpointing mechanism takes care of "no data loss".
One scenario I could not replicate is that, the method from SDK unable to
send messages to SNS but remains silent not t
I think we have to make some compromise here. Either updating the
definition of "temporal table", or extending the definition of "temporal
join".
I'm also fine with Rui's proposal that "temporal join" can also work with a
regular table.
Best,
Jark
On Fri, 21 Aug 2020 at 23:49, Leonard Xu wrote:
Nikola created FLINK-19029:
--
Summary: Collect mulitple jobs in 1 UI
Key: FLINK-19029
URL: https://issues.apache.org/jira/browse/FLINK-19029
Project: Flink
Issue Type: New Feature
Component
Jark Wu created FLINK-19030:
---
Summary: Support lookup source for filesystem connector
Key: FLINK-19030
URL: https://issues.apache.org/jira/browse/FLINK-19030
Project: Flink
Issue Type: New Feature
Hi everyone,
I would like to start a discussion thread on "Support Pandas UDAF in
PyFlink"
Pandas UDF has been supported in FLINK 1.11 (FLIP-97[1]). It solves the
high serialization/deserialization overhead in Python UDF and makes it
convenient to leverage the popular Python libraries such as Pan
