File tree
1,058 files changed
+63422
-42334
lines changed- dev-support
- bin
- docker
- pkg-resolver
- hadoop-assemblies
- src/main/resources/assemblies
- hadoop-build-tools
- hadoop-client-modules
- hadoop-client
- hadoop-client-api
- hadoop-client-check-invariants
- hadoop-client-check-test-invariants
- hadoop-client-integration-tests
- hadoop-client-minicluster
- hadoop-client-runtime
- hadoop-cloud-storage-project
- hadoop-cloud-storage
- hadoop-cos
- hadoop-huaweicloud
- hadoop-common-project
- hadoop-annotations
- hadoop-auth
- src
- main/java/org/apache/hadoop/security/authentication
- server
- util
- site/markdown
- test/java/org/apache/hadoop/security/authentication/util
- hadoop-auth-examples
- src/main/java/org/apache/hadoop/security/authentication/examples
- hadoop-common
- dev-support
- src
- main
- java/org/apache/hadoop
- conf
- fs
- impl
- prefetch
- shell
- http
- io
- ipc
- metrics
- log
- metrics2/impl
- oncrpc
- security
- portmap
- security
- alias
- token/delegation
- web
- util
- curator
- resources
- site/markdown
- filesystem
- test/java/org/apache/hadoop
- conf
- fs
- contract
- sftp
- sftp
- ha
- http
- io
- ipc
- metrics2/sink
- net
- oncrpc
- security
- portmap
- security
- alias
- token/delegation
- util
- curator
- hadoop-kms
- src/main/java/org/apache/hadoop/crypto/key/kms/server
- hadoop-minikdc
- hadoop-nfs
- hadoop-registry
- src/main/java/org/apache/hadoop/registry
- client
- binding
- impl/zk
- server/dns
- hadoop-dist
- hadoop-hdfs-project
- hadoop-hdfs
- src
- main
- java/org/apache/hadoop/hdfs
- protocol/datatransfer/sasl
- qjournal/server
- security/token/block
- server
- blockmanagement
- common
- datanode
- fsdataset/impl
- metrics
- web/webhdfs
- diskbalancer/command
- namenode
- ha
- web/resources
- tools
- offlineEditsViewer
- offlineImageViewer
- util
- resources
- webapps/hdfs
- site/markdown
- test/java/org/apache/hadoop
- hdfs
- protocol/datatransfer/sasl
- qjournal/server
- server
- blockmanagement
- datanode
- fsdataset/impl
- diskbalancer/command
- namenode
- ha
- tools
- web
- tools
- hadoop-hdfs-client
- src
- main
- java/org/apache/hadoop/hdfs
- client
- protocol
- datatransfer/sasl
- protocolPB
- server/namenode/ha
- util
- web
- proto
- test/java/org/apache/hadoop/hdfs/web
- hadoop-hdfs-httpfs
- src/main/java/org/apache/hadoop/fs/http
- client
- server
- hadoop-hdfs-native-client
- hadoop-hdfs-nfs
- src
- main/java/org/apache/hadoop/hdfs/nfs/nfs3
- test/java/org/apache/hadoop/hdfs/nfs/nfs3
- hadoop-hdfs-rbf
- src
- main
- java/org/apache/hadoop/hdfs/server/federation
- fairness
- metrics
- resolver
- router
- security/token
- store
- impl
- protocol/impl/pb
- resources
- webapps/router
- site/markdown
- test/java/org/apache/hadoop/hdfs/server/federation
- fairness
- router
- hadoop-mapreduce-project
- hadoop-mapreduce-client
- hadoop-mapreduce-client-app
- src/test/java/org/apache/hadoop/mapreduce/v2/app
- job/impl
- hadoop-mapreduce-client-common
- hadoop-mapreduce-client-core
- src
- main
- java/org/apache/hadoop
- mapred
- mapreduce
- jobhistory
- lib
- input
- partition
- security
- split
- tools
- resources
- test/java/org/apache/hadoop
- mapred
- mapreduce/lib
- input
- output
- hadoop-mapreduce-client-hs
- src/site/markdown
- hadoop-mapreduce-client-hs-plugins
- hadoop-mapreduce-client-jobclient
- src/test/java/org/apache/hadoop
- fs
- mapred
- jobcontrol
- mapreduce
- lib/input
- hadoop-mapreduce-client-nativetask
- src
- main/java/org/apache/hadoop/mapred/nativetask
- util
- test/java/org/apache/hadoop/mapred/nativetask/buffer
- hadoop-mapreduce-client-shuffle
- src
- main/java/org/apache/hadoop/mapred
- test/java/org/apache/hadoop/mapred
- hadoop-mapreduce-client-uploader
- hadoop-mapreduce-examples
- src/main/java/org/apache/hadoop/examples
- dancing
- pi
- terasort
- hadoop-maven-plugins
- src/main/java/org/apache/hadoop/maven/plugin/util
- hadoop-minicluster
- hadoop-project
- src/site/markdown
- hadoop-project-dist
- hadoop-tools
- hadoop-aliyun
- hadoop-archive-logs
- hadoop-archives
- 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
- auth
- delegation
- impl
- prefetch
- s3guard
- select
- tools
- site/markdown/tools/hadoop-aws
- test
- java/org/apache/hadoop/fs
- contract/s3a
- s3a
- adapter
- audit
- auth
- delegation
- commit
- staging
- impl
- performance
- prefetch
- s3guard
- scale
- select
- statistics
- test
- tools
- resources
- hadoop-azure
- src
- main/java/org/apache/hadoop/fs
- azure
- azurebfs
- constants
- contracts
- exceptions
- services
- extensions
- oauth2
- security
- services
- utils
- site/markdown
- test/java/org/apache/hadoop/fs
- azure
- azurebfs
- constants
- extensions
- services
- hadoop-azure-datalake
- hadoop-benchmark
- hadoop-datajoin
- hadoop-distcp
- src
- main/java/org/apache/hadoop/tools
- mapred
- test/java/org/apache/hadoop/tools
- util
- hadoop-dynamometer
- hadoop-dynamometer-blockgen
- hadoop-dynamometer-dist
- hadoop-dynamometer-infra
- hadoop-dynamometer-workload
- hadoop-extras
- src/main/java/org/apache/hadoop/tools
- hadoop-federation-balance
- hadoop-fs2img
- src/main/java/org/apache/hadoop/hdfs/server/namenode
- hadoop-gridmix
- src/main/java/org/apache/hadoop/mapred/gridmix
- hadoop-kafka
- src
- main/java/org/apache/hadoop/metrics2/sink
- test/java/org/apache/hadoop/metrics2/impl
- hadoop-openstack
- hadoop-pipes
- hadoop-resourceestimator
- src/test/java/org/apache/hadoop/resourceestimator/solver/impl
- hadoop-rumen
- src/main/java/org/apache/hadoop/tools/rumen
- hadoop-sls
- hadoop-streaming
- src
- main/java/org/apache/hadoop
- record
- streaming
- io
- mapreduce
- test/java/org/apache/hadoop/streaming
- mapreduce
- hadoop-tools-dist
- hadoop-yarn-project
- hadoop-yarn
- bin
- hadoop-yarn-api
- src
- main
- java/org/apache/hadoop/yarn
- conf
- exceptions
- server/api
- protocolrecords
- util/constraint
- proto
- server
- test/java/org/apache/hadoop/yarn
- api/resource
- conf
- hadoop-yarn-applications
- hadoop-yarn-applications-catalog
- hadoop-yarn-applications-catalog-docker
- hadoop-yarn-applications-catalog-webapp
- hadoop-yarn-applications-distributedshell
- hadoop-yarn-applications-mawo
- hadoop-yarn-applications-mawo-core
- hadoop-yarn-applications-unmanaged-am-launcher
- src/main/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher
- hadoop-yarn-services
- hadoop-yarn-services-api
- hadoop-yarn-services-core
- src/main/java/org/apache/hadoop/yarn/service/utils
- hadoop-yarn-client
- src
- main/java/org/apache/hadoop/yarn/client/cli
- test/java/org/apache/hadoop/yarn/client
- api/impl
- cli
- hadoop-yarn-common
- src
- main
- java/org/apache/hadoop/yarn
- client/api/impl
- logaggregation
- filecontroller
- ifile
- tfile
- server/api
- impl/pb
- client
- service
- protocolrecords/impl/pb
- state
- util
- timeline
- resources
- test/java/org/apache/hadoop/yarn
- client/api/impl
- logaggregation/filecontroller/ifile
- hadoop-yarn-csi
- hadoop-yarn-registry
- hadoop-yarn-server
- hadoop-yarn-server-applicationhistoryservice
- src/main/java/org/apache/hadoop/yarn/server
- applicationhistoryservice
- timeline
- hadoop-yarn-server-common
- src
- main
- java/org/apache/hadoop/yarn
- lib
- server
- federation
- policies/manager
- store
- impl
- records
- impl/pb
- sql
- utils
- utils
- webapp
- proto
- test/java/org/apache/hadoop/yarn/server
- federation
- policies
- manager
- store/impl
- hadoop-yarn-server-globalpolicygenerator
- src
- main/java/org/apache/hadoop/yarn/server/globalpolicygenerator
- webapp
- dao
- test/java/org/apache/hadoop/yarn/server/globalpolicygenerator
- policygenerator
- webapp
- hadoop-yarn-server-nodemanager
- src
- main/java/org/apache/hadoop/yarn/server/nodemanager
- containermanager
- linux/resources
- localizer
- webapp
- test/java/org/apache/hadoop/yarn/server/nodemanager
- containermanager
- launcher
- linux
- resources
- runtime
- docker
- localizer
- webapp/dao/gpu
- hadoop-yarn-server-resourcemanager
- src
- main/java/org/apache/hadoop/yarn/server/resourcemanager
- federation
- monitor/invariants
- reservation
- planning
- scheduler
- capacity
- allocator
- conf
- policy
- common/fica
- fair
- converter
- weightconversion
- placement
- security
- webapp
- dao
- test
- java/org/apache/hadoop/yarn/server/resourcemanager
- monitor/capacity
- mockframework
- nodelabels
- recovery
- reservation
- planning
- rmapp
- scheduler
- capacity
- conf
- constraint
- fair
- converter
- weightconversion
- fifo
- placement
- policy
- 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
- rmadmin
- subcluster
- capacity
- fair
- webapp
- resources
- hadoop-yarn-server-tests
- src/test/java/org/apache/hadoop/yarn/server/timelineservice/security
- hadoop-yarn-server-timeline-pluginstorage
- src/test/java/org/apache/hadoop/yarn/server/timeline
- hadoop-yarn-server-timelineservice
- src/main/java/org/apache/hadoop/yarn/server/timelineservice/storage
- hadoop-yarn-server-timelineservice-documentstore
- src/test/java/org/apache/hadoop/yarn/server/timelineservice/documentstore
- hadoop-yarn-server-timelineservice-hbase
- hadoop-yarn-server-timelineservice-hbase-client
- hadoop-yarn-server-timelineservice-hbase-common
- hadoop-yarn-server-timelineservice-hbase-server
- hadoop-yarn-server-timelineservice-hbase-server-1
- hadoop-yarn-server-timelineservice-hbase-server-2
- hadoop-yarn-server-timelineservice-hbase-tests
- hadoop-yarn-server-web-proxy
- src
- main/java/org/apache/hadoop/yarn/server/webproxy
- test/java/org/apache/hadoop/yarn/server/webproxy
- hadoop-yarn-site
- src/site/markdown
- hadoop-yarn-ui
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,058 files changed
+63422
-42334
lines changedLines changed: 14 additions & 15 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
7 | 7 |
| |
8 | 8 |
| |
9 | 9 |
| |
10 |
| - | |
| 10 | + | |
11 | 11 |
| |
12 | 12 |
| |
13 | 13 |
| |
| |||
74 | 74 |
| |
75 | 75 |
| |
76 | 76 |
| |
77 |
| - | |
78 |
| - | |
79 |
| - | |
80 |
| - | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
81 | 81 |
| |
82 | 82 |
| |
83 | 83 |
| |
| |||
433 | 433 |
| |
434 | 434 |
| |
435 | 435 |
| |
436 |
| - | |
437 |
| - | |
438 |
| - | |
439 |
| - | |
| 436 | + | |
| 437 | + | |
| 438 | + | |
| 439 | + | |
440 | 440 |
| |
441 | 441 |
| |
442 | 442 |
| |
| |||
472 | 472 |
| |
473 | 473 |
| |
474 | 474 |
| |
475 |
| - | |
476 |
| - | |
477 |
| - | |
478 |
| - | |
479 |
| - | |
| 475 | + | |
| 476 | + | |
| 477 | + | |
| 478 | + | |
480 | 479 |
| |
481 | 480 |
| |
482 | 481 |
| |
| |||
531 | 530 |
| |
532 | 531 |
| |
533 | 532 |
| |
534 |
| - | |
| 533 | + | |
535 | 534 |
| |
536 | 535 |
| |
537 | 536 |
| |
|
Lines changed: 22 additions & 19 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
210 | 210 |
| |
211 | 211 |
| |
212 | 212 |
| |
| 213 | + | |
213 | 214 |
| |
214 | 215 |
| |
215 | 216 |
| |
216 | 217 |
| |
217 | 218 |
| |
218 |
| - | |
| 219 | + | |
219 | 220 |
| |
220 | 221 |
| |
221 | 222 |
| |
| |||
250 | 251 |
| |
251 | 252 |
| |
252 | 253 |
| |
253 |
| - | |
254 |
| - | |
255 |
| - | |
256 |
| - | |
257 |
| - | |
258 |
| - | |
259 |
| - | |
| 254 | + | |
| 255 | + | |
| 256 | + | |
| 257 | + | |
| 258 | + | |
| 259 | + | |
| 260 | + | |
260 | 261 |
| |
261 | 262 |
| |
262 | 263 |
| |
| |||
294 | 295 |
| |
295 | 296 |
| |
296 | 297 |
| |
297 |
| - | |
298 | 298 |
| |
299 | 299 |
| |
300 | 300 |
| |
| |||
335 | 335 |
| |
336 | 336 |
| |
337 | 337 |
| |
| 338 | + | |
| 339 | + | |
| 340 | + | |
338 | 341 |
| |
339 | 342 |
| |
340 |
| - | |
| 343 | + | |
341 | 344 |
| |
342 | 345 |
| |
343 | 346 |
| |
| |||
360 | 363 |
| |
361 | 364 |
| |
362 | 365 |
| |
363 |
| - | |
| 366 | + | |
364 | 367 |
| |
365 | 368 |
| |
366 | 369 |
| |
| |||
479 | 482 |
| |
480 | 483 |
| |
481 | 484 |
| |
482 |
| - | |
483 |
| - | |
| 485 | + | |
| 486 | + | |
| 487 | + | |
484 | 488 |
| |
485 |
| - | |
| 489 | + | |
486 | 490 |
| |
487 | 491 |
| |
488 |
| - | |
489 |
| - | |
490 |
| - | |
491 |
| - | |
492 |
| - | |
| 492 | + | |
| 493 | + | |
| 494 | + | |
| 495 | + | |
493 | 496 |
| |
494 | 497 |
| |
495 | 498 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
66 | 66 |
| |
67 | 67 |
| |
68 | 68 |
| |
69 |
| - | |
| 69 | + | |
70 | 70 |
| |
71 | 71 |
| |
72 | 72 |
| |
|
Lines changed: 3 additions & 3 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
504 | 504 |
| |
505 | 505 |
| |
506 | 506 |
| |
507 |
| - | |
508 |
| - | |
509 |
| - | |
| 507 | + | |
| 508 | + | |
| 509 | + | |
510 | 510 |
| |
511 | 511 |
| |
512 | 512 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
66 | 66 |
| |
67 | 67 |
| |
68 | 68 |
| |
69 |
| - | |
| 69 | + | |
70 | 70 |
| |
71 | 71 |
| |
72 | 72 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
66 | 66 |
| |
67 | 67 |
| |
68 | 68 |
| |
69 |
| - | |
| 69 | + | |
70 | 70 |
| |
71 | 71 |
| |
72 | 72 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
76 | 76 |
| |
77 | 77 |
| |
78 | 78 |
| |
79 |
| - | |
| 79 | + | |
80 | 80 |
| |
81 | 81 |
| |
82 | 82 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
101 | 101 |
| |
102 | 102 |
| |
103 | 103 |
| |
104 |
| - | |
| 104 | + | |
105 | 105 |
| |
106 | 106 |
| |
107 | 107 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
66 | 66 |
| |
67 | 67 |
| |
68 | 68 |
| |
69 |
| - | |
| 69 | + | |
70 | 70 |
| |
71 | 71 |
| |
72 | 72 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
40 | 40 |
| |
41 | 41 |
| |
42 | 42 |
| |
43 |
| - | |
| 43 | + | |
44 | 44 |
| |
45 | 45 |
| |
46 | 46 |
| |
|
Lines changed: 5 additions & 4 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
27 | 27 |
| |
28 | 28 |
| |
29 | 29 |
| |
30 |
| - | |
| 30 | + | |
31 | 31 |
| |
32 | 32 |
| |
33 | 33 |
| |
34 | 34 |
| |
35 | 35 |
| |
36 |
| - | |
| 36 | + | |
37 | 37 |
| |
38 | 38 |
| |
39 | 39 |
| |
40 | 40 |
| |
41 |
| - | |
| 41 | + | |
42 | 42 |
| |
43 | 43 |
| |
44 | 44 |
| |
45 |
| - | |
| 45 | + | |
46 | 46 |
| |
47 | 47 |
| |
48 | 48 |
| |
| 49 | + | |
49 | 50 |
| |
50 | 51 |
| |
51 | 52 |
| |
|
0 commit comments