diff options
| author | Jacques Nadeau <jacques@apache.org> | 2016-01-15 11:45:29 -0800 |
|---|---|---|
| committer | Jacques Nadeau <jacques@apache.org> | 2016-01-20 07:30:00 -0800 |
| commit | 664d34e3c64c3b52e1ed6347cab9ea27a4722a28 (patch) | |
| tree | 2be14f3d44bdc393bd1e3db867bb4026143ada8c /contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java | |
| parent | 43414e1e2731c85a52febaaedebfa2f392dd6d2f (diff) | |
DRILL-4277: Fix for JdbcPrel serialization issue.
This closes #326.
Diffstat (limited to 'contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java')
| -rw-r--r-- | contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java b/contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java index 2433fbd3d..22894c932 100644 --- a/contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java +++ b/contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java @@ -80,7 +80,8 @@ public class JdbcPrel extends AbstractRelNode implements Prel { @Override public PhysicalOperator getPhysicalOperator(PhysicalPlanCreator creator) throws IOException { - return new JdbcGroupScan(sql, convention.getPlugin(), rows); + JdbcGroupScan output = new JdbcGroupScan(sql, convention.getPlugin(), rows); + return creator.addMetadata(this, output); } @Override |