some test · leonardBang/flink-sql-etl

some test

Leonard Xu committed on Mar 27, 2020, 02:37 AM

Showing 10 changed files +84 additions -11 deletions

M data-generator/src/main/java/kafka/AvroSchemaRegistryTest.java +3 -1

M data-generator/src/main/java/kafka/CsvsDataSender.java +11 -1

M etl-job/pom.xml +11 -6

A etl-job/src/main/java/Test.java +13

M etl-job/src/main/java/kafka2es/Kafka2AppendEs.java +1 -1

M etl-job/src/main/java/kafka2file/StreamETLKafka2HdfsSQL.java +5 -1

A etl-job/src/main/resources/job-sql/kafka2file/Csv2HivePartition.sql +10

A etl-job/src/main/resources/job-sql/kafka2file/Csv2HiveSink.sql +14

A etl-job/src/main/resources/job-sql/kafka2file/Kafka2HiveSink.sql +15

M pom.xml +1 -1