Github user karanmehta93 commented on a diff in the pull request:
https://github.com/apache/phoenix/pull/338#discussion_r215432475
--- Diff:
phoenix-core/src/main/java/org/apache/phoenix/jdbc/LoggingPhoenixStatement.java
---
@@ -25,28 +28,38 @@
private PhoenixMetricsLog phoenixMetricsLog;
private String sql;
-
- public LoggingPhoenixStatement(Statement stmt, PhoenixMetricsLog
phoenixMetricsLog) {
+ private Connection conn;
+
+ public LoggingPhoenixStatement(Connection conn, Statement stmt,
PhoenixMetricsLog phoenixMetricsLog) {
super(stmt);
this.phoenixMetricsLog = phoenixMetricsLog;
+ this.conn = conn;
--- End diff --
same comment as above.
---
