zhaoxuezhi

Results 2 issues of zhaoxuezhi

您好: 感谢您的开源代码,但是我用的过程中,如果下一首,上一首点的快,就会发现日志控制台经常会报一个错误,然后崩溃了: Terminating app due to uncaught exception 'NSInternalInconsistencyException', reason: 'An instance 0x2ada1a0 of class DOUAudioStreamer was deallocated while key value observers were still registered with it. Current observation info:...

StarRocksSinkOptions.builder() .withProperty("jdbc-url", "jdbc:mysql://192.168.0.126:9030/starrocks_demo") .withProperty("load-url", "192.168.0.126:8030") .withProperty("username", "root") .withProperty("password", "") .withProperty("table-name", "detail") .withProperty("database-name", "test") .withProperty("sink.properties.format", "json") .withProperty("sink.properties.strip_outer_array", "true") // 设置并行度,多并行度情况下需要考虑如何保证数据有序性 .withProperty("sink.parallelism", "1") .build()); flink sink 到starrocks,必须设置table-name属性吗?如果必须设置,意味着每一个starrocks的table,对应flink就要有一个sink,因此也必须对应一个独立的job,那如果我要同步20个msyql表到starrocks,就要建20个job,这很占资源,也不合理啊,有什么思路解决这个问题啊?