[issues 3232] integrate flink-json to pulsar (apache#3234)

* Implements a batch program on Pulsar topic by writing Flink DataSet as Avro.

* fix up

* remove avro generated

* fix up time-out

* fix up time-out

* fix up

* modify review content code

* modify Tests FAILURE

* run Tests

* run Tests

* fix up pulsar-flink and flink-consumer-source

* fix up pulsar-flink and flink-consumer-source

* add flink streaming table as a Pulsar stream that serializes data in Avro format.

* integrate flink-json to pulsar

pulsar-flink/pom.xml

@@ -49,6 +49,12 @@
       <optional>true</optional>
     </dependency>
 
+    <dependency>
+      <groupId>org.apache.flink</groupId>
+      <artifactId>flink-json</artifactId>
+      <version>${flink.version}</version>
+    </dependency>
+
     <dependency>
       <groupId>org.apache.flink</groupId>
       <artifactId>flink-avro</artifactId>

pulsar-flink/src/main/java/org/apache/flink/streaming/connectors/pulsar/PulsarJsonTableSink.java

@@ -20,7 +20,7 @@
 
 import org.apache.flink.api.common.serialization.SerializationSchema;
 import org.apache.flink.api.java.typeutils.RowTypeInfo;
-import org.apache.flink.streaming.connectors.pulsar.serde.JsonRowSerializationSchema;
+import org.apache.flink.formats.json.JsonRowSerializationSchema;
 import org.apache.flink.types.Row;
 import org.apache.pulsar.client.api.ProducerConfiguration;