flink-sql-submit

flink-sql-submit copied to clipboard

使用大佬写的工具，将SQL任务提交到yarn上，会出现日志没有权限或日志全都打到jobmanger.err里面？

YJF1002

qzzhujixue

Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' in the classpath. Reason: No context matches.

fan-code

在同一个程序中，当我使用DDL语句注册多个Source，也同时注册了多个Sink。我使用INSERT INTO语句写入Sink，我遇到的问题是最多只能同时写5个Sink，超过5个就会丢数据，请问是哪里有限制还是我的操作有问题？

601madman

-- -- 开启 mini-batch -- SET table.exec.mini-batch.enabled=true; -- -- mini-batch的时间间隔，即作业需要额外忍受的延迟 -- SET table.exec.mini-batch.allow-latency=1s; -- -- 一个 mini-batch 中允许最多缓存的数据 -- SET table.exec.mini-batch.size=1000; -- -- 开启 local-global 优化 -- SET table.optimizer.agg-phase-strategy=TWO_PHASE; --...

allon2

1 unable to create db: rename flink-test > flink_test 2 after create db using flink_test, where and how to crate the following table? Caused by: java.sql.BatchUpdateException: Table 'flink_test.pvuv_sink' doesn't exist...

bochuxt