otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r542886903
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -586,6 +592,7 @@ public void onData
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r540379906
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -586,6 +592,7 @@ public void onData
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r539871040
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -586,6 +592,7 @@ public void onData
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r539630414
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -586,6 +592,7 @@ public void onData
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r539630414
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -586,6 +592,7 @@ public void onData
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r539516440
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -370,26 +391,19 @@ public MergeStat
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r539504808
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -674,7 +683,10 @@ public void onCom
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r539504808
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -674,7 +683,10 @@ public void onCom
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r539500739
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -586,6 +592,7 @@ public void onData
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r539050327
##
File path:
common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/RemoteBlockPushResolverSuite.java
##
@@ -411,6 +415,269 @@ void delete
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r538952136
##
File path:
common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/RemoteBlockPushResolverSuite.java
##
@@ -411,6 +415,269 @@ void delete
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r538952136
##
File path:
common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/RemoteBlockPushResolverSuite.java
##
@@ -411,6 +415,269 @@ void delete
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r538952136
##
File path:
common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/RemoteBlockPushResolverSuite.java
##
@@ -411,6 +415,269 @@ void delete
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r538952136
##
File path:
common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/RemoteBlockPushResolverSuite.java
##
@@ -411,6 +415,269 @@ void delete
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r538950538
##
File path:
common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/RemoteBlockPushResolverSuite.java
##
@@ -411,6 +415,269 @@ void delete
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r538944996
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -370,26 +391,19 @@ public MergeStat
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r538685008
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -825,43 +884,68 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r538672700
##
File path:
common/network-shuffle/src/test/java/org/apache/spark/network/shuffle/RemoteBlockPushResolverSuite.java
##
@@ -411,6 +415,269 @@ void delete
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r537778170
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -17,6 +17,7 @@
package org.apach
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r536368742
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r536347251
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -369,27 +388,19 @@ public MergeStat
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r536347122
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -825,45 +881,79 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r535532790
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -825,45 +881,79 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r535507691
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -825,45 +881,79 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r534352437
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -877,7 +886,7 @@ void closeAllFiles
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r533785143
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -877,7 +886,7 @@ void closeAllFiles
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r533783839
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -877,7 +886,7 @@ void closeAllFiles
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r533694433
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r532947313
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r529837473
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r529823126
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528907429
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528907429
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528907429
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528907429
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528519186
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528519186
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528519186
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528507583
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528504439
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528266788
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528229428
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528229564
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
otterc commented on a change in pull request #30433:
URL: https://github.com/apache/spark/pull/30433#discussion_r528229428
##
File path:
common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/RemoteBlockPushResolver.java
##
@@ -827,13 +833,16 @@ void resetChunkT
44 matches
Mail list logo