[jira] [Created] (FLINK-10982) Test DataStream to Table for Flink 1.6.2

["YUZHOU HONG (JIRA)" <ji...@apache.org>]

YUZHOU HONG created FLINK-10982:
-----------------------------------

             Summary: Test DataStream to Table for Flink 1.6.2 
                 Key: FLINK-10982
                 URL: https://issues.apache.org/jira/browse/FLINK-10982
             Project: Flink
          Issue Type: Test
          Components: Table API & SQL
    Affects Versions: 1.6.2
         Environment: jdk1.8, flink1.6,  macOS 10.13
            Reporter: YUZHOU HONG


I am a newcomer for Flink Table API & SQL. When I reference official doc to test a demo that converts two DataStream into a Table, then union all them, the system reports an exception called "Exception in thread "main" java.lang.NoSuchFieldError: DOT".

By the way:  The part of the official doc I read is [https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/table/common.html]

 

here are my codes and exception stack trace.
{code:java}
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.TimeCharacteristic;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableEnvironment;
import org.apache.flink.table.api.java.StreamTableEnvironment;
import org.apache.flink.types.Row;

public class StreamToSql {
    public static void main(String[] args) throws Exception {
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        StreamTableEnvironment tEnv = TableEnvironment.getTableEnvironment(env);

        env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
        env.setParallelism(1);
        DataStream<Tuple2<Integer, String>> stream1 = env.fromElements(new Tuple2<>(1, "hello"));
        DataStream<Tuple2<Integer, String>> stream2 = env.fromElements(new Tuple2<>(1, "hello"));

        // stream1.print();

        Table table1 = tEnv.fromDataStream(stream1, "count, word");
        Table table2 = tEnv.fromDataStream(stream2, "count, word");
        Table table = table1
                .where("LIKE(word, 'F%')")
                .unionAll(table2);

        DataStream<Row> res = tEnv.toAppendStream(table, Row.class);
        res.print();
        env.execute("StreamToSql");
    }
}

{code}
 

 
{code:java}
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/yizhou/.m2/repository/org/slf4j/slf4j-log4j12/1.7.5/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/yizhou/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.6.2/log4j-slf4j-impl-2.6.2.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/yizhou/.m2/repository/ch/qos/logback/logback-classic/1.1.3/logback-classic-1.1.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
Exception in thread "main" java.lang.NoSuchFieldError: DOT
 at org.apache.flink.table.validate.BasicOperatorTable.<init>(FunctionCatalog.scala:316)
 at org.apache.flink.table.validate.FunctionCatalog.getSqlOperatorTable(FunctionCatalog.scala:58)
 at org.apache.flink.table.api.TableEnvironment.getSqlOperatorTable(TableEnvironment.scala:129)
 at org.apache.flink.table.api.TableEnvironment.frameworkConfig$lzycompute(TableEnvironment.scala:92)
 at org.apache.flink.table.api.TableEnvironment.frameworkConfig(TableEnvironment.scala:86)
 at org.apache.flink.table.api.TableEnvironment.relBuilder$lzycompute(TableEnvironment.scala:98)
 at org.apache.flink.table.api.TableEnvironment.relBuilder(TableEnvironment.scala:98)
 at org.apache.flink.table.api.TableEnvironment.typeFactory$lzycompute(TableEnvironment.scala:103)
 at org.apache.flink.table.api.TableEnvironment.typeFactory(TableEnvironment.scala:103)
 at org.apache.flink.table.api.TableEnvironment.scanInternal(TableEnvironment.scala:564)
 at org.apache.flink.table.api.TableEnvironment.scan(TableEnvironment.scala:519)
 at org.apache.flink.table.api.java.StreamTableEnvironment.fromDataStream(StreamTableEnvironment.scala:89)
 at realtime.stream.StreamToSql.main(StreamToSql.java:25)
Process finished with exit code 1


{code}
 

 

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)