File tree 2 files changed +3
-2
lines changed
test/src/test/java/org/apache/rocketmq/test/route
2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -24,6 +24,7 @@ build --enable_platform_specific_config
24
24
test --action_env=TEST_TMPDIR=/tmp
25
25
26
26
test --experimental_strict_java_deps=warn
27
+ test --experimental_ui_max_stdouterr_bytes=10485760
27
28
build --experimental_strict_java_deps=warn
28
29
29
30
test --test_output=errors
Original file line number Diff line number Diff line change @@ -121,7 +121,7 @@ public void testCreateOrUpdateTopic_EnableSplitRegistration() {
121
121
122
122
String testTopic = "test-topic-" ;
123
123
124
- for (int i = 0 ; i < 1000 ; i ++) {
124
+ for (int i = 0 ; i < 10 ; i ++) {
125
125
TopicConfig topicConfig = new TopicConfig (testTopic + i , 8 , 8 );
126
126
brokerController1 .getTopicConfigManager ().updateTopicConfig (topicConfig );
127
127
brokerController2 .getTopicConfigManager ().updateTopicConfig (topicConfig );
@@ -132,7 +132,7 @@ public void testCreateOrUpdateTopic_EnableSplitRegistration() {
132
132
brokerController2 .registerBrokerAll (false , true , true );
133
133
brokerController3 .registerBrokerAll (false , true , true );
134
134
135
- for (int i = 0 ; i < 1000 ; i ++) {
135
+ for (int i = 0 ; i < 10 ; i ++) {
136
136
TopicRouteData route = MQAdminTestUtils .examineTopicRouteInfo (NAMESRV_ADDR , testTopic + i );
137
137
assertThat (route .getBrokerDatas ()).hasSize (3 );
138
138
assertThat (route .getQueueDatas ()).hasSize (3 );
You can’t perform that action at this time.
0 commit comments