Flink SQL 使用 Datagen SequenceGenerator 出现 OutOfMemoryError: Java heap space 异常

Posted @SmartSi

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink SQL 使用 Datagen SequenceGenerator 出现 OutOfMemoryError: Java heap space 异常相关的知识,希望对你有一定的参考价值。

传送门:那些年我们踩过的 Flink 坑系列


Flink 1.13.5

1. 现象

在使用 Datagen Connector 的序列化生成器 SequenceGenerator 生成模拟数据抛出 OutOfMemoryError 异常,具体 DDL 如下所示:

CREATE TABLE session_behavior (
  session_id STRING COMMENT \'会话Id\',
  uid BIGINT COMMENT \'用户Id\'
) 

以上是关于Flink SQL 使用 Datagen SequenceGenerator 出现 OutOfMemoryError: Java heap space 异常的主要内容,如果未能解决你的问题,请参考以下文章

Flink Table API & SQL DataGen Connector

Flink 实践教程:入门:写入 Elasticsearch

使用 Keras fit_generator 和 datagen.flow 时出现内存错误

DataGen 的 JSON 值替换

flink 读取mysql并使用flink sql

soapui中文教程---DataGen TestStep