Skip to content

Commit a3694d1

Browse files
committed
Fix integration test
1 parent 94af14f commit a3694d1

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it/SolaceIOMultipleSempIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -172,7 +172,7 @@ private Pipeline createWriterPipeline(
172172
.withWriterType(writerType)
173173
.withDeliveryMode(DeliveryMode.PERSISTENT)
174174
.withNumberOfClientsPerWorker(1)
175-
.withMaxNumOfUsedWorkers(1)
175+
.withNumShards(1)
176176
.withSessionServiceFactory(
177177
BasicAuthJcsmpSessionServiceFactory.builder()
178178
.host("localhost:" + solaceContainerJcsmpPort)

0 commit comments

Comments
 (0)