Google App Engine v. 1.9.48을 사용하고 있습니다. 일부 데이터 저장소 쿼리 중 무작위로 "CancellationException : 작업 취소됨"오류가 발생했습니다. 그리고 정확히이 오류의 원인을 정확히 알지 못합니다. other에서 Stackoverflow posts, 나는 이것이 막연하게 시간 제한과 관련이 있다는 것을 모호하지만 이해하지 못하고있다. TaskQueues를 사용하지 않고있다. 여기에 그 오류를 던지고있다Google 데이터 스토어 쿼리를 수행하는 동안 "CancellationException : 작업 취소됨"오류가 발생했습니다.
java.util.concurrent.CancellationException: Task was cancelled.
at com.google.common.util.concurrent.AbstractFuture.cancellationExceptionWithCause(AbstractFuture.java:1126)
at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:504)
at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:407)
at com.google.common.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:86)
....
at com.sun.proxy.$Proxy14.size(Unknown Source)
at main.java.com.continentalist.app.model.Model.getEntitySentimentCounts(Model.java:285)
at main.java.com.continentalist.app.model.Model.access$100(Model.java:37)
at main.java.com.continentalist.app.model.Model$2.vrun(Model.java:251)
at com.googlecode.objectify.VoidWork.run(VoidWork.java:14)
at com.googlecode.objectify.VoidWork.run(VoidWork.java:11)
at com.googlecode.objectify.ObjectifyService.run(ObjectifyService.java:81)
...
내 애플 리케이션 엔진 코드 :
다음은 스택 추적입니다. 나는 오류가 (일반적으로 list().size()
중 하나)에서 발생되는 줄 주석 추가 : 당신은 .list().size()
를 호출 할 필요는 없습니다
private EntityAnalysis getEntitySentimentCounts(ComboCall comboCall) {
Query<ObjectifyArticle> queryArticles = ofy().load().type(ObjectifyArticle.class);
queryArticles = queryArticles.filter("domain", comboCall.getDomain());
Set<Entity> entitySet = comboCall.getEntitySet();
SentimentCount[] allSentimentCounts = new SentimentCount[entitySet.size()];
int index = 0;
for(Entity eachEntity : entitySet) {
SentimentCount sentimentCount = new SentimentCount();
String eachEntityName = eachEntity.getText();
Query<ObjectifyArticle> newQuery = queryArticles;
newQuery = newQuery.filter("entityName", eachEntityName);
sentimentCount.setEntityName(eachEntityName);
Query<ObjectifyArticle> positiveFilter = newQuery;
positiveFilter = positiveFilter.filter("entityType", POSITIVE);
int positive = positiveFilter.list().size(); // ERROR EITHER HERE
sentimentCount.setPositiveCount(positive+"");
Query<ObjectifyArticle> negativeFilter = newQuery;
negativeFilter = negativeFilter.filter("entityType", NEGATIVE);
int negative = negativeFilter.list().size(); // OR HERE
sentimentCount.setNegativeCount(""+negative);
Query<ObjectifyArticle> neutralFilter = newQuery;
neutralFilter = neutralFilter.filter("entityType", NEUTRAL);
int neutral = neutralFilter.list().size(); // OR HERE
sentimentCount.setNeutralCount(""+neutral);
allSentimentCounts[index] = sentimentCount;
index++;
}
EntityAnalysis entityAnalysis = new EntityAnalysis();
entityAnalysis.setDomain(comboCall.getDomain());
entityAnalysis.setSentimentCount(allSentimentCounts);
return entityAnalysis;
}
단지 업데이트를 제공합니다 - 당신이 제안한대로 키 전용 쿼리와'chunkAll()'을 끝내기 시작했습니다. 당신 말이 맞아서 더 빠릅니다. 그러나 여전히 확장 성을 높이기 위해 내 데이터 모델을 다시 생각해야합니다. 옵션을 가져 주셔서 감사합니다. – BlueChips23
커서를 사용하여 매우 긴 쿼리를 실행할 수 있습니다. 즉, 쿼리가 500보다 작아 질 때까지 쿼리의 커서를 설정하고 쿼리를 설정하고 다시 실행하여 다음 500 개의 엔터티를 가져 오는 등 쿼리를 실행할 수 있습니다. 루프 내에서 몇 줄의 코드 일 뿐이며 필요한 경우 수백만 개의 엔티티를 처리 할 수 있습니다. –