Github user meiercaleb commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/251#discussion_r153536190
--- Diff:
extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/observers/StatementPatternObserver.java
---
@@ -49,7 +50,7 @@ public Observation parseObservation(final TransactionBase
tx, final Bytes row) t
requireNonNull(row);
// Read the Statement Pattern metadata.
- final String spNodeId = BindingSetRow.make(row).getNodeId();
+ final String spNodeId =
BindingSetRow.makeFromShardedRow(Bytes.of(SP_PREFIX), row).getNodeId();
--- End diff --
Done.
---
