test(java): add Pinot connector E2E coverage

.github/actions/java-gradle/pre-merge/action.yml

@@ -143,6 +143,11 @@ runs:
           mkdir -p reports/java-tests
           cp -r foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/build/test-results reports/java-tests/flink
         fi
+        if [ -d "foreign/java/external-processors/iggy-connector-pinot/build/test-results" ]; then
+          echo "Found test reports in pinot"
+          mkdir -p reports/java-tests
+          cp -r foreign/java/external-processors/iggy-connector-pinot/build/test-results reports/java-tests/pinot
+        fi
 
     - name: Stop Iggy server
       if: always() && inputs.task == 'test'
@@ -188,4 +193,5 @@ runs:
         paths: |
           foreign/java/java-sdk/build/test-results/**/TEST-*.xml
           foreign/java/external-processors/iggy-connector-flink/iggy-connector-library/build/test-results/**/TEST-*.xml
+          foreign/java/external-processors/iggy-connector-pinot/build/test-results/**/TEST-*.xml
       if: ${{ !cancelled() && inputs.task == 'test' }}

foreign/java/external-processors/iggy-connector-pinot/build.gradle.kts

@@ -19,6 +19,7 @@
 
 plugins {
     id("iggy.java-library-conventions")
+    alias(libs.plugins.shadow)
 }
 
 dependencies {
@@ -43,20 +44,36 @@ dependencies {
     testImplementation(platform(libs.junit.bom))
     testImplementation(libs.bundles.testing)
     testImplementation(libs.pinot.spi) // Need Pinot SPI for tests
+    testImplementation(libs.testcontainers)
     testRuntimeOnly(libs.slf4j.simple)
 }
 
-// Assemble connector plugin with all dependencies for Docker deployment
-tasks.register<Copy>("assemblePlugin") {
-    from(tasks.named("jar"))
-    from(configurations.runtimeClasspath)
+tasks.shadowJar {
+    duplicatesStrategy = DuplicatesStrategy.EXCLUDE
+    relocate("io.netty", "org.apache.iggy.connector.pinot.shaded.io.netty")
+    mergeServiceFiles()
+}
+
+// Assemble connector plugin with isolated dependencies for Docker deployment
+tasks.register<Sync>("assemblePlugin") {
+    from(tasks.named("shadowJar"))
     into(layout.buildDirectory.dir("plugin"))
 }
 
 tasks.named("jar") {
     finalizedBy("assemblePlugin")
 }
 
+tasks.named<Test>("test") {
+    dependsOn("assemblePlugin")
+    inputs.dir(layout.projectDirectory.dir("deployment"))
+    inputs.property("useExternalServer", providers.environmentVariable("USE_EXTERNAL_SERVER").isPresent)
+    inputs.property("externalTcpPort", providers.environmentVariable("EXTERNAL_TCP_PORT").orElse("8090"))
+    systemProperty("iggy.pinot.image", "apachepinot/pinot:${libs.versions.pinot.get()}")
+    systemProperty("iggy.pinot.plugin.dir", layout.buildDirectory.dir("plugin").get().asFile.absolutePath)
+    systemProperty("iggy.pinot.deployment.dir", layout.projectDirectory.dir("deployment").asFile.absolutePath)
+}
+
 publishing {
     publications {
         named<MavenPublication>("maven") {