请问这个可以用于flink1.8吗?
Closed this issue · 4 comments
ShydowLi commented
你好,请问这个可以用于flink1.8不?
aleksanchezz commented
Good day, @ShydowLi !
We haven't tested it with flink1.8, but, we use minimum of flink code - only SinkFunction
interface and we build thin-jar (no dependencies)
You can try add it into dependencies, exclude flink-1.9 and add your version - it should implement yours
Something like that:
<project>
<artifactId>your-project</artifactId>
<dependencies>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_${your.scala.version}</artifactId>
<version>${your.flink.version}</version>
</dependency>
<dependency>
<groupId>ru.ivi.opensource</groupId>
<artifactId>flink-clickhouse-sink</artifactId>
<version>1.1.0</version>
<exclusions>
<exclusion>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.11</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
<project>
ShydowLi commented
@aleksanchezz thank you,I will try it
ShydowLi commented
非常感谢,按照你的方法是能运行的
mchernyakov commented
@ShydowLi thanks for the feedback. Closing the issue.