Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Flume >> mail # dev >> Review Request 18544: Hive Streaming sink


Copy link to this message
-
Re: Review Request 18544: Hive Streaming sink

This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/18544/

(Updated June 14, 2014, 4:19 a.m.)
Review request for Flume.
Changes

Uploading new patch v2 :
addressed loose ends in unit tests
fixed issues related to recovering from intermittent HDFS and Hive failures.
Bugs: FLUME-1734
    https://issues.apache.org/jira/browse/FLUME-1734
Repository: flume-git
Description

Hive streaming sink.
Diffs (updated)

  bin/flume-ng e09e26b
  conf/log4j.properties 3918511
  flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java ac11558
  flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java 0a1cd7a
  flume-ng-dist/pom.xml 690fec5
  flume-ng-doc/sphinx/FlumeUserGuide.rst b2058f5
  flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java ff32c45
  flume-ng-legacy-sources/flume-thrift-source/src/test/java/org/apache/flume/source/thriftLegacy/TestThriftLegacySource.java 8e08f22
  flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java 7f966b0
  flume-ng-sinks/flume-hive-sink/pom.xml PRE-CREATION
  flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveDelimitedTextSerializer.java PRE-CREATION
  flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveEventSerializer.java PRE-CREATION
  flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveJsonSerializer.java PRE-CREATION
  flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveSink.java PRE-CREATION
  flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java PRE-CREATION
  flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestHiveSink.java PRE-CREATION
  flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestHiveWriter.java PRE-CREATION
  flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestUtil.java PRE-CREATION
  flume-ng-sinks/flume-hive-sink/src/test/resources/log4j.properties PRE-CREATION
  flume-ng-sinks/pom.xml 56c4dee
  flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/Scribe.java eba8d2e
  pom.xml 4dae2c9

Diff: https://reviews.apache.org/r/18544/diff/
Testing

 This version lacks unit tests.
Thanks,

Roshan Naik