读取两个没有关联关系的文件，使用Flink不知道怎么表达

HI, 先读取文件A，每读取一行数据后, 拿这条数据去另外一个文件B中查找与之匹配的行（有匹配规则），请问这种场景使用Flink 怎么表达？ -- Sent from: http://apache-flink.147419.n8.nabble.com/

flink sql 写hive并行度设置问题

Hi， 请问： env.setParallelism(8); source = select * from table1, Table filterTable = source.filter(x-> x>10).limit(1); try (CloseableIterator rows = filterTable.execute().collect()) { while (rows.hasNext()) { Row r = rows.next(); String a = r.getField(1).toString();

flink sql 并行度问题

Hi, 请问： env.setParallelism(8); source = select * from table1, Table filterTable = source.filter(x-> x>10); try (CloseableIterator rows = filterTable.execute().collect()) { while (rows.hasNext()) { Row r = rows.next(); String a = r.getField(1).toString();