diff --git a/.github/workflows/maven-ci-cd.yaml b/.github/workflows/maven-ci-cd.yaml
index e7f1f85aa..dcf001394 100644
--- a/.github/workflows/maven-ci-cd.yaml
+++ b/.github/workflows/maven-ci-cd.yaml
@@ -109,11 +109,16 @@ jobs:
if: ${{ steps.cache-maven.outputs.cache-hit != 'true' }}
run: |
MAVEN_VERSION=3.9.10
- wget https://downloads.apache.org/maven/maven-3/$MAVEN_VERSION/binaries/apache-maven-$MAVEN_VERSION-bin.tar.gz
- tar xzvf apache-maven-$MAVEN_VERSION-bin.tar.gz
- sudo mv apache-maven-$MAVEN_VERSION /opt/maven
+ if [ ! -d "/opt/maven/apache-maven-$MAVEN_VERSION" ]; then
+ wget https://downloads.apache.org/maven/maven-3/$MAVEN_VERSION/binaries/apache-maven-$MAVEN_VERSION-bin.tar.gz
+ tar xzvf apache-maven-$MAVEN_VERSION-bin.tar.gz
+ sudo mkdir -p /opt/maven
+ sudo mv apache-maven-$MAVEN_VERSION /opt/maven/
+ rm apache-maven-$MAVEN_VERSION-bin.tar.gz
+ fi
sudo rm -f /usr/bin/mvn
- sudo ln -s /opt/maven/bin/mvn /usr/bin/mvn
+ sudo ln -sf /opt/maven/apache-maven-$MAVEN_VERSION/bin/mvn /usr/bin/mvn
+
#--- Step ------------------------------------------------------------------
diff --git a/committer/apachekafka/pom.xml b/committer/apachekafka/pom.xml
index 00be1ce32..51464de81 100644
--- a/committer/apachekafka/pom.xml
+++ b/committer/apachekafka/pom.xml
@@ -1,5 +1,5 @@
-
- info.picocli
- picocli
+ com.norconex.crawler
+ nx-grid-jdbc
+ runtime
- -->
-
+
@@ -135,14 +104,6 @@
test-jar
test
-
org.junit.jupiter
@@ -231,10 +192,10 @@
- org.sonatype.plugins
- nexus-staging-maven-plugin
+ org.sonatype.central
+ central-publishing-maven-plugin
-
+
diff --git a/crawler/core/src/main/java/com/norconex/crawler/core/metrics/CrawlerMetricsImpl.java b/crawler/core/src/main/java/com/norconex/crawler/core/metrics/CrawlerMetricsImpl.java
index ca13617b2..e2e98c01e 100644
--- a/crawler/core/src/main/java/com/norconex/crawler/core/metrics/CrawlerMetricsImpl.java
+++ b/crawler/core/src/main/java/com/norconex/crawler/core/metrics/CrawlerMetricsImpl.java
@@ -144,6 +144,14 @@ public void close() {
flushBatch();
if (scheduler != null) {
scheduler.shutdown();
+ try {
+ if (!scheduler.awaitTermination(5, TimeUnit.SECONDS)) {
+ scheduler.shutdownNow();
+ }
+ } catch (InterruptedException e) {
+ scheduler.shutdownNow();
+ Thread.currentThread().interrupt();
+ }
}
}
diff --git a/crawler/core/src/main/java/com/norconex/crawler/core/session/CrawlSessionManager.java b/crawler/core/src/main/java/com/norconex/crawler/core/session/CrawlSessionManager.java
index f00ccc271..97a362cf0 100644
--- a/crawler/core/src/main/java/com/norconex/crawler/core/session/CrawlSessionManager.java
+++ b/crawler/core/src/main/java/com/norconex/crawler/core/session/CrawlSessionManager.java
@@ -78,8 +78,8 @@ public void withCrawlContext(Consumer consumer) {
consumer.accept(ctx);
} finally {
// Ensure cleanup happens even if an exception occurs
- CrawlContextDestroyer.destroy(ctx);
swallow(heartbeatScheduler::shutdown);
+ CrawlContextDestroyer.destroy(ctx);
}
}
diff --git a/crawler/fs/pom.xml b/crawler/fs/pom.xml
index d2c454a7f..3a5a73532 100644
--- a/crawler/fs/pom.xml
+++ b/crawler/fs/pom.xml
@@ -1,5 +1,5 @@
sonatype-oss-snapshots
Sonatype OSS Snapshot Repository
https://oss.sonatype.org/content/repositories/snapshots
-
true
@@ -226,6 +229,11 @@
nx-grid-local
${project.version}
+
+ com.norconex.crawler
+ nx-grid-jdbc
+ ${project.version}
+
@@ -879,22 +887,6 @@
-
-
-
-
-
-
org.projectlombok
lombok-maven-plugin
@@ -1228,19 +1212,6 @@
-
-
Norconex Inc.
https://norconex.com