You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by is...@apache.org on 2023/02/02 17:34:08 UTC
[airavata] branch develop updated: bug fix in data analyzer
This is an automated email from the ASF dual-hosted git repository.
isjarana pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/airavata.git
The following commit(s) were added to refs/heads/develop by this push:
new 8eef0e1433 bug fix in data analyzer
new 2dc66ff72e Merge pull request #384 from isururanawaka/metaschedular
8eef0e1433 is described below
commit 8eef0e1433af29fa1afd90ad0c03c93e0a298397
Author: Isuru Ranawaka <ir...@gmail.com>
AuthorDate: Thu Feb 2 12:33:07 2023 -0500
bug fix in data analyzer
---
.../metascheduler/metadata/analyzer/impl/DataAnalyzerImpl.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/modules/airavata-metascheduler/metadata-analyzer/src/main/java/org/apache/airavata/metascheduler/metadata/analyzer/impl/DataAnalyzerImpl.java b/modules/airavata-metascheduler/metadata-analyzer/src/main/java/org/apache/airavata/metascheduler/metadata/analyzer/impl/DataAnalyzerImpl.java
index 294c385f4d..53c2948051 100644
--- a/modules/airavata-metascheduler/metadata-analyzer/src/main/java/org/apache/airavata/metascheduler/metadata/analyzer/impl/DataAnalyzerImpl.java
+++ b/modules/airavata-metascheduler/metadata-analyzer/src/main/java/org/apache/airavata/metascheduler/metadata/analyzer/impl/DataAnalyzerImpl.java
@@ -56,10 +56,11 @@ public class DataAnalyzerImpl implements DataAnalyzer {
Map<String, Double> timeDistribution = client.getAVGTimeDistribution(gateway,15);
- if(!timeDistribution.isEmpty() && timeDistribution.size()==3) {
- LOGGER.info("orch Time: " + timeDistribution.get("orchTime") + " queued Time "
- + timeDistribution.get("queuedTime") + " helix Time " + timeDistribution.get("helix"));
+ String msg ="";
+ for(Map.Entry<String, Double> entry: timeDistribution.entrySet()){
+ msg = " avg time "+entry.getKey()+" : "+entry.getValue();
}
+ LOGGER.info(msg);
} catch (Exception ex) {
String msg = "Error occurred while executing data analyzer" + ex.getMessage();