Concat indexPrefix to read alias to not break this functionality

frittentheke · frittentheke · commit 558952190008 · 2020-03-26T19:54:24.000+01:00
Signed-off-by: Christian Rohmann &lt;christian.rohmann@inovex.de&gt;
diff --git a/jaeger-spark-dependencies-elasticsearch/src/main/java/io/jaegertracing/spark/dependencies/elastic/ElasticsearchDependenciesJob.java b/jaeger-spark-dependencies-elasticsearch/src/main/java/io/jaegertracing/spark/dependencies/elastic/ElasticsearchDependenciesJob.java
@@ -204,7 +204,7 @@ private static String prefix(String prefix) {
 
   public void run(String peerServiceTag) {
 	  if (this.useAliases) {
-		  run(new String[]{"jaeger-span-read"}, indexDate("jaeger-dependencies") ,peerServiceTag);
+		  run(new String[]{prefix(indexPrefix) + "jaeger-span-read", prefixBefore19(indexPrefix) + "jaeger-span-read"}, indexDate("jaeger-dependencies") ,peerServiceTag);
 	  }
 	  else {
 		  run(indexDate("jaeger-span"), indexDate("jaeger-dependencies") ,peerServiceTag);

Original file line number	Diff line number	Diff line change
`@@ -204,7 +204,7 @@ private static String prefix(String prefix) {`
`204`	`204`
`205`	`205`	`public void run(String peerServiceTag) {`
`206`	`206`	`if (this.useAliases) {`
`207`		`- run(new String[]{"jaeger-span-read"}, indexDate("jaeger-dependencies") ,peerServiceTag);`
	`207`	`+ run(new String[]{prefix(indexPrefix) + "jaeger-span-read", prefixBefore19(indexPrefix) + "jaeger-span-read"}, indexDate("jaeger-dependencies") ,peerServiceTag);`
`208`	`208`	`}`
`209`	`209`	`else {`
`210`	`210`	`run(indexDate("jaeger-span"), indexDate("jaeger-dependencies") ,peerServiceTag);`