Skip to content
This repository was archived by the owner on Sep 2, 2024. It is now read-only.

Commit 24b38d5

Browse files
Excavator: Upgrades Baseline to the latest version
1 parent 6b643d9 commit 24b38d5

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

async-shuffle-upload-core/src/main/java/com/palantir/spark/shuffle/async/s3/reader/FallbackToS3ShuffleIterator.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -36,20 +36,21 @@
3636
import org.apache.spark.storage.ShuffleBlockId;
3737
import org.apache.spark.storage.ShuffleDataBlockId;
3838
import org.apache.spark.storage.ShuffleIndexBlockId;
39-
import org.slf4j.Logger;
4039
import org.slf4j.LoggerFactory;
4140

4241
public final class FallbackToS3ShuffleIterator implements Iterator<ShuffleBlockInputStream> {
4342

44-
private static final Logger LOG = LoggerFactory.getLogger(FallbackToS3ShuffleIterator.class);
43+
static {
44+
LoggerFactory.getLogger(FallbackToS3ShuffleIterator.class);
45+
}
4546

4647
private final Iterator<ShuffleBlockInputStream> fetchFromExecutorsIterator;
4748
private final S3FetcherIterator s3FetcherIterator;
4849
private final Map<ShuffleBlockId, ShuffleBlockInfo> remainingAttemptsByBlock;
4950
private final boolean shouldCompressShuffle;
5051
private final SerializerManager serializerManager;
5152
private final CompressionCodec compressionCodec;
52-
private final ShuffleDriverEndpointRef driverEndpointRef;
53+
5354

5455
public FallbackToS3ShuffleIterator(
5556
Iterator<ShuffleBlockInputStream> fetchFromExecutorsIterator,
@@ -75,7 +76,7 @@ public FallbackToS3ShuffleIterator(
7576
this.s3FetcherIterator = s3FetcherIterator;
7677
Preconditions.checkState(!s3FetcherIterator.isInitialized(),
7778
"S3 Fetcher iterator already initialized");
78-
this.driverEndpointRef = driverEndpointRef;
79+
7980
}
8081

8182
@Override

build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ buildscript {
2424
classpath 'com.netflix.nebula:gradle-info-plugin:5.2.0'
2525
classpath 'com.netflix.nebula:nebula-publishing-plugin:14.1.1'
2626
classpath 'com.palantir.gradle.consistentversions:gradle-consistent-versions:1.12.4'
27-
classpath 'com.palantir.baseline:gradle-baseline-java:2.40.1'
27+
classpath 'com.palantir.baseline:gradle-baseline-java:2.47.0'
2828
classpath 'com.palantir.gradle.gitversion:gradle-git-version:0.12.2'
2929
classpath 'gradle.plugin.org.inferred:gradle-processors:3.1.0'
3030
classpath 'com.palantir.sls-packaging:gradle-sls-packaging:4.3.3'

0 commit comments

Comments
 (0)