Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2084#discussion_r176075242
--- Diff:
examples/flink/src/main/scala/org/apache/carbondata/examples/FlinkExample.scala
---
@@ -21,6 +21,7 @@ import org.apache.flink.api.java.ExecutionEnvironment
import org.apache.hadoop.conf.Configuration
import org.apache.hadoop.mapreduce.Job
+import org.apache.carbondata.examples.util.ExampleUtils
--- End diff --
why this is required?---
