Flume
  1. Flume
  2. FLUME-1734

Create a Hive Sink based on the new Hive Streaming support

    Details

    • Type: New Feature New Feature
    • Status: Resolved
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: v1.2.0
    • Fix Version/s: v1.6.0
    • Component/s: Sinks+Sources
    • Labels:
    • Release Note:
      Hide
      Committed! Thanks Roshan!
      Show
      Committed! Thanks Roshan!

      Description

      Hive 0.13 has introduced Streaming support which is itself transactional in nature and fits well with Flume's transaction model.
      Short overview of Hive's Streaming support on which this sink is based can be found here:
      http://hive.apache.org/javadocs/r0.13.1/api/hcatalog/streaming/index.html

      This jira is for creating a sink that would continuously stream data into Hive tables using the above APIs. The primary goal being that the data streamed by the sink should be instantly queryable (using say Hive or Pig) without requiring additional post-processing steps on behalf of the users. Sink should manage the creation of new partitions periodically if needed.

      1. FLUME-1734.draft.1.patch
        0.5 kB
        Roshan Naik
      2. FLUME-1734.draft.2.patch
        45 kB
        Roshan Naik
      3. FLUME-1734.v1.patch
        103 kB
        Roshan Naik
      4. FLUME-1734.v10.patch
        109 kB
        Roshan Naik
      5. FLUME-1734.v10b.patch
        109 kB
        Roshan Naik
      6. FLUME-1734.v2.patch
        107 kB
        Roshan Naik
      7. FLUME-1734.v4.patch
        109 kB
        Roshan Naik
      8. FLUME-1734.v5.patch
        110 kB
        Roshan Naik
      9. FLUME-1734.v6.patch
        108 kB
        Roshan Naik
      10. FLUME-1734.v7.patch
        24 kB
        Roshan Naik
      11. FLUME-1734.v8.patch
        108 kB
        Roshan Naik
      12. FLUME-1734.v9.patch
        109 kB
        Roshan Naik

        Issue Links

          Activity

          Transition Time In Source Status Execution Times Last Executer Last Execution Date
          Open Open Patch Available Patch Available
          570d 8h 14m 1 Roshan Naik 14/Jun/14 05:21
          Patch Available Patch Available Resolved Resolved
          241d 2h 55m 1 Hari Shreedharan 10/Feb/15 07:17
          Johny Rufus made changes -
          Fix Version/s v1.6.0 [ 12327047 ]
          Hide
          Roshan Naik added a comment -
          Show
          Roshan Naik added a comment - Thanks Hari Shreedharan .
          Hide
          Hudson added a comment -

          UNSTABLE: Integrated in flume-trunk #713 (See https://builds.apache.org/job/flume-trunk/713/)
          FLUME-1734. Add a Hive Sink based on Hive Streaming support. (hshreedharan: http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=a7f9255a83beb222e1f3e871dff2d44568fa3f43)

          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c671.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7d1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19c1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c691.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e80.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1db0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc00.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c660.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c91.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ea1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8c1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b40.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6f1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c760.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3c0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c620.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e41.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5d1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c551.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc70.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c171.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c731.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19b0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e20.dat
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveEventSerializer.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c680.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c771.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c150.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8d1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19d0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c331.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b81.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c230.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e00.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7e1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb00.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ba0.dat
          • flume-ng-doc/sphinx/FlumeUserGuide.rst
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c881.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c930.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d61.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6d1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cd1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c901.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc41.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1da1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1aa0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c60.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c640.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c831.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c791.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1961.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c361.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c90.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3d1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c300.dat
          • pom.xml
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9e1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b20.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1de0.dat
          • conf/log4j.properties
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbe1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c391.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b50.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cad1.dat
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveDelimitedTextSerializer.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1eb0.dat
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveSink.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c961.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c41.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7f1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ec1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1951.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ad0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6a0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/log/log4.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e60.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c941.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c700.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c421.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c441.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c560.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c871.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e71.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cf0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/db.lck
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca51.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2a1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a61.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb61.dat
          • flume-ng-sinks/flume-hive-sink/src/test/resources/log4j.properties
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc91.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca40.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d01.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cf0.dat
          • flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c891.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c600.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c281.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c861.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a21.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c971.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d30.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c51.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2e1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7c1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc51.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ee0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c451.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bf0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c81.dat
          • flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestHiveWriter.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c751.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca21.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca01.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1d1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c571.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/dbex.lck
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f01.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb51.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/log/log3.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c111.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c801.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c60.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a00.dat
          • flume-ng-dist/pom.xml
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d18f1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1af1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c711.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c851.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c950.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c40.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c01.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c380.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e90.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c651.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c811.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c631.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c130.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ef0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6c0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a50.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1911.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8f0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19a0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19f0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c221.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1dc0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ae0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c321.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3f1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/caf1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c121.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cac1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c591.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c581.dat
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveJsonSerializer.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1920.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1be0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c411.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc81.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a91.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d50.dat
          • bin/flume-ng
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc20.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c20.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c51.dat
          • flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestUtil.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c921.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cca1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbb1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c80.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1c0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a80.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cba1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b61.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca61.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca70.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ac0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1940.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c400.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c910.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c70.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cd1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19e1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c740.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb40.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c71.dat
          • flume-ng-sinks/flume-hive-sink/pom.xml
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b90.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cab1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cb0.dat
          • flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestHiveSink.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b01.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c611.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a40.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c461.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/log/logmirror.ctrl
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f20.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c211.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca81.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3a1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c161.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bc1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb21.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c180.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb80.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7a0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ab1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1991.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3e1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5c0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c351.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1a1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f11.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1930.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2f0.dat
          • flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/Scribe.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bb0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1900.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1980.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d21.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c780.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/log/log.ctrl
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9f0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c101.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1df1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ce1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c311.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbd1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cc0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c20.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ca1.dat
          • flume-ng-sinks/pom.xml
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5e0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cae1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ed0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bd1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9a1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c241.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d18e0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d90.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c290.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c991.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f50.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f41.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b70.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c430.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb11.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/caa1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d40.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/service.properties
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/Config.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d71.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c371.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c340.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d80.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2d0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e50.dat
          • flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java
          • flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5f1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9c1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c191.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c141.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c271.dat
          • flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8e1.dat
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a70.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5a0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb71.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c260.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbc0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6e0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9d0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb91.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c540.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1dd1.dat
          • flume-ng-legacy-sources/flume-thrift-source/src/test/java/org/apache/flume/source/thriftLegacy/TestThriftLegacySource.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8a1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2c1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1970.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc61.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c720.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca90.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f30.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c200.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ce0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c251.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbf1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c981.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c821.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc11.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c841.dat
          Show
          Hudson added a comment - UNSTABLE: Integrated in flume-trunk #713 (See https://builds.apache.org/job/flume-trunk/713/ ) FLUME-1734 . Add a Hive Sink based on Hive Streaming support. (hshreedharan: http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=a7f9255a83beb222e1f3e871dff2d44568fa3f43 ) flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c671.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7d1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19c1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c691.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e80.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1db0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc00.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c660.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c91.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ea1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8c1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b40.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6f1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c760.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3c0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c620.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e41.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5d1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c551.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc70.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c171.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c731.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19b0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e20.dat flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveEventSerializer.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c680.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c771.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c150.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8d1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19d0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c331.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b81.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c230.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e00.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7e1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb00.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ba0.dat flume-ng-doc/sphinx/FlumeUserGuide.rst flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c881.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c930.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d61.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6d1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cd1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c901.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc41.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1da1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1aa0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c60.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c640.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c831.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c791.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1961.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c361.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c90.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3d1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c300.dat pom.xml flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9e1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b20.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1de0.dat conf/log4j.properties flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbe1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c391.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b50.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cad1.dat flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveDelimitedTextSerializer.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1eb0.dat flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveSink.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c961.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c41.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7f1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ec1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1951.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ad0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6a0.dat flume-ng-sinks/flume-hive-sink/metastore_db/log/log4.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e60.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c941.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c700.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c421.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c441.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c560.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c871.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e71.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cf0.dat flume-ng-sinks/flume-hive-sink/metastore_db/db.lck flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca51.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2a1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a61.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb61.dat flume-ng-sinks/flume-hive-sink/src/test/resources/log4j.properties flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc91.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca40.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d01.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cf0.dat flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c891.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c600.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c281.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c861.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a21.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c971.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d30.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c51.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2e1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7c1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc51.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ee0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c451.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bf0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c81.dat flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestHiveWriter.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c751.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca21.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca01.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1d1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c571.dat flume-ng-sinks/flume-hive-sink/metastore_db/dbex.lck flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f01.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb51.dat flume-ng-sinks/flume-hive-sink/metastore_db/log/log3.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c111.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c801.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c60.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a00.dat flume-ng-dist/pom.xml flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d18f1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1af1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c711.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c851.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c950.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c40.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c01.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c380.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e90.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c651.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c811.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c631.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c130.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ef0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6c0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a50.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1911.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8f0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19a0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19f0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c221.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1dc0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ae0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c321.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3f1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/caf1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c121.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cac1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c591.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c581.dat flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveJsonSerializer.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1920.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1be0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c411.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc81.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a91.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d50.dat bin/flume-ng flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc20.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c20.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c51.dat flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestUtil.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c921.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cca1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbb1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c80.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1c0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a80.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cba1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b61.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca61.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca70.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ac0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1940.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c400.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c910.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c70.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cd1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19e1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c740.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb40.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c71.dat flume-ng-sinks/flume-hive-sink/pom.xml flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b90.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cab1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cb0.dat flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestHiveSink.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b01.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c611.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a40.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c461.dat flume-ng-sinks/flume-hive-sink/metastore_db/log/logmirror.ctrl flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f20.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c211.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca81.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3a1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c161.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bc1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb21.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c180.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb80.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7a0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ab1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1991.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3e1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5c0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c351.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1a1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f11.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1930.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2f0.dat flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/Scribe.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bb0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1900.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1980.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d21.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c780.dat flume-ng-sinks/flume-hive-sink/metastore_db/log/log.ctrl flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9f0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c101.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1df1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ce1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c311.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbd1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cc0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c20.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ca1.dat flume-ng-sinks/pom.xml flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5e0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cae1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ed0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bd1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9a1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c241.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d18e0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d90.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c290.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c991.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f50.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f41.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b70.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c430.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb11.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/caa1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d40.dat flume-ng-sinks/flume-hive-sink/metastore_db/service.properties flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/Config.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d71.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c371.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c340.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d80.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2d0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e50.dat flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5f1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9c1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c191.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c141.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c271.dat flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8e1.dat flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a70.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5a0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb71.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c260.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbc0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6e0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9d0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb91.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c540.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1dd1.dat flume-ng-legacy-sources/flume-thrift-source/src/test/java/org/apache/flume/source/thriftLegacy/TestThriftLegacySource.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8a1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2c1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1970.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc61.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c720.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca90.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f30.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c200.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ce0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c251.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbf1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c981.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c821.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc11.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c841.dat
          Hide
          Hudson added a comment -

          SUCCESS: Integrated in Flume-trunk-hbase-98 #70 (See https://builds.apache.org/job/Flume-trunk-hbase-98/70/)
          FLUME-1734. Add a Hive Sink based on Hive Streaming support. (hshreedharan: http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=a7f9255a83beb222e1f3e871dff2d44568fa3f43)

          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1af1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc11.dat
          • conf/log4j.properties
          • flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestUtil.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1db0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cca1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3d1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cc0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbe1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c371.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d18f1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c921.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c60.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f41.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c640.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e50.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1930.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbb1.dat
          • flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestHiveWriter.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb91.dat
          • flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ab1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c230.dat
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/Config.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19e1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c551.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c540.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6e0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d40.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a80.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c241.dat
          • flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c70.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8c1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ce1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c361.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c771.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1dd1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc70.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ed0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c731.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5e0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cae1.dat
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveJsonSerializer.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c221.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5f1.dat
          • flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c930.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c881.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a70.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8d1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c941.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c340.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bf0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc91.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c441.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b81.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b01.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c200.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c211.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7e1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1991.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c581.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cd1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbd1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d80.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc61.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca21.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/caa1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c91.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e71.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c451.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c400.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f50.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a91.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cb0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c811.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1920.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ce0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c90.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca90.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/db.lck
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1911.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2a1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c260.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/service.properties
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c271.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1aa0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d18e0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c981.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c311.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/log/log4.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c740.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a50.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3e1.dat
          • flume-ng-dist/pom.xml
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c760.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c571.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c461.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b20.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19b0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca70.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c281.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c430.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c121.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c991.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1dc0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cf0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cd1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3a1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbc0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c321.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ad0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8f0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e00.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c251.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c391.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c421.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/log/log3.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc0.dat
          • flume-ng-sinks/flume-hive-sink/src/test/resources/log4j.properties
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc51.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb80.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb11.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2d0.dat
          • flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestHiveSink.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c780.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5a0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c591.dat
          • flume-ng-doc/sphinx/FlumeUserGuide.rst
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c60.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5c0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb40.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7d1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a00.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3c0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb00.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c631.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7c1.dat
          • flume-ng-sinks/pom.xml
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1de0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2c1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9c1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8a1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e20.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb71.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c380.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2e1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ca1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb51.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1951.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c821.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f30.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c01.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2f0.dat
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19d0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c891.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c51.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b40.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cab1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d01.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d30.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c141.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b61.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d90.dat
          • pom.xml
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ee0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c411.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c81.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ac0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c331.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cad1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7a0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c101.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c560.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c80.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f11.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d21.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9a1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c711.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f01.dat
          • bin/flume-ng
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c671.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ae0.dat
          • flume-ng-legacy-sources/flume-thrift-source/src/test/java/org/apache/flume/source/thriftLegacy/TestThriftLegacySource.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c40.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c831.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19a0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bb0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c620.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca01.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a40.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8e1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c950.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c971.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/log/logmirror.ctrl
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca40.dat
          • flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/Scribe.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19f0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/dbex.lck
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6c0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c171.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb21.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1900.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b70.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c290.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c680.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bd1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19c1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbf1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c130.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c651.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6a0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c901.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e90.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c861.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c71.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c841.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca61.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c691.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c801.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1980.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c20.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1d1.dat
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveSink.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e80.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cac1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3f1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9f0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6d1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6f1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc81.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c611.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c41.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c161.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/caf1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f20.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9d0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb61.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c700.dat
          • flume-ng-sinks/flume-hive-sink/pom.xml
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c600.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c751.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d50.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1be0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a61.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d71.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1961.dat
          • flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1da1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c51.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b90.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c180.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c191.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5d1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c111.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c20.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc41.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c660.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ec1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d61.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bc1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1eb0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c300.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c720.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c791.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca51.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b50.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cf0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/log/log.ctrl
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2b1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc20.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1c0.dat
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveEventSerializer.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ea1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e41.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9e1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca81.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c851.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e60.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cba1.dat
          • flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveDelimitedTextSerializer.java
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc00.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c871.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ef0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca31.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1df1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ba0.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1970.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1a1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7f1.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c961.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c150.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1940.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b10.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a21.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c351.dat
          • flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c910.dat
          Show
          Hudson added a comment - SUCCESS: Integrated in Flume-trunk-hbase-98 #70 (See https://builds.apache.org/job/Flume-trunk-hbase-98/70/ ) FLUME-1734 . Add a Hive Sink based on Hive Streaming support. (hshreedharan: http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=a7f9255a83beb222e1f3e871dff2d44568fa3f43 ) flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1af1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc11.dat conf/log4j.properties flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestUtil.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1db0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cca1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3d1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cc0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbe1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c371.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d18f1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c921.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c60.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f41.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c640.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e50.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1930.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbb1.dat flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestHiveWriter.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb91.dat flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ab1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c230.dat flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/Config.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19e1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c551.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c540.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6e0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d40.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a80.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c241.dat flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c70.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8c1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ce1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c361.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c771.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1dd1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc70.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ed0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c731.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5e0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cae1.dat flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveJsonSerializer.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c221.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5f1.dat flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c930.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c881.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a70.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8d1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c941.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c340.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bf0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc91.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c441.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b81.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b01.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c200.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c211.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7e1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1991.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c581.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cd1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbd1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d80.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc61.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca21.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/caa1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c91.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e71.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c451.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c400.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f50.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a91.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cb0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c811.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1920.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ce0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c90.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca90.dat flume-ng-sinks/flume-hive-sink/metastore_db/db.lck flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1911.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2a1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c260.dat flume-ng-sinks/flume-hive-sink/metastore_db/service.properties flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c271.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1aa0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d18e0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c981.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c311.dat flume-ng-sinks/flume-hive-sink/metastore_db/log/log4.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c740.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a50.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3e1.dat flume-ng-dist/pom.xml flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c760.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c571.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c461.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b20.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19b0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca70.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c281.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c430.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c121.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c991.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1dc0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cf0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cd1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3a1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbc0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c321.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ad0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8f0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e00.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c251.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c391.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c421.dat flume-ng-sinks/flume-hive-sink/metastore_db/log/log3.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc0.dat flume-ng-sinks/flume-hive-sink/src/test/resources/log4j.properties flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc51.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb80.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb11.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2d0.dat flume-ng-sinks/flume-hive-sink/src/test/java/org/apache/flume/sink/hive/TestHiveSink.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c780.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5a0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c591.dat flume-ng-doc/sphinx/FlumeUserGuide.rst flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c60.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5c0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb40.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7d1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a00.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3c0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb00.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c631.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7c1.dat flume-ng-sinks/pom.xml flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1de0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2c1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9c1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8a1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e20.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb71.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c380.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2e1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ca1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb51.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1951.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c821.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f30.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c01.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2f0.dat flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19d0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c891.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c51.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b40.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cab1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d01.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d30.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c141.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b61.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d90.dat pom.xml flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ee0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c411.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c81.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ac0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c331.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cad1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7a0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c101.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c560.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c80.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f11.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d21.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9a1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c711.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f01.dat bin/flume-ng flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c671.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ae0.dat flume-ng-legacy-sources/flume-thrift-source/src/test/java/org/apache/flume/source/thriftLegacy/TestThriftLegacySource.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c40.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c831.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19a0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bb0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c620.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca01.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a40.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c8e1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c950.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c971.dat flume-ng-sinks/flume-hive-sink/metastore_db/log/logmirror.ctrl flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca40.dat flume-ng-sources/flume-scribe-source/src/main/java/org/apache/flume/source/scribe/Scribe.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19f0.dat flume-ng-sinks/flume-hive-sink/metastore_db/dbex.lck flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6c0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c171.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb21.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1900.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b70.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c290.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c680.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bd1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d19c1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cbf1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c130.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c651.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6a0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c901.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e90.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c861.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c71.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c841.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca61.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c691.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c801.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1980.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c20.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1d1.dat flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveSink.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e80.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cac1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3f1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9f0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6d1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c6f1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc81.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c611.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c41.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c161.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/caf1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f20.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9d0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb61.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c700.dat flume-ng-sinks/flume-hive-sink/pom.xml flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c600.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c751.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d50.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1be0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a61.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d71.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1961.dat flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1da1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c51.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b90.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c180.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c191.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5d1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c111.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c20.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc41.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1c10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c660.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ec1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1d61.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1bc1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1eb0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c300.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c720.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c791.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca51.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b50.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1cf0.dat flume-ng-sinks/flume-hive-sink/metastore_db/log/log.ctrl flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2b1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc20.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1c0.dat flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveEventSerializer.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ea1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e41.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c9e1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca81.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c851.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1e60.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cba1.dat flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveDelimitedTextSerializer.java flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cc00.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c871.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ef0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/ca31.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/cb1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1df1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1ba0.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1970.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1a1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c7f1.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c961.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c150.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1940.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1b10.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/d1a21.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c351.dat flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c910.dat
          Hari Shreedharan made changes -
          Status Patch Available [ 10002 ] Resolved [ 5 ]
          Release Note Committed! Thanks Roshan!
          Resolution Fixed [ 1 ]
          Hide
          ASF subversion and git services added a comment -

          Commit 5dfd3d963762b23add165a9034c5ef93493d2bc7 in flume's branch refs/heads/flume-1.6 from Hari Shreedharan
          [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=5dfd3d9 ]

          FLUME-1734. Add a Hive Sink based on Hive Streaming support.

          (Roshan Naik via Hari Shreedharan)

          Show
          ASF subversion and git services added a comment - Commit 5dfd3d963762b23add165a9034c5ef93493d2bc7 in flume's branch refs/heads/flume-1.6 from Hari Shreedharan [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=5dfd3d9 ] FLUME-1734 . Add a Hive Sink based on Hive Streaming support. (Roshan Naik via Hari Shreedharan)
          Hide
          ASF subversion and git services added a comment -

          Commit a7f9255a83beb222e1f3e871dff2d44568fa3f43 in flume's branch refs/heads/trunk from Hari Shreedharan
          [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=a7f9255 ]

          FLUME-1734. Add a Hive Sink based on Hive Streaming support.

          (Roshan Naik via Hari Shreedharan)

          Show
          ASF subversion and git services added a comment - Commit a7f9255a83beb222e1f3e871dff2d44568fa3f43 in flume's branch refs/heads/trunk from Hari Shreedharan [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=a7f9255 ] FLUME-1734 . Add a Hive Sink based on Hive Streaming support. (Roshan Naik via Hari Shreedharan)
          Hide
          Hari Shreedharan added a comment -

          The version of the hive sink in the top-level pom was 1.4.0. I changed this to 1.6.0-SNAPSHOT, built against hadoop-1 and hbase-98 profiles. Looks good, committing now.

          Show
          Hari Shreedharan added a comment - The version of the hive sink in the top-level pom was 1.4.0. I changed this to 1.6.0-SNAPSHOT, built against hadoop-1 and hbase-98 profiles. Looks good, committing now.
          Hide
          Hari Shreedharan added a comment -

          I am going to try this one again tonight. If it applies and builds fine, I will commit this tonight.

          Show
          Hari Shreedharan added a comment - I am going to try this one again tonight. If it applies and builds fine, I will commit this tonight.
          Roshan Naik made changes -
          Attachment FLUME-1734.v10b.patch [ 12695722 ]
          Hide
          Roshan Naik added a comment - - edited

          Hari Shreedharan .. uploading patch v10b - rebased with flume-1.6 branch

          Show
          Roshan Naik added a comment - - edited Hari Shreedharan .. uploading patch v10b - rebased with flume-1.6 branch
          Hide
          Hari Shreedharan added a comment -

          Roshan Naik - This does not apply, can you please rebase?

          Show
          Hari Shreedharan added a comment - Roshan Naik - This does not apply, can you please rebase?
          Hide
          Roshan Naik added a comment -

          perhaps because i was issuing mvn clean before switching mvn build profile.

          Show
          Roshan Naik added a comment - perhaps because i was issuing mvn clean before switching mvn build profile.
          Roshan Naik made changes -
          Attachment FLUME-1734.v10.patch [ 12694022 ]
          Hide
          Roshan Naik added a comment -

          I can see how this happens though for some strange reason these files didn't get reported in my runs. i am adding to the rat exclusion list with this v10 patch

          Show
          Roshan Naik added a comment - I can see how this happens though for some strange reason these files didn't get reported in my runs. i am adding to the rat exclusion list with this v10 patch
          Hide
          Hari Shreedharan added a comment -

          2 Unknown Licenses

          *******************************

          Unapproved licenses:

          /Users/hshreedharan/work/flume-latest/flume/flume-ng-sinks/flume-hive-sink/metastore_db/db.lck
          /Users/hshreedharan/work/flume-latest/flume/flume-ng-sinks/flume-hive-sink/metastore_db/service.properties

          Show
          Hari Shreedharan added a comment - 2 Unknown Licenses ******************************* Unapproved licenses: /Users/hshreedharan/work/flume-latest/flume/flume-ng-sinks/flume-hive-sink/metastore_db/db.lck /Users/hshreedharan/work/flume-latest/flume/flume-ng-sinks/flume-hive-sink/metastore_db/service.properties
          Hide
          Roshan Naik added a comment -

          can u please provide the rat.txt file from the run ?

          Show
          Roshan Naik added a comment - can u please provide the rat.txt file from the run ?
          Hide
          Hari Shreedharan added a comment -

          I get this error:
          [ERROR] Failed to execute goal org.apache.rat:apache-rat-plugin:0.7:check (verify.rat) on project flume-hive-sink: Too many unapproved licenses: 2 -> [Help 1]

          This is due to some metastore files hanging around in the target directory. Either these should be cleaned up or add an exclusion for the target directory.

          Show
          Hari Shreedharan added a comment - I get this error: [ERROR] Failed to execute goal org.apache.rat:apache-rat-plugin:0.7:check (verify.rat) on project flume-hive-sink: Too many unapproved licenses: 2 -> [Help 1] This is due to some metastore files hanging around in the target directory. Either these should be cleaned up or add an exclusion for the target directory.
          Roshan Naik made changes -
          Attachment FLUME-1734.v9.patch [ 12693796 ]
          Hide
          Roshan Naik added a comment -

          Hari Shreedharan uploading patch.. excluding hive-sink from the hadoop1 profile. verified tests on both hbase-98 and hadoop2 profiles.

          Show
          Roshan Naik added a comment - Hari Shreedharan uploading patch.. excluding hive-sink from the hadoop1 profile. verified tests on both hbase-98 and hadoop2 profiles.
          Hide
          Roshan Naik added a comment -

          Seems like the modification to disable it in the hadoop1 profile did not get captured.

          My apologies. Will update soon.

          Show
          Roshan Naik added a comment - Seems like the modification to disable it in the hadoop1 profile did not get captured. My apologies. Will update soon.
          Hide
          Hari Shreedharan added a comment -

          There are a lot of test failures in the default profile:
          testSecondWriterAfterFirstCommits(org.apache.flume.sink.hive.TestHiveWriter) Time elapsed: 0 sec <<< ERROR!
          java.lang.RuntimeException: java.lang.RuntimeException: Unable to instantiate org.apache.hadoop.hive.metastore.HiveMetaStoreClient
          at org.apache.hadoop.hive.ql.session.SessionState.start(SessionState.java:346)
          at org.apache.flume.sink.hive.TestHiveWriter.<init>(TestHiveWriter.java:94)
          at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
          at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
          at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
          at java.lang.reflect.Constructor.newInstance(Constructor.java:526)

          Show
          Hari Shreedharan added a comment - There are a lot of test failures in the default profile: testSecondWriterAfterFirstCommits(org.apache.flume.sink.hive.TestHiveWriter) Time elapsed: 0 sec <<< ERROR! java.lang.RuntimeException: java.lang.RuntimeException: Unable to instantiate org.apache.hadoop.hive.metastore.HiveMetaStoreClient at org.apache.hadoop.hive.ql.session.SessionState.start(SessionState.java:346) at org.apache.flume.sink.hive.TestHiveWriter.<init>(TestHiveWriter.java:94) at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
          Hide
          Hari Shreedharan added a comment -

          Running tests on this one now. If all tests pass, I will commit this.

          Show
          Hari Shreedharan added a comment - Running tests on this one now. If all tests pass, I will commit this.
          Roshan Naik made changes -
          Attachment FLUME-1734.v8.patch [ 12692594 ]
          Hide
          Roshan Naik added a comment -

          revising v8 patch.

          Show
          Roshan Naik added a comment - revising v8 patch.
          Roshan Naik made changes -
          Attachment FLUME-1734.v8.patch [ 12692407 ]
          Roshan Naik made changes -
          Attachment FLUME-1734.v8.patch [ 12692407 ]
          Hide
          Roshan Naik added a comment -

          Uploading patch.

          • Fixed : thrift version in hadoop1 profile.
          • fixed : missing Java files
          Show
          Roshan Naik added a comment - Uploading patch. Fixed : thrift version in hadoop1 profile. fixed : missing Java files
          Hide
          Roshan Naik added a comment -

          sorry just got back from vacation.. will update soon.

          Show
          Roshan Naik added a comment - sorry just got back from vacation.. will update soon.
          Hide
          Hari Shreedharan added a comment -

          Roshan Naik Any update here?

          Show
          Hari Shreedharan added a comment - Roshan Naik Any update here?
          Hide
          Hari Shreedharan added a comment -

          Roshan Naik - It looks like you forgot to add the Hive sink in the last patch. Missed a git add perhaps?

          Also, in the hadoop-1 profile, we cannot upgrade thrift without upgrading the minimum hbase version. Hbase 92 requires thrift 0.7 and using thrift RPC with hbase on the same agent will cause issues if thrift is upgraded to 0.9 (Thrift is not binary compatible between versions 0.7 and 0.9). If this change is required, I recommend making this sink hadoop-2 and hbase-98 profile only.

          Show
          Hari Shreedharan added a comment - Roshan Naik - It looks like you forgot to add the Hive sink in the last patch. Missed a git add perhaps? Also, in the hadoop-1 profile, we cannot upgrade thrift without upgrading the minimum hbase version. Hbase 92 requires thrift 0.7 and using thrift RPC with hbase on the same agent will cause issues if thrift is upgraded to 0.9 (Thrift is not binary compatible between versions 0.7 and 0.9). If this change is required, I recommend making this sink hadoop-2 and hbase-98 profile only.
          Hide
          Hari Shreedharan added a comment -

          I believe the old versions of hbase (0.92.x or 0.94.x) - not sure which require thrift 0.7.x - if you run thrift source and hbase sink with this version of hbase there would be NoClassDefFoundErrors - we could just support this sink in the hadoop-2/hbase-98 profiles like the dataset sink.

          Show
          Hari Shreedharan added a comment - I believe the old versions of hbase (0.92.x or 0.94.x) - not sure which require thrift 0.7.x - if you run thrift source and hbase sink with this version of hbase there would be NoClassDefFoundErrors - we could just support this sink in the hadoop-2/hbase-98 profiles like the dataset sink.
          Roshan Naik made changes -
          Attachment FLUME-1734.v7.patch [ 12688433 ]
          Hide
          Roshan Naik added a comment - - edited

          Hari Shreedharan .. Uploading patch. tests should now run fine in both hbase-98 and hadoop1 profiles. Also updated doc to note experimental.

          Show
          Roshan Naik added a comment - - edited Hari Shreedharan .. Uploading patch. tests should now run fine in both hbase-98 and hadoop1 profiles. Also updated doc to note experimental.
          Hide
          Hari Shreedharan added a comment -

          No with hadoop-1. If it does not work with hadoop-1, can you disable it for hadoop-1 (like the kite dataset sink)

          Show
          Hari Shreedharan added a comment - No with hadoop-1. If it does not work with hadoop-1, can you disable it for hadoop-1 (like the kite dataset sink)
          Hide
          Roshan Naik added a comment -

          oh.. let me take a look.. did u get a clean run with hbase-98/hadoop2 profile ?

          Show
          Roshan Naik added a comment - oh.. let me take a look.. did u get a clean run with hbase-98/hadoop2 profile ?
          Hide
          Hari Shreedharan added a comment -

          This is failing several tests in the hadoop-1 profile.

          Roshan Naik - Can you take a look?

          Show
          Hari Shreedharan added a comment - This is failing several tests in the hadoop-1 profile. Roshan Naik - Can you take a look?
          Hide
          Hari Shreedharan added a comment -

          Great. I am going to run tests and commit this then.

          Show
          Hari Shreedharan added a comment - Great. I am going to run tests and commit this then.
          Hide
          Brock Noland added a comment -

          That sounds fine to me. +1 on the statement of experimental status.

          Show
          Brock Noland added a comment - That sounds fine to me. +1 on the statement of experimental status.
          Hide
          Hari Shreedharan added a comment -

          Brock Noland - Let me know if you have any more concerns. Else I will commit this soon.

          Roshan Naik - Can you add a comment stating that this is experimental and should not be used in production right now.

          Show
          Hari Shreedharan added a comment - Brock Noland - Let me know if you have any more concerns. Else I will commit this soon. Roshan Naik - Can you add a comment stating that this is experimental and should not be used in production right now.
          Hide
          Roshan Naik added a comment -

          Hi Brock Noland ... wanted attention on this one. thanks.

          Show
          Roshan Naik added a comment - Hi Brock Noland ... wanted attention on this one. thanks.
          Roshan Naik made changes -
          Attachment FLUME-1734.v6.patch [ 12681228 ]
          Hide
          Roshan Naik added a comment -

          Uploading patch which addresses Brock Noland's review comments.

          Show
          Roshan Naik added a comment - Uploading patch which addresses Brock Noland 's review comments.
          Hide
          Roshan Naik added a comment -

          Brock Noland could you please review it again and see if its ready for commit ?

          Show
          Roshan Naik added a comment - Brock Noland could you please review it again and see if its ready for commit ?
          Roshan Naik made changes -
          Attachment FLUME-1734.v5.patch [ 12668532 ]
          Hide
          Roshan Naik added a comment -

          uploading minor fix to pom.xml in patch

          Show
          Roshan Naik added a comment - uploading minor fix to pom.xml in patch
          Roshan Naik made changes -
          Attachment FLUME-1734.v4.patch [ 12666130 ]
          Hide
          Roshan Naik added a comment - - edited

          Thanks Brock Noland for your review comments. Uploading new patch which addresses the comments.. Reviewboard has also been updated

          Show
          Roshan Naik added a comment - - edited Thanks Brock Noland for your review comments. Uploading new patch which addresses the comments.. Reviewboard has also been updated
          Roshan Naik made changes -
          Description Hive 0.13 has introduced Streaming support which is itself transactional in nature and fits well with Flume's transaction model.
          Short overview of Hive's Streaming support on which this sink is based can be found here:
          https://issues.apache.org/jira/secure/attachment/12639278/package.html


          This jira is for creating a sink that would continuously stream data into Hive tables using the above APIs. The primary goal being that the data streamed by the sink should be instantly queryable (using say Hive or Pig) without requiring additional post-processing steps on behalf of the users. Sink should manage the creation of new partitions periodically if needed.


          Hive 0.13 has introduced Streaming support which is itself transactional in nature and fits well with Flume's transaction model.
          Short overview of Hive's Streaming support on which this sink is based can be found here:
          http://hive.apache.org/javadocs/r0.13.1/api/hcatalog/streaming/index.html


          This jira is for creating a sink that would continuously stream data into Hive tables using the above APIs. The primary goal being that the data streamed by the sink should be instantly queryable (using say Hive or Pig) without requiring additional post-processing steps on behalf of the users. Sink should manage the creation of new partitions periodically if needed.


          Roshan Naik made changes -
          Link This issue blocks FLUME-2433 [ FLUME-2433 ]
          Roshan Naik made changes -
          Description Create a sink that would stream data into HCatalog partitions. The primary goal being that once the data is loaded into Hadoop, it should be automatically queryable (using say Hive or Pig) without requiring additional post processing steps on behalf of the users. Sink should manage the creation of new partitions and committing them periodically. Hive 0.13 has introduced Streaming support which is itself transactional in nature and fits well with Flume's transaction model.
          Short overview of Hive's Streaming support on which this sink is based can be found here:
          https://issues.apache.org/jira/secure/attachment/12639278/package.html


          This jira is for creating a sink that would continuously stream data into Hive tables using the above APIs. The primary goal being that the data streamed by the sink should be instantly queryable (using say Hive or Pig) without requiring additional post-processing steps on behalf of the users. Sink should manage the creation of new partitions periodically if needed.


          Roshan Naik made changes -
          Status Open [ 1 ] Patch Available [ 10002 ]
          Hide
          Roshan Naik added a comment -

          Hive Sink Patch is now ready for review.

          Show
          Roshan Naik added a comment - Hive Sink Patch is now ready for review.
          Roshan Naik made changes -
          Attachment FLUME-1734.v2.patch [ 12650436 ]
          Hide
          Roshan Naik added a comment -

          Uploading new patch v2 :

          • fleshed out the tests some more
          • fixed issues related to recovering from intermittent HDFS and Hive failures.
          Show
          Roshan Naik added a comment - Uploading new patch v2 : fleshed out the tests some more fixed issues related to recovering from intermittent HDFS and Hive failures.
          Roshan Naik made changes -
          Attachment FLUME-1734.v1.patch [ 12639554 ]
          Roshan Naik made changes -
          Attachment FLUME-1734.v1.patch [ 12644685 ]
          Hide
          Roshan Naik added a comment -

          updating FLUME-1734.v1.patch

          Show
          Roshan Naik added a comment - updating FLUME-1734 .v1.patch
          Roshan Naik made changes -
          Attachment FLUME-1734.v1.patch [ 12639554 ]
          Roshan Naik made changes -
          Attachment FLUME-1734.v1.patch [ 12639550 ]
          Roshan Naik made changes -
          Attachment FLUME-1734.v1.patch [ 12639550 ]
          Hide
          Roshan Naik added a comment -

          Uploading fully functional patch.

          Show
          Roshan Naik added a comment - Uploading fully functional patch.
          Roshan Naik made changes -
          Attachment FLUME-1734.draft.2.patch [ 12631482 ]
          Hide
          Roshan Naik added a comment -

          Updating patch... adding serializer support to sink

          Show
          Roshan Naik added a comment - Updating patch... adding serializer support to sink
          Hide
          Roshan Naik added a comment -

          Link to review board

          Show
          Roshan Naik added a comment - Link to review board
          Roshan Naik made changes -
          Remote Link This issue links to "Review Board Link (Web Link)" [ 14251 ]
          Roshan Naik made changes -
          Attachment FLUME-1734.draft.1.patch [ 12631316 ]
          Hide
          Roshan Naik added a comment -

          Draft patch for review. No tests currently.

          Show
          Roshan Naik added a comment - Draft patch for review. No tests currently.
          Roshan Naik made changes -
          Link This issue is blocked by HIVE-4196 [ HIVE-4196 ]
          Roshan Naik made changes -
          Link This issue depends upon HIVE-5687 [ HIVE-5687 ]
          Roshan Naik made changes -
          Summary Create a Hive Sink Create a Hive Sink based on the new Hive Streaming support
          Roshan Naik made changes -
          Summary Create a HCatalog Sink Create a Hive Sink
          Hide
          Roshan Naik added a comment -

          Update:
          The HCatalog based streaming support (HIVE-4196) in Hive has been abandoned in favor of a different approach (HIVE-5687) based on Hive native ACID transactions support.

          So planning to rename this JIRA to "create a hive sink."

          Show
          Roshan Naik added a comment - Update: The HCatalog based streaming support ( HIVE-4196 ) in Hive has been abandoned in favor of a different approach ( HIVE-5687 ) based on Hive native ACID transactions support. So planning to rename this JIRA to "create a hive sink."
          Hari Shreedharan made changes -
          Field Original Value New Value
          Link This issue is blocked by HIVE-4196 [ HIVE-4196 ]
          Hide
          Hari Shreedharan added a comment -

          Thanks for following up on this Roshan.

          Show
          Hari Shreedharan added a comment - Thanks for following up on this Roshan.
          Hide
          Roshan Naik added a comment -

          FYI: Due to limitations in the current Hive and HCatalog support for streaming clients, a new initiative is being pursued in Hive (and HCatalog) to support streaming clients.

          https://issues.apache.org/jira/browse/HIVE-4196

          One of things being baked into it the ability to support transactional commits needed by Flume sinks.

          Show
          Roshan Naik added a comment - FYI: Due to limitations in the current Hive and HCatalog support for streaming clients, a new initiative is being pursued in Hive (and HCatalog) to support streaming clients. https://issues.apache.org/jira/browse/HIVE-4196 One of things being baked into it the ability to support transactional commits needed by Flume sinks.
          Hide
          Mike Percy added a comment -

          Hi Roshan,
          Cool! A couple aspects to consider as you are mulling this over:

          • If a Flume Transaction is committed by the sink then the data must be persisted. We need to avoid getting into states where any committed Channel.take() could be lost somehow. One way to do that today (requires some setup though) is to write to an external Hive table and then periodically do a LOAD via Oozie or something, which could move the files out of the external table and into the desired partitions.
          • If the HCat APIs don't work with secure meta stores or secure HDFS yet, it might be worth considering other APIs at the moment. However, if it can navigate the necessary Hive & Hadoop security features to partition and write the data, it sounds great to me! This is just my opinion, of course you are welcome to take it or leave it.
          Show
          Mike Percy added a comment - Hi Roshan, Cool! A couple aspects to consider as you are mulling this over: If a Flume Transaction is committed by the sink then the data must be persisted. We need to avoid getting into states where any committed Channel.take() could be lost somehow. One way to do that today (requires some setup though) is to write to an external Hive table and then periodically do a LOAD via Oozie or something, which could move the files out of the external table and into the desired partitions. If the HCat APIs don't work with secure meta stores or secure HDFS yet, it might be worth considering other APIs at the moment. However, if it can navigate the necessary Hive & Hadoop security features to partition and write the data, it sounds great to me! This is just my opinion, of course you are welcome to take it or leave it.
          Hide
          Roshan Naik added a comment - - edited

          Mike,
          1. There will be no map reduce. This will all be client side (i.e flume agents) streaming data in parallel into HCatalog. Clients will compute the specific partition into which the data will be written. Periodically (configurable) they would 'commit' the currently open partition and roll-over to a new partition. Until the partition is committed the data will not be query-able. There is one restriction... once a partition is committed its data cannot be modified it.

          2. org.apache.hcatalog.data.transfer.*

          3. I have not verified the secure mode HCat operation, but it appears to be supported. Will get back to you.

          4. At the moment, I dont see much code overlap with HDFS sink for the core data movement functionality. There may be always room for sharing other smaller tidbits.

          Show
          Roshan Naik added a comment - - edited Mike, 1. There will be no map reduce. This will all be client side (i.e flume agents) streaming data in parallel into HCatalog. Clients will compute the specific partition into which the data will be written. Periodically (configurable) they would 'commit' the currently open partition and roll-over to a new partition. Until the partition is committed the data will not be query-able. There is one restriction... once a partition is committed its data cannot be modified it. 2. org.apache.hcatalog.data.transfer.* 3. I have not verified the secure mode HCat operation, but it appears to be supported. Will get back to you. 4. At the moment, I dont see much code overlap with HDFS sink for the core data movement functionality. There may be always room for sharing other smaller tidbits.
          Hide
          Mike Percy added a comment -

          Hey Roshan,
          Sounds interesting. Please pardon my limited knowledge about HCatalog, but I have a few questions about the approach you are proposing.

          1. Would all of the partitions be calculated on the client side? Or would all of that loading logic happen via map/reduce jobs? Or would it be a mix?
          2. If client side, what are the HCatalog API calls that can be used to stream the data onto HDFS?
          3. Would this be able to support a secure Metastore? What about Kerberized HDFS clusters?
          4. How much overlap do you see with the HDFS sink?

          The HCatalog docs that I've found only seem to talk about using HCatalog in the context of Hive, Pig, and other types of MapReduce jobs.

          Show
          Mike Percy added a comment - Hey Roshan, Sounds interesting. Please pardon my limited knowledge about HCatalog, but I have a few questions about the approach you are proposing. 1. Would all of the partitions be calculated on the client side? Or would all of that loading logic happen via map/reduce jobs? Or would it be a mix? 2. If client side, what are the HCatalog API calls that can be used to stream the data onto HDFS? 3. Would this be able to support a secure Metastore? What about Kerberized HDFS clusters? 4. How much overlap do you see with the HDFS sink? The HCatalog docs that I've found only seem to talk about using HCatalog in the context of Hive, Pig, and other types of MapReduce jobs.
          Roshan Naik created issue -

            People

            • Assignee:
              Roshan Naik
              Reporter:
              Roshan Naik
            • Votes:
              0 Vote for this issue
              Watchers:
              12 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development