英文: Flink custom trigger not triggering onProcessingTime 问题 I have a custom trigger currently implem...
54评论apache-flink
flink-streaming
Flink自定义触发器未在处理时间上触发。
54评论apache-flink
flink-streaming
54评论apache-flink
flink-streaming
“Flink并行性与事件时间窗口”
英文: Flink Parallelism with event time window 问题 I'm reading from Kafka from a topic with partition =...
46评论apache-flink
flink-streaming
Pyflink将Varchar转换为Long吗？
英文: Pyflink->Elastic converts Varchar to Long? 问题 I started working with Pyflink last week and fo...
58评论apache-flink
elasticsearch
Flink RocksDB自定义选项工厂配置错误，禁用块缓存。
英文: Flink RocksDB custom options factory config error disable block cache 问题 I am running Flink 1.15...
67评论apache-flink
scala
使用Flink SQL客户端提交SQL查询。如何从检查点或保存点还原？
英文: Using flink sql client to submit sql query. How to I restore from checkpoint or savepoint 问题 I h...
48评论apache-flink
flink-streaming
配置未指定检查点目录 ‘state.checkpoints.dir’
英文: The configuration does not specify the checkpoint directory 'state.checkpoints.dir' 问题 在...
49评论apache-flink
flink-streaming
使用CTE在Apache Flink SQL中
英文: Using CTE in apache flink sql 问题 以下是要翻译的内容： 我正在尝试编写一个在Flink中使用CTE的SQL语句。 我有一个定义的表 CREATE TABLE t...
46评论apache-flink
flink-streaming
如何在Apache Flink中发生事件时启动计时器？
英文: How to start a timer when an event occurs in Apache Flink? 问题 我想在Flink中接收到事件时启动计时器，定期发送计时器值，并在接收...
44评论apache-flink
flink-streaming
如何在Flink中找到两个不连续事件之间的事件时间差异？
英文: How do I find the event time difference between two non consecutive events in Flink? 问题 我想要计算在Ap...
55评论apache-flink
flink-streaming
非法访问，在Debian中使用JDK 9创建StreamTableEnvironment
英文: Illegal access to create StreamTableEnvironment with JDK 9 in debian 问题 我在我的 Flink 1.11 应用程序中创建了...
117评论apache-flink
java
4