使用flink時,遇到的問題

1. 問題一: java.lang.IllegalArgumentException: Field names are not unique. 異常原因時字段名稱不唯一,指的是使用 public RowTypeInfo(TypeInformation<?>[] types, String[] fieldNames){} 這個構造函數時,fieldNames字段名稱不唯一; flink會在這裏校驗.

>>阅读原文<<