Skip to content

Commit e2935b0

Browse files
[TPC-H] Adjust default cluster sizes (#1370)
1 parent b68eba7 commit e2935b0

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

tests/tpch/conftest.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,7 @@ def cluster_spec(scale):
147147
if scale == 10:
148148
return {
149149
"worker_vm_types": ["m6i.large"],
150-
"n_workers": 16,
150+
"n_workers": 8,
151151
**everywhere,
152152
}
153153
elif scale == 100:
@@ -158,15 +158,15 @@ def cluster_spec(scale):
158158
}
159159
elif scale == 1000:
160160
return {
161-
"worker_vm_types": ["m6i.large"],
161+
"worker_vm_types": ["m6i.xlarge"],
162162
"n_workers": 32,
163163
**everywhere,
164164
}
165165
elif scale == 10000:
166166
return {
167-
"worker_vm_types": ["m6i.2xlarge"],
168-
"n_workers": 64,
169-
"worker_disk_size": 100,
167+
"worker_vm_types": ["m6i.xlarge"],
168+
"n_workers": 32,
169+
"worker_disk_size": 200,
170170
**everywhere,
171171
}
172172

@@ -294,15 +294,15 @@ def fs(local):
294294
def machine_spec(scale):
295295
if scale == 10:
296296
return {
297-
"vm_type": "m6i.8xlarge",
297+
"vm_type": "m6i.4xlarge",
298298
}
299299
elif scale == 100:
300300
return {
301301
"vm_type": "m6i.8xlarge",
302302
}
303303
elif scale == 1000:
304304
return {
305-
"vm_type": "m6i.16xlarge",
305+
"vm_type": "m6i.32xlarge",
306306
}
307307
elif scale == 10000:
308308
return {

0 commit comments

Comments
 (0)