Компиляция примера Apache Flink в Eclipse

Question

Я пытаюсь запустить этот example, где некоторые DataStreams объединяются. Я использую Eclipse для этого, и я добавил зависимости Maven, как указано here. Вот мои зависимости:

<dependencies> 
    <dependency> 
     <groupId>org.apache.flink</groupId> 
     <artifactId>flink-java</artifactId> 
     <version>1.0.3</version> 
    </dependency> 
    <dependency> 
     <groupId>org.apache.flink</groupId> 
     <artifactId>flink-streaming-java_2.10</artifactId> 
     <version>1.0.3</version> 
    </dependency> 
    <dependency> 
     <groupId>org.apache.flink</groupId> 
     <artifactId>flink-clients_2.10</artifactId> 
     <version>1.0.3</version> 
    </dependency> 
    <!-- http://mvnrepository.com/artifact/org.apache.commons/commons-collections4 --> 
    <dependency> 
     <groupId>org.apache.commons</groupId> 
     <artifactId>commons-collections4</artifactId> 
     <version>4.0</version> 
    </dependency> 
</dependencies> 

Однако некоторые классы не распознаются (см. Рисунок).

Answer 1

Пример вы связываете с написана для Флинка 0.9 и вы добавляете зависимостей для Флинка 1.0. API DataStream был сильно переработан между этими версиями. Вы должны либо использовать зависимости для Flink 0.9.x, либо попробовать более свежий пример. Например, вы можете попробовать WikipediaAnalysis example from the Flink v1.0 documentation.