flink-streaming 相关问题

Apache Flink是一个用于可扩展批处理和流数据处理的开源平台。 Flink在一个系统中支持批量和流分析。分析程序可以用Java和Scala中简洁优雅的API编写。

我们目前在kubernetes上以job cluster的形式运行flink，使用的是这个 helm模板：https:/github.comdocker-flinkexamplestreemasterhelmflink（添加了一些配置）。如果我想...

apache-flink flink-streaming

回答 1 投票 0

需要一个用于FLINK 1.3.3的Prometheus库。

我们正计划使用Prometheus来进行度量监控，目前我们的大部分应用都在FLINK 1.3.3中运行，有什么Prometheus度量的jar吗？我检查了maven...没有看到任何东西...。

apache-flink prometheus flink-streaming

回答 1 投票 0

使用Rocksdb到期后，Flink ValueState将从存储中删除吗？

我正在将Flink版本1.10.1与rocksdb后端一起使用。我知道rocksdb使用“托管内存”中的内存，并且没有为托管内存设置任何特定值。它是由Flink完成的。当我...

apache-flink flink-streaming rocksdb

回答 1 投票 0

Flink SQL：UDTF传递行类型参数

CREATE TABLE user_log（data ROW（id String，user_id String，class_id String））WITH（'connector.type'='kafka'，...）;插入到接收器SELECT * FROM user_log作为选项卡，LATERAL TABLE（...

apache-flink flink-streaming flink-sql

回答 1 投票 0

NIFI在给定条件的帮助下从API提取数据

我试图从NIFI内的其余API提取数据，但有以下几种情况。 1）我有Rest API，它使用给定的参数示例填充从Cassandra数据库获取的数据...

apache-flink apache-nifi flink-streaming apache-nifi-registry

回答 1 投票 0

如何向Apache Flink表添加新行

是否可以向flink表添加新记录/行？例如，我具有以下表配置：ExecutionEnvironment env = TableEnvironmentLoader.getExecutionEnvironment（）; ...

java apache-flink flink-streaming flink-sql flink-batch

回答 1 投票 0

与S3接收器一起流式传输时精确到Flink

我是Flink的新手，我正在尝试编写一次具有精确语义的简单流作业，该作业从Kafka侦听并将数据写入S3。当我说“精确一次”时，我的意思是我不想...

amazon-s3 apache-flink flink-streaming

回答 1 投票 1

Flink动态更新流作业

我正在收到有关不同主题的一系列Avro格式的事件。我想使用这些并以拼花形式写入s3。我写了下面的工作，为每个事件创建一个不同的流...

java apache-flink flink-streaming

回答 1 投票 0

会话窗口链接

有人可以帮助我了解flink中的窗口（会话）何时以及如何发生？或如何处理样品？例如，如果有连续的事件流入，则事件...

apache-flink flink-streaming

回答 2 投票 0

在源头的flink中对整个dataStream进行分区，并保持分区直到接收器

我正在使用队列（Apache Pulsar）中的跟踪日志。我使用了5个keyedPrcoessFunction，最后将有效负载下沉到Postgres Db。我需要为每个keyedProcessFunction订购每个customerId。 ...

apache-flink flink-streaming flink-cep flink-sql flink-batch

回答 1 投票 0

FlinkSQL：如何在SQL中过滤出错误格式的JSON？

[CREATE TABLE user_log（a STRING，b STRING）WITH（'connector.type'='kafka'，'connector.version'='universal'，'connector.topic'='test'，'connector.properties.0 .key'='...

apache-flink flink-streaming flink-sql

回答 2 投票 0

可能的快照机制在Apache Flink中花费越来越多的内存

我正在学习快照机制在Flink中的工作方式。据我了解，JobManager将以固定的间隔将障碍插入每个数据源中，并且每个操作员都会在创建快照后对其进行快照...

apache-flink flink-streaming snapshot fault-tolerance

回答 1 投票 0

如何在Apache Flink中拆分NodeObject的数据

我正在使用Flink处理来自某些数据源（例如Kafka，Pravega等）的数据。就我而言，数据源是Pravega，它为我提供了flink连接器。我的数据源正在发送...

json apache-flink flink-streaming

回答 1 投票 0

Apache Flink：无法从ObjectNode :: get]中提取密钥>

我正在使用Flink处理来自某些数据源（例如Kafka，Pravega等）的数据。就我而言，数据源是Pravega，它为我提供了flink连接器。我的数据源正在发送...