MAPREDUCE-7121. add Abortable so that we can abort output by bschell · Pull Request #402 · apache/hadoop · GitHub
More Web Proxy on the site http://driver.im/
You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
In the case of using a remote filesystem with mapreduce, upon task attempt failure we ensure the file output stream gets aborted before being closed which prevents partial results from being uploaded.
The patch appears to include 1 new or modified test files.
_ trunk Compile Tests _
0
mvndep
25
Maven dependency ordering for branch
+1
mvninstall
1043
trunk passed
+1
compile
1050
trunk passed
+1
checkstyle
150
trunk passed
+1
mvnsite
122
trunk passed
+1
shadedclient
986
branch has no errors when building and testing our client artifacts.
+1
javadoc
87
trunk passed
0
spotbugs
80
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
191
trunk passed
_ Patch Compile Tests _
0
mvndep
22
Maven dependency ordering for patch
+1
mvninstall
74
the patch passed
+1
compile
1023
the patch passed
-1
javac
1023
root generated 1 new + 1476 unchanged - 0 fixed = 1477 total (was 1476)
-0
checkstyle
147
root: The patch generated 10 new + 854 unchanged - 2 fixed = 864 total (was 856)
-1
mvnsite
38
hadoop-mapreduce-client-core in the patch failed.
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
635
patch has no errors when building and testing our client artifacts.
+1
javadoc
80
the patch passed
-1
findbugs
122
hadoop-common-project/hadoop-common generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
-1
findbugs
34
hadoop-mapreduce-client-core in the patch failed.
_ Other Tests _
-1
unit
534
hadoop-common in the patch failed.
-1
unit
41
hadoop-mapreduce-client-core in the patch failed.
-1
asflicense
38
The patch generated 2 ASF License warnings.
6522
Reason
Tests
FindBugs
module:hadoop-common-project/hadoop-common
instanceof will always return true for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:[line 881]
The patch appears to include 1 new or modified test files.
_ trunk Compile Tests _
0
mvndep
22
Maven dependency ordering for branch
+1
mvninstall
1033
trunk passed
+1
compile
1013
trunk passed
+1
checkstyle
153
trunk passed
+1
mvnsite
128
trunk passed
+1
shadedclient
956
branch has no errors when building and testing our client artifacts.
+1
javadoc
91
trunk passed
0
spotbugs
76
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
190
trunk passed
_ Patch Compile Tests _
0
mvndep
23
Maven dependency ordering for patch
+1
mvninstall
77
the patch passed
+1
compile
968
the patch passed
-1
javac
968
root generated 1 new + 1476 unchanged - 0 fixed = 1477 total (was 1476)
-0
checkstyle
146
root: The patch generated 10 new + 854 unchanged - 2 fixed = 864 total (was 856)
+1
mvnsite
113
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
669
patch has no errors when building and testing our client artifacts.
+1
javadoc
95
the patch passed
-1
findbugs
127
hadoop-common-project/hadoop-common generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
-1
findbugs
90
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
_ Other Tests _
+1
unit
532
hadoop-common in the patch passed.
+1
unit
335
hadoop-mapreduce-client-core in the patch passed.
-1
asflicense
48
The patch generated 2 ASF License warnings.
6835
Reason
Tests
FindBugs
module:hadoop-common-project/hadoop-common
instanceof will always return true for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:[line 881]
instanceof will always return false in org.apache.hadoop.mapred.ReduceTask.runOldReducer(JobConf, TaskUmbilicalProtocol, Task$TaskReporter, RawKeyValueIterator, RawComparator, Class, Class), since a org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter<OUTKEY,OUTVALUE> can't be a org.apache.hadoop.fs.common.Abortable At ReduceTask.java:in org.apache.hadoop.mapred.ReduceTask.runOldReducer(JobConf, TaskUmbilicalProtocol, Task$TaskReporter, RawKeyValueIterator, RawComparator, Class, Class), since a org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter<OUTKEY,OUTVALUE> can't be a org.apache.hadoop.fs.common.Abortable At ReduceTask.java:[line 461]
The patch appears to include 1 new or modified test files.
_ trunk Compile Tests _
0
mvndep
22
Maven dependency ordering for branch
+1
mvninstall
1083
trunk passed
+1
compile
1072
trunk passed
+1
checkstyle
146
trunk passed
+1
mvnsite
125
trunk passed
+1
shadedclient
975
branch has no errors when building and testing our client artifacts.
+1
javadoc
104
trunk passed
0
spotbugs
82
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
204
trunk passed
_ Patch Compile Tests _
0
mvndep
24
Maven dependency ordering for patch
+1
mvninstall
78
the patch passed
+1
compile
1020
the patch passed
-1
javac
1020
root generated 1 new + 1476 unchanged - 0 fixed = 1477 total (was 1476)
-0
checkstyle
148
root: The patch generated 10 new + 854 unchanged - 2 fixed = 864 total (was 856)
+1
mvnsite
122
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
678
patch has no errors when building and testing our client artifacts.
+1
javadoc
98
the patch passed
-1
findbugs
136
hadoop-common-project/hadoop-common generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
-1
findbugs
95
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
_ Other Tests _
-1
unit
532
hadoop-common in the patch failed.
+1
unit
338
hadoop-mapreduce-client-core in the patch passed.
-1
asflicense
52
The patch generated 2 ASF License warnings.
7097
Reason
Tests
FindBugs
module:hadoop-common-project/hadoop-common
instanceof will always return true for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:[line 881]
instanceof will always return false in org.apache.hadoop.mapred.ReduceTask.runOldReducer(JobConf, TaskUmbilicalProtocol, Task$TaskReporter, RawKeyValueIterator, RawComparator, Class, Class), since a org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter<OUTKEY,OUTVALUE> can't be a org.apache.hadoop.fs.common.Abortable At ReduceTask.java:in org.apache.hadoop.mapred.ReduceTask.runOldReducer(JobConf, TaskUmbilicalProtocol, Task$TaskReporter, RawKeyValueIterator, RawComparator, Class, Class), since a org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter<OUTKEY,OUTVALUE> can't be a org.apache.hadoop.fs.common.Abortable At ReduceTask.java:[line 461]
The patch appears to include 1 new or modified test files.
_ trunk Compile Tests _
0
mvndep
22
Maven dependency ordering for branch
+1
mvninstall
1067
trunk passed
+1
compile
1079
trunk passed
+1
checkstyle
147
trunk passed
+1
mvnsite
110
trunk passed
+1
shadedclient
999
branch has no errors when building and testing our client artifacts.
+1
javadoc
80
trunk passed
0
spotbugs
78
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
192
trunk passed
_ Patch Compile Tests _
0
mvndep
28
Maven dependency ordering for patch
+1
mvninstall
74
the patch passed
+1
compile
1022
the patch passed
-1
javac
1022
root generated 1 new + 1476 unchanged - 0 fixed = 1477 total (was 1476)
-0
checkstyle
140
root: The patch generated 10 new + 854 unchanged - 2 fixed = 864 total (was 856)
+1
mvnsite
106
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
616
patch has no errors when building and testing our client artifacts.
+1
javadoc
82
the patch passed
-1
findbugs
122
hadoop-common-project/hadoop-common generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
-1
findbugs
86
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
_ Other Tests _
+1
unit
546
hadoop-common in the patch passed.
-1
unit
27
hadoop-mapreduce-client-core in the patch failed.
-1
asflicense
40
The patch generated 2 ASF License warnings.
6640
Reason
Tests
FindBugs
module:hadoop-common-project/hadoop-common
instanceof will always return true for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:[line 881]
instanceof will always return false in org.apache.hadoop.mapred.ReduceTask.runOldReducer(JobConf, TaskUmbilicalProtocol, Task$TaskReporter, RawKeyValueIterator, RawComparator, Class, Class), since a org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter<OUTKEY,OUTVALUE> can't be a org.apache.hadoop.fs.common.Abortable At ReduceTask.java:in org.apache.hadoop.mapred.ReduceTask.runOldReducer(JobConf, TaskUmbilicalProtocol, Task$TaskReporter, RawKeyValueIterator, RawComparator, Class, Class), since a org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter<OUTKEY,OUTVALUE> can't be a org.apache.hadoop.fs.common.Abortable At ReduceTask.java:[line 461]
The patch appears to include 1 new or modified test files.
_ trunk Compile Tests _
0
mvndep
22
Maven dependency ordering for branch
+1
mvninstall
1096
trunk passed
+1
compile
1234
trunk passed
+1
checkstyle
147
trunk passed
+1
mvnsite
108
trunk passed
+1
shadedclient
972
branch has no errors when building and testing our client artifacts.
+1
javadoc
82
trunk passed
0
spotbugs
75
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
199
trunk passed
_ Patch Compile Tests _
0
mvndep
24
Maven dependency ordering for patch
+1
mvninstall
79
the patch passed
+1
compile
1193
the patch passed
-1
javac
1193
root generated 1 new + 1469 unchanged - 0 fixed = 1470 total (was 1469)
-0
checkstyle
141
root: The patch generated 10 new + 854 unchanged - 2 fixed = 864 total (was 856)
+1
mvnsite
106
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
632
patch has no errors when building and testing our client artifacts.
+1
javadoc
87
the patch passed
-1
findbugs
130
hadoop-common-project/hadoop-common generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
-1
findbugs
81
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
_ Other Tests _
+1
unit
540
hadoop-common in the patch passed.
+1
unit
336
hadoop-mapreduce-client-core in the patch passed.
-1
asflicense
49
The patch generated 2 ASF License warnings.
7331
Reason
Tests
FindBugs
module:hadoop-common-project/hadoop-common
instanceof will always return true for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:[line 881]
instanceof will always return false in org.apache.hadoop.mapred.ReduceTask.runOldReducer(JobConf, TaskUmbilicalProtocol, Task$TaskReporter, RawKeyValueIterator, RawComparator, Class, Class), since a org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter<OUTKEY,OUTVAL
8000
UE> can't be a org.apache.hadoop.fs.common.Abortable At ReduceTask.java:in org.apache.hadoop.mapred.ReduceTask.runOldReducer(JobConf, TaskUmbilicalProtocol, Task$TaskReporter, RawKeyValueIterator, RawComparator, Class, Class), since a org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter<OUTKEY,OUTVALUE> can't be a org.apache.hadoop.fs.common.Abortable At ReduceTask.java:[line 461]
The patch appears to include 1 new or modified test files.
_ trunk Compile Tests _
0
mvndep
23
Maven dependency ordering for branch
+1
mvninstall
1053
trunk passed
+1
compile
1066
trunk passed
+1
checkstyle
142
trunk passed
+1
mvnsite
103
trunk passed
+1
shadedclient
925
branch has no errors when building and testing our client artifacts.
+1
javadoc
86
trunk passed
0
spotbugs
80
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
199
trunk passed
_ Patch Compile Tests _
0
mvndep
24
Maven dependency ordering for patch
+1
mvninstall
83
the patch passed
+1
compile
1112
the patch passed
-1
javac
1112
root generated 1 new + 1469 unchanged - 0 fixed = 1470 total (was 1469)
-0
checkstyle
147
root: The patch generated 10 new + 854 unchanged - 2 fixed = 864 total (was 856)
+1
mvnsite
112
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
666
patch has no errors when building and testing our client artifacts.
+1
javadoc
82
the patch passed
-1
findbugs
127
hadoop-common-project/hadoop-common generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
-1
findbugs
83
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
_ Other Tests _
+1
unit
532
hadoop-common in the patch passed.
+1
unit
319
hadoop-mapreduce-client-core in the patch passed.
-1
asflicense
41
The patch generated 2 ASF License warnings.
6971
Reason
Tests
FindBugs
module:hadoop-common-project/hadoop-common
instanceof will always return true for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:[line 881]
instanceof will always return false in org.apache.hadoop.mapred.ReduceTask.runOldReducer(JobConf, TaskUmbilicalProtocol, Task$TaskReporter, RawKeyValueIterator, RawComparator, Class, Class), since a org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter<OUTKEY,OUTVALUE> can't be a org.apache.hadoop.fs.common.Abortable At ReduceTask.java:in org.apache.hadoop.mapred.ReduceTask.runOldReducer(JobConf, TaskUmbilicalProtocol, Task$TaskReporter, RawKeyValueIterator, RawComparator, Class, Class), since a org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter<OUTKEY,OUTVALUE> can't be a org.apache.hadoop.fs.common.Abortable At ReduceTask.java:[line 461]
The patch appears to include 1 new or modified test files.
_ trunk Compile Tests _
0
mvndep
21
Maven dependency ordering for branch
+1
mvninstall
1090
trunk passed
+1
compile
1095
trunk passed
+1
checkstyle
144
trunk passed
+1
mvnsite
109
trunk passed
+1
shadedclient
946
branch has no errors when building and testing our client artifacts.
+1
javadoc
97
trunk passed
0
spotbugs
73
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
197
trunk passed
_ Patch Compile Tests _
0
mvndep
20
Maven dependency ordering for patch
+1
mvninstall
77
the patch passed
+1
compile
1025
the patch passed
-1
javac
1025
root generated 1 new + 1469 unchanged - 0 fixed = 1470 total (was 1469)
-0
checkstyle
148
root: The patch generated 10 new + 854 unchanged - 2 fixed = 864 total (was 856)
+1
mvnsite
107
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
641
patch has no errors when building and testing our client artifacts.
+1
javadoc
84
the patch passed
-1
findbugs
125
hadoop-common-project/hadoop-common generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
-1
findbugs
28
hadoop-mapreduce-client-core in the patch failed.
_ Other Tests _
-1
unit
502
hadoop-common in the patch failed.
-1
unit
29
hadoop-mapreduce-client-core in the patch failed.
-1
asflicense
41
The patch generated 2 ASF License warnings.
6554
Reason
Tests
FindBugs
module:hadoop-common-project/hadoop-common
instanceof will always return true for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:[line 881]
The patch appears to include 1 new or modified test files.
_ trunk Compile Tests _
0
mvndep
27
Maven dependency ordering for branch
+1
mvninstall
1013
trunk passed
+1
compile
977
trunk passed
+1
checkstyle
157
trunk passed
+1
mvnsite
132
trunk passed
+1
shadedclient
1016
branch has no errors when building and testing our client artifacts.
+1
javadoc
104
trunk passed
0
spotbugs
80
Used deprecated FindBugs config; considering switching to SpotBugs.
+1
findbugs
199
trunk passed
_ Patch Compile Tests _
0
mvndep
23
Maven dependency ordering for patch
+1
mvninstall
77
the patch passed
+1
compile
925
the patch passed
-1
javac
925
root generated 1 new + 1469 unchanged - 0 fixed = 1470 total (was 1469)
-0
checkstyle
162
root: The patch generated 10 new + 854 unchanged - 2 fixed = 864 total (was 856)
+1
mvnsite
128
the patch passed
+1
whitespace
0
The patch has no whitespace issues.
+1
shadedclient
689
patch has no errors when building and testing our client artifacts.
+1
javadoc
106
the patch passed
-1
findbugs
128
hadoop-common-project/hadoop-common generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
-1
findbugs
89
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core generated 1 new + 0 unchanged - 0 fixed = 1 total (was 0)
_ Other Tests _
+1
unit
580
hadoop-common in the patch passed.
+1
unit
333
hadoop-mapreduce-client-core in the patch passed.
-1
asflicense
53
The patch generated 2 ASF License warnings.
6994
Reason
Tests
FindBugs
module:hadoop-common-project/hadoop-common
instanceof will always return true for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:for all non-null values in org.apache.hadoop.io.SequenceFile$Writer.abort(), since all org.apache.hadoop.fs.FSDataOutputStream are instances of org.apache.hadoop.fs.common.Abortable At SequenceFile.java:[line 881]
instanceof will always return false in org.apache.hadoop.mapred.ReduceTask.runOldReducer(JobConf, TaskUmbilicalProtocol, Task$TaskReporter, RawKeyValueIterator, RawComparator, Class, Class), since a org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter<OUTKEY,OUTVALUE> can't be a org.apache.hadoop.fs.common.Abortable At ReduceTask.java:in org.apache.hadoop.mapred.ReduceTask.runOldReducer(JobConf, TaskUmbilicalProtocol, Task$TaskReporter, RawKeyValueIterator, RawComparator, Class, Class), since a org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter<OUTKEY,OUTVALUE> can't be a org.apache.hadoop.fs.common.Abortable At ReduceTask.java:[line 461]
Add it so Samza compiles with the latest kafka.
Author: xiliu <xiliu@xiliu-ld1.linkedin.biz>
Reviewers: Boris Shkolnik <sborya@gmail.com>
Closesapache#402 from xinyuiscool/SAMZA-1553
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not
2D40
supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
This patch adds abortable to mapreduce outputs
In the case of using a remote filesystem with mapreduce, upon task attempt failure we ensure the file output stream gets aborted before being closed which prevents partial results from being uploaded.