This is an automated email from the ASF dual-hosted git repository. stoty pushed a commit to branch 5.1 in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/5.1 by this push: new 666a5a7 PHOENIX-6556 Log INPUT_TABLE_CONDITIONS for MR jobs 666a5a7 is described below commit 666a5a75be90439888efdffbbf904ac2cb44e832 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 66debc0..737c2ef 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 @@ -511,14 +511,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; }