apache flink org.apache.hadoop.ipc.rpcexception：RPC响应将字符串写入HDFS时超过最大数据长度
探索如何从Apache Flink中写入HDFS，我尝试了以下操作： val sink: StreamingFileSink[String] = StreamingFileSink .forRowFormat(new Path("hdfs://…
Flink Python DataStream API Kafka消费者-NoclassDeffoundError bytearrayDeserializer错误
我在pyflink的PY4J侧有一个错误。代码下面： env = StreamExecutionEnvironment.get_execution_environment() env.add_jars("file:/" + os.getcwd() +…
即使在Pojos和Avro概念上，flink默认为Kryo序列化
我正在尝试进行弗林克状态模式进化的POC。我正在使用Flink 1.15.0和Java 11。 我尝试创建3个数据类 - 每种序列化类型之一： io.peleg.kryo.user - 使…
FLINK-通过REST API提交Flink作业时如何传递自定义参数
我需要在Flink作业中提供一个解密的密码，以将其连接到Redis。但是，Redis密码只能在本地机器上解密。因此，我的计划是首先在本地解密，然后在通过RES…
使用Flink中的检查点功能，用户会调用prinitizestate和snapshotstate还是在幕后处理
我在此处按照一个示例： https://github.com/apache/flink/flink/blob/master/master/master/flink-streaming-java/src/src/main/java/java/java/org/…
Flink Elasticsearch Connector 7带SSL
在我的Flink工作中，我正在尝试使用 Elasticsearch7 连接器。当使用 elasticsearch7sinkbuilder 时，我找不到通过SSL通信的方法？ 另外，还有一个弃用…
如何将无界的水表发送到Kafka水槽？
我正在使用表API创建两个流，让我们称其为A和B。使用ExecutesQL我正在加入两个表。输出为表格。我想将连接的结果发送到Kafka水槽。请在下面找到代码。…
Flink插入MySQL最新数据行
我在MySQL中得到了一个建议表，该表中有3列：user_id，item_id，stark，Flink将计算一些建议并在用户单击项目时将结果插入mySQL，我只希望MySQL存储由…
FLINK -KAFKA连接器恰好一次错误
我正在使用Flink 1.15.0。 For Kafka integration I wrote KafkaSource: public static KafkaSource kafkaSource(String bootstrapServers, String to…
如何将包含时间段_ltz的表转换为pyflink 1.15.0中的dataStream？
我使用pyflink 1.15.0的Kinesis连接器读取事件使用源表。 An example of the sorts of data that are in this stream is 请注意，数据流包含许多不同…
无法运行Flink Jar：标识符的多个工厂;默认值＆＃x27;该实施
我正在使用以下提到的POM文件来编写Flink代码， 2025-02-10 13:45:30 3 0
如何设置Flink TaskManager总截flink内存？
我想在Kubernetes上运行很多Pyflink作业，那里处理的状态和事件数量很小，因此我想在群集中使用尽可能少的内存，以便我可以大部分包装包装。有效。我…
