Skip to content

Commit

Permalink
GEOMESA-3388 Update to Accumulo 2.1.3
Browse files Browse the repository at this point in the history
  • Loading branch information
elahrvivaz committed Aug 27, 2024
1 parent a667fa3 commit e509c37
Show file tree
Hide file tree
Showing 9 changed files with 62 additions and 49 deletions.
23 changes: 11 additions & 12 deletions build/cqs.tsv
Original file line number Diff line number Diff line change
Expand Up @@ -44,16 +44,16 @@ commons-codec:commons-codec 1.16.0 compile
commons-dbcp:commons-dbcp 1.4 compile
commons-io:commons-io 2.15.1 compile
commons-jxpath:commons-jxpath 1.3 compile
commons-logging:commons-logging 1.2 compile
commons-logging:commons-logging 1.3.3 compile
commons-pool:commons-pool 1.6 compile
io.airlift:aircompressor 0.27 compile
io.dropwizard.metrics:metrics-core 3.2.6 compile
io.dropwizard.metrics:metrics-graphite 3.2.6 compile
io.dropwizard.metrics:metrics-jvm 3.2.6 compile
io.github.azagniotov:dropwizard-metrics-cloudwatch 1.0.13 compile
io.micrometer:micrometer-commons 1.11.1 compile
io.micrometer:micrometer-core 1.11.1 compile
io.micrometer:micrometer-observation 1.11.1 compile
io.micrometer:micrometer-commons 1.12.2 compile
io.micrometer:micrometer-core 1.12.2 compile
io.micrometer:micrometer-observation 1.12.2 compile
io.netty:netty-all 4.1.106.Final compile
io.netty:netty-buffer 4.1.106.Final compile
io.netty:netty-codec 4.1.106.Final compile
Expand Down Expand Up @@ -84,11 +84,10 @@ io.netty:netty-transport-rxtx 4.1.106.Final compile
io.netty:netty-transport-sctp 4.1.106.Final compile
io.netty:netty-transport-udt 4.1.106.Final compile
io.opentelemetry:opentelemetry-api 1.15.0 compile
io.opentelemetry:opentelemetry-api 1.27.0 compile
io.opentelemetry:opentelemetry-api 1.34.1 compile
io.opentelemetry:opentelemetry-context 1.15.0 compile
io.opentelemetry:opentelemetry-context 1.27.0 compile
io.opentelemetry:opentelemetry-context 1.34.1 compile
io.opentelemetry:opentelemetry-semconv 1.15.0-alpha compile
io.opentelemetry:opentelemetry-semconv 1.27.0-alpha compile
io.prometheus:simpleclient 0.16.0 compile
io.prometheus:simpleclient_common 0.16.0 compile
io.prometheus:simpleclient_dropwizard 0.16.0 compile
Expand Down Expand Up @@ -148,9 +147,9 @@ net.sf.saxon:Saxon-HE 12.4 compile
org.antlr:antlr4-runtime 4.7.2 compile
org.apache.accumulo:accumulo-access 1.0.0-beta compile
org.apache.accumulo:accumulo-core 2.0.1 compile
org.apache.accumulo:accumulo-core 2.1.2 compile
org.apache.accumulo:accumulo-core 2.1.3 compile
org.apache.accumulo:accumulo-hadoop-mapreduce 2.0.1 compile
org.apache.accumulo:accumulo-hadoop-mapreduce 2.1.2 compile
org.apache.accumulo:accumulo-hadoop-mapreduce 2.1.3 compile
org.apache.arrow:arrow-format 17.0.0 compile
org.apache.arrow:arrow-memory-core 17.0.0 compile
org.apache.arrow:arrow-memory-netty 17.0.0 compile
Expand Down Expand Up @@ -275,7 +274,7 @@ org.slf4j:slf4j-api 1.7.36 compile
org.threeten:threeten-extra 1.7.1 compile
org.xmlresolver:xmlresolver 5.2.2 compile
org.xmlresolver:xmlresolver data:5.2.2 compile
org.yaml:snakeyaml 2.0 compile
org.yaml:snakeyaml 2.2 compile
picocontainer:picocontainer 1.2 compile
redis.clients:jedis 5.1.0 compile
si.uom:si-quantity 2.1 compile
Expand All @@ -291,7 +290,7 @@ com.datastax.cassandra:cassandra-driver-mapping 3.11.5 provided
io.confluent:kafka-avro-serializer 6.2.9 provided
io.confluent:kafka-schema-registry-client 6.2.9 provided
javax.media:jai_core 1.1.3 provided
org.apache.accumulo:accumulo-start 2.1.2 provided
org.apache.accumulo:accumulo-start 2.1.3 provided
org.apache.commons:commons-text 1.10.0 provided
org.apache.hadoop:hadoop-annotations 3.4.0 provided
org.apache.hadoop:hadoop-aws 3.4.0 provided
Expand Down Expand Up @@ -325,7 +324,7 @@ com.sun.xml.bind:jaxb-impl 2.2.3 test
com.uber:h3 4.1.1 test
commons-lang:commons-lang 2.6 test
junit:junit 4.13.2 test
org.apache.accumulo:accumulo-test 2.1.2 test
org.apache.accumulo:accumulo-test 2.1.3 test
org.apache.arrow:arrow-vector tests:17.0.0 test
org.apache.cassandra:cassandra-all 3.11.14 test
org.apache.cassandra:cassandra-thrift 3.11.14 test
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ case object AccumuloContainer extends StrictLogging {

val ImageName =
DockerImageName.parse("ghcr.io/geomesa/accumulo-uno")
.withTag(sys.props.getOrElse("accumulo.docker.tag", "2.1.2"))
.withTag(sys.props.getOrElse("accumulo.docker.tag", "2.1.3"))

val Namespace = "gm"

Expand Down
9 changes: 9 additions & 0 deletions geomesa-accumulo/geomesa-accumulo-dist/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -100,6 +100,15 @@
<groupId>org.json4s</groupId>
<artifactId>json4s-native_${scala.binary.version}</artifactId>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-handler</artifactId>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-transport-native-epoll</artifactId>
<classifier>linux-x86_64</classifier>
</dependency>
</dependencies>

<profiles>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,10 +46,9 @@ function get_accumulo_classpath() {
if [[ -d "$ACCUMULO_LIB" ]]; then
accumulo_cp="$accumulo_cp:$(find_jars "$ACCUMULO_LIB" true)"
fi
# for zookeeper only include the single root jar
if [[ -d "${ZOOKEEPER_HOME}" ]]; then
ZOOKEEPER_JAR="$(find -L "$ZOOKEEPER_HOME" -maxdepth 1 -type f -name "*zookeeper*jar" | head -n 1)"
accumulo_cp="$accumulo_cp:${ZOOKEEPER_JAR}"
ZK_JARS="$(find -L "$ZOOKEEPER_HOME" -maxdepth 2 -name 'zookeeper*.jar' | paste -sd: -)"
accumulo_cp="$accumulo_cp:${ZK_JARS}"
fi
# if there's a geomesa runtime jar in accumulo, exclude it from the classpath
echo "$accumulo_cp" | sed -E 's/[^:]*geomesa-accumulo-distributed-runtime[^:]*jar//'
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,37 +39,42 @@ function dependencies() {
"org.apache.accumulo:accumulo-start:${accumulo_version}:jar"
"org.apache.accumulo:accumulo-hadoop-mapreduce:${accumulo_version}:jar"
"org.apache.zookeeper:zookeeper:${zk_version}:jar"
"org.apache.commons:commons-configuration2:2.8.0:jar"
"org.apache.commons:commons-text:1.10.0:jar"
"org.apache.commons:commons-configuration2:2.10.1:jar"
"org.apache.commons:commons-text:1.11.0:jar"
"org.apache.commons:commons-collections4:4.4:jar"
"org.apache.commons:commons-vfs2:2.9.0:jar"
"commons-collections:commons-collections:3.2.2:jar"
"commons-logging:commons-logging:1.2:jar"
"commons-logging:commons-logging:1.3.3:jar"
"org.apache.hadoop:hadoop-auth:${hadoop_version}:jar"
"org.apache.hadoop:hadoop-common:${hadoop_version}:jar"
"org.apache.hadoop:hadoop-hdfs:${hadoop_version}:jar"
"org.apache.htrace:htrace-core:3.1.0-incubating:jar"
"org.apache.htrace:htrace-core4:4.1.0-incubating:jar"
"com.fasterxml.woodstox:woodstox-core:5.3.0:jar"
"org.codehaus.woodstox:stax2-api:4.2.1:jar"
"com.google.guava:guava:${guava_install_version}:jar"
"io.netty:netty-codec:%%netty.version%%:jar"
"io.netty:netty-handler:%%netty.version%%:jar"
"io.netty:netty-resolver:%%netty.version%%:jar"
"io.netty:netty-transport:%%netty.version%%:jar"
"io.netty:netty-transport-classes-epoll:%%netty.version%%:jar"
"io.netty:netty-transport-native-epoll:%%netty.version%%:jar:linux-x86_64"
"io.netty:netty-transport-native-unix-common:%%netty.version%%:jar"
)

# add accumulo 2.1 jars if needed
if version_ge "${accumulo_version}" 2.1.0; then
local micrometer_version
local opentelemetry_version

if version_ge "${accumulo_version}" 2.1.3; then
micrometer_version="1.12.2"
opentelemetry_version="1.34.1"
else
# these versions seem compatible even though they're not the exact versions shipped
micrometer_version="1.11.1"
opentelemetry_version="1.27.0"
gavs+=(
"io.opentelemetry:opentelemetry-semconv:${opentelemetry_version}-alpha:jar"
)
fi

gavs+=(
"org.apache.thrift:libthrift:%%thrift.version%%:jar"
"io.opentelemetry:opentelemetry-api:1.19.0:jar"
"io.opentelemetry:opentelemetry-context:1.19.0:jar"
"io.opentelemetry:opentelemetry-semconv:1.19.0-alpha:jar"
"io.micrometer:micrometer-core:1.9.6:jar"
"io.micrometer:micrometer-core:${micrometer_version}:jar"
"io.micrometer:micrometer-commons:${micrometer_version}:jar"
"io.opentelemetry:opentelemetry-api:${opentelemetry_version}:jar"
"io.opentelemetry:opentelemetry-context:${opentelemetry_version}:jar"
)
else
gavs+=(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ object HadoopSharedCluster extends StrictLogging {

val ImageName =
DockerImageName.parse("ghcr.io/geomesa/accumulo-uno")
.withTag(sys.props.getOrElse("accumulo.docker.tag", "2.1.2"))
.withTag(sys.props.getOrElse("accumulo.docker.tag", "2.1.3"))

lazy val Container: HadoopContainer = tryContainer.get

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ class ZookeeperOffsetManagerTest extends Specification with BeforeAfterAll with
override def beforeAll(): Unit = {
val image =
DockerImageName.parse("zookeeper")
.withTag(sys.props.getOrElse("zookeeper.docker.tag", "3.6.4"))
.withTag(sys.props.getOrElse("zookeeper.docker.tag", "3.9.2"))
container = new GenericContainer(image)
container.addExposedPort(2181)
container.start()
Expand Down
13 changes: 4 additions & 9 deletions geomesa-tools/conf-filtered/geomesa-env.sh
Original file line number Diff line number Diff line change
Expand Up @@ -167,18 +167,14 @@ function get_classpath_version() {
# find_jars [path] [bool: do not descend into sub directories]
function find_jars() {
local home="$1"
local jars=()
local jars=""
if [[ -d "${home}" ]]; then
local find_args
find_args=("-type" "f" "-iname" "*.jar" "-not" "-iname" "*-sources.jar" "-not" "-iname" "*-tests.jar" "-print0")
find_args=("-type" "f" "-iname" "*.jar" "-not" "-iname" "*-sources.jar" "-not" "-iname" "*-tests.jar")
if [[ "$2" == "true" ]]; then
find_args=("-maxdepth" "1" "${find_args[@]}")
fi
# read results of find into jars array
# don't use mapfile to support bash < 4.4 (RHEL 7)
while IFS= read -r -d $'\0'; do
jars+=("$REPLY")
done < <(find "-L" "$home" "${find_args[@]}")
jars="$(find "-L" "$home" "${find_args[@]}" | paste -sd: -)"
if [[ -d "${home}/native" ]]; then
# TODO this doesn't export back to the parent shell... fix it
if [[ -z "${JAVA_LIBRARY_PATH}" ]]; then
Expand All @@ -188,8 +184,7 @@ function find_jars() {
fi
fi
fi
ret=$(IFS=: ; echo "${jars[*]}")
echo "$ret"
echo "$jars"
}

# args: destination for missing jars, current classpath, gavs, '--no-prompt'
Expand Down
16 changes: 11 additions & 5 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -79,6 +79,7 @@
<commons.dbcp.version>2.11.0</commons.dbcp.version>
<commons.io.version>2.15.1</commons.io.version>
<commons.lang3.version>3.14.0</commons.lang3.version>
<commons.logging.version>1.3.3</commons.logging.version>
<commons.pool2.version>2.12.0</commons.pool2.version>
<commons.text.version>1.11.0</commons.text.version>
<cqengine.version>3.6.0</cqengine.version>
Expand Down Expand Up @@ -126,7 +127,7 @@
<hadoop.minicluster.mockito.version>2.28.2</hadoop.minicluster.mockito.version>

<!-- provided artifacts, not bundled to support multiple environments -->
<accumulo.version>2.1.2</accumulo.version>
<accumulo.version>2.1.3</accumulo.version>
<accumulo-20.version>2.0.1</accumulo-20.version>
<zookeeper.version>3.9.2</zookeeper.version>
<thrift.version>0.17.0</thrift.version>
Expand Down Expand Up @@ -199,12 +200,12 @@
<maven.test.jvmargs>${maven.test.memory} ${maven.test.opens}</maven.test.jvmargs>
<test.fork.count>2</test.fork.count>
<test.enable.assertions>false</test.enable.assertions> <!-- arrow tests become extremely slow with assertions enabled-->
<test.accumulo.docker.tag>2.1.2</test.accumulo.docker.tag>
<test.accumulo.docker.tag>2.1.3</test.accumulo.docker.tag>
<test.redis.docker.tag>7-alpine</test.redis.docker.tag>
<test.postgres.docker.tag>15.1</test.postgres.docker.tag>
<test.postgis.docker.tag>15-3.4</test.postgis.docker.tag>
<test.confluent.docker.tag>7.6.0</test.confluent.docker.tag> <!-- confluent 7.6.x corresponds to kafka 3.6.x -->
<test.zookeeper.docker.tag>3.6.4</test.zookeeper.docker.tag>
<test.zookeeper.docker.tag>3.9.2</test.zookeeper.docker.tag>

<!-- documentation -->
<!-- bump version right before performing releases for the README and the documentation -->
Expand All @@ -213,13 +214,13 @@
<copyright.year>2024</copyright.year>

<!-- recommended installation versions -->
<accumulo.version.recommended>2.1.2</accumulo.version.recommended>
<accumulo.version.recommended>2.1.3</accumulo.version.recommended>
<hbase.version.recommended>2.5.7</hbase.version.recommended>
<hbase.thirdparty.version.recommended>4.1.5</hbase.thirdparty.version.recommended>
<cassandra.server.version.recommended>3.11.14</cassandra.server.version.recommended>
<cassandra.driver.version.recommended>3.11.3</cassandra.driver.version.recommended>
<hadoop.version.recommended>3.4.0</hadoop.version.recommended>
<zookeeper.version.recommended>3.9.1</zookeeper.version.recommended>
<zookeeper.version.recommended>3.9.2</zookeeper.version.recommended>
<confluent.version.recommended>7.6.0</confluent.version.recommended>
</properties>

Expand Down Expand Up @@ -1606,6 +1607,11 @@
<artifactId>commons-lang3</artifactId>
<version>${commons.lang3.version}</version>
</dependency>
<dependency>
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
<version>${commons.logging.version}</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-text</artifactId>
Expand Down

0 comments on commit e509c37

Please sign in to comment.