Merge pull request #19 from knaufk/flink114

Flink114

README.md

@@ -28,8 +28,9 @@ mvn clean package
 
 1. [Setup Ververica Platform](https://docs.ververica.com/getting_started/installation.html).
 2. Get the link to the flink-faker JAR from the [Releases](https://github.com/knaufk/flink-faker/releases).
-3. Start Ververica Platorm > SQL > Connectors > Create Connector, provide the external URL from step 2 and finish the setup.  
-   ![Howto add flink-faker to Ververica Platform](add-faker-connector.gif)
+3. Start Ververica Platorm > SQL > Connectors > Create Connector, provide the external URL from step 2 and finish the setup.
+
+![Howto add flink-faker to Ververica Platform](add-faker-connector.gif)
 
 ## Usage
 

pom.xml

@@ -12,7 +12,7 @@
 
   <properties>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-    <flink.version>1.13.0</flink.version>
+    <flink.version>1.14.0</flink.version>
     <java.version>1.8</java.version>
     <scala.binary.version>2.12</scala.binary.version>
     <maven.compiler.source>${java.version}</maven.compiler.source>
@@ -35,7 +35,7 @@
   </dependency>
   <dependency>
     <groupId>org.apache.flink</groupId>
-    <artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
+    <artifactId>flink-table-planner_${scala.binary.version}</artifactId>
     <version>${flink.version}</version>
     <scope>test</scope>
   </dependency>

src/main/java/com/github/knaufk/flink/faker/FlinkFakerTableSourceFactory.java

@@ -68,8 +68,6 @@ public class FlinkFakerTableSourceFactory implements DynamicTableSourceFactory {
   @Override
   public FlinkFakerTableSource createDynamicTableSource(final Context context) {
 
-    Faker faker = new Faker();
-
     CatalogTable catalogTable = context.getCatalogTable();
 
     Configuration options = new Configuration();