Skip to content

Commit

Permalink
[SP-4201][BACKLOG-22072] DET / DataServices not working with Stream L…
Browse files Browse the repository at this point in the history
…ookup step

 - restored info-sensitive cache keys for previous fields
  • Loading branch information
mchen-len-son authored and kevinramsey committed Dec 3, 2018
1 parent 8ac9ab0 commit 35ff0cf
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions engine/src/main/java/org/pentaho/di/trans/TransMeta.java
Original file line number Diff line number Diff line change
Expand Up @@ -120,6 +120,7 @@
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;

import javax.ws.rs.HEAD;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
Expand Down Expand Up @@ -1392,10 +1393,12 @@ public List<StepMeta> findPreviousSteps( StepMeta stepMeta ) {
public List<StepMeta> findPreviousSteps( StepMeta stepMeta, boolean info ) {



if ( stepMeta == null ) {
return new ArrayList<>();
}


String cacheKey = getStepMetaCacheKey( stepMeta, info );
List<StepMeta> previousSteps = previousStepCache.get( cacheKey );

Expand Down Expand Up @@ -1570,6 +1573,7 @@ public StepMeta findNextStep( StepMeta stepMeta, int nr ) {
public StepMeta[] getPrevSteps( StepMeta stepMeta ) {



List<StepMeta> prevSteps = previousStepCache.get( getStepMetaCacheKey( stepMeta, true ) );


Expand Down Expand Up @@ -6401,6 +6405,7 @@ public NamedClusterEmbedManager getNamedClusterEmbedManager( ) {
}



/**
*
* @return
Expand Down Expand Up @@ -6471,5 +6476,6 @@ private static RowMetaInterface[] cloneRowMetaInterfaces( RowMetaInterface[] inf
}
return cloned;


}
}

0 comments on commit 35ff0cf

Please sign in to comment.