Skip to content

Commit

Permalink
checkstyle
Browse files Browse the repository at this point in the history
  • Loading branch information
ableegoldman committed Nov 22, 2024
1 parent 5a9e2dc commit c0d423e
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -142,16 +142,16 @@ public static void maybeCreateKeyspace(final Map<String, Object> properties) {
errorDetails.put("exceptionType", e.getClass().getName());
if (e instanceof AllNodesFailedException) {
final Map<Node, List<Throwable>> allErrors = ((AllNodesFailedException) e).getAllErrors();
int node_i = 1;
int nodeIdx = 1;
for (final var node : allErrors.entrySet()) {
final String nodeId = "node-" + node_i;
final String nodeId = "node-" + nodeIdx;
errorDetails.put(nodeId + "_endPoint", node.getKey().getEndPoint().asMetricPrefix());

final var nodeErrors = node.getValue();
LOG.error("All errors for node at {}: {}", nodeId, nodeErrors);
int error_i = 1;
int errorIdx = 1;
for (final var error : nodeErrors) {
errorDetails.put(nodeId + "_err-" + error_i, error.getMessage());
errorDetails.put(nodeId + "_err-" + errorIdx, error.getMessage());
}
}
Assert.unreachable(errorMessage, errorDetails);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,8 @@ protected Topology buildTopology() {
})
.groupByKey()
.windowedBy(TimeWindows.ofSizeAndGrace(Duration.ofDays(1), Duration.ofHours(12)))
.reduce(EnrichedOrder::combineWith, Materialized.with(Serdes.String(), RegressionSchema.enrichedOrderSerde()))
.reduce(EnrichedOrder::combineWith,
Materialized.with(Serdes.String(), RegressionSchema.enrichedOrderSerde()))
.toStream()
.selectKey((w, v) -> w.key())
.to(
Expand Down

0 comments on commit c0d423e

Please sign in to comment.