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