fix: race condition when attaching futures to a terminating stream

.github/workflows/build.yml

@@ -63,6 +63,21 @@ jobs:
             || mvn --projects ingester-grpc test
             || mvn --projects ingester-grpc test)
 
+  test_ingester_bulk_protocol:
+    needs: check
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: actions/setup-java@v4
+        with:
+          java-version: '8'
+          distribution: 'zulu'
+      - name: Maven Test
+        run: mvn clean install -DskipTests=true -Dmaven.javadoc.skip=true -B -V
+          && (mvn --projects ingester-bulk-protocol test
+            || mvn --projects ingester-bulk-protocol test
+            || mvn --projects ingester-bulk-protocol test)
+
   test_ingester_protocol:
     needs: check
     runs-on: ubuntu-latest
@@ -79,7 +94,7 @@ jobs:
             || mvn --projects ingester-protocol test)
 
   integration_tests:
-    needs: [test_ingester_common, test_ingester_grpc, test_ingester_protocol]
+    needs: [test_ingester_common, test_ingester_grpc, test_ingester_bulk_protocol, test_ingester_protocol]
     runs-on: ubuntu-latest
     timeout-minutes: 10
     steps:

.github/workflows/mvn_publish.yml

@@ -17,6 +17,7 @@ name: Maven Publish
 on:
   release:
     types: [created]
+  workflow_dispatch:
 
 jobs:
   publish:
@@ -33,6 +34,24 @@ jobs:
           gpg-private-key: ${{ secrets.MAVEN_GPG_PRIVATE_KEY }} # Value of the GPG private key to import
           gpg-passphrase: MAVEN_GPG_PASSPHRASE # env variable for GPG private key passphrase
 
+      - name: Verify snapshot version
+        if: github.event_name == 'workflow_dispatch'
+        run: |
+          version="$(mvn help:evaluate -Dexpression=project.version -q -DforceStdout)"
+          if [[ "$version" != *-SNAPSHOT ]]; then
+            echo "Manual publishing requires a -SNAPSHOT version, got: $version"
+            exit 1
+          fi
+
+      - name: Verify release version
+        if: github.event_name == 'release'
+        run: |
+          version="$(mvn help:evaluate -Dexpression=project.version -q -DforceStdout)"
+          if [[ "$version" == *-SNAPSHOT ]]; then
+            echo "Release publishing requires a non-SNAPSHOT version, got: $version"
+            exit 1
+          fi
+
       - name: Build with Maven
         run: mvn clean deploy --batch-mode -DskipTests -P release -B -U -e
         env:

ingester-all/pom.xml

@@ -21,7 +21,7 @@
     <parent>
         <groupId>io.greptime</groupId>
         <artifactId>greptimedb-ingester</artifactId>
-        <version>0.15.0</version>
+        <version>0.15.1-SNAPSHOT</version>
     </parent>
 
     <artifactId>ingester-all</artifactId>

ingester-bulk-protocol/pom.xml

@@ -21,7 +21,7 @@
     <parent>
         <groupId>io.greptime</groupId>
         <artifactId>greptimedb-ingester</artifactId>
-        <version>0.15.0</version>
+        <version>0.15.1-SNAPSHOT</version>
     </parent>
 
     <artifactId>ingester-bulk-protocol</artifactId>
@@ -118,4 +118,25 @@
             <scope>test</scope>
         </dependency>
     </dependencies>
+
+    <profiles>
+        <profile>
+            <id>java9-plus</id>
+            <activation>
+                <jdk>[9,)</jdk>
+            </activation>
+            <build>
+                <plugins>
+                    <plugin>
+                        <groupId>org.apache.maven.plugins</groupId>
+                        <artifactId>maven-surefire-plugin</artifactId>
+                        <version>2.12.4</version>
+                        <configuration>
+                            <argLine>--add-opens=java.base/java.nio=ALL-UNNAMED</argLine>
+                        </configuration>
+                    </plugin>
+                </plugins>
+            </build>
+        </profile>
+    </profiles>
 </project>