Skip to content

Commit 0106b48

Browse files
committed
fixup! Subscription: apply IoTConsensusV2 as cluster mode for integration test (apache#15546)
1 parent 832dcfd commit 0106b48

File tree

1 file changed

+0
-20
lines changed

1 file changed

+0
-20
lines changed

integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/AbstractSubscriptionRegressionIT.java

Lines changed: 0 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -361,26 +361,6 @@ public List<Integer> consume_tsfile(SubscriptionPullConsumer consumer, List<Stri
361361
return results;
362362
}
363363

364-
public static void consume_data_long(
365-
SubscriptionPullConsumer consumer, Session session, Long timeout)
366-
throws StatementExecutionException, InterruptedException, IoTDBConnectionException {
367-
timeout = System.currentTimeMillis() + timeout;
368-
while (System.currentTimeMillis() < timeout) {
369-
List<SubscriptionMessage> messages = consumer.poll(Duration.ofMillis(POLL_TIMEOUT_MS));
370-
if (messages.isEmpty()) {
371-
Thread.sleep(1000);
372-
}
373-
for (final SubscriptionMessage message : messages) {
374-
for (final Iterator<Tablet> it = message.getSessionDataSetsHandler().tabletIterator();
375-
it.hasNext(); ) {
376-
final Tablet tablet = it.next();
377-
session.insertTablet(tablet);
378-
}
379-
}
380-
consumer.commitSync(messages);
381-
}
382-
}
383-
384364
public void consume_data(SubscriptionPullConsumer consumer)
385365
throws TException,
386366
IOException,

0 commit comments

Comments
 (0)