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
- cli
- client
- api
- binding
- impl
- zk
- types
- server
- dns
- integration
- services
- test/java/org/apache/hadoop/registry/secure
- hadoop-hdfs-project
- hadoop-hdfs
- src
- main
- java/org/apache/hadoop/hdfs
- net
- protocol
- datatransfer/sasl
- protocolPB
- 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-hdfs-client/src/main
- java/org/apache/hadoop/hdfs
- client
- impl
- metrics
- protocol
- datatransfer
- sasl
- protocolPB
- 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-mapreduce-project/hadoop-mapreduce-client
- hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop
- mapred
- mapreduce
- jobhistory
- v2/app
- job/impl
- rm
- speculate
- webapp
- hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/util
- hadoop-mapreduce-client-core/src
- main/java/org/apache/hadoop
- mapred
- pipes
- mapreduce
- counters
- jobhistory
- lib
- db
- input
- output
- security
- task/reduce
- tools
- 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
- src
- main/java/org/apache/hadoop/fs
- azure
- azurebfs
- constants
- contracts/services
- oauth2
- security
- services
- utils
- test/java/org/apache/hadoop/fs
- azure
- integration
- azurebfs
- contract
- extensions
- services
- hadoop-azure-datalake/src/main/java/org/apache/hadoop/fs/adl
- 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
- src/main/java/org/apache/hadoop/yarn/server/timelineservice
- collector
- metrics
- reader
- storage
- common
- 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
- 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-hbase-tests
- src/test/java/org/apache/hadoop/yarn/server/timelineservice/storage
- 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 changedLines changed: 11 additions & 16 deletions
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 |
| |
|
Lines changed: 29 additions & 29 deletions
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 |
| |
|
Lines changed: 9 additions & 10 deletions
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 |
| |
|
Lines changed: 9 additions & 2 deletions
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 |
| |
|
Lines changed: 75 additions & 0 deletions
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 | + |
Lines changed: 5 additions & 9 deletions
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