diff --git a/cat-consumer/src/main/java/com/dianping/cat/consumer/dump/LocalMessageBucketManager.java b/cat-consumer/src/main/java/com/dianping/cat/consumer/dump/LocalMessageBucketManager.java index 872ea5e26a44e038fdca21771a79f1efb0132e02..989ec24246273e3edf4adaa1c03ae56827724d30 100644 --- a/cat-consumer/src/main/java/com/dianping/cat/consumer/dump/LocalMessageBucketManager.java +++ b/cat-consumer/src/main/java/com/dianping/cat/consumer/dump/LocalMessageBucketManager.java @@ -67,7 +67,7 @@ public class LocalMessageBucketManager extends ContainerHolder implements Messag private long m_total; - private int m_gzipThreads = 36; + private int m_gzipThreads = 20; private int m_gzipMessageSize = 5000; diff --git a/cat-core/src/main/java/com/dianping/cat/report/service/BaseRemoteModelService.java b/cat-core/src/main/java/com/dianping/cat/report/service/BaseRemoteModelService.java index 31a30e0b7537e9ef95ec0bb42250faeb748567e5..9cbdddd06b018310cabbff925bfce17f6c6f8eb8 100755 --- a/cat-core/src/main/java/com/dianping/cat/report/service/BaseRemoteModelService.java +++ b/cat-core/src/main/java/com/dianping/cat/report/service/BaseRemoteModelService.java @@ -67,7 +67,7 @@ public abstract class BaseRemoteModelService extends ModelServiceWithCalSuppo t.addData(url.toString()); - InputStream in = Urls.forIO().connectTimeout(1000).readTimeout(5000).openStream(url.toExternalForm()); + InputStream in = Urls.forIO().connectTimeout(1000).readTimeout(10000).openStream(url.toExternalForm()); GZIPInputStream gzip = new GZIPInputStream(in); String xml = Files.forIO().readFrom(gzip, "utf-8");