Hi,
退订请发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org
.
Best,
yunfeng
On Thu, May 9, 2024 at 5:58 PM xpfei0811 wrote:
>
> 退订
>
> 回复的原邮件
> | 发件人 | wangfengyang |
> | 发送日期 | 2024年04月23日 18:10 |
> | 收件人 | user-zh |
> | 主题 | 退订 |
> 退订
流模式和批模式在watermark和一些算子语义等方面上有一些不同，但没看到Join和Window算子上有什么差异，这方面应该在batch
mode下应该是支持的。具体的两种模式的比较可以看一下这个文档
https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/datastream/execution_mode/
On Thu, Apr 18, 2024 at 9:44 AM casel.chen wrote:
>
> 有人尝试这么实践过么？可以给一些建议么？谢谢！
>
>
>
>
>
>
>
>
>
>
>
>
应该是由于这些复杂集合在HBase中没有一个直接与之对应的数据类型，所以Flink SQL没有直接支持的。
一种思路是把这些数据类型按照某种格式（比如json）转换成字符串/序列化成byte array，把字符串存到HBase中，读取出来的时候也再解析/反序列化。
On Mon, Apr 1, 2024 at 7:38 PM 王广邦 wrote:
>
> HBase SQL 连接器（flink-connector-hbase_2.11） 为啥不支持数据类型：ARRAY、MAP / MULTISET、ROW
> 不支持？
>
Hi,
请发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org 来取消订阅邮件。
Best
Yunfeng Zhou
On Mon, Nov 6, 2023 at 5:30 PM maozhaolin wrote:
>
> 退订
Hi,
请发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org 来取消订阅邮件。
Best,
Yunfeng
On Wed, Oct 4, 2023 at 10:07 AM 1 wrote:
>
>
Hi,
请发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org 地址来取消订阅来自
user-zh@flink.apache.org 邮件组的邮件，你可以参考[1][2]
管理你的邮件订阅。
Please send email to user-zh-unsubscr...@flink.apache.org if you want to
unsubscribe the mail from user-zh@flink.apache.org ,
and you can refer [1][2] for more details.
Best,
你好。
如果只是需要从各个subtask中收集一些信息，在JobManager中汇总的话，我觉得可以用累加器和计数器[1]。
如果需要双向通信的话，可以考虑一下FLIP-27[2]引入的OperatorCoordinator。如何通过通信来传递对象可以通过自定义算子或函数来实现。
在自定义算子中使用OperatorCoordinator可能还有一些不方便的地方，可以追踪一下相关ticket的进展[3]。
[1]
