tyler fan created FLINK-15218:
---------------------------------
Summary: java.lang.NoClassDefFoundError: org/apache/flink/table/sources/TableSource
Key: FLINK-15218
URL:
https://issues.apache.org/jira/browse/FLINK-15218 Project: Flink
Issue Type: Bug
Environment: IDEA 2019.2
jdk 1.8
no local flink envirment
Reporter: tyler fan
trying application develop in IDE,
making a simple app like read csv file and register like a table,
------------------------------------
final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
BatchTableEnvironment tableEnv = BatchTableEnvironment.create(env);
String[] colname = new String[] \{"CountryName","CountryCode","IndicatorName","IndicatorCode","1960"};
TypeInformation<?>[] coltype = new TypeInformation<?>[] \{Types.STRING,Types.STRING,Types.STRING,Types.STRING,Types.STRING};
TableSource dds = new CsvTableSource("/home/tylerf/sampledata/gpd.csv",colname,coltype);
tableEnv.registerTableSource("gpd", dds);
Table tab = tableEnv.scan("gpd");
-------------------------------------
In IDEA
got the error like this when i running the sample.
------------------------------------
java.lang.NoClassDefFoundError: org/apache/flink/table/sources/TableSource
------------------------------------
pom is configed the dependence by the document 1.9
-------------------------------------
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>${flink.version}</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-table-api-java-bridge_2.11</artifactId>
<version>1.9.0</version>
<scope>provided</scope>
</dependency>
---------------------------------------------------------
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
Locked
