Hi all, I have been trying to work with PinotSinkF...
# general
m
Hi all, I have been trying to work with PinotSinkFunction for flink https://docs.pinot.apache.org/basics/data-import/batch-ingestion/flink#flink-application. I have not been able to add maven dependency for
org.apache.pinot.connector.flink.sink.PinotSinkFunction;
with flink 1.16 version my pom.xml has following pinot deps
Copy code
<!-- Apache Pinot dependencies -->
<dependency>
   <groupId>org.apache.flink</groupId>
   <artifactId>flink-streaming-java_${scala.version}</artifactId>
   <version>1.12.0</version>
   <scope>provided</scope>
</dependency>
<dependency>
   <groupId>org.apache.pinot</groupId>
   <artifactId>pinot-controller</artifactId>
   <version>${flink.pinot.version}</version>
</dependency>
<dependency>
   <groupId>org.apache.pinot</groupId>
   <artifactId>pinot-segment-writer-file-based</artifactId>
   <version>${flink.pinot.version}</version>
</dependency>
<dependency>
   <groupId>org.apache.pinot</groupId>
   <artifactId>pinot-segment-uploader-default</artifactId>
   <version>${flink.pinot.version}</version>
</dependency>
<dependency>
   <groupId>com.google.guava</groupId>
   <artifactId>guava</artifactId>
   <version>20.0</version>
</dependency>
<dependency>
   <groupId>org.glassfish.jersey.inject</groupId>
   <artifactId>jersey-hk2</artifactId>
   <version>2.35</version>
</dependency>
<dependency>
   <groupId>org.glassfish.jersey.media</groupId>
   <artifactId>jersey-media-json-jackson</artifactId>
   <version>2.35</version>
</dependency>
Would really appreciate your help with dependencies
I tried adding dependency as well
Copy code
<dependency>
   <groupId>org.apache.pinot</groupId>
   <artifactId>pinot-connectors</artifactId>
   <version>0.12.0</version>
   <type>pom</type>
</dependency>
but
Cc: @Phil Sheets @Eric Liu
k
You said you’re trying to work with Flink 1.16, but your pom has:
Copy code
<dependency>
   <groupId>org.apache.flink</groupId>
   <artifactId>flink-streaming-java_${scala.version}</artifactId>
   <version>1.12.0</version>
   <scope>provided</scope>
</dependency>
So why are you using Flink 1.12?