Skip to content

Commit ad4ca63

Browse files
authored
Bump artifacts to latest release (#179)
1 parent abf0439 commit ad4ca63

File tree

16 files changed

+209
-55
lines changed

16 files changed

+209
-55
lines changed

common/network-common/src/main/java/org/apache/spark/network/crypto/TransportCipher.java

Lines changed: 28 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -203,6 +203,11 @@ public long transfered() {
203203
return transferred;
204204
}
205205

206+
@Override
207+
public long transferred() {
208+
return transferred;
209+
}
210+
206211
@Override
207212
public long transferTo(WritableByteChannel target, long position) throws IOException {
208213
Preconditions.checkArgument(position == transfered(), "Invalid position.");
@@ -232,7 +237,7 @@ private void encryptMore() throws IOException {
232237
int copied = byteRawChannel.write(buf.nioBuffer());
233238
buf.skipBytes(copied);
234239
} else {
235-
region.transferTo(byteRawChannel, region.transfered());
240+
region.transferTo(byteRawChannel, region.transferred());
236241
}
237242
cos.write(byteRawChannel.getData(), 0, byteRawChannel.length());
238243
cos.flush();
@@ -241,6 +246,28 @@ private void encryptMore() throws IOException {
241246
0, byteEncChannel.length());
242247
}
243248

249+
@Override
250+
public FileRegion retain() {
251+
super.retain();
252+
return this;
253+
}
254+
255+
@Override
256+
public FileRegion retain(int increment) {
257+
super.retain(increment);
258+
return this;
259+
}
260+
261+
@Override
262+
public FileRegion touch() {
263+
return this;
264+
}
265+
266+
@Override
267+
public FileRegion touch(Object o) {
268+
return this;
269+
}
270+
244271
@Override
245272
protected void deallocate() {
246273
byteRawChannel.reset();

common/network-common/src/main/java/org/apache/spark/network/protocol/MessageWithHeader.java

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,11 @@ public long transfered() {
9595
return totalBytesTransferred;
9696
}
9797

98+
@Override
99+
public long transferred() {
100+
return totalBytesTransferred;
101+
}
102+
98103
/**
99104
* This code is more complicated than you would think because we might require multiple
100105
* transferTo invocations in order to transfer a single MessageWithHeader to avoid busy waiting.
@@ -127,6 +132,28 @@ public long transferTo(final WritableByteChannel target, final long position) th
127132
return writtenHeader + writtenBody;
128133
}
129134

135+
@Override
136+
public FileRegion touch(Object msg) {
137+
return this;
138+
}
139+
140+
@Override
141+
public FileRegion retain() {
142+
super.retain();
143+
return this;
144+
}
145+
146+
@Override
147+
public FileRegion retain(int increment) {
148+
super.retain(increment);
149+
return this;
150+
}
151+
152+
@Override
153+
public FileRegion touch() {
154+
return this;
155+
}
156+
130157
@Override
131158
protected void deallocate() {
132159
header.release();

common/network-common/src/main/java/org/apache/spark/network/sasl/SaslEncryption.java

Lines changed: 28 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,11 @@ public long transfered() {
187187
return transferred;
188188
}
189189

190+
@Override
191+
public long transferred() {
192+
return transferred;
193+
}
194+
190195
/**
191196
* Transfers data from the original message to the channel, encrypting it in the process.
192197
*
@@ -262,7 +267,7 @@ private void nextChunk() throws IOException {
262267
int copied = byteChannel.write(buf.nioBuffer());
263268
buf.skipBytes(copied);
264269
} else {
265-
region.transferTo(byteChannel, region.transfered());
270+
region.transferTo(byteChannel, region.transferred());
266271
}
267272

268273
byte[] encrypted = backend.wrap(byteChannel.getData(), 0, byteChannel.length());
@@ -272,6 +277,28 @@ private void nextChunk() throws IOException {
272277
this.unencryptedChunkSize = byteChannel.length();
273278
}
274279

280+
@Override
281+
public FileRegion touch(Object o) {
282+
return this;
283+
}
284+
285+
@Override
286+
public FileRegion retain() {
287+
super.retain();
288+
return this;
289+
}
290+
291+
@Override
292+
public FileRegion retain(int increment) {
293+
super.retain(increment);
294+
return this;
295+
}
296+
297+
@Override
298+
public FileRegion touch() {
299+
return this;
300+
}
301+
275302
@Override
276303
protected void deallocate() {
277304
if (currentHeader != null) {

common/network-common/src/main/java/org/apache/spark/network/server/TransportServer.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -140,11 +140,12 @@ public void close() {
140140
channelFuture.channel().close().awaitUninterruptibly(10, TimeUnit.SECONDS);
141141
channelFuture = null;
142142
}
143-
if (bootstrap != null && bootstrap.group() != null) {
144-
bootstrap.group().shutdownGracefully();
143+
if (bootstrap != null && bootstrap.config() != null && bootstrap.config().group() != null) {
144+
bootstrap.config().group().shutdownGracefully();
145145
}
146-
if (bootstrap != null && bootstrap.childGroup() != null) {
147-
bootstrap.childGroup().shutdownGracefully();
146+
if (bootstrap != null && bootstrap.config() != null
147+
&& bootstrap.config().childGroup() != null) {
148+
bootstrap.config().childGroup().shutdownGracefully();
148149
}
149150
bootstrap = null;
150151
}

common/network-common/src/test/java/org/apache/spark/network/ProtocolSuite.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ private void testServerToClient(Message msg) {
5656
NettyUtils.createFrameDecoder(), MessageDecoder.INSTANCE);
5757

5858
while (!serverChannel.outboundMessages().isEmpty()) {
59-
clientChannel.writeInbound(serverChannel.readOutbound());
59+
clientChannel.writeOneInbound(serverChannel.readOutbound());
6060
}
6161

6262
assertEquals(1, clientChannel.inboundMessages().size());
@@ -72,7 +72,7 @@ private void testClientToServer(Message msg) {
7272
NettyUtils.createFrameDecoder(), MessageDecoder.INSTANCE);
7373

7474
while (!clientChannel.outboundMessages().isEmpty()) {
75-
serverChannel.writeInbound(clientChannel.readOutbound());
75+
serverChannel.writeOneInbound(clientChannel.readOutbound());
7676
}
7777

7878
assertEquals(1, serverChannel.inboundMessages().size());
@@ -116,8 +116,8 @@ public void encode(ChannelHandlerContext ctx, FileRegion in, List<Object> out)
116116
throws Exception {
117117

118118
ByteArrayWritableChannel channel = new ByteArrayWritableChannel(Ints.checkedCast(in.count()));
119-
while (in.transfered() < in.count()) {
120-
in.transferTo(channel, in.transfered());
119+
while (in.transferred() < in.count()) {
120+
in.transferTo(channel, in.transferred());
121121
}
122122
out.add(Unpooled.wrappedBuffer(channel.getData()));
123123
}

common/network-common/src/test/java/org/apache/spark/network/protocol/MessageWithHeaderSuite.java

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -134,6 +134,11 @@ public long transfered() {
134134
return 8 * written;
135135
}
136136

137+
@Override
138+
public long transferred() {
139+
return 8 * written;
140+
}
141+
137142
@Override
138143
public long transferTo(WritableByteChannel target, long position) throws IOException {
139144
for (int i = 0; i < writesPerCall; i++) {
@@ -148,6 +153,28 @@ public long transferTo(WritableByteChannel target, long position) throws IOExcep
148153
return 8 * writesPerCall;
149154
}
150155

156+
@Override
157+
public FileRegion retain() {
158+
super.retain();
159+
return this;
160+
}
161+
162+
@Override
163+
public FileRegion retain(int increment) {
164+
super.retain(increment);
165+
return this;
166+
}
167+
168+
@Override
169+
public FileRegion touch(Object o) {
170+
return this;
171+
}
172+
173+
@Override
174+
public FileRegion touch() {
175+
return this;
176+
}
177+
151178
@Override
152179
protected void deallocate() {
153180
}

core/src/main/scala/org/apache/spark/storage/DiskStore.scala

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -266,6 +266,22 @@ private class ReadableChannelFileRegion(source: ReadableByteChannel, blockSize:
266266
}
267267

268268
override def deallocate(): Unit = source.close()
269+
270+
override def transferred(): Long = _transferred
271+
272+
override def touch(o: scala.Any): FileRegion = this
273+
274+
override def retain(): FileRegion = {
275+
super.retain()
276+
this
277+
}
278+
279+
override def retain(increment: Int): FileRegion = {
280+
super.retain(increment)
281+
this
282+
}
283+
284+
override def touch(): FileRegion = this
269285
}
270286

271287
private class CountingWritableChannel(sink: WritableByteChannel) extends WritableByteChannel {

dev/deps/spark-deps-hadoop-palantir

Lines changed: 27 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
JavaEWAH-0.3.2.jar
2-
RoaringBitmap-0.5.11.jar
2+
RoaringBitmap-0.6.43.jar
33
ST4-4.0.4.jar
44
activation-1.1.1.jar
55
animal-sniffer-annotation-1.0.jar
66
antlr-2.7.7.jar
77
antlr-runtime-3.4.jar
8-
antlr4-runtime-4.5.3.jar
8+
antlr4-runtime-4.7.jar
99
aopalliance-1.0.jar
10-
aopalliance-repackaged-2.4.0-b34.jar
10+
aopalliance-repackaged-2.5.0-b32.jar
1111
apache-log4j-extras-1.2.17.jar
1212
apacheds-i18n-2.0.0-M15.jar
1313
apacheds-kerberos-codec-2.0.0-M15.jar
@@ -89,12 +89,12 @@ hadoop-yarn-client-2.8.0-palantir3.jar
8989
hadoop-yarn-common-2.8.0-palantir3.jar
9090
hadoop-yarn-server-common-2.8.0-palantir3.jar
9191
hadoop-yarn-server-web-proxy-2.8.0-palantir3.jar
92-
hk2-api-2.4.0-b34.jar
93-
hk2-locator-2.4.0-b34.jar
94-
hk2-utils-2.4.0-b34.jar
92+
hk2-api-2.5.0-b32.jar
93+
hk2-locator-2.5.0-b32.jar
94+
hk2-utils-2.5.0-b32.jar
9595
htrace-core4-4.0.1-incubating.jar
96-
httpclient-4.5.2.jar
97-
httpcore-4.4.4.jar
96+
httpclient-4.5.3.jar
97+
httpcore-4.4.6.jar
9898
ion-java-1.0.1.jar
9999
ivy-2.4.0.jar
100100
jackson-annotations-2.6.5.jar
@@ -113,24 +113,24 @@ jackson-module-scala_2.11-2.6.5.jar
113113
jackson-xc-1.9.13.jar
114114
janino-3.0.0.jar
115115
java-xmlbuilder-1.0.jar
116-
javassist-3.18.1-GA.jar
116+
javassist-3.20.0-GA.jar
117117
javax.annotation-api-1.2.jar
118118
javax.inject-1.jar
119-
javax.inject-2.4.0-b34.jar
119+
javax.inject-2.5.0-b32.jar
120120
javax.servlet-api-3.1.0.jar
121121
javax.ws.rs-api-2.0.1.jar
122122
javolution-5.5.1.jar
123123
jaxb-api-2.2.2.jar
124124
jcip-annotations-1.0.jar
125-
jcl-over-slf4j-1.7.16.jar
125+
jcl-over-slf4j-1.7.25.jar
126126
jdo-api-3.0.1.jar
127-
jersey-client-2.22.2.jar
128-
jersey-common-2.22.2.jar
129-
jersey-container-servlet-2.22.2.jar
130-
jersey-container-servlet-core-2.22.2.jar
131-
jersey-guava-2.22.2.jar
132-
jersey-media-jaxb-2.22.2.jar
133-
jersey-server-2.22.2.jar
127+
jersey-client-2.25.1.jar
128+
jersey-common-2.25.1.jar
129+
jersey-container-servlet-2.25.1.jar
130+
jersey-container-servlet-core-2.25.1.jar
131+
jersey-guava-2.25.1.jar
132+
jersey-media-jaxb-2.25.1.jar
133+
jersey-server-2.25.1.jar
134134
jets3t-0.9.3.jar
135135
jetty-6.1.26.jar
136136
jetty-sslengine-6.1.26.jar
@@ -144,10 +144,10 @@ json4s-ast_2.11-3.2.11.jar
144144
json4s-core_2.11-3.2.11.jar
145145
json4s-jackson_2.11-3.2.11.jar
146146
jsp-api-2.1.jar
147-
jsr305-1.3.9.jar
147+
jsr305-3.0.1.jar
148148
jta-1.1.jar
149149
jtransforms-2.4.0.jar
150-
jul-to-slf4j-1.7.16.jar
150+
jul-to-slf4j-1.7.25.jar
151151
kryo-shaded-3.0.3.jar
152152
kubernetes-client-2.2.13.jar
153153
kubernetes-model-1.0.67.jar
@@ -166,13 +166,13 @@ metrics-json-3.1.2.jar
166166
metrics-jvm-3.1.2.jar
167167
minlog-1.3.0.jar
168168
mx4j-3.0.2.jar
169-
netty-3.9.9.Final.jar
170-
netty-all-4.0.43.Final.jar
169+
netty-3.10.6.Final.jar
170+
netty-all-4.1.9.Final.jar
171171
nimbus-jose-jwt-3.9.jar
172172
objenesis-2.1.jar
173-
okhttp-2.4.0.jar
174-
okhttp-3.6.0.jar
175-
okio-1.11.0.jar
173+
okhttp-2.7.5.jar
174+
okhttp-3.7.0.jar
175+
okio-1.12.0.jar
176176
opencsv-2.3.jar
177177
oro-2.0.8.jar
178178
osgi-resource-locator-1.0.1.jar
@@ -196,8 +196,8 @@ scala-reflect-2.11.8.jar
196196
scala-xml_2.11-1.0.2.jar
197197
scalap-2.11.8.jar
198198
shapeless_2.11-2.3.2.jar
199-
slf4j-api-1.7.16.jar
200-
slf4j-log4j12-1.7.16.jar
199+
slf4j-api-1.7.25.jar
200+
slf4j-log4j12-1.7.25.jar
201201
snakeyaml-1.15.jar
202202
snappy-0.2.jar
203203
snappy-java-1.1.2.6.jar

0 commit comments

Comments
 (0)