You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2017/12/06 01:10:57 UTC

[2/2] kylin git commit: KYLIN-3068 use dfs.blocksize instead of deprecated parameter name

KYLIN-3068 use dfs.blocksize instead of deprecated parameter name

Signed-off-by: shaofengshi <sh...@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/14dd92e0
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/14dd92e0
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/14dd92e0

Branch: refs/heads/master
Commit: 14dd92e00fa1548889bf6e6bba8010f8a6a8cfcf
Parents: 5c435cd
Author: Seva Ostapenko <se...@anovadata.com>
Authored: Tue Dec 5 17:38:57 2017 -0500
Committer: shaofengshi <sh...@apache.org>
Committed: Wed Dec 6 09:08:33 2017 +0800

----------------------------------------------------------------------
 .../kylin/source/hive/cardinality/HiveColumnCardinalityJob.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/14dd92e0/source-hive/src/main/java/org/apache/kylin/source/hive/cardinality/HiveColumnCardinalityJob.java
----------------------------------------------------------------------
diff --git a/source-hive/src/main/java/org/apache/kylin/source/hive/cardinality/HiveColumnCardinalityJob.java b/source-hive/src/main/java/org/apache/kylin/source/hive/cardinality/HiveColumnCardinalityJob.java
index 3942a68..dd32a58 100644
--- a/source-hive/src/main/java/org/apache/kylin/source/hive/cardinality/HiveColumnCardinalityJob.java
+++ b/source-hive/src/main/java/org/apache/kylin/source/hive/cardinality/HiveColumnCardinalityJob.java
@@ -86,7 +86,7 @@ public class HiveColumnCardinalityJob extends AbstractHadoopJob {
 
         Path output = new Path(getOptionValue(OPTION_OUTPUT_PATH));
         FileOutputFormat.setOutputPath(job, output);
-        job.getConfiguration().set("dfs.block.size", "67108864");
+        job.getConfiguration().set("dfs.blocksize", "67108864");
         job.getConfiguration().set("mapreduce.output.fileoutputformat.compress", "false");
 
         // Mapper