は、私は、このガイド以下、FLINKストリーミング状態のバックエンドを使用しようとしているシンボルValueState

Question

を解決することはできません：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にガイドがそれを示している方法を使用することがFLINKの正しいバージョンを持っていない私はどちらかを推測しています、または私は正しいバージョンを持っているかもしれませんが、ValueStateは別のメンバ依存関係に移動されました。以下は

私の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 { 

    } 
} 

事前のおかげでたくさん！

ローレン。

Answer 1

あなたは正しいですFlinkのバージョン0.10.xはまだValueStateを持っていませんでした。少なくとも1.0.0のバージョンに切り替えると大丈夫です。