Fix SimplePOJO content to avoid dedup

Author: mzitnik

flink-connector-clickhouse-base/src/test/java/org/apache/flink/connector/clickhouse/sink/ClickHouseSinkTests.java

@@ -229,7 +229,7 @@ void SimplePOJODataTest() throws Exception {
 
         List<SimplePOJO> simplePOJOList = new ArrayList<>();
         for (int i = 0; i < EXPECTED_ROWS; i++) {
-            simplePOJOList.add(new SimplePOJO());
+            simplePOJOList.add(new SimplePOJO(i));
         }
         // create from list
         DataStream<SimplePOJO> simplePOJOs = env.fromData(simplePOJOList.toArray(new SimplePOJO[0]));

flink-connector-clickhouse-base/src/test/java/org/apache/flink/connector/clickhouse/sink/pojo/SimplePOJO.java

@@ -20,7 +20,7 @@ public class SimplePOJO {
     private double doublePrimitive;
     private Double doubleObject;
 
-    public SimplePOJO() {
+    public SimplePOJO(int index) {
         this.bytePrimitive = Byte.MIN_VALUE;
         this.byteObject = Byte.MAX_VALUE;
 
@@ -30,7 +30,7 @@ public SimplePOJO() {
         this.intPrimitive = Integer.MIN_VALUE;
         this.integerObject = Integer.MAX_VALUE;
 
-        this.longPrimitive = Long.MIN_VALUE;
+        this.longPrimitive = index;
         this.longObject = Long.MAX_VALUE;
 
         this.floatPrimitive = Float.MIN_VALUE;