赞
踩
flink侧输出报错 The program finished with the following exception
The program finished with the following exception:
Could not determine TypeInformation for the OutputTag type. The most common reas on is forgetting to make the OutputTag an anonymous inner class. It is also not possible to use generic type variables with OutputTags, such as 'Tuple2<A, B>'.
org.apache.flink.util.OutputTag.<init>(OutputTag.java:68)
因为代码中new OutputTag(“test”)后面少写了大括号{}
private static OutputTag<String> outputTag = new OutputTag<String>("test");
对于scala是可以少些的,但是java不能少些,这个使用java编写的时候需要注意。
最后加一个大括号 “{}”
private static OutputTag<String> outputTag = new OutputTag<String>("test"){};
1.https://blog.csdn.net/YongDaiMe/article/details/108593102
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。