Commit edc48a7
Merge upstream/main, resolving conflicts
Resolved conflicts between the unclean leader election feature
and upstream additions (previousCurrentVersion, blobDbEnabled).
Kept both sets of changes, with PR schema versions (AdminOperation v96,
StoreMetaValue v41).
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>323 files changed
Lines changed: 23203 additions & 5929 deletions
File tree
- .github/workflows
- clients
- da-vinci-client/src
- main/java/com/linkedin/davinci
- blobtransfer
- client
- client/factory
- config
- consumer
- helix
- ingestion
- kafka/consumer
- stats
- ingestion/heartbeat
- test/java/com/linkedin/davinci
- blobtransfer
- config
- consumer
- ingestion
- kafka/consumer
- stats
- ingestion/heartbeat
- venice-admin-tool/src/test
- java/com/linkedin/venice
- resources
- venice-client
- src
- main/java/com/linkedin/venice/fastclient
- test/java/com/linkedin/venice/fastclient
- venice-producer/src
- main/java/com/linkedin/venice/producer
- online
- test/java/com/linkedin/venice/producer
- online
- venice-push-job/src
- main/java/com/linkedin/venice
- hadoop
- task/datawriter
- spark
- datawriter/jobs
- input/pubsub
- vpj
- test/java/com/linkedin/venice
- hadoop
- spark
- datawriter/jobs
- input/pubsub
- vpj/pubsub/input
- venice-thin-client/src/main/java/com/linkedin/venice/client/schema
- docker
- venice-client
- venice-controller/single-dc-configs
- venice-router/single-dc-configs
- venice-server/single-dc-configs
- docs
- _sass/custom
- assets/style
- contributing
- architecture
- development
- documentation
- proposals
- dev_guide
- how_to
- getting-started
- deployments
- learn-venice
- operations
- advanced
- data-management
- ops_guide
- proposals
- quickstart
- resources
- user-guide
- read-apis
- write-apis
- user_guide
- design_patterns
- read_api
- write_api
- internal
- alpini
- common/alpini-common-base/src/main/java/com/linkedin/alpini/base/misc
- router
- alpini-router-api/src/main/java/com/linkedin/alpini/router/api
- alpini-router-base/src/main/java/com/linkedin/alpini/router
- venice-client-common/src
- main/java/com/linkedin/venice
- exceptions
- stats
- dimensions
- metrics
- test/java/com/linkedin/venice/stats
- dimensions
- metrics
- venice-common/src
- main/java/com/linkedin/venice
- controllerapi
- d2
- guid
- helix
- message
- meta
- utils
- views
- writer
- zk
- test/java/com/linkedin/venice
- meta
- utils
- venice-test-common
- src
- integrationTest/java/com/linkedin/venice
- consumer
- controller
- kafka/consumer
- endToEnd
- helixrebalance
- integration/utils
- router
- utils
- main
- java/com/linkedin/venice
- admin
- pubsub/mock
- utils
- resources/valueSchema/supersetschemas
- services
- venice-controller/src
- main/java/com/linkedin/venice/controller
- kafka
- consumer
- protocol/enums
- stats
- test/java/com/linkedin/venice/controller
- kafka
- consumer
- protocol
- admin
- enums
- stats
- venice-router/src
- main/java/com/linkedin/venice/router
- api
- stats
- streaming
- test/java/com/linkedin/venice/router
- api
- streaming
- venice-server/src
- main/java/com/linkedin/venice
- listener
- server
- test/java/com/linkedin/venice/listener
- tests/venice-pulsar-test/src/pulsarIntegrationTest/resources
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
2147 | 2147 | | |
2148 | 2148 | | |
2149 | 2149 | | |
| 2150 | + | |
| 2151 | + | |
| 2152 | + | |
| 2153 | + | |
| 2154 | + | |
| 2155 | + | |
| 2156 | + | |
| 2157 | + | |
| 2158 | + | |
| 2159 | + | |
| 2160 | + | |
| 2161 | + | |
| 2162 | + | |
| 2163 | + | |
| 2164 | + | |
| 2165 | + | |
| 2166 | + | |
| 2167 | + | |
| 2168 | + | |
| 2169 | + | |
| 2170 | + | |
| 2171 | + | |
| 2172 | + | |
| 2173 | + | |
| 2174 | + | |
| 2175 | + | |
| 2176 | + | |
| 2177 | + | |
| 2178 | + | |
| 2179 | + | |
| 2180 | + | |
| 2181 | + | |
| 2182 | + | |
| 2183 | + | |
| 2184 | + | |
| 2185 | + | |
| 2186 | + | |
| 2187 | + | |
| 2188 | + | |
| 2189 | + | |
| 2190 | + | |
| 2191 | + | |
| 2192 | + | |
| 2193 | + | |
| 2194 | + | |
| 2195 | + | |
| 2196 | + | |
| 2197 | + | |
| 2198 | + | |
| 2199 | + | |
| 2200 | + | |
| 2201 | + | |
| 2202 | + | |
| 2203 | + | |
| 2204 | + | |
| 2205 | + | |
| 2206 | + | |
| 2207 | + | |
| 2208 | + | |
| 2209 | + | |
| 2210 | + | |
| 2211 | + | |
| 2212 | + | |
| 2213 | + | |
| 2214 | + | |
| 2215 | + | |
| 2216 | + | |
| 2217 | + | |
| 2218 | + | |
| 2219 | + | |
| 2220 | + | |
| 2221 | + | |
| 2222 | + | |
| 2223 | + | |
| 2224 | + | |
| 2225 | + | |
| 2226 | + | |
| 2227 | + | |
| 2228 | + | |
| 2229 | + | |
| 2230 | + | |
| 2231 | + | |
| 2232 | + | |
| 2233 | + | |
| 2234 | + | |
| 2235 | + | |
| 2236 | + | |
| 2237 | + | |
| 2238 | + | |
| 2239 | + | |
| 2240 | + | |
| 2241 | + | |
| 2242 | + | |
| 2243 | + | |
| 2244 | + | |
| 2245 | + | |
| 2246 | + | |
2150 | 2247 | | |
2151 | 2248 | | |
2152 | 2249 | | |
| |||
2250 | 2347 | | |
2251 | 2348 | | |
2252 | 2349 | | |
2253 | | - | |
| 2350 | + | |
2254 | 2351 | | |
2255 | 2352 | | |
2256 | 2353 | | |
| |||
| 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 | + | |
This file was deleted.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
18 | 18 | | |
19 | 19 | | |
20 | 20 | | |
| 21 | + | |
21 | 22 | | |
22 | 23 | | |
23 | 24 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
635 | 635 | | |
636 | 636 | | |
637 | 637 | | |
| 638 | + | |
| 639 | + | |
| 640 | + | |
| 641 | + | |
| 642 | + | |
| 643 | + | |
638 | 644 | | |
639 | 645 | | |
640 | 646 | | |
| |||
760 | 766 | | |
761 | 767 | | |
762 | 768 | | |
| 769 | + | |
| 770 | + | |
763 | 771 | | |
764 | 772 | | |
765 | 773 | | |
| |||
771 | 779 | | |
772 | 780 | | |
773 | 781 | | |
| 782 | + | |
| 783 | + | |
774 | 784 | | |
775 | 785 | | |
776 | 786 | | |
| |||
Lines changed: 2 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
60 | 60 | | |
61 | 61 | | |
62 | 62 | | |
| 63 | + | |
| 64 | + | |
63 | 65 | | |
0 commit comments