File tree
1,850 files changed
+81691
-16580
lines changed- dev-support
- bin
- code-formatter
- docker
- pkg-resolver
- hadoop-build-tools/src/main/resources/checkstyle
- hadoop-client-modules
- hadoop-client-api
- hadoop-client-check-invariants
- src/test/resources
- hadoop-client-check-test-invariants
- hadoop-client-integration-tests
- src/test/java/org/apache/hadoop/example
- hadoop-client-minicluster
- hadoop-client-runtime
- hadoop-cloud-storage-project
- hadoop-cos/src/main/java/org/apache/hadoop/fs/cosn/auth
- hadoop-huaweicloud/src/main/java/org/apache/hadoop/fs/obs
- hadoop-common-project
- hadoop-annotations/src/main/java/org/apache/hadoop/classification
- hadoop-auth/src
- main/java/org/apache/hadoop/security/authentication
- client
- server
- util
- test/java/org/apache/hadoop/security/authentication/util
- hadoop-common
- src
- main
- java/org/apache/hadoop
- conf
- crypto
- key
- kms
- random
- fs
- ftp
- impl
- permission
- sftp
- shell
- statistics
- impl
- store
- viewfs
- ha
- http
- io
- compress
- zlib
- zstd
- erasurecode
- rawcoder
- file/tfile
- nativeio
- retry
- ipc
- metrics
- log
- metrics2
- impl
- lib
- sink
- source
- util
- net
- unix
- security
- alias
- authorize
- http
- ssl
- token/delegation
- web
- service
- launcher
- util
- curator
- native/src/org/apache/hadoop/io/nativeio
- resources
- winutils
- site/markdown
- filesystem
- release
- 2.10.0
- 2.10.1
- 3.1.2
- 3.1.3
- 3.1.4
- 3.3.0
- test
- java/org/apache/hadoop
- conf
- fs
- contract
- ftp
- http
- loadGenerator
- shell
- store
- viewfs
- ha
- io
- compress
- zstd
- erasurecode/rawcoder
- ipc
- metrics2/sink
- net
- security
- authorize
- ssl
- token/delegation/web
- test
- util
- functional
- resources
- hadoop-kms
- src
- main/java/org/apache/hadoop/crypto/key/kms/server
- test/java/org/apache/hadoop/crypto/key/kms/server
- hadoop-nfs/src/main/java/org/apache/hadoop
- nfs
- nfs3
- request
- response
- oncrpc
- security
- portmap
- hadoop-registry
- src
- main/java/org/apache/hadoop/registry
- client
- api
- binding
- impl
- zk
- types
- cli
- server
- dns
- integration
- services
- test/java/org/apache/hadoop/registry/secure
- hadoop-hdfs-project
- hadoop-hdfs-client/src/main
- java/org/apache/hadoop/hdfs
- client
- impl
- metrics
- protocolPB
- protocol
- datatransfer
- sasl
- security/token
- block
- delegation
- server
- datanode
- namenode/ha
- protocol
- shortcircuit
- util
- web
- resources
- proto
- hadoop-hdfs-httpfs
- src
- main
- java/org/apache/hadoop
- fs/http
- client
- server
- lib/servlet
- resources
- test/java/org/apache/hadoop/fs/http
- client
- server
- hadoop-hdfs-native-client/src
- main/native/libhdfspp
- tests
- tools
- tools
- hdfs-allow-snapshot
- hdfs-cat
- hdfs-chgrp
- hdfs-chmod
- hdfs-chown
- hdfs-create-snapshot
- hdfs-delete-snapshot
- hdfs-df
- hdfs-disallow-snapshot
- hdfs-du
- hdfs-rename-snapshot
- internal
- hadoop-hdfs-nfs/src
- main/java/org/apache/hadoop/hdfs/nfs
- mount
- nfs3
- test/java/org/apache/hadoop/hdfs/nfs/nfs3
- hadoop-hdfs-rbf/src
- main
- java/org/apache/hadoop/hdfs
- rbfbalance
- server/federation
- fairness
- metrics
- resolver
- order
- router
- security
- store
- driver/impl
- records
- tools/federation
- resources
- webapps/router
- site/markdown
- test/java/org/apache/hadoop/hdfs/server/federation
- fairness
- metrics
- router
- hadoop-hdfs
- src
- main
- java/org/apache/hadoop/hdfs
- net
- protocolPB
- protocol
- datatransfer/sasl
- qjournal
- client
- server
- security/token
- block
- delegation
- server
- aliasmap
- balancer
- blockmanagement
- common
- blockaliasmap/impl
- datanode
- checker
- erasurecode
- fsdataset
- impl
- metrics
- web
- webhdfs
- diskbalancer
- command
- connectors
- datamodel
- planner
- mover
- namenode
- ha
- snapshot
- sps
- top
- window
- visitor
- web/resources
- protocol
- tools
- offlineEditsViewer
- offlineImageViewer
- util
- web
- resources
- proto
- resources
- webapps
- datanode
- hdfs
- site/markdown
- test/java/org/apache/hadoop
- fs
- shell
- viewfs
- hdfs
- protocol/datatransfer/sasl
- qjournal
- client
- server
- server
- balancer
- blockmanagement
- datanode
- fsdataset/impl
- diskbalancer
- command
- mover
- namenode
- ha
- snapshot
- shortcircuit
- tools
- offlineEditsViewer
- offlineImageViewer
- util
- web
- hadoop-mapreduce-project/hadoop-mapreduce-client
- hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop
- mapreduce
- jobhistory
- v2/app
- job/impl
- rm
- speculate
- webapp
- mapred
- hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/util
- hadoop-mapreduce-client-core/src
- main/java/org/apache/hadoop
- mapreduce
- counters
- jobhistory
- lib
- db
- input
- output
- security
- task/reduce
- tools
- mapred
- pipes
- test/java/org/apache/hadoop/mapreduce
- hadoop-mapreduce-client-hs/src/main/java/org/apache/hadoop/mapreduce/v2/hs
- server
- webapp
- dao
- hadoop-mapreduce-client-jobclient/src
- main/java/org/apache/hadoop/mapred
- test/java/org/apache/hadoop/mapred
- hadoop-mapreduce-client-nativetask/src
- main/java/org/apache/hadoop/mapred/nativetask/buffer
- test/java/org/apache/hadoop/mapred/nativetask/testutil
- hadoop-mapreduce-client-shuffle/src/main/java/org/apache/hadoop/mapred
- hadoop-mapreduce-client-uploader/src
- main/java/org/apache/hadoop/mapred/uploader
- test/java/org/apache/hadoop/mapred/uploader
- hadoop-maven-plugins/src/main/java/org/apache/hadoop/maven/plugin/resourcegz
- hadoop-project
- hadoop-tools
- hadoop-aliyun
- src
- main/java/org/apache/hadoop/fs/aliyun/oss
- site/markdown/tools/hadoop-aliyun
- test
- java/org/apache/hadoop/fs/aliyun/oss
- contract
- resources/contract
- hadoop-archive-logs/src
- main/java/org/apache/hadoop/tools
- test/java/org/apache/hadoop/tools
- hadoop-aws/src
- main/java/org/apache/hadoop/fs
- s3a
- api
- audit/impl
- auth
- delegation
- commit
- files
- magic
- staging
- impl
- s3guard
- select
- tools
- s3native
- site/markdown/tools/hadoop-aws
- test/java/org/apache/hadoop/fs
- contract/s3a
- s3a
- audit
- auth
- delegation
- commit
- fileContext
- impl
- performance
- s3guard
- scale
- select
- hadoop-azure-datalake/src/main/java/org/apache/hadoop/fs/adl
- hadoop-azure
- src
- main/java/org/apache/hadoop/fs
- azurebfs
- constants
- contracts/services
- oauth2
- security
- services
- utils
- azure
- test/java/org/apache/hadoop/fs
- azurebfs
- contract
- extensions
- services
- azure
- integration
- hadoop-distcp
- src
- main/java/org/apache/hadoop/tools
- mapred
- test/java/org/apache/hadoop/tools
- hadoop-dynamometer/hadoop-dynamometer-infra/src
- main/java/org/apache/hadoop/tools/dynamometer
- test/java/org/apache/hadoop/tools/dynamometer
- hadoop-federation-balance
- src/main/java/org/apache/hadoop/tools/fedbalance
- procedure
- hadoop-fs2img/src/main/java/org/apache/hadoop/hdfs/server/namenode
- hadoop-gridmix/src/main/java/org/apache/hadoop/mapred/gridmix/emulators/resourceusage
- hadoop-resourceestimator
- hadoop-sls/src
- main/java/org/apache/hadoop/yarn/sls
- appmaster
- nodemanager
- scheduler
- synthetic
- test/java/org/apache/hadoop/yarn/sls
- hadoop-yarn-project
- hadoop-yarn
- bin
- conf
- hadoop-yarn-api
- src/main/java/org/apache/hadoop/yarn
- api/records
- conf
- util/resource
- hadoop-yarn-applications
- hadoop-yarn-applications-catalog/hadoop-yarn-applications-catalog-webapp
- hadoop-yarn-applications-distributedshell
- src
- main/java/org/apache/hadoop/yarn/applications/distributedshell
- test/java/org/apache/hadoop/yarn/applications/distributedshell
- hadoop-yarn-services
- hadoop-yarn-services-api/src/main/java/org/apache/hadoop/yarn/service/client
- hadoop-yarn-services-core
- src
- main/java/org/apache/hadoop/yarn/service
- client
- component
- instance
- containerlaunch
- provider
- defaultImpl
- registry
- utils
- test/java/org/apache/hadoop/yarn/service
- hadoop-yarn-client/src
- main/java/org/apache/hadoop/yarn/client
- api
- async
- impl
- impl
- cli
- util
- test/java/org/apache/hadoop/yarn/client
- hadoop-yarn-common
- src
- main
- java/org/apache/hadoop/yarn
- api
- protocolrecords/impl/pb
- records/impl/pb
- client
- api/impl
- event
- logaggregation
- filecontroller
- ifile
- nodelabels
- security
- client
- server/security
- util
- resource
- timeline
- webapp
- hamlet2
- util
- resources
- test/java/org/apache/hadoop/yarn/logaggregation/filecontroller
- hadoop-yarn-server
- hadoop-yarn-server-applicationhistoryservice
- src
- main/java/org/apache/hadoop/yarn/server
- applicationhistoryservice
- webapp
- timeline
- recovery
- security
- util
- test/java/org/apache/hadoop/yarn/server/timeline
- hadoop-yarn-server-common/src/main/java/org/apache/hadoop/yarn/server
- api
- federation
- failover
- policies
- amrmproxy
- manager
- resolver
- store
- impl
- metrics
- records/impl/pb
- utils
- metrics
- scheduler
- timeline/security
- uam
- utils
- webapp
- hadoop-yarn-server-nodemanager
- src
- main/java/org/apache/hadoop/yarn/server/nodemanager
- amrmproxy
- api
- containermanager
- application
- container
- launcher
- linux
- resources
- fpga
- gpu
- numa
- runtime
- docker
- runc
- localizer
- logaggregation
- monitor
- resourceplugin
- com
- nec
- nvidia
- deviceframework
- fpga
- gpu
- scheduler
- health
- metrics
- nodelabels
- recovery
- scheduler
- security
- timelineservice
- util
- test/java/org/apache/hadoop/yarn/server/nodemanager
- containermanager
- linux
- resources
- runtime
- monitor
- hadoop-yarn-server-resourcemanager
- src
- main
- java/org/apache/hadoop/yarn/server/resourcemanager
- ahs
- amlauncher
- federation
- metrics
- monitor
- capacity
- nodelabels
- placement
- csmappingrule
- preprocessor
- recovery
- records
- impl/pb
- reservation
- planning
- resource
- rmapp
- attempt
- rmcontainer
- rmnode
- scheduler
- activities
- capacity
- allocator
- conf
- placement
- converter
- policy
- preemption
- queuemanagement
- common/fica
- constraint
- distributed
- fair
- converter
- weightconversion
- policies
- fifo
- placement
- policy
- security
- volume/csi
- lifecycle
- webapp
- dao
- helper
- proto
- test
- java/org/apache/hadoop/yarn/server/resourcemanager
- applicationsmanager
- metrics
- monitor/capacity/mockframework
- placement
- csmappingrule
- rmapp
- scheduler
- capacity
- conf
- queuemanagement
- distributed
- webapp
- resources/webapp
- hadoop-yarn-server-router
- src
- main/java/org/apache/hadoop/yarn/server/router
- clientrm
- rmadmin
- webapp
- test/java/org/apache/hadoop/yarn/server/router
- clientrm
- webapp
- hadoop-yarn-server-tests
- src/test/java/org/apache/hadoop/yarn/server
- hadoop-yarn-server-timeline-pluginstorage
- src
- main/java/org/apache/hadoop/yarn/server/timeline
- test/java/org/apache/hadoop/yarn/server/timeline
- hadoop-yarn-server-timelineservice-documentstore/src
- main/java/org/apache/hadoop/yarn/server/timelineservice/documentstore
- reader/cosmosdb
- writer/cosmosdb
- test/java/org/apache/hadoop/yarn/server/timelineservice/documentstore
- hadoop-yarn-server-timelineservice-hbase-tests
- src/test/java/org/apache/hadoop/yarn/server/timelineservice/storage
- hadoop-yarn-server-timelineservice-hbase
- hadoop-yarn-server-timelineservice-hbase-client
- src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage
- reader
- hadoop-yarn-server-timelineservice-hbase-common
- hadoop-yarn-server-timelineservice-hbase-server
- hadoop-yarn-server-timelineservice-hbase-server-1
- src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/flow
- hadoop-yarn-server-timelineservice-hbase-server-2
- src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage/flow
- hadoop-yarn-server-timelineservice
- src/main/java/org/apache/hadoop/yarn/server/timelineservice
- collector
- metrics
- reader
- storage
- common
- hadoop-yarn-server-web-proxy/src/main/java/org/apache/hadoop/yarn/server/webproxy
- amfilter
- hadoop-yarn-site/src/site/markdown
- hadoop-yarn-ui/src/main/webapp/app/serializers
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,850 files changed
+81691
-16580
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
57 | 57 | | |
58 | 58 | | |
59 | 59 | | |
60 | | - | |
| 60 | + | |
61 | 61 | | |
62 | 62 | | |
63 | 63 | | |
| |||
326 | 326 | | |
327 | 327 | | |
328 | 328 | | |
329 | | - | |
| 329 | + | |
330 | 330 | | |
331 | | - | |
332 | | - | |
| 331 | + | |
333 | 332 | | |
334 | | - | |
335 | | - | |
336 | | - | |
337 | | - | |
338 | | - | |
339 | | - | |
| 333 | + | |
| 334 | + | |
340 | 335 | | |
341 | 336 | | |
342 | 337 | | |
343 | 338 | | |
344 | | - | |
| 339 | + | |
345 | 340 | | |
346 | 341 | | |
347 | 342 | | |
348 | | - | |
| 343 | + | |
349 | 344 | | |
350 | | - | |
| 345 | + | |
351 | 346 | | |
352 | 347 | | |
353 | 348 | | |
354 | 349 | | |
355 | 350 | | |
356 | | - | |
| 351 | + | |
357 | 352 | | |
358 | | - | |
| 353 | + | |
359 | 354 | | |
360 | 355 | | |
361 | 356 | | |
362 | | - | |
| 357 | + | |
363 | 358 | | |
364 | 359 | | |
365 | 360 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
218 | 218 | | |
219 | 219 | | |
220 | 220 | | |
221 | | - | |
222 | | - | |
223 | | - | |
224 | | - | |
225 | | - | |
226 | | - | |
| 221 | + | |
| 222 | + | |
| 223 | + | |
| 224 | + | |
| 225 | + | |
| 226 | + | |
227 | 227 | | |
228 | 228 | | |
229 | 229 | | |
| |||
250 | 250 | | |
251 | 251 | | |
252 | 252 | | |
253 | | - | |
254 | 253 | | |
255 | 254 | | |
256 | 255 | | |
| |||
290 | 289 | | |
291 | 290 | | |
292 | 291 | | |
293 | | - | |
| 292 | + | |
294 | 293 | | |
295 | 294 | | |
296 | 295 | | |
297 | 296 | | |
298 | 297 | | |
299 | 298 | | |
300 | 299 | | |
301 | | - | |
302 | | - | |
303 | | - | |
304 | | - | |
| 300 | + | |
| 301 | + | |
| 302 | + | |
| 303 | + | |
305 | 304 | | |
306 | 305 | | |
307 | 306 | | |
308 | 307 | | |
309 | | - | |
| 308 | + | |
310 | 309 | | |
311 | 310 | | |
312 | 311 | | |
| |||
329 | 328 | | |
330 | 329 | | |
331 | 330 | | |
332 | | - | |
333 | | - | |
334 | | - | |
335 | | - | |
336 | | - | |
337 | | - | |
338 | | - | |
339 | | - | |
340 | | - | |
341 | | - | |
342 | | - | |
343 | | - | |
344 | | - | |
345 | | - | |
| 331 | + | |
| 332 | + | |
| 333 | + | |
| 334 | + | |
| 335 | + | |
| 336 | + | |
| 337 | + | |
| 338 | + | |
| 339 | + | |
| 340 | + | |
| 341 | + | |
| 342 | + | |
| 343 | + | |
| 344 | + | |
346 | 345 | | |
347 | | - | |
| 346 | + | |
348 | 347 | | |
349 | 348 | | |
350 | 349 | | |
| |||
364 | 363 | | |
365 | 364 | | |
366 | 365 | | |
367 | | - | |
| 366 | + | |
368 | 367 | | |
369 | 368 | | |
370 | 369 | | |
| |||
495 | 494 | | |
496 | 495 | | |
497 | 496 | | |
| 497 | + | |
498 | 498 | | |
499 | 499 | | |
500 | 500 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
15 | 15 | | |
16 | 16 | | |
17 | 17 | | |
18 | | - | |
| 18 | + | |
19 | 19 | | |
20 | 20 | | |
21 | | - | |
22 | | - | |
23 | | - | |
24 | | - | |
| 21 | + | |
25 | 22 | | |
26 | 23 | | |
27 | 24 | | |
| |||
30 | 27 | | |
31 | 28 | | |
32 | 29 | | |
| 30 | + | |
| 31 | + | |
33 | 32 | | |
34 | | - | |
| 33 | + | |
35 | 34 | | |
36 | 35 | | |
37 | 36 | | |
| |||
128 | 127 | | |
129 | 128 | | |
130 | 129 | | |
131 | | - | |
| 130 | + | |
132 | 131 | | |
133 | 132 | | |
134 | 133 | | |
| |||
174 | 173 | | |
175 | 174 | | |
176 | 175 | | |
177 | | - | |
| 176 | + | |
178 | 177 | | |
179 | 178 | | |
180 | 179 | | |
| |||
220 | 219 | | |
221 | 220 | | |
222 | 221 | | |
223 | | - | |
| 222 | + | |
224 | 223 | | |
225 | 224 | | |
226 | 225 | | |
| |||
263 | 262 | | |
264 | 263 | | |
265 | 264 | | |
266 | | - | |
| 265 | + | |
267 | 266 | | |
268 | 267 | | |
269 | 268 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
513 | 513 | | |
514 | 514 | | |
515 | 515 | | |
516 | | - | |
| 516 | + | |
517 | 517 | | |
518 | 518 | | |
519 | 519 | | |
| |||
546 | 546 | | |
547 | 547 | | |
548 | 548 | | |
549 | | - | |
| 549 | + | |
550 | 550 | | |
551 | 551 | | |
552 | 552 | | |
553 | 553 | | |
554 | 554 | | |
555 | 555 | | |
| 556 | + | |
| 557 | + | |
| 558 | + | |
| 559 | + | |
| 560 | + | |
| 561 | + | |
| 562 | + | |
556 | 563 | | |
557 | 564 | | |
558 | 565 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
29 | 29 | | |
30 | 30 | | |
31 | 31 | | |
32 | | - | |
33 | | - | |
34 | | - | |
35 | | - | |
36 | | - | |
37 | 32 | | |
38 | 33 | | |
39 | 34 | | |
40 | 35 | | |
41 | 36 | | |
42 | 37 | | |
43 | 38 | | |
44 | | - | |
45 | | - | |
| 39 | + | |
| 40 | + | |
46 | 41 | | |
47 | 42 | | |
48 | 43 | | |
49 | 44 | | |
50 | 45 | | |
51 | 46 | | |
52 | | - | |
53 | 47 | | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
54 | 51 | | |
55 | 52 | | |
56 | 53 | | |
| |||
85 | 82 | | |
86 | 83 | | |
87 | 84 | | |
88 | | - | |
89 | 85 | | |
90 | 86 | | |
91 | 87 | | |
| |||
0 commit comments