Skip to content

Commit fb70ec3

Browse files
authored
Merge pull request #86 from Kidcredible300/update-to-2.1.4
Update to 2.1.4
2 parents f7ac7f7 + f1ca703 commit fb70ec3

3 files changed

Lines changed: 16 additions & 43 deletions

File tree

pom.xml

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@
8989
<url>https://github.com/apache/accumulo-proxy/actions</url>
9090
</ciManagement>
9191
<properties>
92-
<accumulo.version>2.1.3</accumulo.version>
92+
<accumulo.version>2.1.4</accumulo.version>
9393
<eclipseFormatterStyle>contrib/Eclipse-Accumulo-Codestyle.xml</eclipseFormatterStyle>
9494
<!-- extra release args for testing -->
9595
<extraReleaseArguments />
@@ -98,7 +98,7 @@
9898
<maven.compiler.source>11</maven.compiler.source>
9999
<maven.compiler.target>11</maven.compiler.target>
100100
<maven.test.redirectTestOutputToFile>true</maven.test.redirectTestOutputToFile>
101-
<slf4j.version>2.0.12</slf4j.version>
101+
<slf4j.version>2.0.17</slf4j.version>
102102
<sourceReleaseAssemblyDescriptor>source-release-tar</sourceReleaseAssemblyDescriptor>
103103
<spotbugs.excludeFilterFile>src/main/spotbugs/exclude-filter.xml</spotbugs.excludeFilterFile>
104104
<thrift.version>0.17.0</thrift.version>
@@ -108,14 +108,14 @@
108108
<dependency>
109109
<groupId>io.micrometer</groupId>
110110
<artifactId>micrometer-bom</artifactId>
111-
<version>1.12.2</version>
111+
<version>1.14.5</version>
112112
<type>pom</type>
113113
<scope>import</scope>
114114
</dependency>
115115
<dependency>
116116
<groupId>org.apache.logging.log4j</groupId>
117117
<artifactId>log4j-bom</artifactId>
118-
<version>2.23.1</version>
118+
<version>2.24.3</version>
119119
<type>pom</type>
120120
<scope>import</scope>
121121
</dependency>
@@ -131,7 +131,7 @@
131131
<dependency>
132132
<groupId>com.github.spotbugs</groupId>
133133
<artifactId>spotbugs-annotations</artifactId>
134-
<version>4.8.3</version>
134+
<version>4.9.3</version>
135135
<optional>true</optional>
136136
</dependency>
137137
<dependency>
@@ -143,7 +143,7 @@
143143
<dependency>
144144
<groupId>com.google.guava</groupId>
145145
<artifactId>guava</artifactId>
146-
<version>32.0.0-jre</version>
146+
<version>33.4.6-jre</version>
147147
</dependency>
148148
<dependency>
149149
<groupId>io.micrometer</groupId>
@@ -217,13 +217,13 @@
217217
<dependency>
218218
<groupId>org.easymock</groupId>
219219
<artifactId>easymock</artifactId>
220-
<version>5.1.0</version>
220+
<version>5.5.0</version>
221221
<scope>test</scope>
222222
</dependency>
223223
<dependency>
224224
<groupId>org.junit.jupiter</groupId>
225225
<artifactId>junit-jupiter-api</artifactId>
226-
<version>5.10.1</version>
226+
<version>5.12.1</version>
227227
<scope>test</scope>
228228
</dependency>
229229
</dependencies>

src/main/java/org/apache/accumulo/proxy/Proxy.java

Lines changed: 6 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@
2525
import java.io.UncheckedIOException;
2626
import java.nio.file.Files;
2727
import java.util.Collection;
28-
import java.util.List;
2928
import java.util.Properties;
3029

3130
import org.apache.accumulo.core.cli.Help;
@@ -60,7 +59,6 @@
6059
import com.google.auto.service.AutoService;
6160

6261
import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
63-
import io.micrometer.core.instrument.MeterRegistry;
6462
import io.micrometer.core.instrument.Tag;
6563

6664
@AutoService(KeywordExecutable.class)
@@ -267,53 +265,28 @@ public static ServerAddress createProxyServer(HostAndPort address,
267265
serverSocketTimeout, address);
268266
}
269267

270-
// TODO: This MetricsInfo is a stub Metrics Info to allow the timed processor to build. If Metrics
271-
// are wanted or needed in a later version of the proxy, this can be updated.
268+
// This MetricsInfo is a stub MetricsInfo to allow the timed processor to build.
269+
// Issue #85 in the GitHub regards updating this with a proper implementation.
272270
static private class ProxyMetricsInfo implements MetricsInfo {
273271

274272
@Override
275273
public boolean isMetricsEnabled() {
276274
return false;
277275
}
278276

279-
@Override
280-
public void addServiceTags(String applicationName, HostAndPort hostAndPort) {
281-
throw new UnsupportedOperationException("Unimplemented method 'addServiceTags'");
282-
}
283-
284-
@Override
285-
public void addCommonTags(List<Tag> updates) {
286-
throw new UnsupportedOperationException("Unimplemented method 'addCommonTags'");
287-
}
288-
289-
@Override
290-
public Collection<Tag> getCommonTags() {
291-
throw new UnsupportedOperationException("Unimplemented method 'getCommonTags'");
292-
}
293-
294-
@Override
295-
public void addRegistry(MeterRegistry registry) {
296-
throw new UnsupportedOperationException("Unimplemented method 'addRegistry'");
297-
}
298-
299277
@Override
300278
public void addMetricsProducers(MetricsProducer... producer) {
301279
return;
302280
}
303281

304282
@Override
305-
public void init() {
306-
throw new UnsupportedOperationException("Unimplemented method 'init'");
307-
}
308-
309-
@Override
310-
public MeterRegistry getRegistry() {
311-
throw new UnsupportedOperationException("Unimplemented method 'getRegistry'");
283+
public void close() {
284+
throw new UnsupportedOperationException("Unimplemented method 'close'");
312285
}
313286

314287
@Override
315-
public void close() {
316-
throw new UnsupportedOperationException("Unimplemented method 'close'");
288+
public void init(Collection<Tag> commonTags) {
289+
throw new UnsupportedOperationException("Unimplemented method 'init'");
317290
}
318291

319292
}

src/main/java/org/apache/accumulo/proxy/TServerUtils.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -505,11 +505,11 @@ public static ServerAddress startTServer(ThriftServerType serverType, TimedProce
505505

506506
final TServer finalServer = serverAddress.server;
507507

508-
Threads.createThread(threadName, () -> {
508+
Threads.createNonCriticalThread(threadName, () -> {
509509
try {
510510
finalServer.serve();
511511
} catch (Error e) {
512-
Halt.halt("Unexpected error in TThreadPoolServer " + e + ", halting.", 1);
512+
Halt.halt(1, "Unexpected error in TThreadPoolServer " + e + ", halting.");
513513
}
514514
}).start();
515515

0 commit comments

Comments
 (0)