问题一:Flink如下报错怎么办? Flink-1.15.2 Standalone oracle-connector-2.3 8核 32G 16 Slots state.backend=rocksdb checkpointDir=file:///... savepointDir=file:///... Environment In Streaming Mode SQL 定义Source和Sink 同时采集16张静态表(无新增数据),全量阶段同步正常,资源充足;然而全量阶段结束后TaskManager内存占用比率依然不停增加,直到内存因此而爆满。 是我哪里设置不对吗?请教各位大佬
Flink如下报错怎么办? Flink-1.15.2 Standalone oracle-connector-2.3 8核 32G 16 Slots state.backend=rocksdb checkpointDir=file:///... savepointDir=file:///... Environment In Streaming Mode SQL 定义Source和Sink 同时采集16张静态表(无新增数据),全量阶段同步正常,资源充足;然而全量阶段结束后TaskManager内存占用比率依然不停增加,直到内存因此而爆满。 是我哪里设置不对吗?请教各位大佬
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/476311?spm=a2c6h.14164896.0.0.33d863bf6fCfyS
问题二:flinksql 写mysql 然后mysql超过八小时超时导致任务报错了。请教大家一下flinksql 有相关的配置吗?
flinksql 写mysql 然后mysql超过八小时超时导致任务报错了。请教大家一下flinksql 有相关的配置吗?
参考回答:
mysql连接配置 autoReconnect=true
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/483325?spm=a2c6h.14164896.0.0.33d863bf6fCfyS
问题三:flinksql写入starrocks,结果starrocks看不到数据,为什么?
flinksql写入starrocks,结果starrocks看不到数据,executesql也不报错 看不到报错信息,为什么?
参考回答:
如果开启了checkpoint,等checkpoint 完成一次呢
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/485030?spm=a2c6h.14164896.0.0.33d863bf6fCfyS
问题四:我flinksql 连接oracle时间长 Closed Connection报错这个怎么设置?
请问大神我flinksql 连接oracle时间长 Closed Connection报错这个怎么设置
参考回答:
可以调整以下参数来解决这个问题:
- 在Oracle端,将SQLNET.EXPIRE_TIME参数值调整为较大的值,比如60分钟,以确保连接不会超时关闭。
- 在阿里云实时计算Flink端,可以设置以下参数:
a. 设置连接池大小,增加连接的可用性,可以通过以下配置设置:
table.exec.connection-pool.size=10
- b. 调整连接空闲超时时间,以保证连接不会被关闭:
table.exec.connection-timeout=5min
- c. 启用TCP keepalive来检测连接是否已关闭:
table.exec.resource.tcp.keepalive=true
- d. 调整Oracle JDBC驱动程序连接参数以启用JDBC批处理,以减少网络延迟:
table.exec.source.driver-class-name=oracle.jdbc.driver.OracleDriver table.exec.source.driver-properties.enableBatch=true
根据以上方法进行调整,应该可以解决连接关闭的问题。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/454470?spm=a2c6h.14164896.0.0.33d863bf6fCfyS
问题五:flinksql使用内置函数 ,报no match found for function signature xxx ,这种要怎么排错呢?
flinksql使用内置函数 ,报no match found for function signature xxx ,这种要怎么排错呢?
参考回答:
官网上用了下划线分割代捷
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/481661?spm=a2c6h.14164896.0.0.352363bfzkoccH