Aiven-Open / Aiven-Open/cloud-storage-connectors-for-apache-kafka

GcsSinkTaskGroupByTopicPartitionPropertiesTest.limited takes very long time

Đang mở
#261 0 bình luận 0 reaction 0 người được giao Xem trên GitHub
GCS
Ngôn ngữ chính
Java
Star
58
Fork
39
Merge trung bình
2 ngày 10 giờ
Pull request đã merge (30 ngày)
5

Mô tả

After upgrade to `google-cloud-nio:0.123.24` (and associated `google-cloud-storage:2.4.5`), `GcsSinkTaskGroupByTopicPartitionPropertiesTest.limited` started running very long time. It used to be a couple of minutes, but is unknown (I wan't patient enough to wait beyond 20 minutes).

Some crude profiling of [this line](https://github.com/aiven/gcs-connector-for-apache-kafka/blob/master/src/test/java/io/aiven/kafka/connect/common/grouper/GcsSinkTaskGroupByTopicPartitionPropertiesTest.java#L84)
```java
Instant started = Instant.now();
task.flush(null);
System.out.println(Duration.between(started, Instant.now()).toMillis());
```
shows that the time in `flush` grew about 10x.
No significant difference in profiles collected by `async-profiler` in `cpu` and `wall` modes.

The test will be disabled and should be enabled once this is fixed.

Hướng dẫn đóng góp

Mở hướng dẫn đóng góp

Đánh giá

Issue này chưa được đánh giá.

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.