не может разрешить символ ValueState

Question

Я пытаюсь использовать FLiNK потокового состояния бэкенд после этого руководства: https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/state.html, но я получаю ошибку: не может решить Символ «ValueState».

Посмотрев немного, я понимаю, что ValueState не в моих зависимостях. Вместо этого только OperatorState находится в org.apache.flink.api.common.state (flink-core).

Однако, если посмотреть на Github, я вижу ValueState в этом пакете: https://github.com/apache/flink/tree/master/flink-core/src/main/java/org/apache/flink/api/common/state

Я предполагаю, что я либо не имеют правильную версию Флинка, чтобы использовать StateBackend путь гид показывает его, или, может быть, у меня есть правильная версия, но ValueState перенесена в другую зависимость от maven.

Ниже мой pom.xml:

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 
<modelVersion>4.0.0</modelVersion> 

<groupId>test</groupId> 
<artifactId>flink-streaming</artifactId> 
<version>1.0-SNAPSHOT</version> 
<packaging>jar</packaging> 

<name>flink-streaming</name> 
<url>http://maven.apache.org</url> 

<properties> 
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 
    <!--<flink.version>0.10.2</flink.version>--> 
    <flink.version>0.10.2</flink.version> 
    <scala.version>2.11.8</scala.version> 
    <scala.dependency.version>2.11</scala.dependency.version> 
</properties> 


<dependencies> 
    <dependency> 
     <groupId>org.scala-lang</groupId> 
     <artifactId>scala-library</artifactId> 
     <version>${scala.version}</version> 
    </dependency> 
    <dependency> 
     <groupId>org.apache.flink</groupId> 
     <artifactId>flink-scala_${scala.dependency.version}</artifactId> 
     <version>${flink.version}</version> 
    </dependency> 
    <dependency> 
     <groupId>org.apache.flink</groupId> 
     <artifactId>flink-clients_${scala.dependency.version}</artifactId> 
     <version>${flink.version}</version> 
    </dependency> 
    <dependency> 
     <groupId>org.apache.flink</groupId> 
     <artifactId>flink-streaming-scala_${scala.dependency.version}</artifactId> 
     <version>${flink.version}</version> 
    </dependency> 
</dependencies> 

<build> 
    <plugins> 
     <plugin> 
      <artifactId>maven-compiler-plugin</artifactId> 
      <version>2.3.2</version> 
      <configuration> 
       <source>1.7</source> 
       <target>1.7</target> 
      </configuration> 
     </plugin> 

     <plugin> 
      <groupId>org.scala-tools</groupId> 
      <artifactId>maven-scala-plugin</artifactId> 
      <executions> 
       <execution> 
        <goals> 
         <goal>compile</goal> 
         <goal>testCompile</goal> 
        </goals> 
       </execution> 
      </executions> 
      <configuration> 
       <jvmArgs> 
        <jvmArg>-Xms64m</jvmArg> 
        <jvmArg>-Xmx1024m</jvmArg> 
       </jvmArgs> 
      </configuration> 
     </plugin> 

    </plugins> 
</build> 

И вот мой код:

import org.apache.flink.api.common.functions.RichFlatMapFunction; 
import org.apache.flink.api.java.tuple.Tuple2; 
import org.apache.flink.util.Collector; 


public class CountWindowAverage extends RichFlatMapFunction<Tuple2<Long,Long>, Tuple2<Long,Long>> { 
    private transient ValueState<Tuple2<Long,Long>> sum; 

    @Override 
    public void flatMap(Tuple2<Long,Long> input, Collector<Tuple2<Long,Long>> out) throws Exception { 

    } 
} 

Большое спасибо заранее за вашу помощь!

Laurent.

Answer 1

Вы правы Версия Флинка 0.10.x еще не указана ValueState. Если вы переключитесь, по крайней мере, на версию 1.0.0, вам все будет в порядке.