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:19 UTC
[phoenix] branch master 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 master
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/master by this push:
new d75e5e4 PHOENIX-6556 Log INPUT_TABLE_CONDITIONS for MR jobs
d75e5e4 is described below
commit d75e5e4299504f74cda4e31801c44bc2d1493568
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;
}