diff --git a/example/flink/pom.xml b/example/flink/pom.xml
index 398c789b5b79f52e792c2985e0a7bced83837f41..31220fd8114f0c31a0ea8033d4a369639e8e0af2 100644
--- a/example/flink/pom.xml
+++ b/example/flink/pom.xml
@@ -54,5 +54,30 @@
             <artifactId>flink-tsfile-connector</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-clients_${scala.library.version}</artifactId>
+            <version>${flink.version}</version>
+            <exclusions>
+                <!-- hive-serde 2.8.4 uses orc-core 1.3.2,
+                which is under incompatible license. So, exclude it.-->
+                <exclusion>
+                    <groupId>org.apache.orc</groupId>
+                    <artifactId>orc-core</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>org.apache.hive</groupId>
+                    <artifactId>hive-storage-api</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>com.google.guava</groupId>
+                    <artifactId>guava</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>org.apache.commons</groupId>
+                    <artifactId>commons-compress</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
     </dependencies>
 </project>
diff --git a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java
index 35e2143e89268a2053cf9955a1c7511bbbab4964..87b06a632b4746a2b2ab4a23f7d5c4ca7b10b626 100644
--- a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java
+++ b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java
@@ -25,6 +25,9 @@ import java.security.SecureRandom;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Random;
+import org.apache.iotdb.tsfile.file.metadata.enums.CompressionType;
+import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
+import org.apache.iotdb.tsfile.file.metadata.enums.TSEncoding;
 
 public class FlinkIoTDBSink {
     public static void main(String[] args) throws Exception {
@@ -37,19 +40,25 @@ public class FlinkIoTDBSink {
         options.setUser("root");
         options.setPassword("root");
         options.setStorageGroup("root.sg");
-        options.setTimeseriesOptionList(Lists.newArrayList(new IoTDBOptions.TimeseriesOption("root.sg.d1.s1")));
+
+        //If the server enables auto_create_schema, then we do not need to register all timeseries here.
+        options.setTimeseriesOptionList(
+            Lists.newArrayList(new IoTDBOptions.TimeseriesOption(
+                "root.sg.d1.s1", TSDataType.DOUBLE, TSEncoding.GORILLA, CompressionType.SNAPPY
+                )));
 
         IoTSerializationSchema serializationSchema = new DefaultIoTSerializationSchema();
         IoTDBSink ioTDBSink = new IoTDBSink(options, serializationSchema)
                 // enable batching
-                .withBatchSize(10);
+                .withBatchSize(10)
+                // how many connectons to the server will be created for each parallelism
+                .withSessionPoolSize(3);
 
         env.addSource(new SensorSource())
                 .name("sensor-source")
                 .setParallelism(1)
                 .addSink(ioTDBSink)
-                .name("iotdb-sink")
-                .setParallelism(1);
+                .name("iotdb-sink");
 
         env.execute("iotdb-flink-example");
     }
diff --git a/pom.xml b/pom.xml
index 1cf788da80f9ce967d3ef23606ef125829107131..11e035ed3467e6aed04e0325f9fda45bc1d1c1cc 100644
--- a/pom.xml
+++ b/pom.xml
@@ -104,6 +104,7 @@
         <maven.compiler.source>1.8</maven.compiler.source>
         <maven.compiler.target>1.8</maven.compiler.target>
         <maven.assembly.version>3.1.0</maven.assembly.version>
+        <scala.library.version>2.11</scala.library.version>
         <scala.version>2.11.12</scala.version>
         <hadoop2.version>2.7.3</hadoop2.version>
         <hive2.version>2.3.6</hive2.version>