[phoenix] branch 4.x updated: PHOENIX-6556 Log INPUT_TABLE_CONDITIONS for MR jobs

[stoty]

This is an automated email from the ASF dual-hosted git repository.

stoty pushed a commit to branch 4.x
in repository https://gitbox.apache.org/repos/asf/phoenix.git


The following commit(s) were added to refs/heads/4.x by this push:
     new bf33145  PHOENIX-6556 Log INPUT_TABLE_CONDITIONS for MR jobs
bf33145 is described below

commit bf33145e332587e6d21a354a83492fcba117574a
Author: Istvan Toth <st...@apache.org>
AuthorDate: Tue Sep 21 10:30:50 2021 +0200

    PHOENIX-6556 Log INPUT_TABLE_CONDITIONS for MR jobs
---
 .../org/apache/phoenix/mapreduce/util/PhoenixConfigurationUtil.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixConfigurationUtil.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixConfigurationUtil.java
index 2074761..2a95b9a 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixConfigurationUtil.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixConfigurationUtil.java
@@ -505,14 +505,16 @@ public final class PhoenixConfigurationUtil {
         Preconditions.checkNotNull(configuration);
         String selectStmt = configuration.get(SELECT_STATEMENT);
         if(isNotEmpty(selectStmt)) {
+            LOGGER.info("Select Statement: " + selectStmt);
             return selectStmt;
         }
         final String tableName = getInputTableName(configuration);
         Preconditions.checkNotNull(tableName);
         final List<ColumnInfo> columnMetadataList = 
getSelectColumnMetadataList(configuration);
         final String conditions = configuration.get(INPUT_TABLE_CONDITIONS);
+        LOGGER.info("Building select statement from input conditions: " + 
conditions);
         selectStmt = QueryUtil.constructSelectStatement(tableName, 
columnMetadataList, conditions);
-        LOGGER.info("Select Statement: "+ selectStmt);
+        LOGGER.info("Select Statement: " + selectStmt);
         configuration.set(SELECT_STATEMENT, selectStmt);
         return selectStmt;
     }