release: prepare for 3.1.4

Cassandra 3.0 version of the JMX added a parameter that allows accepting
the parameter as hex.

This breaks the current implementation with a NoSuchMethodException.

This patch adds the missing implementation.

For a full support, a follow up patch in Scylla is needed, but for the
current functionality it would work.

After this patch usage example:

nodetool getsstables keyspace1 standard1 39303138374b4d343830

Fixes #78

Signed-off-by: Amnon Heiman <amnon@scylladb.com>
(cherry picked from commit ff0723abc6)

.github/CODEOWNERS

@@ -1 +0,0 @@
-* @penberg

.gitignore

@@ -1,9 +0,0 @@
-/target/
-/bin/
-dependency-reduced-pom.xml
-scylla-apiclient/target/
-.classpath
-.project
-.settings
-build/
-/.idea/

README.md

@@ -7,7 +7,7 @@ Scylla JMX server implements the Apache Cassandra JMX interface for compatibilit
 To compile JMX server, run:
 
 ```console
-$ mvn --file scylla-jmx-parent/pom.xml package
+$ mvn package
 ```
 
 ## Running

SCYLLA-VERSION-GEN

@@ -1,47 +1,19 @@
 #!/bin/sh
 
 PRODUCT=scylla
-VERSION=666.development
+VERSION=3.1.4
 
 if test -f version
 then
 	SCYLLA_VERSION=$(cat version | awk -F'-' '{print $1}')
 	SCYLLA_RELEASE=$(cat version | awk -F'-' '{print $2}')
 else
-	DATE=$(date --utc +%Y%m%d)
+	DATE=$(date +%Y%m%d)
 	GIT_COMMIT=$(git log --pretty=format:'%h' -n 1)
 	SCYLLA_VERSION=$VERSION
 	SCYLLA_RELEASE=$DATE.$GIT_COMMIT
 fi
 
-usage() {
-    echo "usage: $0"
-    echo "           [--version product-version-release]          # override p-v-r"
-    exit 1
-}
-
-OVERRIDE=
-while [[ $# > 0 ]]; do
-    case "$1" in
-	--version)
-	    OVERRIDE="$2"
-	    shift 2
-	    ;;
-	*)
-	    usage
-	    ;;
-    esac
-done
-
-if [[ -n "$OVERRIDE" ]]; then
-    # regular expression for p-v-r: alphabetic+dashes for product, trailing non-dashes
-    # for release, everything else for version
-    RE='^([-a-z]+)-(.+)-([^-]+)$'
-    PRODUCT="$(sed -E "s/$RE/\\1/" <<<"$OVERRIDE")"
-    SCYLLA_VERSION="$(sed -E "s/$RE/\\2/" <<<"$OVERRIDE")"
-    SCYLLA_RELEASE="$(sed -E "s/$RE/\\3/" <<<"$OVERRIDE")"
-fi
-
 echo "$SCYLLA_VERSION-$SCYLLA_RELEASE"
 mkdir -p build
 echo "$SCYLLA_VERSION" > build/SCYLLA-VERSION-FILE

dist/common/sysconfig/scylla-jmx

@@ -20,13 +20,10 @@ SCYLLA_CONF=/etc/scylla
 #SCYLLA_JMX_FILE="-cf /etc/scylla.d/scylla-user.cfg"
 
 # The location of the jmx proxy jar file
-SCYLLA_JMX_LOCAL="-l /opt/scylladb/jmx"
+SCYLLA_JMX_LOCAL="-l /usr/lib/scylla/jmx"
 
 # allow to run remotely
 #SCYLLA_JMX_REMOTE="-r"
 
 # allow debug
 #SCYLLA_JMX_DEBUG="-d"
-
-# specify JVM options
-JAVA_TOOL_OPTIONS=""

dist/common/systemd/scylla-jmx.service

@@ -1,18 +0,0 @@
-[Unit]
-Description=Scylla JMX
-Requires=scylla-server.service
-After=scylla-server.service
-
-[Service]
-Type=simple
-EnvironmentFile=/etc/sysconfig/scylla-jmx
-User=scylla
-Group=scylla
-ExecStart=/opt/scylladb/jmx/scylla-jmx $SCYLLA_JMX_PORT $SCYLLA_API_PORT $SCYLLA_API_ADDR $SCYLLA_JMX_ADDR $SCYLLA_JMX_FILE $SCYLLA_JMX_LOCAL $SCYLLA_JMX_REMOTE $SCYLLA_JMX_DEBUG
-KillMode=process
-Restart=on-abnormal
-Slice=scylla-helper.slice
-WorkingDirectory=/var/lib/scylla
-
-[Install]
-WantedBy=multi-user.target

dist/common/systemd/scylla-jmx.service.mustache

@@ -0,0 +1,21 @@
+[Unit]
+Description=Scylla JMX
+Requires=scylla-server.service
+After=scylla-server.service
+
+[Service]
+Type=simple
+{{#debian}}
+EnvironmentFile=/etc/default/scylla-jmx
+{{/debian}}
+{{#redhat}}
+EnvironmentFile=/etc/sysconfig/scylla-jmx
+{{/redhat}}
+User=scylla
+Group=scylla
+ExecStart=/usr/lib/scylla/jmx/scylla-jmx $SCYLLA_JMX_PORT $SCYLLA_API_PORT $SCYLLA_API_ADDR $SCYLLA_JMX_ADDR $SCYLLA_JMX_FILE $SCYLLA_JMX_LOCAL $SCYLLA_JMX_REMOTE $SCYLLA_JMX_DEBUG
+KillMode=process
+Restart=on-abnormal
+
+[Install]
+WantedBy=multi-user.target

dist/debian/build_deb.sh

@@ -0,0 +1,126 @@
+#!/bin/bash -e
+
+PRODUCT=$(cat SCYLLA-PRODUCT-FILE)
+
+. /etc/os-release
+print_usage() {
+    echo "build_deb.sh --reloc-pkg build/scylla-jmx-package.tar.gz"
+    echo "  --reloc-pkg specify relocatable package path"
+    exit 1
+}
+TARGET=stable
+RELOC_PKG=
+while [ $# -gt 0 ]; do
+    case "$1" in
+        "--reloc-pkg")
+            RELOC_PKG=$2
+            shift 2
+            ;;
+        *)
+            print_usage
+            ;;
+    esac
+done
+
+is_redhat_variant() {
+    [ -f /etc/redhat-release ]
+}
+is_debian_variant() {
+    [ -f /etc/debian_version ]
+}
+pkg_install() {
+    if is_redhat_variant; then
+        sudo yum install -y $1
+    elif is_debian_variant; then
+        sudo apt-get install -y $1
+    else
+        echo "Requires to install following command: $1"
+        exit 1
+    fi
+}
+
+if [ ! -e SCYLLA-RELOCATABLE-FILE ]; then
+    echo "do not directly execute build_rpm.sh, use reloc/build_rpm.sh instead."
+    exit 1
+fi
+
+if [ "$(arch)" != "x86_64" ]; then
+    echo "Unsupported architecture: $(arch)"
+    exit 1
+fi
+
+if [ -z "$RELOC_PKG" ]; then
+    print_usage
+    exit 1
+fi
+if [ ! -f "$RELOC_PKG" ]; then
+    echo "$RELOC_PKG is not found."
+    exit 1
+fi
+
+if [ -e debian ] || [ -e build/release ]; then
+    sudo rm -rf debian build
+    mkdir build
+fi
+if is_debian_variant; then
+    sudo apt-get -y update
+fi
+# this hack is needed since some environment installs 'git-core' package, it's
+# subset of the git command and doesn't works for our git-archive-all script.
+if is_redhat_variant && [ ! -f /usr/libexec/git-core/git-submodule ]; then
+    sudo yum install -y git
+fi
+if [ ! -f /usr/bin/git ]; then
+    pkg_install git
+fi
+if [ ! -f /usr/bin/python ]; then
+    pkg_install python
+fi
+if [ ! -f /usr/sbin/debuild ]; then
+    pkg_install devscripts
+fi
+if [ ! -f /usr/bin/dh_testdir ]; then
+    pkg_install debhelper
+fi
+if [ ! -f /usr/bin/fakeroot ]; then
+    pkg_install fakeroot
+fi
+if [ ! -f /usr/bin/pystache ]; then
+    if is_redhat_variant; then
+        sudo yum install -y /usr/bin/pystache
+    elif is_debian_variant; then
+        sudo apt-get install -y python-pystache
+    fi
+fi
+
+if [ "$ID" = "ubuntu" ] && [ ! -f /usr/share/keyrings/debian-archive-keyring.gpg ]; then
+    sudo apt-get install -y debian-archive-keyring
+fi
+if [ "$ID" = "debian" ] && [ ! -f /usr/share/keyrings/ubuntu-archive-keyring.gpg ]; then
+    sudo apt-get install -y ubuntu-archive-keyring
+fi
+
+RELOC_PKG_FULLPATH=$(readlink -f $RELOC_PKG)
+RELOC_PKG_BASENAME=$(basename $RELOC_PKG)
+SCYLLA_VERSION=$(cat SCYLLA-VERSION-FILE | sed 's/\.rc/~rc/')
+SCYLLA_RELEASE=$(cat SCYLLA-RELEASE-FILE)
+
+ln -fv $RELOC_PKG_FULLPATH ../$PRODUCT-jmx_$SCYLLA_VERSION-$SCYLLA_RELEASE.orig.tar.gz
+
+cp -al dist/debian/debian debian
+if [ "$PRODUCT" != "scylla" ]; then
+    for i in debian/scylla-*;do
+        mv $i ${i/scylla-/$PRODUCT-}
+    done
+fi
+
+REVISION="1"
+MUSTACHE_DIST="\"debian\": true, \"$TARGET\": true, \"product\": \"$PRODUCT\", \"$PRODUCT\": true"
+pystache dist/debian/changelog.mustache "{ $MUSTACHE_DIST, \"version\": \"$SCYLLA_VERSION\", \"release\": \"$SCYLLA_RELEASE\", \"revision\": \"$REVISION\", \"codename\": \"$TARGET\" }" > debian/changelog
+pystache dist/debian/rules.mustache "{ $MUSTACHE_DIST }" > debian/rules
+chmod a+rx debian/rules
+pystache dist/debian/control.mustache "{ $MUSTACHE_DIST }" > debian/control
+
+pystache dist/common/systemd/scylla-jmx.service.mustache "{ $MUSTACHE_DIST }" > debian/scylla-jmx.service
+
+debuild -rfakeroot -us -uc

dist/debian/changelog.mustache

@@ -1,4 +1,4 @@
-%{product}-jmx (%{version}-%{release}-%{revision}) %{codename}; urgency=medium
+{{product}}-jmx ({{version}}-{{release}}-{{revision}}) {{codename}}; urgency=medium
 
   * Initial release.
 

dist/debian/control.mustache

@@ -1,14 +1,13 @@
-Source: %{product}-jmx
+Source: {{product}}-jmx
 Maintainer: Takuya ASADA <syuu@scylladb.com>
 Homepage: http://scylladb.com
 Section: database
 Priority: optional
 Standards-Version: 3.9.5
-Rules-Requires-Root: no
 
-Package: %{product}-jmx
+Package: {{product}}-jmx
 Architecture: all
-Depends: ${shlibs:Depends}, ${misc:Depends}, openjdk-8-jre-headless | openjdk-8-jre | oracle-java8-set-default | adoptopenjdk-8-hotspot-jre | openjdk-11-jre-headless | openjdk-11-jre |oracle-java11-set-default , %{product}-server
+Depends: ${shlibs:Depends}, ${misc:Depends}, openjdk-8-jre-headless | openjdk-8-jre | oracle-java8-set-default, {{product}}-server
 Description: Scylla JMX server binaries 
  Scylla is a highly scalable, eventually consistent, distributed,
  partitioned row DB.

dist/debian/debian/rules

@@ -1,23 +0,0 @@
-#!/usr/bin/make -f
-
-include /usr/share/dpkg/pkg-info.mk
-
-override_dh_auto_build:
-
-override_dh_auto_clean:
-
-override_dh_auto_install:
-	dh_auto_install
-	cd scylla-jmx; ./install.sh --packaging --root "$(CURDIR)/debian/tmp" --sysconfdir /etc/default
-
-override_dh_installinit:
-ifeq ($(DEB_SOURCE),scylla-jmx)
-	dh_installinit --no-start
-else
-	dh_installinit --no-start --name scylla-jmx
-endif
-
-override_dh_strip_nondeterminism:
-
-%:
-	dh $@

dist/debian/debian/scylla-jmx.install

@@ -1,4 +0,0 @@
-etc/default/scylla-jmx
-etc/systemd/system/scylla-jmx.service.d/sysconfdir.conf
-opt/scylladb/jmx/*
-usr/lib/scylla/jmx/*

dist/debian/debian/scylla-jmx.postinst

@@ -1,7 +0,0 @@
-#!/bin/sh
-
-if [ -d /run/systemd/system ]; then
-    systemctl --system daemon-reload >/dev/null || true
-fi
-
-#DEBHELPER#

dist/debian/debian/scylla-jmx.postrm

@@ -1,7 +0,0 @@
-#!/bin/sh
-
-if [ -d /run/systemd/system ]; then
-    systemctl --system daemon-reload >/dev/null || true
-fi
-
- #DEBHELPER#

dist/debian/debian/scylla-jmx.service

@@ -1 +0,0 @@
-../../common/systemd/scylla-jmx.service

dist/debian/debian/scylla-jmx.upstart

@@ -0,0 +1,21 @@
+# scylla-jmx - ScyllaDB
+#
+# ScyllaDB
+
+description	"ScyllaDB jmx"
+
+start on started scylla-server
+stop on stopping scylla-server
+
+umask 022
+
+console log
+
+setuid scylla
+setgid scylla
+
+script
+    . /etc/default/scylla-jmx
+    export SCYLLA_HOME SCYLLA_CONF
+    exec /usr/lib/scylla/jmx/scylla-jmx -l /usr/lib/scylla/jmx
+end script

dist/debian/debian_files_gen.py

@@ -1,80 +0,0 @@
-#!/usr/bin/env python3
-# -*- coding: utf-8 -*-
-#
-# Copyright (C) 2020 ScyllaDB
-#
-
-#
-# This file is part of Scylla.
-#
-# Scylla is free software: you can redistribute it and/or modify
-# it under the terms of the GNU Affero General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-#
-# Scylla is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-#
-# You should have received a copy of the GNU General Public License
-# along with Scylla.  If not, see <http://www.gnu.org/licenses/>.
-#
-
-import string
-import os
-import shutil
-import re
-from pathlib import Path
-
-class DebianFilesTemplate(string.Template):
-    delimiter = '%'
-
-scriptdir = os.path.dirname(__file__)
-
-with open(os.path.join(scriptdir, 'changelog.template')) as f:
-    changelog_template = f.read()
-
-with open(os.path.join(scriptdir, 'control.template')) as f:
-    control_template = f.read()
-
-with open('build/SCYLLA-PRODUCT-FILE') as f:
-    product = f.read().strip()
-
-with open('build/SCYLLA-VERSION-FILE') as f:
-    version = f.read().strip().replace('.rc', '~rc').replace('_', '-')
-
-with open('build/SCYLLA-RELEASE-FILE') as f:
-    release = f.read().strip()
-
-if os.path.exists('build/debian/debian'):
-    shutil.rmtree('build/debian/debian')
-shutil.copytree('dist/debian/debian', 'build/debian/debian')
-
-if product != 'scylla':
-    for p in Path('build/debian/debian').glob('scylla-*'):
-        # pat1: scylla-server.service
-        #    -> scylla-enterprise-server.scylla-server.service
-        # pat2: scylla-server.scylla-fstrim.service
-        #    -> scylla-enterprise-server.scylla-fstrim.service
-        # pat3: scylla-conf.install
-        #    -> scylla-enterprise-conf.install
-
-        if m := re.match(r'^scylla(-[^.]+)\.service$', p.name):
-            p.rename(p.parent / f'{product}{m.group(1)}.{p.name}')
-        elif m := re.match(r'^scylla(-[^.]+\.scylla-[^.]+\.[^.]+)$', p.name):
-            p.rename(p.parent / f'{product}{m.group(1)}')
-        else:
-            p.rename(p.parent / p.name.replace('scylla', product, 1))
-
-s = DebianFilesTemplate(changelog_template)
-changelog_applied = s.substitute(product=product, version=version, release=release, revision='1', codename='stable')
-
-s = DebianFilesTemplate(control_template)
-control_applied = s.substitute(product=product)
-
-with open('build/debian/debian/changelog', 'w') as f:
-    f.write(changelog_applied)
-
-with open('build/debian/debian/control', 'w') as f:
-    f.write(control_applied)

dist/debian/rules.mustache

@@ -0,0 +1,37 @@
+#!/usr/bin/make -f
+
+DOC = $(CURDIR)/debian/{{product}}-jmx/usr/share/doc/{{product}}-jmx
+DEST = $(CURDIR)/debian/{{product}}-jmx/usr/lib/scylla/jmx
+M2_REPO= $(CURDIR)/m2
+
+override_dh_auto_build:
+
+override_dh_auto_clean:
+
+override_dh_auto_install:
+	mkdir -p $(CURDIR)/debian/{{product}}-jmx/etc/default/ && \
+	cp $(CURDIR)/dist/common/sysconfig/scylla-jmx  \
+		$(CURDIR)/debian/{{product}}-jmx/etc/default/
+
+	mkdir -p $(DOC) && \
+	cp $(CURDIR)/*.md $(DOC)
+	cp $(CURDIR)/NOTICE $(DOC)
+
+	mkdir -p $(DEST)
+	cp $(CURDIR)/scylla-jmx $(DEST)
+	cp $(CURDIR)/scylla-jmx-1.0.jar $(DEST)
+	mkdir $(DEST)/symlinks
+	ln -sf /usr/bin/java $(DEST)/symlinks/scylla-jmx
+
+override_dh_installinit:
+{{#scylla}}
+	dh_installinit --no-start
+{{/scylla}}
+{{^scylla}}
+	dh_installinit --no-start --name scylla-jmx
+{{/scylla}}
+
+override_dh_strip_nondeterminism:
+
+%:
+	dh $@

dist/redhat/build_rpm.sh

@@ -0,0 +1,75 @@
+#!/bin/bash -e
+
+PRODUCT=$(cat SCYLLA-PRODUCT-FILE)
+
+. /etc/os-release
+print_usage() {
+    echo "build_rpm.sh --reloc-pkg build/scylla-jmx-package.tar.gz"
+    echo "  --reloc-pkg specify relocatable package path"
+    exit 1
+}
+RELOC_PKG=
+while [ $# -gt 0 ]; do
+    case "$1" in
+        "--reloc-pkg")
+            RELOC_PKG=$2
+            shift 2
+            ;;
+        *)
+            print_usage
+            ;;
+    esac
+done
+
+is_redhat_variant() {
+    [ -f /etc/redhat-release ]
+}
+pkg_install() {
+    if is_redhat_variant; then
+        sudo yum install -y $1
+    else
+        echo "Requires to install following command: $1"
+        exit 1
+    fi
+}
+
+if [ ! -e SCYLLA-RELOCATABLE-FILE ]; then
+    echo "do not directly execute build_rpm.sh, use reloc/build_rpm.sh instead."
+    exit 1
+fi
+
+if [ -z "$RELOC_PKG" ]; then
+    print_usage
+    exit 1
+fi
+if [ ! -f "$RELOC_PKG" ]; then
+    echo "$RELOC_PKG is not found."
+    exit 1
+fi
+
+if [ ! -f /usr/bin/rpmbuild ]; then
+    pkg_install rpm-build
+fi
+if [ ! -f /usr/bin/git ]; then
+    pkg_install git
+fi
+if [ ! -f /usr/bin/pystache ]; then
+    if is_redhat_variant; then
+        sudo yum install -y python2-pystache || sudo yum install -y pystache
+    elif is_debian_variant; then
+        sudo apt-get install -y python-pystache
+    fi
+fi
+
+SCYLLA_VERSION=$(cat SCYLLA-VERSION-FILE)
+SCYLLA_RELEASE=$(cat SCYLLA-RELEASE-FILE)
+VERSION=$SCYLLA_VERSION-$SCYLLA_RELEASE
+
+RPMBUILD=$(readlink -f ../)
+mkdir -p $RPMBUILD/{BUILD,BUILDROOT,RPMS,SOURCES,SPECS,SRPMS}
+
+ln -fv $RELOC_PKG $RPMBUILD/SOURCES/
+pystache dist/redhat/scylla-jmx.spec.mustache "{ \"version\": \"$SCYLLA_VERSION\", \"release\": \"$SCYLLA_RELEASE\", \"product\": \"$PRODUCT\", \"$PRODUCT\": true }" > $RPMBUILD/SPECS/scylla-jmx.spec
+
+# this rpm can be install on both fedora / centos7, so drop distribution name from the file name
+rpmbuild -ba --define "_topdir $RPMBUILD" --undefine "dist" $RPM_JOBS_OPTS $RPMBUILD/SPECS/scylla-jmx.spec

dist/redhat/scylla-jmx.spec

@@ -1,75 +0,0 @@
-Name:           %{product}-jmx
-Version:        %{version}
-Release:        %{release}%{?dist}
-Summary:        Scylla JMX
-Group:          Applications/Databases
-
-License:        AGPLv3
-URL:            http://www.scylladb.com/
-Source0:        %{reloc_pkg}
-
-BuildArch:      noarch
-BuildRequires:  systemd-units
-Requires:       %{product}-server jre-1.8.0-headless
-AutoReqProv:    no
-
-%description
-
-
-%prep
-%setup -q -n scylla-jmx
-
-
-%build
-
-%install
-./install.sh --packaging --root "$RPM_BUILD_ROOT"
-
-%pre
-/usr/sbin/groupadd scylla 2> /dev/null || :
-/usr/sbin/useradd -g scylla -s /sbin/nologin -r -d ${_sharedstatedir}/scylla scylla 2> /dev/null || :
-ping -c1 `hostname` > /dev/null 2>&1
-if [ $? -ne 0 ]; then
-echo
-echo "**************************************************************"
-echo "* WARNING: You need to add hostname on /etc/hosts, otherwise *"
-echo "*          scylla-jmx will not able to start up.             *"
-echo "**************************************************************"
-echo
-fi
-
-%post
-if [ $1 -eq 1 ] ; then
-    /usr/bin/systemctl preset scylla-jmx.service ||:
-fi
-
-/usr/bin/systemctl daemon-reload ||:
-
-%preun
-if [ $1 -eq 0 ] ; then
-    /usr/bin/systemctl --no-reload disable scylla-jmx.service ||:
-    /usr/bin/systemctl stop scylla-jmx.service ||:
-fi
-
-%postun
-/usr/bin/systemctl daemon-reload ||:
-
-%clean
-rm -rf $RPM_BUILD_ROOT
-
-
-%files
-%defattr(-,root,root)
-
-%config(noreplace) %{_sysconfdir}/sysconfig/scylla-jmx
-%{_unitdir}/scylla-jmx.service
-/opt/scylladb/jmx/scylla-jmx
-/opt/scylladb/jmx/scylla-jmx-1.1.jar
-/opt/scylladb/jmx/symlinks/scylla-jmx
-%{_prefix}/lib/scylla/jmx/scylla-jmx
-%{_prefix}/lib/scylla/jmx/scylla-jmx-1.1.jar
-%{_prefix}/lib/scylla/jmx/symlinks/scylla-jmx
-
-%changelog
-* Fri Aug  7 2015 Takuya ASADA Takuya ASADA <syuu@cloudius-systems.com>
-- inital version of scylla-tools.spec

dist/redhat/scylla-jmx.spec.mustache

@@ -0,0 +1,80 @@
+Name:           {{product}}-jmx
+Version:        {{version}}
+Release:        {{release}}%{?dist}
+Summary:        Scylla JMX
+Group:          Applications/Databases
+
+License:        AGPLv3
+URL:            http://www.scylladb.com/
+Source0:        scylla-jmx-package.tar.gz
+
+BuildArch:      noarch
+BuildRequires:  systemd-units
+BuildRequires: pystache
+%{?rhel:BuildRequires: python-setuptools}
+Requires:       {{product}}-server java-1.8.0-openjdk-headless
+
+%description
+
+
+%prep
+%setup -c
+
+
+%build
+MUSTACHE_DIST="\"redhat\": true"
+pystache dist/common/systemd/scylla-jmx.service.mustache "{ $MUSTACHE_DIST }" > scylla-jmx.service
+
+%install
+rm -rf $RPM_BUILD_ROOT
+mkdir -p $RPM_BUILD_ROOT%{_sysconfdir}/sysconfig/
+mkdir -p $RPM_BUILD_ROOT%{_unitdir}
+mkdir -p $RPM_BUILD_ROOT%{_prefix}/lib/scylla/
+
+install -m644 dist/common/sysconfig/scylla-jmx $RPM_BUILD_ROOT%{_sysconfdir}/sysconfig/
+install -m644 scylla-jmx.service $RPM_BUILD_ROOT%{_unitdir}/
+install -d -m755 $RPM_BUILD_ROOT%{_prefix}/lib/scylla
+install -d -m755 $RPM_BUILD_ROOT%{_prefix}/lib/scylla/jmx
+install -d -m755 $RPM_BUILD_ROOT%{_prefix}/lib/scylla/jmx/symlinks
+install -m644 scylla-jmx-1.0.jar $RPM_BUILD_ROOT%{_prefix}/lib/scylla/jmx/
+install -m755 scylla-jmx $RPM_BUILD_ROOT%{_prefix}/lib/scylla/jmx
+ln -sf /usr/bin/java $RPM_BUILD_ROOT%{_prefix}/lib/scylla/jmx/symlinks/scylla-jmx
+
+%pre
+/usr/sbin/groupadd scylla 2> /dev/null || :
+/usr/sbin/useradd -g scylla -s /sbin/nologin -r -d ${_sharedstatedir}/scylla scylla 2> /dev/null || :
+ping -c1 `hostname` > /dev/null 2>&1
+if [ $? -ne 0 ]; then
+echo
+echo "**************************************************************"
+echo "* WARNING: You need to add hostname on /etc/hosts, otherwise *"
+echo "*          scylla-jmx will not able to start up.             *"
+echo "**************************************************************"
+echo
+fi
+
+%post
+%systemd_post scylla-jmx.service
+
+%preun
+%systemd_preun scylla-jmx.service
+
+%postun
+%systemd_postun
+
+%clean
+rm -rf $RPM_BUILD_ROOT
+
+
+%files
+%defattr(-,root,root)
+
+%config(noreplace) %{_sysconfdir}/sysconfig/scylla-jmx
+%{_unitdir}/scylla-jmx.service
+%{_prefix}/lib/scylla/jmx/scylla-jmx
+%{_prefix}/lib/scylla/jmx/scylla-jmx-1.0.jar
+%{_prefix}/lib/scylla/jmx/symlinks/scylla-jmx
+
+%changelog
+* Fri Aug  7 2015 Takuya ASADA Takuya ASADA <syuu@cloudius-systems.com>
+- inital version of scylla-tools.spec

install-dependencies.sh

@@ -22,5 +22,5 @@
 if [ "$ID" = "ubuntu" ] || [ "$ID" = "debian" ]; then
     apt -y install maven openjdk-8-jdk-headless
 elif [ "$ID" = "fedora" ] || [ "$ID" = "centos" ]; then
-    dnf install -y maven java-1.8.0-openjdk-devel
+    yum install -y maven java-1.8.0-openjdk-devel
 fi

install.sh

@@ -1,173 +0,0 @@
-#!/bin/bash
-#
-# Copyright (C) 2019 ScyllaDB
-#
-
-#
-# This file is part of Scylla.
-#
-# Scylla is free software: you can redistribute it and/or modify
-# it under the terms of the GNU Affero General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
-#
-# Scylla is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-#
-# You should have received a copy of the GNU General Public License
-# along with Scylla.  If not, see <http://www.gnu.org/licenses/>.
-#
-
-set -e
-
-print_usage() {
-    cat <<EOF
-Usage: install.sh [options]
-
-Options:
-  --root /path/to/root     alternative install root (default /)
-  --prefix /prefix         directory prefix (default /usr)
-  --nonroot                shortcut of '--disttype nonroot'
-  --sysconfdir /etc/sysconfig   specify sysconfig directory name
-  --packaging               use install.sh for packaging
-  --without-systemd         skip installing systemd units
-  --help                   this helpful message
-EOF
-    exit 1
-}
-
-root=/
-sysconfdir=/etc/sysconfig
-nonroot=false
-packaging=false
-without_systemd=false
-
-while [ $# -gt 0 ]; do
-    case "$1" in
-        "--root")
-            root="$2"
-            shift 2
-            ;;
-        "--prefix")
-            prefix="$2"
-            shift 2
-            ;;
-        "--nonroot")
-            nonroot=true
-            shift 1
-            ;;
-        "--sysconfdir")
-            sysconfdir="$2"
-            shift 2
-            ;;
-        "--packaging")
-            packaging=true
-            shift 1
-            ;;
-        "--without-systemd")
-            without_systemd=true
-            shift 1
-            ;;
-        "--help")
-            shift 1
-	    print_usage
-            ;;
-        *)
-            print_usage
-            ;;
-    esac
-done
-
-check_usermode_support() {
-    user=$(systemctl --help|grep -e '--user')
-    [ -n "$user" ]
-}
-
-if ! $packaging; then
-    has_java=false
-    if [ -x /usr/bin/java ]; then
-        javaver=$(/usr/bin/java -version 2>&1|head -n1|cut -f 3 -d " ")
-        has_java=true
-    fi
-    if ! $has_java; then
-        echo "Please install openjdk-8, openjdk-11, or openjdk-17 before running install.sh."
-        exit 1
-    fi
-fi
-
-if [ -z "$prefix" ]; then
-    if $nonroot; then
-        prefix=~/scylladb
-    else
-        prefix=/opt/scylladb
-    fi
-fi
-
-rprefix=$(realpath -m "$root/$prefix")
-if ! $nonroot; then
-    retc="$root/etc"
-    rsysconfdir="$root/$sysconfdir"
-    rusr="$root/usr"
-    rsystemd="$rusr/lib/systemd/system"
-else
-    retc="$rprefix/etc"
-    rsysconfdir="$rprefix/$sysconfdir"
-    rsystemd="$HOME/.config/systemd/user"
-fi
-
-install -d -m755 "$rsysconfdir"
-if ! $without_systemd; then
-    install -d -m755 "$rsystemd"
-fi
-install -d -m755 "$rprefix/scripts" "$rprefix/jmx" "$rprefix/jmx/symlinks"
-
-install -m644 dist/common/sysconfig/scylla-jmx -Dt "$rsysconfdir"
-if ! $without_systemd; then
-    install -m644 dist/common/systemd/scylla-jmx.service  -Dt "$rsystemd"
-fi
-if ! $nonroot && ! $without_systemd; then
-    if [ "$sysconfdir" != "/etc/sysconfig" ]; then
-        install -d -m755 "$retc"/systemd/system/scylla-jmx.service.d
-        cat << EOS > "$retc"/systemd/system/scylla-jmx.service.d/sysconfdir.conf
-[Service]
-EnvironmentFile=
-EnvironmentFile=$sysconfdir/scylla-jmx
-EOS
-    fi
-elif ! $without_systemd; then
-    install -d -m755 "$rsystemd"/scylla-jmx.service.d
-    cat << EOS > "$rsystemd"/scylla-jmx.service.d/nonroot.conf
-[Service]
-EnvironmentFile=
-EnvironmentFile=$retc/sysconfig/scylla-jmx
-ExecStart=
-ExecStart=$rprefix/jmx/scylla-jmx \$SCYLLA_JMX_PORT \$SCYLLA_API_PORT \$SCYLLA_API_ADDR \$SCYLLA_JMX_ADDR \$SCYLLA_JMX_FILE \$SCYLLA_JMX_LOCAL \$SCYLLA_JMX_REMOTE \$SCYLLA_JMX_DEBUG
-User=
-Group=
-WorkingDirectory=$rprefix
-EOS
-fi
-
-install -m644 scylla-jmx-1.1.jar "$rprefix/jmx"
-install -m755 scylla-jmx "$rprefix/jmx"
-ln -sf /usr/bin/java "$rprefix/jmx/symlinks/scylla-jmx"
-if ! $nonroot; then
-    install -m755 -d "$rusr"/lib/scylla/jmx/symlinks
-    ln -srf "$rprefix"/jmx/scylla-jmx-1.1.jar "$rusr"/lib/scylla/jmx/
-    ln -srf "$rprefix"/jmx/scylla-jmx "$rusr"/lib/scylla/jmx/
-    ln -sf /usr/bin/java "$rusr"/lib/scylla/jmx/symlinks/scylla-jmx
-fi
-
-if $nonroot; then
-    sed -i -e "s#/var/lib/scylla#$rprefix#g" "$rsysconfdir"/scylla-jmx
-    sed -i -e "s#/etc/scylla#$rprefix/etc/scylla#g" "$rsysconfdir"/scylla-jmx
-    sed -i -e "s#/opt/scylladb/jmx#$rprefix/jmx#g" "$rsysconfdir"/scylla-jmx
-    if ! $without_systemd && check_usermode_support; then
-        systemctl --user daemon-reload
-    fi
-    echo "Scylla-JMX non-root install completed."
-elif ! $without_systemd && ! $packaging; then
-    systemctl --system daemon-reload
-fi

pom.xml

@@ -2,81 +2,92 @@
     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
 
+    <groupId>com.scylladb.jmx</groupId>
     <artifactId>scylla-jmx</artifactId>
-    <version>1.1</version>
+    <version>1.0</version>
     <packaging>jar</packaging>
 
-    <parent>
-        <groupId>it.cavallium.scylladb.jmx</groupId>
-        <artifactId>scylla-jmx-parent</artifactId>
-        <version>1.1</version>
-        <relativePath>./scylla-jmx-parent/pom.xml</relativePath>
-    </parent>
-
     <name>Scylla JMX</name>
 
+    <properties>
+        <maven.compiler.target>1.8</maven.compiler.target>
+        <maven.compiler.source>1.8</maven.compiler.source>
+    </properties>
+
     <dependencies>
         <dependency>
-            <groupId>it.cavallium.scylladb.jmx</groupId>
-            <artifactId>scylla-apiclient</artifactId>
-            <version>1.1</version>
+            <groupId>org.yaml</groupId>
+                <artifactId>snakeyaml</artifactId>
+                <version>1.16</version>
+            </dependency>
+        <dependency>
+            <groupId>org.glassfish.jersey.core</groupId>
+            <artifactId>jersey-common</artifactId>
+            <version>2.22.1</version>
+        </dependency>
+        <dependency>
+            <groupId>javax.ws.rs</groupId>
+            <artifactId>javax.ws.rs-api</artifactId>
+            <version>2.0.1</version>
+        </dependency>
+        <dependency>
+            <groupId>javax.ws.rs</groupId>
+            <artifactId>jsr311-api</artifactId>
+            <version>1.1.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.glassfish.jersey.core</groupId>
+            <artifactId>jersey-client</artifactId>
+            <version>2.22.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>1.7.5</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-simple</artifactId>
+            <version>1.6.4</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-log4j12</artifactId>
+            <version>1.7.5</version>
         </dependency>
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>
-            <version>4.13.1</version>
+            <version>4.8.2</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.glassfish</groupId>
+            <artifactId>javax.json</artifactId>
+            <version>1.0.4</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+            <version>18.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.collections</groupId>
+            <artifactId>google-collections</artifactId>
+            <version>1.0</version>
+        </dependency>
+        <dependency>
+            <groupId>javax.activation</groupId>
+            <artifactId>activation</artifactId>
+            <version>1.1</version>
+        </dependency>
     </dependencies>
     <build>
         <plugins>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-compiler-plugin</artifactId>
-                <version>3.10.1</version>
-                <configuration>
-                    <source>11</source>
-                    <target>11</target>
-                    <compilerArgs>
-                        <arg>--add-exports</arg>
-                        <arg>java.management/com.sun.jmx.mbeanserver=scylla.jmx</arg>
-                        <arg>--add-exports</arg>
-                        <arg>java.management/com.sun.jmx.interceptor=scylla.jmx</arg>
-                    </compilerArgs>
-                </configuration>
-            </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-shade-plugin</artifactId>
-                <version>3.4.1</version>
-                <configuration>
-                    <artifactSet>
-                        <includes>
-                            <include>*:*</include>
-                        </includes>
-                        <excludes>
-                            <exclude>com.sun.activation:jakarta.activation</exclude>
-                        </excludes>
-                    </artifactSet>
-                    <filters>
-                        <filter>
-                            <artifact>*:*</artifact>
-                            <excludes>
-                                <exclude>module-info.class</exclude>
-                                <exclude>META-INF/versions/*/module-info.class</exclude>
-                                <exclude>META-INF/*.SF</exclude>
-                                <exclude>META-INF/*.DSA</exclude>
-                                <exclude>META-INF/*.RSA</exclude>
-                                <exclude>META-INF/MANIFEST.MF</exclude>
-                                <exclude>META-INF/*.MD</exclude>
-                                <exclude>META-INF/*.md</exclude>
-                                <exclude>META-INF/LICENSE</exclude>
-                                <exclude>META-INF/LICENSE.txt</exclude>
-                                <exclude>META-INF/NOTICE</exclude>
-                            </excludes>
-                        </filter>
-                    </filters>
-                </configuration>
+                <version>2.4.1</version>
                 <executions>
                     <execution>
                         <phase>package</phase>

reloc/build_deb.sh

@@ -1,42 +1,31 @@
 #!/bin/bash -e
 
+. /etc/os-release
 print_usage() {
     echo "build_deb.sh --reloc-pkg build/scylla-jmx-package.tar.gz"
     echo "  --reloc-pkg specify relocatable package path"
-    echo "  --builddir specify Debian package build path"
     exit 1
 }
 
-RELOC_PKG=build/scylla-jmx-package.tar.gz
-BUILDDIR=build/debian
+RELOC_PKG=$(readlink -f build/scylla-jmx-package.tar.gz)
+OPTS=""
 while [ $# -gt 0 ]; do
     case "$1" in
         "--reloc-pkg")
+            OPTS="$OPTS $1 $(readlink -f $2)"
             RELOC_PKG=$2
             shift 2
             ;;
-        "--builddir")
-            BUILDDIR="$2"
-            shift 2
-            ;;
         *)
             print_usage
             ;;
     esac
 done
 
-RELOC_PKG=$(readlink -f $RELOC_PKG)
-rm -rf "$BUILDDIR"/scylla-package "$BUILDDIR"/scylla-package.orig "$BUILDDIR"/debian
-mkdir -p "$BUILDDIR"/scylla-package
-tar -C "$BUILDDIR"/scylla-package -xpf $RELOC_PKG
-cd "$BUILDDIR"/scylla-package
-
-RELOC_PKG=$(readlink -f $RELOC_PKG)
-
-mv scylla-jmx/debian debian
-PKG_NAME=$(dpkg-parsechangelog --show-field Source)
-# XXX: Drop revision number from version string.
-#      Since it always '1', this should be okay for now.
-PKG_VERSION=$(dpkg-parsechangelog --show-field Version |sed -e 's/-1$//')
-ln -fv $RELOC_PKG ../"$PKG_NAME"_"$PKG_VERSION".orig.tar.gz
-debuild -rfakeroot -us -uc
+if [[ ! $OPTS =~ --reloc-pkg ]]; then
+    OPTS="$OPTS --reloc-pkg $RELOC_PKG"
+fi
+mkdir -p build/debian/scylla-package
+tar -C build/debian/scylla-package -xpf $RELOC_PKG
+cd build/debian/scylla-package
+exec ./dist/debian/build_deb.sh $OPTS

reloc/build_reloc.sh

@@ -6,13 +6,11 @@ print_usage() {
     echo "build_reloc.sh --clean --nodeps"
     echo "  --clean clean build directory"
     echo "  --nodeps    skip installing dependencies"
-    echo "  --version V  product-version-release string (overriding SCYLLA-VERSION-GEN)"
     exit 1
 }
 
 CLEAN=
 NODEPS=
-VERSION_OVERRIDE=
 while [ $# -gt 0 ]; do
     case "$1" in
         "--clean")
@@ -23,22 +21,12 @@ while [ $# -gt 0 ]; do
             NODEPS=yes
             shift 1
             ;;
-        "--version")
-            VERSION_OVERRIDE="$2"
-            shift 2
-            ;;
         *)
             print_usage
             ;;
     esac
 done
 
-VERSION=$(./SCYLLA-VERSION-GEN ${VERSION_OVERRIDE:+ --version "$VERSION_OVERRIDE"})
-# the former command should generate build/SCYLLA-PRODUCT-FILE and some other version
-# related files
-PRODUCT=`cat build/SCYLLA-PRODUCT-FILE`
-DEST="build/$PRODUCT-jmx-$VERSION.noarch.tar.gz"
-
 is_redhat_variant() {
     [ -f /etc/redhat-release ]
 }
@@ -56,15 +44,14 @@ if [ "$CLEAN" = "yes" ]; then
     rm -rf build target
 fi
 
-if [ -f "$DEST" ]; then
-    rm "$DEST"
+if [ -f build/scylla-jmx-package.tar.gz ]; then
+    rm build/scylla-jmx-package.tar.gz
 fi
 
 if [ -z "$NODEPS" ]; then
     sudo ./install-dependencies.sh
 fi
 
-mvn -B --file scylla-jmx-parent/pom.xml install
-./SCYLLA-VERSION-GEN ${VERSION_OVERRIDE:+ --version "$VERSION_OVERRIDE"}
-./dist/debian/debian_files_gen.py
-scripts/create-relocatable-package.py "$DEST"
+mvn -B install
+./SCYLLA-VERSION-GEN
+scripts/create-relocatable-package.py build/scylla-jmx-package.tar.gz

reloc/build_rpm.sh

@@ -1,52 +1,30 @@
 #!/bin/bash -e
 
+. /etc/os-release
 print_usage() {
     echo "build_rpm.sh --reloc-pkg build/scylla-jmx-package.tar.gz"
     echo "  --reloc-pkg specify relocatable package path"
-    echo "  --builddir specify rpmbuild directory"
     exit 1
 }
-RELOC_PKG=build/scylla-jmx-package.tar.gz
-BUILDDIR=build/redhat
+RELOC_PKG=$(readlink -f build/scylla-jmx-package.tar.gz)
+OPTS=""
 while [ $# -gt 0 ]; do
     case "$1" in
         "--reloc-pkg")
+            OPTS="$OPTS $1 $(readlink -f $2)"
             RELOC_PKG=$2
             shift 2
             ;;
-        "--builddir")
-            BUILDDIR="$2"
-            shift 2
-            ;;
         *)
             print_usage
             ;;
     esac
 done
 
-RELOC_PKG=$(readlink -f $RELOC_PKG)
-RPMBUILD=$(readlink -f $BUILDDIR)
-mkdir -p "$BUILDDIR"
-tar -C "$BUILDDIR" -xpf $RELOC_PKG scylla-jmx/SCYLLA-RELEASE-FILE scylla-jmx/SCYLLA-RELOCATABLE-FILE scylla-jmx/SCYLLA-VERSION-FILE scylla-jmx/SCYLLA-PRODUCT-FILE scylla-jmx/dist/redhat
-cd "$BUILDDIR"/scylla-jmx
-
-RELOC_PKG_BASENAME=$(basename "$RELOC_PKG")
-SCYLLA_VERSION=$(cat SCYLLA-VERSION-FILE)
-SCYLLA_RELEASE=$(cat SCYLLA-RELEASE-FILE)
-VERSION=$SCYLLA_VERSION-$SCYLLA_RELEASE
-PRODUCT=$(cat SCYLLA-PRODUCT-FILE)
-
-mkdir -p $RPMBUILD/{BUILD,BUILDROOT,RPMS,SOURCES,SPECS,SRPMS}
-
-ln -fv $RELOC_PKG $RPMBUILD/SOURCES/
-
-parameters=(
-    -D"version $SCYLLA_VERSION"
-    -D"release $SCYLLA_RELEASE"
-    -D"product $PRODUCT"
-    -D"reloc_pkg $RELOC_PKG_BASENAME"
-)
-
-cp dist/redhat/scylla-jmx.spec $RPMBUILD/SPECS
-# this rpm can be install on both fedora / centos7, so drop distribution name from the file name
-rpmbuild -ba "${parameters[@]}" --define '_binary_payload w2.xzdio' --define "_topdir $RPMBUILD" --undefine "dist" $RPMBUILD/SPECS/scylla-jmx.spec
+if [[ ! $OPTS =~ --reloc-pkg ]]; then
+    OPTS="$OPTS --reloc-pkg $RELOC_PKG"
+fi
+mkdir -p build/redhat/scylla-package
+tar -C build/redhat/scylla-package -xpf $RELOC_PKG SCYLLA-RELEASE-FILE SCYLLA-RELOCATABLE-FILE SCYLLA-VERSION-FILE SCYLLA-PRODUCT-FILE dist/redhat
+cd build/redhat/scylla-package
+exec ./dist/redhat/build_rpm.sh $OPTS

scripts/create-relocatable-package.py

@@ -27,14 +27,6 @@ import os
 import tarfile
 import pathlib
 
-RELOC_PREFIX='scylla-jmx'
-def reloc_add(self, name, arcname=None, recursive=True, *, filter=None):
-    if arcname:
-        return self.add(name, arcname="{}/{}".format(RELOC_PREFIX, arcname))
-    else:
-        return self.add(name, arcname="{}/{}".format(RELOC_PREFIX, name))
-
-tarfile.TarFile.reloc_add = reloc_add
 
 ap = argparse.ArgumentParser(description='Create a relocatable scylla package.')
 ap.add_argument('dest',
@@ -45,20 +37,13 @@ args = ap.parse_args()
 output = args.dest
 
 ar = tarfile.open(output, mode='w|gz')
-# relocatable package format version = 2.2
-with open('build/.relocatable_package_version', 'w') as f:
-    f.write('2.2\n')
-ar.add('build/.relocatable_package_version', arcname='.relocatable_package_version')
-
 pathlib.Path('build/SCYLLA-RELOCATABLE-FILE').touch()
-ar.reloc_add('build/SCYLLA-RELOCATABLE-FILE', arcname='SCYLLA-RELOCATABLE-FILE')
-ar.reloc_add('build/SCYLLA-RELEASE-FILE', arcname='SCYLLA-RELEASE-FILE')
-ar.reloc_add('build/SCYLLA-VERSION-FILE', arcname='SCYLLA-VERSION-FILE')
-ar.reloc_add('build/SCYLLA-PRODUCT-FILE', arcname='SCYLLA-PRODUCT-FILE')
-ar.reloc_add('dist')
-ar.reloc_add('install.sh')
-ar.reloc_add('target/scylla-jmx-1.1.jar', arcname='scylla-jmx-1.1.jar')
-ar.reloc_add('scripts/scylla-jmx', arcname='scylla-jmx')
-ar.reloc_add('README.md')
-ar.reloc_add('NOTICE')
-ar.reloc_add('build/debian/debian', arcname='debian')
+ar.add('build/SCYLLA-RELOCATABLE-FILE', arcname='SCYLLA-RELOCATABLE-FILE')
+ar.add('build/SCYLLA-RELEASE-FILE', arcname='SCYLLA-RELEASE-FILE')
+ar.add('build/SCYLLA-VERSION-FILE', arcname='SCYLLA-VERSION-FILE')
+ar.add('build/SCYLLA-PRODUCT-FILE', arcname='SCYLLA-PRODUCT-FILE')
+ar.add('dist')
+ar.add('target/scylla-jmx-1.0.jar', arcname='scylla-jmx-1.0.jar')
+ar.add('scripts/scylla-jmx', arcname='scylla-jmx')
+ar.add('README.md')
+ar.add('NOTICE')

scripts/scylla-jmx

@@ -131,13 +131,11 @@ else
     fi
 fi
 
-"$LOCATION_SCRIPTS"/symlinks/scylla-jmx $DEBUG \
+exec "$LOCATION_SCRIPTS"/symlinks/scylla-jmx $DEBUG \
     $API_PORT $API_ADDR $CONF_FILE -Xmx256m -XX:+UseSerialGC \
     -XX:+HeapDumpOnOutOfMemoryError \
     $JMX_AUTH $JMX_SSL $JMX_ADDR $JMX_LOCAL \
-    --add-exports java.management/com.sun.jmx.mbeanserver=ALL-UNNAMED \
-    --add-exports java.management/com.sun.jmx.interceptor=ALL-UNNAMED \
     -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=$JMX_PORT \
     -Djava.rmi.server.hostname=$HOSTNAME -Dcom.sun.management.jmxremote.rmi.port=$JMX_PORT \
     -Djavax.management.builder.initial=com.scylladb.jmx.utils.APIBuilder \
-    $PROPERTIES -jar $LOCATION/scylla-jmx-1.1.jar
+    $PROPERTIES -jar $LOCATION/scylla-jmx-1.0.jar

scylla-apiclient/pom.xml

@@ -1,99 +0,0 @@
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-  <modelVersion>4.0.0</modelVersion>
-
-  <artifactId>scylla-apiclient</artifactId>
-  <packaging>jar</packaging>
-  <version>1.1</version>
-
-  <parent>
-    <relativePath>../scylla-jmx-parent/pom.xml</relativePath>
-    <groupId>it.cavallium.scylladb.jmx</groupId>
-    <artifactId>scylla-jmx-parent</artifactId>
-    <version>1.1</version>
-  </parent>
-
-  <name>Scylla REST API client</name>
-
-  <properties>
-    <jackson.version>2.14.0</jackson.version>
-    <jackson.databind.version>2.14.0</jackson.databind.version>
-  </properties>
-
-  <dependencies>
-    <dependency>
-      <groupId>org.eclipse.parsson</groupId>
-      <artifactId>parsson</artifactId>
-      <version>1.1.1</version>
-    </dependency>
-    <dependency>
-      <groupId>org.yaml</groupId>
-      <artifactId>snakeyaml</artifactId>
-      <version>1.33</version>
-    </dependency>
-    <dependency>
-      <groupId>org.glassfish.jersey.core</groupId>
-      <artifactId>jersey-common</artifactId>
-      <version>3.1.0</version>
-    </dependency>
-    <dependency>
-      <groupId>jakarta.ws.rs</groupId>
-      <artifactId>jakarta.ws.rs-api</artifactId>
-      <version>3.1.0</version>
-    </dependency>
-    <dependency>
-      <groupId>org.glassfish.jersey.core</groupId>
-      <artifactId>jersey-client</artifactId>
-      <version>3.1.0</version>
-    </dependency>
-    <dependency>
-      <groupId>org.glassfish.jersey.inject</groupId>
-      <artifactId>jersey-hk2</artifactId>
-      <version>3.1.0</version>
-    </dependency>
-    <dependency>
-      <groupId>jakarta.json</groupId>
-      <artifactId>jakarta.json-api</artifactId>
-      <version>2.1.1</version>
-    </dependency>
-    <dependency>
-      <groupId>com.google.guava</groupId>
-      <artifactId>guava</artifactId>
-      <version>31.1-jre</version>
-    </dependency>
-    <dependency>
-      <groupId>jakarta.activation</groupId>
-      <artifactId>jakarta.activation-api</artifactId>
-      <version>2.1.1</version>
-    </dependency>
-    <dependency>
-      <groupId>com.fasterxml.jackson.core</groupId>
-      <artifactId>jackson-annotations</artifactId>
-      <version>${jackson.version}</version>
-    </dependency>
-    <dependency>
-      <groupId>com.fasterxml.jackson.core</groupId>
-      <artifactId>jackson-databind</artifactId>
-      <version>${jackson.databind.version}</version>
-    </dependency>
-    <dependency>
-      <groupId>com.fasterxml.jackson.jakarta.rs</groupId>
-      <artifactId>jackson-jakarta-rs-json-provider</artifactId>
-      <version>2.14.1</version>
-    </dependency>
-  </dependencies>
-
-  <build>
-    <plugins>
-      <plugin>
-        <groupId>org.apache.maven.plugins</groupId>
-        <artifactId>maven-compiler-plugin</artifactId>
-        <version>3.10.1</version>
-        <configuration>
-          <release>11</release>
-        </configuration>
-      </plugin>
-    </plugins>
-  </build>
-
-</project>

scylla-apiclient/src/main/java/module-info.java

@@ -1,15 +0,0 @@
-module scylla.apiclient {
-	exports com.scylladb.jmx.api;
-	exports com.scylladb.jmx.api.utils;
-	requires org.eclipse.parsson;
-	requires jakarta.ws.rs;
-	requires com.fasterxml.jackson.jakarta.rs.json;
-	requires jersey.client;
-	requires java.logging;
-	requires jakarta.json;
-	requires java.management;
-	requires org.yaml.snakeyaml;
-	requires com.google.common;
-	requires jersey.common;
-	requires jersey.hk2;
-}

scylla-jmx-parent/pom.xml

@@ -1,29 +0,0 @@
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-  <modelVersion>4.0.0</modelVersion>
-
-  <groupId>it.cavallium.scylladb.jmx</groupId>
-  <artifactId>scylla-jmx-parent</artifactId>
-  <version>1.1</version>
-  <packaging>pom</packaging>
-
-  <modules>
-    <module>../</module>
-    <module>../scylla-apiclient</module>
-  </modules>
-
-  <name>Scylla JMX Parent</name>
-
-  <distributionManagement>
-    <repository>
-      <id>mchv-release-distribution</id>
-      <name>MCHV Release Apache Maven Packages Distribution</name>
-      <url>https://mvn.mchv.eu/repository/mchv</url>
-    </repository>
-    <snapshotRepository>
-      <id>mchv-snapshot-distribution</id>
-      <name>MCHV Snapshot Apache Maven Packages Distribution</name>
-      <url>https://mvn.mchv.eu/repository/mchv-snapshot</url>
-    </snapshotRepository>
-  </distributionManagement>
-</project>

src/main/java/com/scylladb/jmx/api/APIClient.java

@@ -3,24 +3,7 @@
  */
 package com.scylladb.jmx.api;
 
-import com.fasterxml.jackson.jakarta.rs.json.JacksonJsonProvider;
-import jakarta.json.Json;
-import jakarta.json.JsonArray;
-import jakarta.json.JsonObject;
-import jakarta.json.JsonReader;
-import jakarta.json.JsonReaderFactory;
-import jakarta.json.JsonString;
-import jakarta.ws.rs.ProcessingException;
-import jakarta.ws.rs.client.Client;
-import jakarta.ws.rs.client.ClientBuilder;
-import jakarta.ws.rs.client.Entity;
-import jakarta.ws.rs.client.Invocation;
-import jakarta.ws.rs.client.WebTarget;
-import jakarta.ws.rs.core.MediaType;
-import jakarta.ws.rs.core.MultivaluedMap;
-import jakarta.ws.rs.core.Response;
 import java.io.StringReader;
-import java.lang.System.Logger.Level;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
 import java.util.ArrayList;
@@ -35,28 +18,30 @@ import java.util.Set;
 import java.util.function.BiFunction;
 import java.util.logging.Logger;
 
+import javax.json.Json;
+import javax.json.JsonArray;
+import javax.json.JsonObject;
+import javax.json.JsonReader;
+import javax.json.JsonReaderFactory;
+import javax.json.JsonString;
 import javax.management.openmbean.TabularData;
 import javax.management.openmbean.TabularDataSupport;
+import javax.ws.rs.ProcessingException;
+import javax.ws.rs.client.Client;
+import javax.ws.rs.client.ClientBuilder;
+import javax.ws.rs.client.Entity;
+import javax.ws.rs.client.Invocation;
+import javax.ws.rs.client.WebTarget;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.MultivaluedMap;
+import javax.ws.rs.core.Response;
 
 import org.glassfish.jersey.client.ClientConfig;
 
-import com.scylladb.jmx.api.utils.SnapshotDetailsTabularData;
+import com.scylladb.jmx.utils.SnapshotDetailsTabularData;
 
 public class APIClient {
     private Map<String, CacheEntry> cache = new HashMap<String, CacheEntry>();
-    private final APIConfig config;
-    private final ClientConfig clientConfig;
-    private final Client client;
-    private JsonReaderFactory factory = Json.createReaderFactory(null);
-
-    private static final Logger logger = Logger.getLogger(APIClient.class.getName());
-
-    public APIClient(APIConfig config) {
-        this.config = config;
-        this.clientConfig = new ClientConfig();
-        clientConfig.register(new JacksonJsonProvider());
-        this.client = ClientBuilder.newClient(clientConfig);
-    }
 
     private String getCacheKey(String key, MultivaluedMap<String, String> param, long duration) {
         if (duration <= 0) {
@@ -89,12 +74,21 @@ public class APIClient {
         return (value != null && value.valid(duration)) ? value.jsonObject() : null;
     }
 
+    private JsonReaderFactory factory = Json.createReaderFactory(null);
+    private static final Logger logger = Logger.getLogger(APIClient.class.getName());
+
+    private final APIConfig config;
+
+    public APIClient(APIConfig config) {
+        this.config = config;
+    }
 
     private String getBaseUrl() {
         return config.getBaseUrl();
     }
 
     public Invocation.Builder get(String path, MultivaluedMap<String, String> queryParams) {
+        Client client = ClientBuilder.newClient(new ClientConfig());
         WebTarget webTarget = client.target(getBaseUrl()).path(path);
         if (queryParams != null) {
             for (Entry<String, List<String>> qp : queryParams.entrySet()) {

src/main/java/com/scylladb/jmx/api/CacheEntry.java

@@ -21,8 +21,7 @@
 
 package com.scylladb.jmx.api;
 
-
-import jakarta.json.JsonObject;
+import javax.json.JsonObject;
 
 class CacheEntry {
     private long time;

src/main/java/com/scylladb/jmx/main/Main.java

@@ -27,27 +27,12 @@ import com.scylladb.jmx.api.APIConfig;
 import com.scylladb.jmx.metrics.APIMBean;
 
 public class Main {
-
-    private static APIConfig config;
-    private static APIClient client;
-
-    public static synchronized APIConfig getApiConfig() {
-        if (config == null) {
-            config = new APIConfig();
-        }
-        return config;
-    }
-
-    public static synchronized APIClient getApiClient() {
-        if (client == null) {
-            client = new APIClient(getApiConfig());
-        }
-        return client;
-    }
+    // todo: command line options. Make us an agent class (also)
+    private static final APIConfig config = new APIConfig();
+    public static final APIClient client = new APIClient(config);
 
     public static void main(String[] args) throws Exception {
-        System.out.printf("Java %s%n", System.getProperty("java.version"));
-        System.out.printf("Connecting to %s%n", getApiConfig().getBaseUrl());
+        System.out.println("Connecting to " + config.getBaseUrl());
         System.out.println("Starting the JMX server");
 
         MBeanServer server = getPlatformMBeanServer();
@@ -55,7 +40,7 @@ public class Main {
                 CommitLog.class, Gossiper.class, EndpointSnitchInfo.class, FailureDetector.class, CacheService.class,
                 CompactionManager.class, GCInspector.class, StreamManager.class)) {
             Constructor<? extends APIMBean> c = clazz.getDeclaredConstructor(APIClient.class);
-            APIMBean m = c.newInstance(getApiClient());
+            APIMBean m = c.newInstance(client);
             server.registerMBean(m, null);
         }
 

src/main/java/com/scylladb/jmx/metrics/APIMBean.java

@@ -1,7 +1,6 @@
 package com.scylladb.jmx.metrics;
 
 import java.lang.reflect.Field;
-import java.util.EnumSet;
 import java.util.Set;
 import java.util.function.Function;
 import java.util.function.Predicate;
@@ -56,39 +55,35 @@ public class APIMBean implements MBeanRegistration {
      * @param generator
      *            {@link Function} to create a new MBean instance for a given
      *            {@link ObjectName}
+     * 
      * @return
      * @throws MalformedObjectNameException
      */
-	public static boolean checkRegistration(JmxMBeanServer server, Set<ObjectName> all,
-			EnumSet<RegistrationMode> mode, final Predicate<ObjectName> predicate,
-			Function<ObjectName, Object> generator) throws MalformedObjectNameException {
-		Set<ObjectName> registered = queryNames(server, predicate);
-		if (mode.contains(RegistrationMode.Remove)) {
-			for (ObjectName name : registered) {
-				if (!all.contains(name)) {
-					try {
-						server.getMBeanServerInterceptor().unregisterMBean(name);
-					} catch (MBeanRegistrationException | InstanceNotFoundException e) {
-					}
-				}
-			}
-		}
+    public static boolean checkRegistration(JmxMBeanServer server, Set<ObjectName> all,
+            final Predicate<ObjectName> predicate, Function<ObjectName, Object> generator)
+            throws MalformedObjectNameException {
+        Set<ObjectName> registered = queryNames(server, predicate);
+        for (ObjectName name : registered) {
+            if (!all.contains(name)) {
+                try {
+                    server.getMBeanServerInterceptor().unregisterMBean(name);
+                } catch (MBeanRegistrationException | InstanceNotFoundException e) {
+                }
+            }
+        }
 
-		int added = 0;
-		if (mode.contains(RegistrationMode.Add)) {
-			for (ObjectName name : all) {
-				if (!registered.contains(name)) {
-					try {
-						server.getMBeanServerInterceptor().registerMBean(generator.apply(name), name);
-						added++;
-					} catch (InstanceAlreadyExistsException | MBeanRegistrationException
-							| NotCompliantMBeanException e) {
-					}
-				}
-			}
-		}
-		return added > 0;
-	}
+        int added = 0;
+        for (ObjectName name : all) {
+            if (!registered.contains(name)) {
+                try {
+                    server.getMBeanServerInterceptor().registerMBean(generator.apply(name), name);
+                    added++;
+                } catch (InstanceAlreadyExistsException | MBeanRegistrationException | NotCompliantMBeanException e) {
+                }
+            }
+        }
+        return added > 0;
+    }
 
     /**
      * Helper method to query {@link ObjectName}s from an {@link MBeanServer}

src/main/java/com/scylladb/jmx/metrics/RegistrationChecker.java

@@ -1,69 +0,0 @@
-package com.scylladb.jmx.metrics;
-
-import static com.scylladb.jmx.metrics.RegistrationMode.Remove;
-import static com.scylladb.jmx.metrics.RegistrationMode.Wait;
-import static java.util.EnumSet.allOf;
-import static java.util.EnumSet.of;
-
-import java.net.UnknownHostException;
-import java.util.EnumSet;
-import java.util.concurrent.locks.Lock;
-import java.util.concurrent.locks.ReentrantLock;
-
-import javax.management.OperationsException;
-
-import com.scylladb.jmx.api.APIClient;
-import com.sun.jmx.mbeanserver.JmxMBeanServer;
-
-/**
- * Helper type to do optional locking for registration. Allows for
- * per-bind-point locks and registration, instead of per-type or per-instance
- * locks which may be misguiding, since for example one instance can be bound to
- * many MBeanServers etc.
- * 
- * Also allows for polled checks, i.e. try-lock and either wait or skip. Wait,
- * because we probably should not repeat things hidden by this type too often,
- * and skip because for example a periodic task checking can just skip if a
- * user-initiated registration check is being done.
- * 
- * @author calle
- *
- */
-@SuppressWarnings("restriction")
-public abstract class RegistrationChecker {
-    private final Lock lock = new ReentrantLock();
-
-    public static final EnumSet<RegistrationMode> REMOVE_NO_WAIT = of(Remove);
-    public static final EnumSet<RegistrationMode> ADD_AND_REMOVE = allOf(RegistrationMode.class);
-
-    public final void reap(APIClient client, JmxMBeanServer server) throws OperationsException, UnknownHostException {
-        check(client, server, REMOVE_NO_WAIT);
-    }
-
-    public final void check(APIClient client, JmxMBeanServer server) throws OperationsException, UnknownHostException {
-        check(client, server, ADD_AND_REMOVE);
-    }
-
-    public final void check(APIClient client, JmxMBeanServer server, EnumSet<RegistrationMode> mode)
-            throws OperationsException, UnknownHostException {
-        if (!lock.tryLock()) {
-            if (mode.contains(Wait)) {
-                // someone is doing update.
-                // since this is jmx, and sloppy, we'll just
-                // assume that once he is done, things are
-                // good enough.
-                lock.lock();
-                lock.unlock();
-            }
-            return;
-        }
-        try {
-            doCheck(client, server, mode);
-        } finally {
-            lock.unlock();
-        }
-    }
-
-    protected abstract void doCheck(APIClient client, JmxMBeanServer server, EnumSet<RegistrationMode> mode)
-            throws OperationsException, UnknownHostException;
-}

src/main/java/com/scylladb/jmx/metrics/RegistrationMode.java

@@ -1,5 +0,0 @@
-package com.scylladb.jmx.metrics;
-
-public enum RegistrationMode {
-	Wait, Add, Remove,
-}

src/main/java/com/scylladb/jmx/utils/APIBuilder.java

@@ -3,7 +3,7 @@ package com.scylladb.jmx.utils;
  * Copyright 2016 ScyllaDB
  */
 
-import static com.scylladb.jmx.main.Main.getApiClient;
+import static com.scylladb.jmx.main.Main.client;
 import static com.sun.jmx.mbeanserver.Util.wildmatch;
 import static java.util.logging.Level.SEVERE;
 import static javax.management.MBeanServerDelegate.DELEGATE_NAME;
@@ -172,7 +172,7 @@ public class APIBuilder extends MBeanServerBuilder {
                         logger.log(SEVERE, "Unexpected error.", x);
                     }
                 } finally {
-                    lock.writeLock().unlock();
+                    lock.writeLock().lock();
                 }
             }
         }
@@ -491,6 +491,6 @@ public class APIBuilder extends MBeanServerBuilder {
             throw new RuntimeException(e);
         }
 
-        return new APIMBeanServer(getApiClient(), nested);
+        return new APIMBeanServer(client, nested);
     }
 }

src/main/java/com/scylladb/jmx/utils/APIMBeanServer.java

@@ -1,13 +1,8 @@
 package com.scylladb.jmx.utils;
 
-import static java.util.Arrays.asList;
-import static java.util.concurrent.Executors.newScheduledThreadPool;
-import static java.util.concurrent.TimeUnit.MINUTES;
-
 import java.io.ObjectInputStream;
 import java.net.UnknownHostException;
 import java.util.Set;
-import java.util.concurrent.ScheduledExecutorService;
 import java.util.logging.Logger;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
@@ -39,17 +34,12 @@ import org.apache.cassandra.db.ColumnFamilyStore;
 import org.apache.cassandra.metrics.StreamingMetrics;
 
 import com.scylladb.jmx.api.APIClient;
-import com.scylladb.jmx.metrics.RegistrationChecker;
 import com.sun.jmx.mbeanserver.JmxMBeanServer;
 
 @SuppressWarnings("restriction")
 public class APIMBeanServer implements MBeanServer {
     @SuppressWarnings("unused")
     private static final Logger logger = Logger.getLogger(APIMBeanServer.class.getName());
-    private static final ScheduledExecutorService executor = newScheduledThreadPool(1);
-
-    private final RegistrationChecker columnFamilyStoreChecker = ColumnFamilyStore.createRegistrationChecker();
-    private final RegistrationChecker streamingMetricsChecker = StreamingMetrics.createRegistrationChecker();
 
     private final APIClient client;
     private final JmxMBeanServer server;
@@ -57,16 +47,6 @@ public class APIMBeanServer implements MBeanServer {
     public APIMBeanServer(APIClient client, JmxMBeanServer server) {
         this.client = client;
         this.server = server;
-        
-    	executor.scheduleWithFixedDelay(() -> {
-    		for (RegistrationChecker c : asList(columnFamilyStoreChecker, streamingMetricsChecker)) {
-    			try {
-    				c.reap(client, server);
-    	        } catch (OperationsException | UnknownHostException e) {
-    	            // TODO: log?
-    	        }
-    		}
-        }, 1, 5, MINUTES);
     }
 
     private static ObjectInstance prepareForRemote(final ObjectInstance i) {
@@ -307,21 +287,24 @@ public class APIMBeanServer implements MBeanServer {
 
     static final Pattern tables = Pattern.compile("^\\*?((Index)?ColumnFamil(ies|y)|(Index)?(Table(s)?)?)$");
 
-    private void checkRegistrations(ObjectName name) {
+    private boolean checkRegistrations(ObjectName name) {
         if (name != null && server.isRegistered(name)) {
-            return;
+            return false;
         }
         
+        boolean result = false;
+        
         try {
             String type = name != null ? name.getKeyProperty("type") : null;            
             if (type == null || tables.matcher(type).matches()) {
-            	columnFamilyStoreChecker.check(client, server);
+                result |= ColumnFamilyStore.checkRegistration(client, server);
             }
             if (type == null || StreamingMetrics.TYPE_NAME.equals(type)) {
-            	streamingMetricsChecker.check(client, server);
+                result |= StreamingMetrics.checkRegistration(client, server);
             }
-        } catch (OperationsException | UnknownHostException e) {
+        } catch (MalformedObjectNameException | UnknownHostException e) {
             // TODO: log
         }
+        return result;
     }
 }

src/main/java/com/scylladb/jmx/utils/DateXmlAdapter.java

@@ -1,18 +0,0 @@
-package com.scylladb.jmx.utils;
-
-import jakarta.xml.bind.annotation.adapters.XmlAdapter;
-import java.time.Instant;
-import java.util.Date;
-
-public class DateXmlAdapter extends XmlAdapter<String, Date> {
-    @Override
-    public String marshal(Date v) throws Exception {
-        return Instant.ofEpochMilli(v.getTime()).toString();
-    }
-
-    @Override
-    public Date unmarshal(String v) throws Exception {
-        return new Date(Instant.parse(v).toEpochMilli());
-    }
-
-}

src/main/java/com/scylladb/jmx/utils/FileUtils.java

@@ -22,7 +22,7 @@
  * Modified by Cloudius Systems
  */
 
-package com.scylladb.jmx.api.utils;
+package com.scylladb.jmx.utils;
 
 import java.io.File;
 import java.text.DecimalFormat;

src/main/java/com/scylladb/jmx/utils/Pair.java

@@ -22,7 +22,7 @@
  * Modified by Cloudius Systems
  */
 
-package com.scylladb.jmx.api.utils;
+package com.scylladb.jmx.utils;
 
 import com.google.common.base.Objects;
 

src/main/java/com/scylladb/jmx/utils/SnapshotDetailsTabularData.java

@@ -20,7 +20,7 @@
  *
  * Modified by Cloudius Systems
  */
-package com.scylladb.jmx.api.utils;
+package com.scylladb.jmx.utils;
 
 import java.util.Map;
 

src/main/java/module-info.java

@@ -1,16 +0,0 @@
-module scylla.jmx {
-	opens com.scylladb.jmx.utils;
-	exports com.scylladb.jmx.utils;
-	opens com.scylladb.jmx.main;
-	exports com.scylladb.jmx.main;
-	opens com.scylladb.jmx.metrics;
-	exports com.scylladb.jmx.metrics;
-	requires java.logging;
-	requires java.management;
-	requires scylla.apiclient;
-	requires jakarta.json;
-	requires jakarta.ws.rs;
-	requires com.google.common;
-	requires jakarta.xml.bind;
-	requires com.fasterxml.jackson.annotation;
-}

src/main/java/org/apache/cassandra/db/ColumnFamilyStore.java

@@ -23,22 +23,13 @@
  */
 package org.apache.cassandra.db;
 
-import static jakarta.json.Json.createObjectBuilder;
 import static java.lang.String.valueOf;
 import static java.util.Arrays.asList;
 import static java.util.stream.Collectors.toMap;
+import static javax.json.Json.createObjectBuilder;
 
-import jakarta.json.Json;
-import jakarta.json.JsonArray;
-import jakarta.json.JsonObject;
-import jakarta.json.JsonObjectBuilder;
-import jakarta.json.JsonReader;
-import jakarta.ws.rs.core.MultivaluedHashMap;
-import jakarta.ws.rs.core.MultivaluedMap;
 import java.io.StringReader;
-import java.io.OutputStream;
 import java.util.Collections;
-import java.util.EnumSet;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
@@ -51,10 +42,14 @@ import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;
 import java.util.logging.Logger;
 
+import javax.json.Json;
+import javax.json.JsonArray;
+import javax.json.JsonObject;
+import javax.json.JsonObjectBuilder;
+import javax.json.JsonReader;
 import javax.management.MBeanServer;
 import javax.management.MalformedObjectNameException;
 import javax.management.ObjectName;
-import javax.management.OperationsException;
 import javax.management.openmbean.CompositeData;
 import javax.management.openmbean.CompositeDataSupport;
 import javax.management.openmbean.CompositeType;
@@ -63,13 +58,13 @@ import javax.management.openmbean.OpenType;
 import javax.management.openmbean.SimpleType;
 import javax.management.openmbean.TabularDataSupport;
 import javax.management.openmbean.TabularType;
+import javax.ws.rs.core.MultivaluedHashMap;
+import javax.ws.rs.core.MultivaluedMap;
 
 import org.apache.cassandra.metrics.TableMetrics;
 
 import com.scylladb.jmx.api.APIClient;
 import com.scylladb.jmx.metrics.MetricsMBean;
-import com.scylladb.jmx.metrics.RegistrationChecker;
-import com.scylladb.jmx.metrics.RegistrationMode;
 import com.sun.jmx.mbeanserver.JmxMBeanServer;
 import com.google.common.base.Throwables;
 
@@ -187,22 +182,15 @@ public class ColumnFamilyStore extends MetricsMBean implements ColumnFamilyStore
                 "org.apache.cassandra.db:type=" + type + ",keyspace=" + keyspace + ",columnfamily=" + name);
     }
 
-	public static RegistrationChecker createRegistrationChecker() {
-		return new RegistrationChecker() {
-			@Override
-			protected void doCheck(APIClient client, JmxMBeanServer server, EnumSet<RegistrationMode> mode)
-					throws OperationsException {
-				JsonArray mbeans = client.getJsonArray("/column_family/");
-				Set<ObjectName> all = new HashSet<ObjectName>();
-				for (int i = 0; i < mbeans.size(); i++) {
-					JsonObject mbean = mbeans.getJsonObject(i);
-					all.add(getName(mbean.getString("type"), mbean.getString("ks"), mbean.getString("cf")));
-				}
-				checkRegistration(server, all, mode,
-						n -> TYPE_NAMES.contains(n.getKeyProperty("type")), n -> new ColumnFamilyStore(client, n));
-			}
-		};
-	}
+    public static boolean checkRegistration(APIClient client, JmxMBeanServer server) throws MalformedObjectNameException {
+        JsonArray mbeans = client.getJsonArray("/column_family/");
+        Set<ObjectName> all = new HashSet<ObjectName>();
+        for (int i = 0; i < mbeans.size(); i++) {
+            JsonObject mbean = mbeans.getJsonObject(i);
+            all.add(getName(mbean.getString("type"), mbean.getString("ks"), mbean.getString("cf")));
+        }
+        return checkRegistration(server, all, n -> TYPE_NAMES.contains(n.getKeyProperty("type")), n -> new ColumnFamilyStore(client, n));
+    }
 
     /**
      * @return the name of the column family
@@ -332,7 +320,7 @@ public class ColumnFamilyStore extends MetricsMBean implements ColumnFamilyStore
     @Override
     public boolean isAutoCompactionDisabled() {
         log(" isAutoCompactionDisabled()");
-        return !client.getBooleanValue("column_family/autocompaction/" + getCFName());
+        return client.getBooleanValue("column_family/autocompaction/" + getCFName());
     }
 
     /** Number of tombstoned cells retreived during the last slicequery */
@@ -546,7 +534,6 @@ public class ColumnFamilyStore extends MetricsMBean implements ColumnFamilyStore
         TabularDataSupport result = new TabularDataSupport(COUNTER_TYPE);
 
         JsonArray counters = tableSamplerResult.getJsonArray((samplerType.equalsIgnoreCase("reads")) ? "read" : "write");
-        long cardinality = tableSamplerResult.getJsonNumber((samplerType.equalsIgnoreCase("reads")) ? "read_cardinality" : "write_cardinality").longValue();
         long size = 0;
         if (counters != null) {
             size = (count > counters.size()) ? counters.size() : count;
@@ -559,6 +546,7 @@ public class ColumnFamilyStore extends MetricsMBean implements ColumnFamilyStore
                                 counter.getString("partition") })); // string
             }
         }
-        return new CompositeDataSupport(SAMPLING_RESULT, SAMPLER_NAMES, new Object[] { cardinality, result });
+        //FIXME: size is not the cardinality, a true value needs to be propogated
+        return new CompositeDataSupport(SAMPLING_RESULT, SAMPLER_NAMES, new Object[] { size, result });
     }
 }

src/main/java/org/apache/cassandra/db/compaction/CompactionHistoryTabularData.java

@@ -22,8 +22,8 @@
  */
 package org.apache.cassandra.db.compaction;
 
-import jakarta.json.JsonArray;
-import jakarta.json.JsonObject;
+import javax.json.JsonArray;
+import javax.json.JsonObject;
 import javax.management.openmbean.CompositeDataSupport;
 import javax.management.openmbean.CompositeType;
 import javax.management.openmbean.OpenDataException;

src/main/java/org/apache/cassandra/db/compaction/CompactionManager.java

@@ -17,18 +17,18 @@
  */
 package org.apache.cassandra.db.compaction;
 
-import jakarta.json.JsonArray;
-import jakarta.json.JsonObject;
-import jakarta.ws.rs.core.MultivaluedHashMap;
-import jakarta.ws.rs.core.MultivaluedMap;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.logging.Logger;
 
+import javax.json.JsonArray;
+import javax.json.JsonObject;
 import javax.management.openmbean.OpenDataException;
 import javax.management.openmbean.TabularData;
+import javax.ws.rs.core.MultivaluedHashMap;
+import javax.ws.rs.core.MultivaluedMap;
 
 import org.apache.cassandra.metrics.CompactionMetrics;
 
@@ -75,7 +75,7 @@ public class CompactionManager extends MetricsMBean implements CompactionManager
             result.put("keyspace", compaction.getString("ks"));
             result.put("columnfamily", compaction.getString("cf"));
             result.put("unit", compaction.getString("unit"));
-            result.put("compactionId", (compaction.containsKey("id"))? compaction.getString("id") : "<none>");
+            result.put("compactionId", "<none>");
             results.add(result);
         }
         return results;

src/main/java/org/apache/cassandra/gms/FailureDetector.java

@@ -24,13 +24,13 @@
 
 package org.apache.cassandra.gms;
 
-import jakarta.json.JsonArray;
-import jakarta.json.JsonObject;
-import jakarta.json.JsonValue;
 import java.net.UnknownHostException;
 import java.util.HashMap;
 import java.util.Map;
 
+import javax.json.JsonArray;
+import javax.json.JsonObject;
+import javax.json.JsonValue;
 import javax.management.openmbean.CompositeData;
 import javax.management.openmbean.CompositeDataSupport;
 import javax.management.openmbean.CompositeType;

src/main/java/org/apache/cassandra/gms/Gossiper.java

@@ -23,11 +23,12 @@
  */
 package org.apache.cassandra.gms;
 
-import jakarta.ws.rs.core.MultivaluedHashMap;
-import jakarta.ws.rs.core.MultivaluedMap;
 import java.net.UnknownHostException;
 import java.util.logging.Logger;
 
+import javax.ws.rs.core.MultivaluedHashMap;
+import javax.ws.rs.core.MultivaluedMap;
+
 import com.scylladb.jmx.api.APIClient;
 import com.scylladb.jmx.metrics.APIMBean;
 

src/main/java/org/apache/cassandra/locator/EndpointSnitchInfo.java

@@ -19,12 +19,13 @@ package org.apache.cassandra.locator;
 
 import static java.util.Collections.singletonMap;
 
-import jakarta.ws.rs.core.MultivaluedHashMap;
-import jakarta.ws.rs.core.MultivaluedMap;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
 import java.util.logging.Logger;
 
+import javax.ws.rs.core.MultivaluedHashMap;
+import javax.ws.rs.core.MultivaluedMap;
+
 import com.scylladb.jmx.api.APIClient;
 import com.scylladb.jmx.metrics.APIMBean;
 

src/main/java/org/apache/cassandra/metrics/CompactionMetrics.java

@@ -23,11 +23,11 @@
  */
 package org.apache.cassandra.metrics;
 
-import jakarta.json.JsonArray;
-import jakarta.json.JsonObject;
 import java.util.HashMap;
 import java.util.Map;
 
+import javax.json.JsonArray;
+import javax.json.JsonObject;
 import javax.management.MalformedObjectNameException;
 
 /**
@@ -55,7 +55,7 @@ public class CompactionMetrics implements Metrics {
 
         registry.register(() -> registry.gauge((client) -> {
             Map<String, Map<String, Integer>> result = new HashMap<>();
-            JsonArray compactions = client.getJsonArray("compaction_manager/metrics/pending_tasks_by_table");
+            JsonArray compactions = client.getJsonArray("compaction_manager/compactions");
 
             for (int i = 0; i < compactions.size(); i++) {
                 JsonObject c = compactions.getJsonObject(i);
@@ -68,7 +68,7 @@ public class CompactionMetrics implements Metrics {
                 }
 
                 Map<String, Integer> map = result.get(ks);
-                map.put(cf, (int)(c.getJsonNumber("task").longValue()));
+                map.put(cf, (int)(c.getJsonNumber("total").longValue() - c.getJsonNumber("completed").longValue()));
             }
             return result;
         }), factory.createMetricName("PendingTasksByTableName"));

src/main/java/org/apache/cassandra/metrics/MetricsRegistry.java

@@ -21,9 +21,6 @@ import static com.scylladb.jmx.api.APIClient.getReader;
 import static java.lang.Math.floor;
 import static java.util.logging.Level.SEVERE;
 
-import jakarta.json.JsonArray;
-import jakarta.json.JsonNumber;
-import jakarta.json.JsonObject;
 import java.util.Arrays;
 import java.util.Locale;
 import java.util.concurrent.TimeUnit;
@@ -32,6 +29,9 @@ import java.util.function.Function;
 import java.util.function.Supplier;
 import java.util.logging.Logger;
 
+import javax.json.JsonArray;
+import javax.json.JsonNumber;
+import javax.json.JsonObject;
 import javax.management.InstanceAlreadyExistsException;
 import javax.management.MBeanRegistrationException;
 import javax.management.MBeanServer;

src/main/java/org/apache/cassandra/metrics/StreamingMetrics.java

@@ -24,23 +24,20 @@
 package org.apache.cassandra.metrics;
 
 import static java.util.Arrays.asList;
+import static java.util.Collections.emptySet;
 import static org.apache.cassandra.metrics.DefaultNameFactory.createMetricName;
 
-import jakarta.json.JsonArray;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
-import java.util.EnumSet;
 import java.util.HashSet;
 import java.util.Set;
 
+import javax.json.JsonArray;
 import javax.management.MalformedObjectNameException;
 import javax.management.ObjectName;
-import javax.management.OperationsException;
 
 import com.scylladb.jmx.api.APIClient;
 import com.scylladb.jmx.metrics.APIMBean;
-import com.scylladb.jmx.metrics.RegistrationChecker;
-import com.scylladb.jmx.metrics.RegistrationMode;
 import com.sun.jmx.mbeanserver.JmxMBeanServer;
 
 /**
@@ -68,44 +65,45 @@ public class StreamingMetrics {
         return TYPE_NAME.equals(n.getKeyProperty("type"));
     }
 
-	public static RegistrationChecker createRegistrationChecker() {
-		return new RegistrationChecker() {			
-			@Override
-			protected void doCheck(APIClient client, JmxMBeanServer server, EnumSet<RegistrationMode> mode) throws OperationsException, UnknownHostException {
-				Set<ObjectName> all = new HashSet<ObjectName>(globalNames);
-				JsonArray streams = client.getJsonArray("/stream_manager/");
-				for (int i = 0; i < streams.size(); i++) {
-					JsonArray sessions = streams.getJsonObject(i).getJsonArray("sessions");
-					for (int j = 0; j < sessions.size(); j++) {
-						String peer = sessions.getJsonObject(j).getString("peer");
-						String scope = InetAddress.getByName(peer).getHostAddress().replaceAll(":", ".");
-						all.add(createMetricName(TYPE_NAME, "IncomingBytes", scope));
-						all.add(createMetricName(TYPE_NAME, "OutgoingBytes", scope));
-					}
-				}
+    public static void unregister(APIClient client, JmxMBeanServer server) throws MalformedObjectNameException {
+        APIMBean.checkRegistration(server, emptySet(), StreamingMetrics::isStreamingName, (n) -> null);
+    }
 
-				MetricsRegistry registry = new MetricsRegistry(client, server);
-				APIMBean.checkRegistration(server, all, mode, StreamingMetrics::isStreamingName, n -> {
-					String scope = n.getKeyProperty("scope");
-					String name = n.getKeyProperty("name");
+    public static boolean checkRegistration(APIClient client, JmxMBeanServer server)
+            throws MalformedObjectNameException, UnknownHostException {
 
-					String url = null;
-					if ("ActiveOutboundStreams".equals(name)) {
-						url = "/stream_manager/metrics/outbound";
-					} else if ("IncomingBytes".equals(name) || "TotalIncomingBytes".equals(name)) {
-						url = "/stream_manager/metrics/incoming";
-					} else if ("OutgoingBytes".equals(name) || "TotalOutgoingBytes".equals(name)) {
-						url = "/stream_manager/metrics/outgoing";
-					}
-					if (url == null) {
-						throw new IllegalArgumentException();
-					}
-					if (scope != null) {
-						url = url + "/" + scope;
-					}
-					return registry.counter(url);
-				});
-			}
-		};
-	}
+        Set<ObjectName> all = new HashSet<ObjectName>(globalNames);
+        JsonArray streams = client.getJsonArray("/stream_manager/");
+        for (int i = 0; i < streams.size(); i++) {
+            JsonArray sessions = streams.getJsonObject(i).getJsonArray("sessions");
+            for (int j = 0; j < sessions.size(); j++) {
+                String peer = sessions.getJsonObject(j).getString("peer");
+                String scope = InetAddress.getByName(peer).getHostAddress().replaceAll(":", ".");
+                all.add(createMetricName(TYPE_NAME, "IncomingBytes", scope));
+                all.add(createMetricName(TYPE_NAME, "OutgoingBytes", scope));
+            }
+        }
+
+        MetricsRegistry registry = new MetricsRegistry(client, server);
+        return APIMBean.checkRegistration(server, all, StreamingMetrics::isStreamingName, n -> {
+            String scope = n.getKeyProperty("scope");
+            String name = n.getKeyProperty("name");
+
+            String url = null;
+            if ("ActiveOutboundStreams".equals(name)) {
+                url = "/stream_manager/metrics/outbound";
+            } else if ("IncomingBytes".equals(name) || "TotalIncomingBytes".equals(name)) {
+                url = "/stream_manager/metrics/incoming";
+            } else if ("OutgoingBytes".equals(name) || "TotalOutgoingBytes".equals(name)) {
+                url = "/stream_manager/metrics/outgoing";
+            }
+            if (url == null) {
+                throw new IllegalArgumentException();
+            }
+            if (scope != null) {
+                url = url + "/" + scope;
+            }
+            return registry.counter(url);
+        });
+    }
 }

src/main/java/org/apache/cassandra/metrics/TableMetrics.java

@@ -19,8 +19,6 @@ package org.apache.cassandra.metrics;
 
 import static com.scylladb.jmx.api.APIClient.getReader;
 
-import java.io.InvalidObjectException;
-import java.io.ObjectStreamException;
 import java.util.Hashtable;
 import java.util.function.BiFunction;
 import java.util.function.Function;
@@ -297,6 +295,7 @@ public class TableMetrics implements Metrics {
         registry.createDummyTableGauge(Double.class, "PercentRepaired");
     }
 
+    @SuppressWarnings("serial")
     static class TableMetricObjectName extends javax.management.ObjectName {
         private final TableMetricStringNameFactory factory;
         private final String metricName;
@@ -401,18 +400,6 @@ public class TableMetrics implements Metrics {
         public boolean isPropertyValuePattern() {
             return false;
         }
-        
-        /**
-         * This type is not really serializable. 
-         * Replace it with vanilla objectname.
-         */
-		private Object writeReplace() throws ObjectStreamException {
-			try {
-				return new ObjectName(getDomain(), getKeyPropertyList());
-			} catch (MalformedObjectNameException e) {
-				throw new InvalidObjectException(toString());
-			}
-		}
     }
 
     static interface TableMetricStringNameFactory {

src/main/java/org/apache/cassandra/net/MessagingService.java

@@ -24,8 +24,6 @@ package org.apache.cassandra.net;
 
 import static java.util.Collections.emptyMap;
 
-import jakarta.json.JsonArray;
-import jakarta.json.JsonObject;
 import java.net.UnknownHostException;
 import java.util.HashMap;
 import java.util.Map;
@@ -34,6 +32,9 @@ import java.util.logging.Logger;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
+import javax.json.JsonArray;
+import javax.json.JsonObject;
+
 import org.apache.cassandra.metrics.DroppedMessageMetrics;
 
 import com.scylladb.jmx.api.APIClient;

src/main/java/org/apache/cassandra/service/CacheService.java

@@ -24,11 +24,12 @@
 
 package org.apache.cassandra.service;
 
-import jakarta.ws.rs.core.MultivaluedHashMap;
-import jakarta.ws.rs.core.MultivaluedMap;
 import java.util.concurrent.ExecutionException;
 import java.util.logging.Logger;
 
+import javax.ws.rs.core.MultivaluedHashMap;
+import javax.ws.rs.core.MultivaluedMap;
+
 import org.apache.cassandra.metrics.CacheMetrics;
 
 import com.scylladb.jmx.api.APIClient;

src/main/java/org/apache/cassandra/service/PerTableSSTableInfo.java

@@ -1,66 +0,0 @@
-package org.apache.cassandra.service;
-
-import static com.sun.jmx.mbeanserver.MXBeanMappingFactory.DEFAULT;
-
-import jakarta.xml.bind.annotation.XmlRootElement;
-import java.io.InvalidObjectException;
-import java.util.List;
-
-import javax.management.openmbean.CompositeData;
-import javax.management.openmbean.OpenDataException;
-
-import com.sun.jmx.mbeanserver.MXBeanMapping;
-
-@SuppressWarnings("restriction")
-@XmlRootElement
-public class PerTableSSTableInfo {
-    private static final MXBeanMapping mxBeanMapping;
-
-    static {
-        try {
-            mxBeanMapping = DEFAULT.mappingForType(PerTableSSTableInfo.class, DEFAULT);
-        } catch (OpenDataException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-    private String keyspace;
-    private List<SSTableInfo> sstables;
-    private String table;
-
-    public String getTable() {
-        return table;
-    }
-
-    public void setTable(String table) {
-        this.table = table;
-    }
-
-    public String getKeyspace() {
-        return keyspace;
-    }
-
-    public void setKeyspace(String keyspace) {
-        this.keyspace = keyspace;
-    }
-
-    public List<SSTableInfo> getSSTables() {
-        return sstables;
-    }
-
-    public void setSSTableInfos(List<SSTableInfo> sstableInfos) {
-        this.sstables = sstableInfos;
-    }
-
-    public CompositeData toCompositeData() {
-        try {
-            return (CompositeData) mxBeanMapping.toOpenValue(this);
-        } catch (OpenDataException e) {
-            throw new Error(e); // should not reach.
-        }
-    }
-
-    public static PerTableSSTableInfo from(CompositeData data) throws InvalidObjectException {
-        return (PerTableSSTableInfo) mxBeanMapping.fromOpenValue(data);
-    }
-}

src/main/java/org/apache/cassandra/service/SSTableInfo.java

@@ -1,153 +0,0 @@
-package org.apache.cassandra.service;
-
-import jakarta.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
-import java.util.Collections;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.scylladb.jmx.utils.DateXmlAdapter;
-
-public class SSTableInfo {
-    private long size;
-
-    @JsonProperty("data_size")
-    private long dataSize;
-
-    @JsonProperty("index_size")
-    private long indexSize;
-
-    @JsonProperty("filter_size")
-    private long filterSize;
-
-    @XmlJavaTypeAdapter(type = Date.class, value = DateXmlAdapter.class)
-    private Date timestamp;
-
-    private long generation;
-
-    private long level;
-
-    private String version;
-
-    private Map<String, String> properties;
-
-    public void setProperties(Map<String, String> properties) {
-        this.properties = properties;
-    }
-
-    @JsonIgnore
-    private Map<String, Map<String, String>> extendedProperties;
-
-    public String getVersion() {
-        return version;
-    }
-
-    public void setVersion(String version) {
-        this.version = version;
-    }
-
-    public long getSize() {
-        return size;
-    }
-
-    public void setSize(long size) {
-        this.size = size;
-    }
-
-    public long getDataSize() {
-        return dataSize;
-    }
-
-    public void setDataSize(long dataSize) {
-        this.dataSize = dataSize;
-    }
-
-    public long getIndexSize() {
-        return indexSize;
-    }
-
-    public void setIndexSize(long indexSize) {
-        this.indexSize = indexSize;
-    }
-
-    public long getFilterSize() {
-        return filterSize;
-    }
-
-    public void setFilterSize(long filterSize) {
-        this.filterSize = filterSize;
-    }
-
-    public Date getTimestamp() {
-        return timestamp;
-    }
-
-    public void setTimestamp(Date timestamp) {
-        this.timestamp = timestamp;
-    }
-
-    public long getGeneration() {
-        return generation;
-    }
-
-    public void setGeneration(long generation) {
-        this.generation = generation;
-    }
-
-    public long getLevel() {
-        return level;
-    }
-
-    public void setLevel(long level) {
-        this.level = level;
-    }
-
-    public Map<String, String> getProperties() {
-        return properties;
-    }
-
-    public Map<String, Map<String, String>> getExtendedProperties() {
-        return extendedProperties;
-    }
-
-    public void setExtendedProperties(Map<String, Map<String, String>> extendedProperties) {
-        this.extendedProperties = extendedProperties;
-    }
-
-    @JsonProperty("properties")
-    private void unpackProperties(List<Map<String, String>> maps) {
-        Map<String, String> result = new HashMap<>();
-        for (Map<String, String> map : maps) {
-            String key = map.get("key");
-            String value = map.get("value");
-            result.put(key, value);
-        }
-        properties = result;
-    }
-
-    @JsonProperty("extended_properties")
-    private void unpackNested(List<Map<String, Object>> properties) {
-        Map<String, Map<String, String>> result = new HashMap<String, Map<String, String>>();
-
-        for (Map<String, Object> map : properties) {
-            Object name = map.get("group");
-            if (name != null) {
-                Map<String, String> dst = new HashMap<>();
-                List<?> value = (List<?>) map.get("attributes");
-                for (Object v : value) {
-                    Map<?, ?> subMap = (Map<?, ?>) v;
-                    dst.put(String.valueOf(subMap.get("key")), String.valueOf(subMap.get("value")));
-                }
-                result.put(String.valueOf(name), dst);
-            } else {
-                for (Map.Entry<String, Object> e : map.entrySet()) {
-                    result.put(e.getKey(), Collections.singletonMap(String.valueOf(e.getValue()), ""));
-                }
-            }
-        }
-        extendedProperties = result;
-    }
-}

src/main/java/org/apache/cassandra/service/StorageProxy.java

@@ -25,15 +25,18 @@ package org.apache.cassandra.service;
 
 import static java.util.Collections.emptySet;
 
-import jakarta.json.JsonArray;
-import jakarta.ws.rs.core.MultivaluedHashMap;
-import jakarta.ws.rs.core.MultivaluedMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.logging.Logger;
 
+import javax.json.JsonArray;
+import javax.json.JsonObject;
+import javax.management.ObjectName;
+import javax.ws.rs.core.MultivaluedHashMap;
+import javax.ws.rs.core.MultivaluedMap;
+
 import org.apache.cassandra.db.ColumnFamilyStore;
 import org.apache.cassandra.metrics.CASClientRequestMetrics;
 import org.apache.cassandra.metrics.ClientRequestMetrics;
@@ -56,8 +59,7 @@ public class StorageProxy extends MetricsMBean implements StorageProxyMBean {
                 new ClientRequestMetrics("RangeSlice", "/storage_proxy/metrics/range"),
                 new ClientRequestMetrics("Write", "storage_proxy/metrics/write"),
                 new CASClientRequestMetrics("CASWrite", "storage_proxy/metrics/cas_write"),
-                new CASClientRequestMetrics("CASRead", "storage_proxy/metrics/cas_read"),
-                new ClientRequestMetrics("ViewWrite", "storage_proxy/metrics/view_write"));
+                new CASClientRequestMetrics("CASRead", "storage_proxy/metrics/cas_read"));
     }
 
     @Override

src/main/java/org/apache/cassandra/service/StorageService.java

@@ -24,16 +24,10 @@ package org.apache.cassandra.service;
 
 import static java.util.Arrays.asList;
 
-import jakarta.json.JsonArray;
-import jakarta.json.JsonObject;
-import jakarta.ws.rs.core.GenericType;
-import jakarta.ws.rs.core.MultivaluedHashMap;
-import jakarta.ws.rs.core.MultivaluedMap;
 import java.io.IOException;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
 import java.nio.ByteBuffer;
-import java.util.Arrays;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.HashMap;
@@ -48,8 +42,9 @@ import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeoutException;
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.logging.Logger;
-import java.util.stream.Collectors;
 
+import javax.json.JsonArray;
+import javax.json.JsonObject;
 import javax.management.ListenerNotFoundException;
 import javax.management.MBeanNotificationInfo;
 import javax.management.Notification;
@@ -57,24 +52,19 @@ import javax.management.NotificationBroadcaster;
 import javax.management.NotificationBroadcasterSupport;
 import javax.management.NotificationFilter;
 import javax.management.NotificationListener;
-import javax.management.openmbean.CompositeData;
-import javax.management.openmbean.CompositeDataSupport;
-import javax.management.openmbean.CompositeType;
-import javax.management.openmbean.OpenDataException;
-import javax.management.openmbean.OpenType;
-import javax.management.openmbean.SimpleType;
 import javax.management.openmbean.TabularData;
-import javax.management.openmbean.TabularDataSupport;
-import javax.management.openmbean.TabularType;
+import javax.ws.rs.core.MultivaluedHashMap;
+import javax.ws.rs.core.MultivaluedMap;
 
 import org.apache.cassandra.metrics.StorageMetrics;
 import org.apache.cassandra.repair.RepairParallelism;
+import org.glassfish.jersey.client.ClientConfig;
+import org.glassfish.jersey.client.ClientProperties;
 
 import com.google.common.base.Joiner;
 import com.scylladb.jmx.api.APIClient;
 import com.scylladb.jmx.metrics.MetricsMBean;
-import com.scylladb.jmx.api.utils.FileUtils;
-import com.google.common.base.Throwables;
+import com.scylladb.jmx.utils.FileUtils;
 
 /**
  * This abstraction contains the token/identifier of this node on the identifier
@@ -85,41 +75,6 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
     private static final Logger logger = Logger.getLogger(StorageService.class.getName());
     private static final Timer timer = new Timer("Storage Service Repair", true);
 
-    private static final String[] COUNTER_NAMES = new String[]{"raw", "count", "error", "string"};
-    private static final String[] COUNTER_DESCS = new String[]
-    { "partition key in raw hex bytes",
-      "value of this partition for given sampler",
-      "value is within the error bounds plus or minus of this",
-      "the partition key turned into a human readable format" };
-    private static final CompositeType COUNTER_COMPOSITE_TYPE;
-    private static final TabularType COUNTER_TYPE;
-
-    private static final String[] OPERATION_NAMES = new String[]{"read", "write"};
-
-    private static final String[] SAMPLER_NAMES = new String[]{"cardinality", "partitions"};
-    private static final String[] SAMPLER_DESCS = new String[]
-    { "cardinality of partitions",
-      "list of counter results" };
-
-    private static final String SAMPLING_RESULTS_NAME = "SAMPLING_RESULTS";
-    private static final CompositeType SAMPLING_RESULT;
-
-    static
-    {
-        try
-        {
-            OpenType<?>[] counterTypes = new OpenType[] { SimpleType.STRING, SimpleType.LONG, SimpleType.LONG, SimpleType.STRING };
-            COUNTER_COMPOSITE_TYPE = new CompositeType(SAMPLING_RESULTS_NAME, SAMPLING_RESULTS_NAME, COUNTER_NAMES, COUNTER_DESCS, counterTypes);
-            COUNTER_TYPE = new TabularType(SAMPLING_RESULTS_NAME, SAMPLING_RESULTS_NAME, COUNTER_COMPOSITE_TYPE, COUNTER_NAMES);
-
-            OpenType<?>[] samplerTypes = new OpenType[] { SimpleType.LONG, COUNTER_TYPE };
-            SAMPLING_RESULT = new CompositeType(SAMPLING_RESULTS_NAME, SAMPLING_RESULTS_NAME, SAMPLER_NAMES, SAMPLER_DESCS, samplerTypes);
-        } catch (OpenDataException e)
-        {
-            throw Throwables.propagate(e);
-        }
-    }
-
     private final NotificationBroadcasterSupport notificationBroadcasterSupport = new NotificationBroadcasterSupport();
 
     @Override
@@ -314,7 +269,7 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
     @Override
     public Map<List<String>, List<String>> getRangeToEndpointMap(String keyspace) {
         log(" getRangeToEndpointMap(String keyspace)");
-        return client.getMapListStrValue("/storage_service/range_to_endpoint_map/" + keyspace);
+        return client.getMapListStrValue("/storage_service/range/" + keyspace);
     }
 
     /**
@@ -520,12 +475,6 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
         return client.getListInetAddressValue("");
     }
 
-    @Override
-    public void checkAndRepairCdcStreams() throws IOException {
-        log(" checkAndRepairCdcStreams() throws IOException");
-        client.post("/storage_service/cdc_streams_check_and_repair");
-    }
-
     /**
      * Takes the snapshot for the given keyspaces. A snapshot name must be
      * specified.
@@ -552,9 +501,7 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
             APIClient.set_query_param(queryParams, "cf", parts[1]);
         }
         APIClient.set_query_param(queryParams, "kn", APIClient.join(keyspaceNames));
-        if (options.containsKey("skipFlush")) {
-            APIClient.set_query_param(queryParams, "sf", options.get("skipFlush"));
-        }
+        // TODO: origin has one recognized option: skip flush. We don't.
         client.post("/storage_service/snapshots", queryParams);
     }
 
@@ -657,8 +604,7 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
     }
 
     @Override 
-    public void forceKeyspaceCompactionForTokenRange(String keyspaceName, String startToken, String endToken,
-            String... tableNames) throws IOException, ExecutionException, InterruptedException {
+    public void forceKeyspaceCompactionForTokenRange(String keyspaceName, String startToken, String endToken, String... tableNames) throws IOException, ExecutionException, InterruptedException {
         // TODO: actually handle token ranges.
         forceKeyspaceCompaction(keyspaceName, tableNames);
     }
@@ -697,7 +643,7 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
         APIClient.set_bool_query_param(queryParams, "disable_snapshot", disableSnapshot);
         APIClient.set_bool_query_param(queryParams, "skip_corrupted", skipCorrupted);
         APIClient.set_query_param(queryParams, "cf", APIClient.join(columnFamilies));
-        return client.getIntValue("/storage_service/keyspace_scrub/" + keyspaceName, queryParams);
+        return client.getIntValue("/storage_service/keyspace_scrub/" + keyspaceName);
     }
 
     /**
@@ -923,7 +869,7 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
     @Deprecated
     public int forceRepairAsync(String keyspace, boolean isSequential, Collection<String> dataCenters,
             Collection<String> hosts, boolean primaryRange, boolean repairedAt, String... columnFamilies)
-            throws IOException {
+                    throws IOException {
         log(" forceRepairAsync(String keyspace, boolean isSequential, Collection<String> dataCenters, Collection<String> hosts,  boolean primaryRange, boolean repairedAt, String... columnFamilies) throws IOException");
         return repairRangeAsync(null, null, keyspace, isSequential, dataCenters, hosts, primaryRange, repairedAt,
                 columnFamilies);
@@ -991,21 +937,13 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
      *            the host id to remove
      */
     @Override
-    public void removeNode(String hostIdString, String ignoreNodes) {
-        log(" removeNode(String token, String ignoreNodes)");
+    public void removeNode(String hostIdString) {
+        log(" removeNode(String token)");
         MultivaluedMap<String, String> queryParams = new MultivaluedHashMap<String, String>();
         APIClient.set_query_param(queryParams, "host_id", hostIdString);
-        if (ignoreNodes != null) {
-            APIClient.set_query_param(queryParams, "ignore_nodes", ignoreNodes);
-        }
         client.post("/storage_service/remove_node", queryParams);
     }
 
-    public void removeNode(String hostIdString) {
-        String ignoreNodes = null;
-        removeNode(hostIdString, ignoreNodes);
-    }
-
     /**
      * Get the status of a token removal.
      */
@@ -1360,19 +1298,12 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
     }
 
     /**
-     * Same as {@link #rebuild(String)}, but only for specified keyspace and
-     * ranges.
+     * Same as {@link #rebuild(String)}, but only for specified keyspace and ranges.
      *
-     * @param sourceDc
-     *            Name of DC from which to select sources for streaming or null
-     *            to pick any node
-     * @param keyspace
-     *            Name of the keyspace which to rebuild or null to rebuild all
-     *            keyspaces.
-     * @param tokens
-     *            Range of tokens to rebuild or null to rebuild all token
-     *            ranges. In the format of:
-     *            "(start_token_1,end_token_1],(start_token_2,end_token_2],...(start_token_n,end_token_n]"
+     * @param sourceDc Name of DC from which to select sources for streaming or null to pick any node
+     * @param keyspace Name of the keyspace which to rebuild or null to rebuild all keyspaces.
+     * @param tokens Range of tokens to rebuild or null to rebuild all token ranges. In the format of:
+     *               "(start_token_1,end_token_1],(start_token_2,end_token_2],...(start_token_n,end_token_n]"
      */
     @Override
     public void rebuild(String sourceDc, String keyspace, String tokens, String specificSources) {
@@ -1425,25 +1356,15 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
      *            The parent keyspace name
      * @param cfName
      *            The ColumnFamily name where SSTables belong
-     * @param isLoadAndStream
-     *            Whether or not arbitrary SSTables should be loaded (and streamed to the owning nodes)
      */
     @Override
-    public void loadNewSSTables(String ksName, String cfName, boolean isLoadAndStream) {
-        log(" loadNewSSTables(String ksName, String cfName, boolean isLoadAndStream)");
+    public void loadNewSSTables(String ksName, String cfName) {
+        log(" loadNewSSTables(String ksName, String cfName)");
         MultivaluedMap<String, String> queryParams = new MultivaluedHashMap<String, String>();
         queryParams.add("cf", cfName);
-        if (isLoadAndStream) {
-            queryParams.add("load_and_stream", "true");
-        }
         client.post("/storage_service/sstables/" + ksName, queryParams);
     }
 
-    @Override
-    public void loadNewSSTables(String ksName, String cfName) {
-        loadNewSSTables(ksName, cfName, false);
-    }
-
     /**
      * Return a List of Tokens representing a sample of keys across all
      * ColumnFamilyStores.
@@ -1514,7 +1435,13 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
         log("enableAutoCompaction(String ks, String... columnFamilies)");
         MultivaluedMap<String, String> queryParams = new MultivaluedHashMap<String, String>();
         APIClient.set_query_param(queryParams, "cf", APIClient.join(columnFamilies));
-        client.post("/storage_service/auto_compaction/" + ks, queryParams);
+        try {
+            client.post("/storage_service/auto_compaction/" + ks, queryParams);
+        } catch (RuntimeException e) {
+            // FIXME should throw the right exception
+            throw new IOException(e.getMessage());
+        }
+
     }
 
     @Override
@@ -1733,7 +1660,7 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
     public int scrub(boolean disableSnapshot, boolean skipCorrupted, boolean checkData, int jobs, String keyspaceName,
             String... columnFamilies) throws IOException, ExecutionException, InterruptedException {
         // "jobs" not (yet) relevant for scylla. (though possibly useful...)
-        return scrub(disableSnapshot, skipCorrupted, checkData, keyspaceName, columnFamilies);
+        return scrub(disableSnapshot, skipCorrupted, checkData, 0, keyspaceName, columnFamilies);
     }
 
     @Override
@@ -1777,99 +1704,4 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
         log(" resumeBootstrap");
         return false;
     }
-
-    @Override
-    public List<CompositeData> getSSTableInfo(String keyspace, String table) {
-        if (keyspace == null && table != null) {
-            throw new IllegalArgumentException("Missing keyspace name");
-        }
-        MultivaluedMap<String, String> queryParams = null;
-
-        if (keyspace != null) {
-            queryParams = new MultivaluedHashMap<String, String>();
-            queryParams.add("keyspace", keyspace);
-        }
-        if (table != null) {
-            queryParams.add("cf", table);
-        }
-
-        return client.get("/storage_service/sstable_info", queryParams)
-                .get(new GenericType<List<PerTableSSTableInfo>>() {
-                }).stream().map((i) -> i.toCompositeData()).collect(Collectors.toList());
-    }
-    
-    @Override
-    public List<CompositeData> getSSTableInfo() {
-        return getSSTableInfo(null, null);
-    }
-
-    @Override
-    public int scrub(boolean disableSnapshot, boolean skipCorrupted, boolean checkData, boolean reinsertOverflowedTTL,
-            int jobs, String keyspaceName, String... columnFamilies)
-            throws IOException, ExecutionException, InterruptedException {
-        MultivaluedMap<String, String> queryParams = new MultivaluedHashMap<String, String>();
-        APIClient.set_bool_query_param(queryParams, "disable_snapshot", disableSnapshot);
-        APIClient.set_bool_query_param(queryParams, "skip_corrupted", skipCorrupted);
-        APIClient.set_query_param(queryParams, "cf", APIClient.join(columnFamilies));
-        return client.getIntValue("/storage_service/keyspace_scrub/" + keyspaceName, queryParams);
-    }
-
-    @Override
-    public int scrub(boolean disableSnapshot, String scrubMode, boolean checkData, boolean reinsertOverflowedTTL,
-            int jobs, String keyspaceName, String... columnFamilies)
-            throws IOException, ExecutionException, InterruptedException {
-        MultivaluedMap<String, String> queryParams = new MultivaluedHashMap<String, String>();
-        APIClient.set_bool_query_param(queryParams, "disable_snapshot", disableSnapshot);
-        if (!"".equals(scrubMode)) {
-            APIClient.set_query_param(queryParams, "scrub_mode", scrubMode);
-        }
-        APIClient.set_query_param(queryParams, "cf", APIClient.join(columnFamilies));
-        return client.getIntValue("/storage_service/keyspace_scrub/" + keyspaceName, queryParams);
-    }
-
-    @Override
-    public long getUptime() {
-        log("getUptime()");
-        return client.getLongValue("/system/uptime_ms");
-    }
-
-    @Override
-    public CompositeData getToppartitions(String sampler, List<String> keyspaceFilters, List<String> tableFilters, int duration, int capacity, int count) throws OpenDataException {
-        return getToppartitions(Arrays.asList(sampler), keyspaceFilters, tableFilters, duration, capacity, count).get(sampler.toLowerCase());
-    }
-
-    @Override
-    public Map<String, CompositeData> getToppartitions(List<String> samplers, List<String> keyspaceFilters, List<String> tableFilters, int duration, int capacity, int count) throws OpenDataException {
-        MultivaluedMap<String, String> queryParams = new MultivaluedHashMap<String, String>();
-        APIClient.set_query_param(queryParams, "duration", Integer.toString(duration));
-        APIClient.set_query_param(queryParams, "capacity", Integer.toString(capacity));
-        APIClient.set_query_param(queryParams, "keyspace_filters", keyspaceFilters != null ? APIClient.join(keyspaceFilters.toArray(new String[0])) : null);
-        APIClient.set_query_param(queryParams, "table_filters", tableFilters != null ? APIClient.join(tableFilters.toArray(new String[0])) : null);
-        JsonObject result = client.getJsonObj("/storage_service/toppartitions", queryParams);
-
-        Map<String, CompositeData> resultsMap = new HashMap<>();
-
-        for (String operation : OPERATION_NAMES) {
-            JsonArray counters = result.getJsonArray(operation);
-            long cardinality = result.getJsonNumber(operation + "_cardinality").longValue();
-            long size = 0;
-            TabularDataSupport tabularResult = new TabularDataSupport(COUNTER_TYPE);
-
-            if (counters != null) {
-                size = (count > counters.size()) ? counters.size() : count;
-                for (int i = 0; i < size; i++) {
-                    JsonObject counter = counters.getJsonObject(i);
-                    tabularResult.put(new CompositeDataSupport(COUNTER_COMPOSITE_TYPE, COUNTER_NAMES,
-                            new Object[] { counter.getString("partition"), // raw
-                                    counter.getJsonNumber("count").longValue(), // count
-                                    counter.getJsonNumber("error").longValue(), // error
-                                    counter.getString("partition") })); // string
-                }
-            }
-
-            resultsMap.put(operation + "s", new CompositeDataSupport(SAMPLING_RESULT, SAMPLER_NAMES, new Object[] { cardinality, tabularResult }));
-        }
-
-        return resultsMap;
-    }
 }

src/main/java/org/apache/cassandra/service/StorageServiceMBean.java

@@ -35,9 +35,7 @@ import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeoutException;
 
 import javax.management.NotificationEmitter;
-import javax.management.openmbean.CompositeData;
 import javax.management.openmbean.TabularData;
-import javax.management.openmbean.OpenDataException;
 
 public interface StorageServiceMBean extends NotificationEmitter {
     /**
@@ -214,7 +212,6 @@ public interface StorageServiceMBean extends NotificationEmitter {
 
     public List<InetAddress> getNaturalEndpoints(String keyspaceName, ByteBuffer key);
 
-    public void checkAndRepairCdcStreams() throws IOException;
     /**
      * Takes the snapshot for the given keyspaces. A snapshot name must be
      * specified.
@@ -350,10 +347,6 @@ public interface StorageServiceMBean extends NotificationEmitter {
      * scrubbed.
      *
      * Scrubbed CFs will be snapshotted first, if disableSnapshot is false
-     *
-     * scrubMode controls what scrub does when encountering corruption.
-     * It replaces skipCorrupted where skipCorrupted is equivalent to scrubMode="SKIP".
-     * Can be one of: "ABORT", "SKIP", "SEGREGATE", or "VALIDATE".
      */
     @Deprecated
     public int scrub(boolean disableSnapshot, boolean skipCorrupted, String keyspaceName, String... tableNames)
@@ -363,19 +356,9 @@ public interface StorageServiceMBean extends NotificationEmitter {
     public int scrub(boolean disableSnapshot, boolean skipCorrupted, boolean checkData, String keyspaceName,
             String... tableNames) throws IOException, ExecutionException, InterruptedException;
 
-    @Deprecated
     public int scrub(boolean disableSnapshot, boolean skipCorrupted, boolean checkData, int jobs, String keyspaceName,
             String... columnFamilies) throws IOException, ExecutionException, InterruptedException;
 
-    @Deprecated
-    public int scrub(boolean disableSnapshot, boolean skipCorrupted, boolean checkData, boolean reinsertOverflowedTTL,
-            int jobs, String keyspaceName, String... columnFamilies)
-            throws IOException, ExecutionException, InterruptedException;
-
-    public int scrub(boolean disableSnapshot, String scrubMode, boolean checkData, boolean reinsertOverflowedTTL,
-            int jobs, String keyspaceName, String... columnFamilies)
-            throws IOException, ExecutionException, InterruptedException;
-
     /**
      * Verify (checksums of) the given keyspace. If tableNames array is empty,
      * all CFs are verified.
@@ -513,11 +496,8 @@ public interface StorageServiceMBean extends NotificationEmitter {
      * removeToken removes token (and all data associated with enpoint that had
      * it) from the ring
      */
-    @Deprecated
     public void removeNode(String token);
 
-    public void removeNode(String token, String ignoreNodes);
-
     /**
      * Get the status of a token removal.
      */
@@ -810,16 +790,7 @@ public interface StorageServiceMBean extends NotificationEmitter {
      *            The parent keyspace name
      * @param cfName
      *            The ColumnFamily name where SSTables belong
-     * @param isLoadAndStream
-     *            Whether or not arbitrary SSTables should be loaded (and streamed to the owning nodes)
      */
-    public void loadNewSSTables(String ksName, String cfName, boolean isLoadAndStream);
-
-    /**
-     * @deprecated use {@link #loadNewSSTables(String ksName, String cfName, boolean isLoadAndStream)} instead.
-     * This is kept for backward compatibility.
-     */
-    @Deprecated
     public void loadNewSSTables(String ksName, String cfName);
 
     /**
@@ -901,15 +872,4 @@ public interface StorageServiceMBean extends NotificationEmitter {
      * Sets the hinted handoff throttle in kb per second, per delivery thread.
      */
     public boolean resumeBootstrap();
-    
-    public List<CompositeData> getSSTableInfo(String keyspace, String table);
-
-    public List<CompositeData> getSSTableInfo();
-    
-    /** retun the system uptime */
-    public long getUptime();
-
-    public CompositeData getToppartitions(String sampler, List<String> keyspaceFilters, List<String> tableFilters, int duration, int capacity, int count) throws OpenDataException;
-    
-    public Map<String, CompositeData> getToppartitions(List<String> samplers, List<String> keyspaceFilters, List<String> tableFilters, int duration, int capacity, int count) throws OpenDataException;
 }

src/main/java/org/apache/cassandra/streaming/ProgressInfo.java

@@ -24,14 +24,15 @@
 
 package org.apache.cassandra.streaming;
 
-import jakarta.json.JsonArray;
-import jakarta.json.JsonObject;
 import java.io.Serializable;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
 import java.util.HashMap;
 import java.util.Map;
 
+import javax.json.JsonArray;
+import javax.json.JsonObject;
+
 import com.google.common.base.Objects;
 
 /**

src/main/java/org/apache/cassandra/streaming/SessionInfo.java

@@ -24,8 +24,6 @@
 
 package org.apache.cassandra.streaming;
 
-import jakarta.json.JsonArray;
-import jakarta.json.JsonObject;
 import java.io.Serializable;
 import java.net.InetAddress;
 import java.net.UnknownHostException;
@@ -34,6 +32,9 @@ import java.util.HashSet;
 import java.util.Map;
 import java.util.Set;
 
+import javax.json.JsonArray;
+import javax.json.JsonObject;
+
 import com.google.common.collect.Iterables;
 
 /**

src/main/java/org/apache/cassandra/streaming/StreamManager.java

@@ -24,12 +24,12 @@
 
 package org.apache.cassandra.streaming;
 
-import jakarta.json.JsonArray;
-import jakarta.json.JsonObject;
 import java.util.HashSet;
 import java.util.Set;
 import java.util.logging.Logger;
 
+import javax.json.JsonArray;
+import javax.json.JsonObject;
 import javax.management.ListenerNotFoundException;
 import javax.management.MBeanNotificationInfo;
 import javax.management.NotificationBroadcasterSupport;

src/main/java/org/apache/cassandra/streaming/StreamSummary.java

@@ -24,12 +24,13 @@
 
 package org.apache.cassandra.streaming;
 
-import jakarta.json.JsonArray;
-import jakarta.json.JsonObject;
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.UUID;
 
+import javax.json.JsonArray;
+import javax.json.JsonObject;
+
 import com.google.common.base.Objects;
 
 /**