Commit 8567e8f
committed
Merge remote-tracking branch 'origin/HDFS-17531' into HDFS-17656
# Conflicts:
# hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.javaFile tree
394 files changed
+12661
-2101
lines changed- hadoop-client-modules
- hadoop-client-minicluster
- hadoop-client-runtime
- hadoop-cloud-storage-project/hadoop-huaweicloud
- hadoop-common-project
- hadoop-auth
- hadoop-common
- src
- main
- bin
- java/org/apache/hadoop
- conf
- fs
- impl
- statistics
- store
- audit
- ipc
- metrics2/impl
- net/unix
- security
- util/functional
- native/src/org/apache/hadoop/crypto
- resources
- site/markdown
- filesystem
- test
- java/org/apache/hadoop
- constants
- fs
- contract
- impl
- io
- serializer/avro
- ipc
- net/unix
- security/http
- test
- resources/contract
- hadoop-kms
- hadoop-nfs
- hadoop-registry
- hadoop-dist
- src/main
- compose/hadoop
- docker
- hadoop-hdfs-project
- hadoop-hdfs-client
- src/main/java/org/apache/hadoop/hdfs
- client
- protocol/datatransfer/sasl
- security/token/delegation
- shortcircuit
- hadoop-hdfs-httpfs
- src/main/java/org/apache/hadoop/fs/http/client
- hadoop-hdfs-native-client
- src/main/native
- libhdfspp/tests
- libhdfs
- hadoop-hdfs-nfs
- hadoop-hdfs-rbf
- src
- main/java/org/apache/hadoop/hdfs/server/federation
- metrics
- resolver/order
- test/java/org/apache/hadoop/hdfs/server/federation
- metrics
- router
- hadoop-hdfs
- src
- main
- java/org/apache/hadoop/hdfs
- net
- protocol/datatransfer/sasl
- server
- balancer
- blockmanagement
- datanode
- fsdataset/impl
- namenode
- resources
- webapps/hdfs
- site/markdown
- test/java/org/apache/hadoop
- fs
- hdfs
- net
- protocol/datatransfer/sasl
- server
- balancer
- blockmanagement
- namenode
- ha
- snapshot
- shortcircuit
- web
- hadoop-mapreduce-project/hadoop-mapreduce-client
- hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/rm
- hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop
- mapreduce
- jobhistory
- lib/input
- mapred
- hadoop-mapreduce-client-hs/src/test/java/org/apache/hadoop/mapreduce/v2/hs/webapp
- hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce
- hadoop-mapreduce-client-uploader/src/main/java/org/apache/hadoop/mapred/uploader
- hadoop-maven-plugins
- hadoop-project
- hadoop-tools
- hadoop-aliyun/src/main/java/org/apache/hadoop/fs/aliyun/oss
- hadoop-archive-logs
- hadoop-archives
- hadoop-aws
- src
- main/java/org/apache/hadoop/fs/s3a
- api
- audit/impl
- commit
- impl
- magic
- impl
- logging
- statistics
- impl
- site/markdown/tools/hadoop-aws
- test/java/org/apache/hadoop/fs
- contract/s3a
- s3a
- audit
- impl
- commit
- integration
- staging
- fileContext
- impl
- logging
- performance
- scale
- statistics
- test
- hadoop-azure
- src
- main/java/org/apache/hadoop/fs/azurebfs
- constants
- services
- site/markdown
- test/java/org/apache/hadoop/fs/azurebfs
- contract
- services
- utils
- hadoop-compat-bench
- hadoop-datajoin
- hadoop-distcp
- src
- main/java/org/apache/hadoop/tools
- mapred
- test/java/org/apache/hadoop/tools
- hadoop-dynamometer
- hadoop-dynamometer-blockgen
- hadoop-dynamometer-infra
- hadoop-dynamometer-workload
- hadoop-extras
- hadoop-federation-balance
- hadoop-fs2img
- hadoop-gridmix
- src/test/java/org/apache/hadoop/mapred/gridmix
- hadoop-kafka
- hadoop-rumen/src/main/java/org/apache/hadoop/tools/rumen
- hadoop-sls
- src/main/java/org/apache/hadoop/yarn/sls
- hadoop-streaming
- hadoop-yarn-project/hadoop-yarn
- dev-support
- hadoop-yarn-api
- src/main/java/org/apache/hadoop/yarn/conf
- hadoop-yarn-applications
- hadoop-yarn-applications-catalog/hadoop-yarn-applications-catalog-webapp
- src/test/java/org/apache/hadoop/yarn/appcatalog/application
- hadoop-yarn-applications-distributedshell
- src/main/java/org/apache/hadoop/yarn/applications/distributedshell
- hadoop-yarn-applications-unmanaged-am-launcher/src/main/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher
- hadoop-yarn-services
- dev-support
- hadoop-yarn-services-api
- hadoop-yarn-services-core
- src/test/java/org/apache/hadoop/yarn/service/containerlaunch
- hadoop-yarn-client
- src/main/java/org/apache/hadoop/yarn/client/cli
- hadoop-yarn-common
- src/main/resources
- hadoop-yarn-server
- hadoop-yarn-server-applicationhistoryservice
- src/main/java/org/apache/hadoop/yarn/server/timeline
- security
- hadoop-yarn-server-common
- src/main/java/org/apache/hadoop/yarn/server/federation
- policies
- amrmproxy
- dao
- store/utils
- utils
- hadoop-yarn-server-globalpolicygenerator/src/main/java/org/apache/hadoop/yarn/server/globalpolicygenerator/policygenerator
- hadoop-yarn-server-nodemanager
- src
- main/java/org/apache/hadoop/yarn/server/nodemanager
- containermanager
- linux/resources
- localizer
- test/java/org/apache/hadoop/yarn/server/nodemanager
- containermanager
- linux
- resources
- gpu
- runtime
- resourceplugin/com/nec
- hadoop-yarn-server-resourcemanager
- src
- main/java/org/apache/hadoop/yarn/server/resourcemanager
- monitor/capacity
- rmapp
- rmnode
- scheduler
- activities
- capacity
- allocator
- common/fica
- fair
- placement
- test/java/org/apache/hadoop/yarn/server/resourcemanager
- scheduler
- capacity
- fair/converter
- hadoop-yarn-server-router
- src
- main/java/org/apache/hadoop/yarn/server/router
- rmadmin
- webapp
- test/java/org/apache/hadoop/yarn/server/router
- clientrm
- rmadmin
- secure
- subcluster
- hadoop-yarn-server-tests
- hadoop-yarn-server-timeline-pluginstorage
- hadoop-yarn-server-timelineservice-documentstore
- src/test/java/org/apache/hadoop/yarn/server/timelineservice/documentstore
- reader/cosmosdb
- writer/cosmosdb
- hadoop-yarn-server-timelineservice-hbase-tests
- hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client
- hadoop-yarn-server-timelineservice
- hadoop-yarn-server-web-proxy
- 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.
394 files changed
+12661
-2101
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
244 | 244 | | |
245 | 245 | | |
246 | 246 | | |
247 | | - | |
| 247 | + | |
248 | 248 | | |
249 | | - | |
| 249 | + | |
250 | 250 | | |
251 | 251 | | |
252 | 252 | | |
| |||
297 | 297 | | |
298 | 298 | | |
299 | 299 | | |
300 | | - | |
| 300 | + | |
301 | 301 | | |
302 | | - | |
303 | 302 | | |
304 | 303 | | |
305 | 304 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
168 | 168 | | |
169 | 169 | | |
170 | 170 | | |
| 171 | + | |
| 172 | + | |
| 173 | + | |
| 174 | + | |
171 | 175 | | |
172 | 176 | | |
173 | 177 | | |
| |||
403 | 407 | | |
404 | 408 | | |
405 | 409 | | |
406 | | - | |
| 410 | + | |
407 | 411 | | |
408 | 412 | | |
409 | 413 | | |
| |||
761 | 765 | | |
762 | 766 | | |
763 | 767 | | |
764 | | - | |
| 768 | + | |
765 | 769 | | |
766 | 770 | | |
767 | 771 | | |
| |||
773 | 777 | | |
774 | 778 | | |
775 | 779 | | |
| 780 | + | |
| 781 | + | |
| 782 | + | |
| 783 | + | |
| 784 | + | |
| 785 | + | |
| 786 | + | |
| 787 | + | |
| 788 | + | |
776 | 789 | | |
777 | 790 | | |
778 | 791 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
229 | 229 | | |
230 | 230 | | |
231 | 231 | | |
232 | | - | |
233 | | - | |
| 232 | + | |
| 233 | + | |
| 234 | + | |
234 | 235 | | |
235 | 236 | | |
236 | 237 | | |
| |||
245 | 246 | | |
246 | 247 | | |
247 | 248 | | |
248 | | - | |
| 249 | + | |
249 | 250 | | |
250 | 251 | | |
251 | 252 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
173 | 173 | | |
174 | 174 | | |
175 | 175 | | |
176 | | - | |
177 | | - | |
| 176 | + | |
| 177 | + | |
178 | 178 | | |
| 179 | + | |
| 180 | + | |
| 181 | + | |
| 182 | + | |
| 183 | + | |
| 184 | + | |
179 | 185 | | |
180 | 186 | | |
181 | 187 | | |
182 | 188 | | |
183 | | - | |
| 189 | + | |
184 | 190 | | |
| 191 | + | |
| 192 | + | |
| 193 | + | |
| 194 | + | |
| 195 | + | |
| 196 | + | |
185 | 197 | | |
186 | 198 | | |
187 | 199 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
49 | 49 | | |
50 | 50 | | |
51 | 51 | | |
| 52 | + | |
52 | 53 | | |
53 | 54 | | |
54 | 55 | | |
| |||
182 | 183 | | |
183 | 184 | | |
184 | 185 | | |
| 186 | + | |
| 187 | + | |
| 188 | + | |
| 189 | + | |
185 | 190 | | |
186 | 191 | | |
187 | 192 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
88 | 88 | | |
89 | 89 | | |
90 | 90 | | |
91 | | - | |
92 | | - | |
| 91 | + | |
| 92 | + | |
93 | 93 | | |
94 | 94 | | |
95 | 95 | | |
| |||
211 | 211 | | |
212 | 212 | | |
213 | 213 | | |
| 214 | + | |
| 215 | + | |
| 216 | + | |
| 217 | + | |
| 218 | + | |
| 219 | + | |
214 | 220 | | |
215 | 221 | | |
216 | 222 | | |
| |||
245 | 251 | | |
246 | 252 | | |
247 | 253 | | |
248 | | - | |
| 254 | + | |
249 | 255 | | |
250 | 256 | | |
251 | 257 | | |
| |||
Lines changed: 23 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1569 | 1569 | | |
1570 | 1570 | | |
1571 | 1571 | | |
| 1572 | + | |
| 1573 | + | |
| 1574 | + | |
| 1575 | + | |
| 1576 | + | |
| 1577 | + | |
| 1578 | + | |
| 1579 | + | |
| 1580 | + | |
| 1581 | + | |
| 1582 | + | |
| 1583 | + | |
| 1584 | + | |
| 1585 | + | |
| 1586 | + | |
| 1587 | + | |
| 1588 | + | |
| 1589 | + | |
| 1590 | + | |
| 1591 | + | |
| 1592 | + | |
| 1593 | + | |
1572 | 1594 | | |
1573 | 1595 | | |
1574 | 1596 | | |
| |||
1597 | 1619 | | |
1598 | 1620 | | |
1599 | 1621 | | |
| 1622 | + | |
1600 | 1623 | | |
1601 | 1624 | | |
1602 | 1625 | | |
| |||
Lines changed: 3 additions & 3 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
84 | 84 | | |
85 | 85 | | |
86 | 86 | | |
87 | | - | |
| 87 | + | |
88 | 88 | | |
89 | 89 | | |
90 | 90 | | |
| |||
511 | 511 | | |
512 | 512 | | |
513 | 513 | | |
514 | | - | |
| 514 | + | |
515 | 515 | | |
516 | | - | |
| 516 | + | |
517 | 517 | | |
518 | 518 | | |
519 | 519 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
770 | 770 | | |
771 | 771 | | |
772 | 772 | | |
773 | | - | |
| 773 | + | |
774 | 774 | | |
775 | 775 | | |
776 | 776 | | |
| |||
Lines changed: 6 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
736 | 736 | | |
737 | 737 | | |
738 | 738 | | |
| 739 | + | |
| 740 | + | |
| 741 | + | |
| 742 | + | |
| 743 | + | |
| 744 | + | |
739 | 745 | | |
740 | 746 | | |
741 | 747 | | |
| |||
0 commit comments