You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by st...@apache.org on 2021/09/23 17:13:48 UTC
[phoenix] branch 5.1 updated: PHOENIX-6556 Log
INPUT_TABLE_CONDITIONS for MR jobs
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;
}