You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2016/09/13 07:03:14 UTC
[2/4] storm git commit: STORM-1969 Modify HiveTopology to show usage
of non-partition table
STORM-1969 Modify HiveTopology to show usage of non-partition table
* HiveTopology is no longer using partition
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/746bbafc
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/746bbafc
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/746bbafc
Branch: refs/heads/1.0.x-branch
Commit: 746bbafcdf9fd7a4d8779b5c7009bc13195c66da
Parents: a40f144
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Thu Jul 14 18:02:06 2016 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Tue Sep 13 16:01:06 2016 +0900
----------------------------------------------------------------------
.../src/test/java/org/apache/storm/hive/bolt/HiveTopology.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/746bbafc/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/HiveTopology.java
----------------------------------------------------------------------
diff --git a/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/HiveTopology.java b/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/HiveTopology.java
index 8b61d5e..4afd298 100644
--- a/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/HiveTopology.java
+++ b/external/storm-hive/src/test/java/org/apache/storm/hive/bolt/HiveTopology.java
@@ -51,7 +51,6 @@ public class HiveTopology {
config.setNumWorkers(1);
UserDataSpout spout = new UserDataSpout();
DelimitedRecordHiveMapper mapper = new DelimitedRecordHiveMapper()
- .withTimeAsPartitionField("yyyy/MM/dd/hh")
.withColumnFields(new Fields(colNames));
HiveOptions hiveOptions;
if (args.length == 6) {