commit | 1e0bdebc1dbcad27ab84a11574a03611c1d8560b | [log] [tgz] |
---|---|---|
author | wpl <1269223860@qq.com> | Wed Dec 19 19:19:47 2018 +0800 |
committer | Sijie Guo <guosijie@gmail.com> | Wed Dec 19 19:19:47 2018 +0800 |
tree | db2ba243f275ddf2a01be40788c9c3503e3c7db4 | |
parent | 6afa34d17098ca1a0101a5fd68cb968b81ed56ae [diff] |
fix up pulsar-flink and flink-consumer-source (#3212) ### Motivation fix up flink-consumer-source example run error ### Modifications modify pom.xml, sl4j and log4j2 ### Result 1. log conflict, sl4j and log4j2 2. flink-consumer-source example use pulsar-flink model class and api, cann't execution 3. pulsar-flink not use jar but flink-consumer-source use, like flink-scala