[jira] [Updated] (FLUME-1734) Create a Hive Sink based on the new Hive Streaming support

2014-06-13 Thread Roshan Naik (JIRA)

 [ 
https://issues.apache.org/jira/browse/FLUME-1734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Roshan Naik updated FLUME-1734:
---

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.




  was: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. 


> Create a Hive Sink based on the new Hive Streaming support
> --
>
> Key: FLUME-1734
> URL: https://issues.apache.org/jira/browse/FLUME-1734
> Project: Flume
>  Issue Type: New Feature
>  Components: Sinks+Sources
>Affects Versions: v1.2.0
>Reporter: Roshan Naik
>Assignee: Roshan Naik
>  Labels: features
> Attachments: FLUME-1734.draft.1.patch, FLUME-1734.draft.2.patch, 
> FLUME-1734.v1.patch, FLUME-1734.v2.patch
>
>
> 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.



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Commented] (FLUME-2393) [User Guide]Incorrect rendering of Twitter firehose Source header, displayed as Twitter 1% firehose Source

2014-06-13 Thread Ashish Paliwal (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031450#comment-14031450
 ] 

Ashish Paliwal commented on FLUME-2393:
---

Ahh got it, my mistake

> [User Guide]Incorrect rendering of Twitter firehose Source header, displayed 
> as Twitter 1% firehose Source
> --
>
> Key: FLUME-2393
> URL: https://issues.apache.org/jira/browse/FLUME-2393
> Project: Flume
>  Issue Type: Documentation
>  Components: Docs
>Affects Versions: v1.5.0
>Reporter: Ashish Paliwal
>Assignee: Ashish Paliwal
>Priority: Minor
> Attachments: FLUME-2393-0.patch, 
> Screen-Shot-2014-06-14-at-8.47.34-am.jpg
>
>
> Twitter firehose Source header is rendered incorrectly, has 1% in between and 
> is displayed as "Twitter 1% firehose Source"



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Commented] (FLUME-2393) [User Guide]Incorrect rendering of Twitter firehose Source header, displayed as Twitter 1% firehose Source

2014-06-13 Thread Roshan Naik (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031449#comment-14031449
 ] 

Roshan Naik commented on FLUME-2393:


Looks fine. It is supposed to be 'Twitter 1%' as AFAIKT from the description. 

> [User Guide]Incorrect rendering of Twitter firehose Source header, displayed 
> as Twitter 1% firehose Source
> --
>
> Key: FLUME-2393
> URL: https://issues.apache.org/jira/browse/FLUME-2393
> Project: Flume
>  Issue Type: Documentation
>  Components: Docs
>Affects Versions: v1.5.0
>Reporter: Ashish Paliwal
>Assignee: Ashish Paliwal
>Priority: Minor
> Attachments: FLUME-2393-0.patch, 
> Screen-Shot-2014-06-14-at-8.47.34-am.jpg
>
>
> Twitter firehose Source header is rendered incorrectly, has 1% in between and 
> is displayed as "Twitter 1% firehose Source"



--
This message was sent by Atlassian JIRA
(v6.2#6252)


Re: Review Request 18544: Hive Streaming sink

2014-06-13 Thread Roshan Naik

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

(Updated June 14, 2014, 4:19 a.m.)


Review request for Flume.


Changes
---

Uploading new patch v2 :
addressed loose ends in unit tests
fixed issues related to recovering from intermittent HDFS and Hive failures.


Bugs: FLUME-1734
https://issues.apache.org/jira/browse/FLUME-1734


Repository: flume-git


Description
---

Hive streaming sink.


Diffs (updated)
-

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

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


Testing
---

 This version lacks unit tests.


Thanks,

Roshan Naik



[jira] [Updated] (FLUME-1734) Create a Hive Sink based on the new Hive Streaming support

2014-06-13 Thread Roshan Naik (JIRA)

 [ 
https://issues.apache.org/jira/browse/FLUME-1734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Roshan Naik updated FLUME-1734:
---

Attachment: FLUME-1734.v2.patch

Uploading new patch v2 :
 - fleshed out the tests some more
 - fixed issues related to recovering from intermittent HDFS and Hive failures.

> Create a Hive Sink based on the new Hive Streaming support
> --
>
> Key: FLUME-1734
> URL: https://issues.apache.org/jira/browse/FLUME-1734
> Project: Flume
>  Issue Type: New Feature
>  Components: Sinks+Sources
>Affects Versions: v1.2.0
>Reporter: Roshan Naik
>Assignee: Roshan Naik
>  Labels: features
> Attachments: FLUME-1734.draft.1.patch, FLUME-1734.draft.2.patch, 
> FLUME-1734.v1.patch, FLUME-1734.v2.patch
>
>
> 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. 



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Updated] (FLUME-2402) Warning seen when overflow is disabled for Spillable Channel

2014-06-13 Thread Roshan Naik (JIRA)

 [ 
https://issues.apache.org/jira/browse/FLUME-2402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Roshan Naik updated FLUME-2402:
---

Attachment: FLUME-2402.patch

Uploading patch

> Warning seen when overflow is disabled for Spillable Channel
> 
>
> Key: FLUME-2402
> URL: https://issues.apache.org/jira/browse/FLUME-2402
> Project: Flume
>  Issue Type: Bug
>  Components: Channel
>Affects Versions: v1.5.0
>Reporter: Roshan Naik
>  Labels: SpillableChannel
> Attachments: FLUME-2402.patch
>
>
> When overflow is disabled by setting overflowCapacity=0  the below warning is 
> reported (by underlying File channel)
> 2014-06-13 20:56:56,908i Invalid capacity specified, initializing channel to 
> default capacity of 100 
> File channel's capacity should be overridden with some small number in such a 
> config.



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Created] (FLUME-2402) Warning seen when overflow is disabled for Spillable Channel

2014-06-13 Thread Roshan Naik (JIRA)
Roshan Naik created FLUME-2402:
--

 Summary: Warning seen when overflow is disabled for Spillable 
Channel
 Key: FLUME-2402
 URL: https://issues.apache.org/jira/browse/FLUME-2402
 Project: Flume
  Issue Type: Bug
  Components: Channel
Affects Versions: v1.5.0
Reporter: Roshan Naik


When overflow is disabled by setting overflowCapacity=0  the below warning is 
reported (by underlying File channel)

2014-06-13 20:56:56,908i Invalid capacity specified, initializing channel to 
default capacity of 100 



File channel's capacity should be overridden with some small number in such a 
config.



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Commented] (FLUME-2024) Add ExecSource flush timeout to Flume User Guide

2014-06-13 Thread Hudson (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031439#comment-14031439
 ] 

Hudson commented on FLUME-2024:
---

SUCCESS: Integrated in flume-trunk #641 (See 
[https://builds.apache.org/job/flume-trunk/641/])
FLUME-2024.  Add ExecSource flush timeout to Flume User Guide (roshan: 
http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=b74e35aeb6aea87a29f062f55c79a499c6497abe)
* flume-ng-core/src/main/java/org/apache/flume/source/ExecSource.java
* flume-ng-doc/sphinx/FlumeUserGuide.rst


> Add ExecSource flush timeout to Flume User Guide
> 
>
> Key: FLUME-2024
> URL: https://issues.apache.org/jira/browse/FLUME-2024
> Project: Flume
>  Issue Type: Bug
>Affects Versions: v1.4.0
>Reporter: Hari Shreedharan
>Assignee: Ashish Paliwal
> Fix For: v1.6.0
>
> Attachments: FLUME-2024-0.patch
>
>




--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Updated] (FLUME-2393) [User Guide]Incorrect rendering of Twitter firehose Source header, displayed as Twitter 1% firehose Source

2014-06-13 Thread Ashish Paliwal (JIRA)

 [ 
https://issues.apache.org/jira/browse/FLUME-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashish Paliwal updated FLUME-2393:
--

Attachment: Screen-Shot-2014-06-14-at-8.47.34-am.jpg

Screenshot attached, see the title, made a circle to highlight 1%

> [User Guide]Incorrect rendering of Twitter firehose Source header, displayed 
> as Twitter 1% firehose Source
> --
>
> Key: FLUME-2393
> URL: https://issues.apache.org/jira/browse/FLUME-2393
> Project: Flume
>  Issue Type: Documentation
>  Components: Docs
>Affects Versions: v1.5.0
>Reporter: Ashish Paliwal
>Assignee: Ashish Paliwal
>Priority: Minor
> Attachments: FLUME-2393-0.patch, 
> Screen-Shot-2014-06-14-at-8.47.34-am.jpg
>
>
> Twitter firehose Source header is rendered incorrectly, has 1% in between and 
> is displayed as "Twitter 1% firehose Source"



--
This message was sent by Atlassian JIRA
(v6.2#6252)


Re: [VOTE] Apache Flume 1.5.0.1 RC1

2014-06-13 Thread Roshan Naik
Ah yes.. now i recall. Thanks.
+1
-roshan


On Fri, Jun 13, 2014 at 6:30 PM, Hari Shreedharan  wrote:

> Did you compile hbase 94 against Hadoop 2 before running the build? Hbase
> did not release Hadoop 2 compatible artifacts.
>
> On Friday, June 13, 2014, Roshan Naik  wrote:
>
> > Do we plan to support -Dhadoop.profile=2  ? it appears to be failing on
> > asynchbase tests:
> >
> > # mvn  -Dhadoop.profile=2
> >
> > -roshan
> >
> >
> >
> > *---*
> > * T E S T S*
> > *---*
> > *Running org.apache.flume.sink.hbase.TestAsyncHBaseSink*
> > *Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.549
> sec
> > <<< FAILURE!*
> > *org.apache.flume.sink.hbase.TestAsyncHBaseSink  Time elapsed: 548 sec
>  <<<
> > ERROR!*
> > *java.lang.NoSuchMethodError:
> >
> >
> org.apache.hadoop.hdfs.MiniDFSCluster.(ILorg/apache/hadoop/conf/Configuration;IZZZLorg/apache/hadoop/hdfs/server/common/HdfsConstants$StartupOption;[Ljava/lang/String;[Ljava/lang/String;[J)V*
> > * at
> >
> >
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniDFSCluster(HBaseTestingUtility.java:433)*
> > * at
> >
> >
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:601)*
> > * at
> >
> >
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:557)*
> > * at
> >
> >
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:526)*
> > * at
> >
> >
> org.apache.flume.sink.hbase.TestAsyncHBaseSink.setUp(TestAsyncHBaseSink.java:69)*
> > * at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)*
> > * at
> >
> >
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)*
> > * at
> >
> >
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)*
> > * at java.lang.reflect.Method.invoke(Method.java:597)*
> > * at
> >
> >
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:45)*
> > * at
> >
> >
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15)*
> > * at
> >
> >
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:42)*
> > * at
> >
> >
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:27)*
> > * at
> >
> >
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:30)*
> > * at org.junit.runners.ParentRunner.run(ParentRunner.java:300)*
> > * at
> >
> >
> org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:252)*
> > * at
> >
> >
> org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:141)*
> > * at
> >
> >
> org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:112)*
> > * at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)*
> > * at
> >
> >
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)*
> > * at
> >
> >
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)*
> > * at java.lang.reflect.Method.invoke(Method.java:597)*
> > * at
> >
> >
> org.apache.maven.surefire.util.ReflectionUtils.invokeMethodWithArray(ReflectionUtils.java:189)*
> > * at
> >
> >
> org.apache.maven.surefire.booter.ProviderFactory$ProviderProxy.invoke(ProviderFactory.java:165)*
> > * at
> >
> >
> org.apache.maven.surefire.booter.ProviderFactory.invokeProvider(ProviderFactory.java:85)*
> > * at
> >
> >
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:115)*
> > * at
> > org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:75)*
> >
> > *Running org.apache.flume.sink.hbase.TestHBaseSink*
> > *Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.557
> sec
> > <<< FAILURE!*
> > *org.apache.flume.sink.hbase.TestHBaseSink  Time elapsed: 557 sec  <<<
> > ERROR!*
> > *java.lang.NoSuchMethodError:
> >
> >
> org.apache.hadoop.hdfs.MiniDFSCluster.(ILorg/apache/hadoop/conf/Configuration;IZZZLorg/apache/hadoop/hdfs/server/common/HdfsConstants$StartupOption;[Ljava/lang/String;[Ljava/lang/String;[J)V*
> > * at
> >
> >
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniDFSCluster(HBaseTestingUtility.java:433)*
> > * at
> >
> >
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:601)*
> > * at
> >
> >
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:557)*
> > * at
> >
> >
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:526)*
> > * at
> >
> org.apache.flume.sink.hbase.TestHBaseSink.setUpOnce(TestHBaseSink.java:81)*
> > * at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)*
> > * at
> >
> >
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)*
> > * at
> >
> >
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)*
> 

[jira] [Updated] (FLUME-2024) Add ExecSource flush timeout to Flume User Guide

2014-06-13 Thread Roshan Naik (JIRA)

 [ 
https://issues.apache.org/jira/browse/FLUME-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Roshan Naik updated FLUME-2024:
---

Fix Version/s: v1.6.0

> Add ExecSource flush timeout to Flume User Guide
> 
>
> Key: FLUME-2024
> URL: https://issues.apache.org/jira/browse/FLUME-2024
> Project: Flume
>  Issue Type: Bug
>Affects Versions: v1.4.0
>Reporter: Hari Shreedharan
>Assignee: Ashish Paliwal
> Fix For: v1.6.0
>
> Attachments: FLUME-2024-0.patch
>
>




--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Commented] (FLUME-2024) Add ExecSource flush timeout to Flume User Guide

2014-06-13 Thread ASF subversion and git services (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031422#comment-14031422
 ] 

ASF subversion and git services commented on FLUME-2024:


Commit b74e35aeb6aea87a29f062f55c79a499c6497abe in flume's branch 
refs/heads/trunk from [~roshan_naik]
[ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=b74e35a ]

FLUME-2024.  Add ExecSource flush timeout to Flume User Guide

(Ashish Paliwal via Roshan Naik)


> Add ExecSource flush timeout to Flume User Guide
> 
>
> Key: FLUME-2024
> URL: https://issues.apache.org/jira/browse/FLUME-2024
> Project: Flume
>  Issue Type: Bug
>Affects Versions: v1.4.0
>Reporter: Hari Shreedharan
>Assignee: Ashish Paliwal
> Attachments: FLUME-2024-0.patch
>
>




--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Commented] (FLUME-2024) Add ExecSource flush timeout to Flume User Guide

2014-06-13 Thread ASF subversion and git services (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031421#comment-14031421
 ] 

ASF subversion and git services commented on FLUME-2024:


Commit a7f0306919c1c7a80c7e0b586a93840cf9c0ec8e in flume's branch 
refs/heads/flume-1.6 from [~roshan_naik]
[ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=a7f0306 ]

FLUME-2024.  Add ExecSource flush timeout to Flume User Guide

(Ashish Paliwal via Roshan Naik)


> Add ExecSource flush timeout to Flume User Guide
> 
>
> Key: FLUME-2024
> URL: https://issues.apache.org/jira/browse/FLUME-2024
> Project: Flume
>  Issue Type: Bug
>Affects Versions: v1.4.0
>Reporter: Hari Shreedharan
>Assignee: Ashish Paliwal
> Attachments: FLUME-2024-0.patch
>
>




--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Commented] (FLUME-2024) Add ExecSource flush timeout to Flume User Guide

2014-06-13 Thread Roshan Naik (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031410#comment-14031410
 ] 

Roshan Naik commented on FLUME-2024:


+1

> Add ExecSource flush timeout to Flume User Guide
> 
>
> Key: FLUME-2024
> URL: https://issues.apache.org/jira/browse/FLUME-2024
> Project: Flume
>  Issue Type: Bug
>Affects Versions: v1.4.0
>Reporter: Hari Shreedharan
>Assignee: Ashish Paliwal
> Attachments: FLUME-2024-0.patch
>
>




--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Commented] (FLUME-2393) [User Guide]Incorrect rendering of Twitter firehose Source header, displayed as Twitter 1% firehose Source

2014-06-13 Thread Roshan Naik (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031397#comment-14031397
 ] 

Roshan Naik commented on FLUME-2393:


Does not look like there is a rendering issue AFAIKT from 
 http://flume.apache.org/FlumeUserGuide.html

> [User Guide]Incorrect rendering of Twitter firehose Source header, displayed 
> as Twitter 1% firehose Source
> --
>
> Key: FLUME-2393
> URL: https://issues.apache.org/jira/browse/FLUME-2393
> Project: Flume
>  Issue Type: Documentation
>  Components: Docs
>Affects Versions: v1.5.0
>Reporter: Ashish Paliwal
>Assignee: Ashish Paliwal
>Priority: Minor
> Attachments: FLUME-2393-0.patch
>
>
> Twitter firehose Source header is rendered incorrectly, has 1% in between and 
> is displayed as "Twitter 1% firehose Source"



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Comment Edited] (FLUME-2197) Memory Channel has GC issues

2014-06-13 Thread Roshan Naik (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031389#comment-14031389
 ] 

Roshan Naik edited comment on FLUME-2197 at 6/14/14 1:41 AM:
-

During the first 6 mins or so... the total size of allocated objects is still 
below the max heap size. Once it reaches the max heap size,  the allocation 
graph flattens. You can see the Green portion does not bump up any more. In 
this state Java is basically doing a minimal GC (tiny peaks) and not a deep gc. 
So things stay kind of flat.

In the flat section after 6mins, you can see more of the tiny peaks  (small gc 
cycles) per unit time in the mem ch graph.


was (Author: roshan_naik):
During the first 6 mins or so... the total size of allocated objects is still 
below the max heap size. Once it reaches the max heap size,  the allocation 
graph flattens. You can see the Green portion does bump up any more. In this 
state Java is basically doing a minimal GC (tiny peaks) and not a deep gc. So 
things stay kind of flat.

In the flat section after 6mins, you can see more of the tiny peaks  (small gc 
cycles) per unit time in the mem ch graph.

> Memory Channel has GC issues
> 
>
> Key: FLUME-2197
> URL: https://issues.apache.org/jira/browse/FLUME-2197
> Project: Flume
>  Issue Type: Bug
>Reporter: Hari Shreedharan
>Assignee: Roshan Naik
> Attachments: mem ch - mem alloc.png, spill ch - mem alloc.png
>
>
> Due to the fact that we use a LinkedBlockingDeque as the backing queue for 
> the MemoryChannel, we end up hitting GC issues more often than we should.



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Comment Edited] (FLUME-2197) Memory Channel has GC issues

2014-06-13 Thread Roshan Naik (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031389#comment-14031389
 ] 

Roshan Naik edited comment on FLUME-2197 at 6/14/14 1:38 AM:
-

During the first 6 mins or so... the total size of allocated objects is still 
below the max heap size. Once it reaches the max heap size,  the allocation 
graph flattens. You can see the Green portion does bump up any more. In this 
state Java is basically doing a minimal GC (tiny peaks) and not a deep gc. So 
things stay kind of flat.

In the flat section after 6mins, you can see more of the tiny peaks  (small gc 
cycles) per unit time in the mem ch graph.


was (Author: roshan_naik):
During the first 6 mins or so... the total size of allocated objects is still 
well below the max heap size. Once it reaches the max heap size,  the 
allocation graph flattens. You can see the Green portion does bump up any more. 
In this state Java is basically doing a minimal GC (tiny peaks) and not a deep 
gc. So things stay kind of flat.

In the flat section after 6mins, you can see more of the tiny peaks  (small gc 
cycles) per unit time in the mem ch graph.

> Memory Channel has GC issues
> 
>
> Key: FLUME-2197
> URL: https://issues.apache.org/jira/browse/FLUME-2197
> Project: Flume
>  Issue Type: Bug
>Reporter: Hari Shreedharan
>Assignee: Roshan Naik
> Attachments: mem ch - mem alloc.png, spill ch - mem alloc.png
>
>
> Due to the fact that we use a LinkedBlockingDeque as the backing queue for 
> the MemoryChannel, we end up hitting GC issues more often than we should.



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Commented] (FLUME-2197) Memory Channel has GC issues

2014-06-13 Thread Roshan Naik (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031389#comment-14031389
 ] 

Roshan Naik commented on FLUME-2197:


During the first 6 mins or so... the total size of allocated objects is still 
well below the max heap size. Once it reaches the max heap size,  the 
allocation graph flattens. You can see the Green portion does bump up any more. 
In this state Java is basically doing a minimal GC (tiny peaks) and not a deep 
gc. So things stay kind of flat.

In the flat section after 6mins, you can see more of the tiny peaks  (small gc 
cycles) per unit time in the mem ch graph.

> Memory Channel has GC issues
> 
>
> Key: FLUME-2197
> URL: https://issues.apache.org/jira/browse/FLUME-2197
> Project: Flume
>  Issue Type: Bug
>Reporter: Hari Shreedharan
>Assignee: Roshan Naik
> Attachments: mem ch - mem alloc.png, spill ch - mem alloc.png
>
>
> Due to the fact that we use a LinkedBlockingDeque as the backing queue for 
> the MemoryChannel, we end up hitting GC issues more often than we should.



--
This message was sent by Atlassian JIRA
(v6.2#6252)


Re: [VOTE] Apache Flume 1.5.0.1 RC1

2014-06-13 Thread Hari Shreedharan
Did you compile hbase 94 against Hadoop 2 before running the build? Hbase
did not release Hadoop 2 compatible artifacts.

On Friday, June 13, 2014, Roshan Naik  wrote:

> Do we plan to support -Dhadoop.profile=2  ? it appears to be failing on
> asynchbase tests:
>
> # mvn  -Dhadoop.profile=2
>
> -roshan
>
>
>
> *---*
> * T E S T S*
> *---*
> *Running org.apache.flume.sink.hbase.TestAsyncHBaseSink*
> *Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.549 sec
> <<< FAILURE!*
> *org.apache.flume.sink.hbase.TestAsyncHBaseSink  Time elapsed: 548 sec  <<<
> ERROR!*
> *java.lang.NoSuchMethodError:
>
> org.apache.hadoop.hdfs.MiniDFSCluster.(ILorg/apache/hadoop/conf/Configuration;IZZZLorg/apache/hadoop/hdfs/server/common/HdfsConstants$StartupOption;[Ljava/lang/String;[Ljava/lang/String;[J)V*
> * at
>
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniDFSCluster(HBaseTestingUtility.java:433)*
> * at
>
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:601)*
> * at
>
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:557)*
> * at
>
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:526)*
> * at
>
> org.apache.flume.sink.hbase.TestAsyncHBaseSink.setUp(TestAsyncHBaseSink.java:69)*
> * at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)*
> * at
>
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)*
> * at
>
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)*
> * at java.lang.reflect.Method.invoke(Method.java:597)*
> * at
>
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:45)*
> * at
>
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15)*
> * at
>
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:42)*
> * at
>
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:27)*
> * at
>
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:30)*
> * at org.junit.runners.ParentRunner.run(ParentRunner.java:300)*
> * at
>
> org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:252)*
> * at
>
> org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:141)*
> * at
>
> org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:112)*
> * at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)*
> * at
>
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)*
> * at
>
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)*
> * at java.lang.reflect.Method.invoke(Method.java:597)*
> * at
>
> org.apache.maven.surefire.util.ReflectionUtils.invokeMethodWithArray(ReflectionUtils.java:189)*
> * at
>
> org.apache.maven.surefire.booter.ProviderFactory$ProviderProxy.invoke(ProviderFactory.java:165)*
> * at
>
> org.apache.maven.surefire.booter.ProviderFactory.invokeProvider(ProviderFactory.java:85)*
> * at
>
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:115)*
> * at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:75)*
>
> *Running org.apache.flume.sink.hbase.TestHBaseSink*
> *Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.557 sec
> <<< FAILURE!*
> *org.apache.flume.sink.hbase.TestHBaseSink  Time elapsed: 557 sec  <<<
> ERROR!*
> *java.lang.NoSuchMethodError:
>
> org.apache.hadoop.hdfs.MiniDFSCluster.(ILorg/apache/hadoop/conf/Configuration;IZZZLorg/apache/hadoop/hdfs/server/common/HdfsConstants$StartupOption;[Ljava/lang/String;[Ljava/lang/String;[J)V*
> * at
>
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniDFSCluster(HBaseTestingUtility.java:433)*
> * at
>
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:601)*
> * at
>
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:557)*
> * at
>
> org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:526)*
> * at
> org.apache.flume.sink.hbase.TestHBaseSink.setUpOnce(TestHBaseSink.java:81)*
> * at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)*
> * at
>
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)*
> * at
>
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)*
> * at java.lang.reflect.Method.invoke(Method.java:597)*
> * at
>
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:45)*
> * at
>
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15)*
> * at
>
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:42)*
> * at
>
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBe

[jira] [Commented] (FLUME-2197) Memory Channel has GC issues

2014-06-13 Thread Otis Gospodnetic (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031381#comment-14031381
 ] 

Otis Gospodnetic commented on FLUME-2197:
-

Thanks for the graphs, Roshan.
bq. Spill Channel contains a modified implementation of mem channel and 
addresses this GC issue and some other locking issues.

I don't get why you said this when the graphs for both mem and spillable 
channel look very similar and show the same "flat after ~6 minutrs" pattern?


> Memory Channel has GC issues
> 
>
> Key: FLUME-2197
> URL: https://issues.apache.org/jira/browse/FLUME-2197
> Project: Flume
>  Issue Type: Bug
>Reporter: Hari Shreedharan
>Assignee: Roshan Naik
> Attachments: mem ch - mem alloc.png, spill ch - mem alloc.png
>
>
> Due to the fact that we use a LinkedBlockingDeque as the backing queue for 
> the MemoryChannel, we end up hitting GC issues more often than we should.



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Updated] (FLUME-2197) Memory Channel has GC issues

2014-06-13 Thread Roshan Naik (JIRA)

 [ 
https://issues.apache.org/jira/browse/FLUME-2197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Roshan Naik updated FLUME-2197:
---

Attachment: spill ch - mem alloc.png
mem ch - mem alloc.png

Hard to quantify the impact verbally. Attached images show GC activity of mem 
channel and  Spillable Channel (with overflow disabled). Spill Channel contains 
a modified implementation of mem channel and addresses this GC issue and some 
other locking issues.

 In boths runs, java was setup to have a minHeap & maxHeap at 3GB and 6GB 
respectively.   You can see the allocation graphs inching higher till max heap 
size is reached (after 6 mins) and then staying flat. 

Answer to your question lies in the number of peaks in each graph. Each peak 
indicates the start of a GC cycle. 


> Memory Channel has GC issues
> 
>
> Key: FLUME-2197
> URL: https://issues.apache.org/jira/browse/FLUME-2197
> Project: Flume
>  Issue Type: Bug
>Reporter: Hari Shreedharan
>Assignee: Roshan Naik
> Attachments: mem ch - mem alloc.png, spill ch - mem alloc.png
>
>
> Due to the fact that we use a LinkedBlockingDeque as the backing queue for 
> the MemoryChannel, we end up hitting GC issues more often than we should.



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Commented] (FLUME-2365) Please create a DOAP file for your TLP

2014-06-13 Thread Hudson (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031372#comment-14031372
 ] 

Hudson commented on FLUME-2365:
---

SUCCESS: Integrated in flume-trunk #640 (See 
[https://builds.apache.org/job/flume-trunk/640/])
FLUME-2365. Add DOAP file for Flume. (harishreedharan: 
http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=f7e240ff3e376bac2dc0fb91e7c7ae32a933f899)
* doap_Flume.rdf


> Please create a DOAP file for your TLP
> --
>
> Key: FLUME-2365
> URL: https://issues.apache.org/jira/browse/FLUME-2365
> Project: Flume
>  Issue Type: Task
>Reporter: Sebb
>Assignee: Ashish Paliwal
> Attachments: flume.rdf
>
>
> As per my recent e-mail to your dev list, please can you set up a DOAP for 
> your project and get it added to files.xml?
> Please see http://projects.apache.org/create.html
> Once you have created the DOAP and committed it to your source code 
> repository, please submit it for inclusion in the Apache projects listing as 
> per:
> http://projects.apache.org/create.html#submit
> Remember, if you ever move or rename the doap file in future, please
> ensure that files.xml is updated to point to the new location.
> Thanks!



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Updated] (FLUME-2365) Please create a DOAP file for your TLP

2014-06-13 Thread Hari Shreedharan (JIRA)

 [ 
https://issues.apache.org/jira/browse/FLUME-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Hari Shreedharan updated FLUME-2365:


Assignee: Ashish Paliwal

> Please create a DOAP file for your TLP
> --
>
> Key: FLUME-2365
> URL: https://issues.apache.org/jira/browse/FLUME-2365
> Project: Flume
>  Issue Type: Task
>Reporter: Sebb
>Assignee: Ashish Paliwal
> Attachments: flume.rdf
>
>
> As per my recent e-mail to your dev list, please can you set up a DOAP for 
> your project and get it added to files.xml?
> Please see http://projects.apache.org/create.html
> Once you have created the DOAP and committed it to your source code 
> repository, please submit it for inclusion in the Apache projects listing as 
> per:
> http://projects.apache.org/create.html#submit
> Remember, if you ever move or rename the doap file in future, please
> ensure that files.xml is updated to point to the new location.
> Thanks!



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Commented] (FLUME-2365) Please create a DOAP file for your TLP

2014-06-13 Thread Hari Shreedharan (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031329#comment-14031329
 ] 

Hari Shreedharan commented on FLUME-2365:
-

I committed the DOAP file after making some minor changes. 

[~aprabhakar] - Could you please make the change to the sites.xml page as 
described here:http://projects.apache.org/create.html (Submitting your file 
section)

> Please create a DOAP file for your TLP
> --
>
> Key: FLUME-2365
> URL: https://issues.apache.org/jira/browse/FLUME-2365
> Project: Flume
>  Issue Type: Task
>Reporter: Sebb
> Attachments: flume.rdf
>
>
> As per my recent e-mail to your dev list, please can you set up a DOAP for 
> your project and get it added to files.xml?
> Please see http://projects.apache.org/create.html
> Once you have created the DOAP and committed it to your source code 
> repository, please submit it for inclusion in the Apache projects listing as 
> per:
> http://projects.apache.org/create.html#submit
> Remember, if you ever move or rename the doap file in future, please
> ensure that files.xml is updated to point to the new location.
> Thanks!



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Commented] (FLUME-2365) Please create a DOAP file for your TLP

2014-06-13 Thread ASF subversion and git services (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031326#comment-14031326
 ] 

ASF subversion and git services commented on FLUME-2365:


Commit b0824298560faba2e15199c20d39bf4f9d64c2b4 in flume's branch 
refs/heads/flume-1.6 from [~hshreedharan]
[ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=b082429 ]

FLUME-2365. Add DOAP file for Flume.

(Ashish Paliwal via Hari Shreedharan)


> Please create a DOAP file for your TLP
> --
>
> Key: FLUME-2365
> URL: https://issues.apache.org/jira/browse/FLUME-2365
> Project: Flume
>  Issue Type: Task
>Reporter: Sebb
> Attachments: flume.rdf
>
>
> As per my recent e-mail to your dev list, please can you set up a DOAP for 
> your project and get it added to files.xml?
> Please see http://projects.apache.org/create.html
> Once you have created the DOAP and committed it to your source code 
> repository, please submit it for inclusion in the Apache projects listing as 
> per:
> http://projects.apache.org/create.html#submit
> Remember, if you ever move or rename the doap file in future, please
> ensure that files.xml is updated to point to the new location.
> Thanks!



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[jira] [Commented] (FLUME-2365) Please create a DOAP file for your TLP

2014-06-13 Thread ASF subversion and git services (JIRA)

[ 
https://issues.apache.org/jira/browse/FLUME-2365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14031325#comment-14031325
 ] 

ASF subversion and git services commented on FLUME-2365:


Commit f7e240ff3e376bac2dc0fb91e7c7ae32a933f899 in flume's branch 
refs/heads/trunk from [~hshreedharan]
[ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=f7e240f ]

FLUME-2365. Add DOAP file for Flume.

(Ashish Paliwal via Hari Shreedharan)


> Please create a DOAP file for your TLP
> --
>
> Key: FLUME-2365
> URL: https://issues.apache.org/jira/browse/FLUME-2365
> Project: Flume
>  Issue Type: Task
>Reporter: Sebb
> Attachments: flume.rdf
>
>
> As per my recent e-mail to your dev list, please can you set up a DOAP for 
> your project and get it added to files.xml?
> Please see http://projects.apache.org/create.html
> Once you have created the DOAP and committed it to your source code 
> repository, please submit it for inclusion in the Apache projects listing as 
> per:
> http://projects.apache.org/create.html#submit
> Remember, if you ever move or rename the doap file in future, please
> ensure that files.xml is updated to point to the new location.
> Thanks!



--
This message was sent by Atlassian JIRA
(v6.2#6252)


Re: [VOTE] Apache Flume 1.5.0.1 RC1

2014-06-13 Thread Roshan Naik
Do we plan to support -Dhadoop.profile=2  ? it appears to be failing on
asynchbase tests:

# mvn  -Dhadoop.profile=2

-roshan



*---*
* T E S T S*
*---*
*Running org.apache.flume.sink.hbase.TestAsyncHBaseSink*
*Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.549 sec
<<< FAILURE!*
*org.apache.flume.sink.hbase.TestAsyncHBaseSink  Time elapsed: 548 sec  <<<
ERROR!*
*java.lang.NoSuchMethodError:
org.apache.hadoop.hdfs.MiniDFSCluster.(ILorg/apache/hadoop/conf/Configuration;IZZZLorg/apache/hadoop/hdfs/server/common/HdfsConstants$StartupOption;[Ljava/lang/String;[Ljava/lang/String;[J)V*
* at
org.apache.hadoop.hbase.HBaseTestingUtility.startMiniDFSCluster(HBaseTestingUtility.java:433)*
* at
org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:601)*
* at
org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:557)*
* at
org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:526)*
* at
org.apache.flume.sink.hbase.TestAsyncHBaseSink.setUp(TestAsyncHBaseSink.java:69)*
* at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)*
* at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)*
* at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)*
* at java.lang.reflect.Method.invoke(Method.java:597)*
* at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:45)*
* at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15)*
* at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:42)*
* at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:27)*
* at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:30)*
* at org.junit.runners.ParentRunner.run(ParentRunner.java:300)*
* at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:252)*
* at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:141)*
* at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:112)*
* at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)*
* at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)*
* at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)*
* at java.lang.reflect.Method.invoke(Method.java:597)*
* at
org.apache.maven.surefire.util.ReflectionUtils.invokeMethodWithArray(ReflectionUtils.java:189)*
* at
org.apache.maven.surefire.booter.ProviderFactory$ProviderProxy.invoke(ProviderFactory.java:165)*
* at
org.apache.maven.surefire.booter.ProviderFactory.invokeProvider(ProviderFactory.java:85)*
* at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:115)*
* at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:75)*

*Running org.apache.flume.sink.hbase.TestHBaseSink*
*Tests run: 1, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 0.557 sec
<<< FAILURE!*
*org.apache.flume.sink.hbase.TestHBaseSink  Time elapsed: 557 sec  <<<
ERROR!*
*java.lang.NoSuchMethodError:
org.apache.hadoop.hdfs.MiniDFSCluster.(ILorg/apache/hadoop/conf/Configuration;IZZZLorg/apache/hadoop/hdfs/server/common/HdfsConstants$StartupOption;[Ljava/lang/String;[Ljava/lang/String;[J)V*
* at
org.apache.hadoop.hbase.HBaseTestingUtility.startMiniDFSCluster(HBaseTestingUtility.java:433)*
* at
org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:601)*
* at
org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:557)*
* at
org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster(HBaseTestingUtility.java:526)*
* at
org.apache.flume.sink.hbase.TestHBaseSink.setUpOnce(TestHBaseSink.java:81)*
* at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)*
* at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)*
* at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)*
* at java.lang.reflect.Method.invoke(Method.java:597)*
* at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:45)*
* at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15)*
* at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:42)*
* at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:27)*
* at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:30)*
* at org.junit.runners.ParentRunner.run(ParentRunner.java:300)*
* at
org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:252)*
* at
org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:141)*
* at
org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:112)*

Re: [VOTE] Apache Flume 1.5.0.1 RC1

2014-06-13 Thread Hari Shreedharan
Thanks Cos!  


Thanks,
Hari


On Thursday, June 12, 2014 at 11:45 PM, Konstantin Boudnik wrote:

> I will give it a sping in Bigtop tomorrow - sorry for the delay: been a crazy
> week ;(
> 
> Thanks guys!
> Cos
> 
> On Thu, Jun 12, 2014 at 10:36PM, Arvind Prabhakar wrote:
> > +1
> > 
> > Thanks for shepherding this Hari.
> > 
> > Regards,
> > Arvind Prabhakar
> > 
> > 
> > On Tue, Jun 10, 2014 at 3:40 PM, Hari Shreedharan 
> > mailto:hshreedha...@cloudera.com)
> > > wrote:
> > 
> > 
> > > This is a vote for the next release of Apache Flume, version 1.5.0.1. We
> > > are voting on release candidate RC1.
> > > 
> > > It fixes the following issues:
> > > http://s.apache.org/v7X
> > > 
> > > *** Please cast your vote within the next 72 hours ***
> > > 
> > > The tarball (*.tar.gz), signature (*.asc), and checksums (*.md5, *.sha1)
> > > for the source and binary artifacts can be found here:
> > > https://people.apache.org/~hshreedharan/apache-flume-1.5.0.1-rc1/
> > > 
> > > Maven staging repo:
> > > https://repository.apache.org/content/repositories/orgapacheflume-1004/
> > > 
> > > The tag to be voted on:
> > > 
> > > 
> > > https://git-wip-us.apache.org/repos/asf?p=flume.git;a=commit;h=ceda6aa1126a01370641caf729d8b1dd6d80aa61
> > > 
> > > Flume's KEYS file containing PGP keys we use to sign the release:
> > > http://www.apache.org/dist/flume/KEYS
> > > 
> > > 
> > > Thanks,
> > > Hari
> > > 
> > 
> > 
> 
> 
> 




Re: [VOTE] Apache Flume 1.5.0.1 RC1

2014-06-13 Thread Hari Shreedharan
Roshan, 

No. The released artifacts are going to be on hadoop-1 itself. Until we can 
come up with a naming scheme and the related build changes so that the 
artifacts for hadoop-1 and 2 can exist simultaneously - we probably should 
stick to just releasing the 1.0 compatible artifacts. 


Thanks,
Hari


On Thursday, June 12, 2014 at 8:04 PM, Roshan Naik wrote:

> Will the released binaries be built with the new -Dhadoop.profile=hbase-98
> option ?
> 
> 
> On Wed, Jun 11, 2014 at 8:54 AM, Ashish  (mailto:paliwalash...@gmail.com)> wrote:
> 
> > +1
> > 
> > Build works good and all tests pass
> > 
> > 
> > On Wed, Jun 11, 2014 at 4:10 AM, Hari Shreedharan <
> > hshreedha...@cloudera.com (mailto:hshreedha...@cloudera.com)
> > > wrote:
> > 
> > 
> > > This is a vote for the next release of Apache Flume, version 1.5.0.1. We
> > > are voting on release candidate RC1.
> > > 
> > > It fixes the following issues:
> > > http://s.apache.org/v7X
> > > 
> > > *** Please cast your vote within the next 72 hours ***
> > > 
> > > The tarball (*.tar.gz), signature (*.asc), and checksums (*.md5, *.sha1)
> > > for the source and binary artifacts can be found here:
> > > https://people.apache.org/~hshreedharan/apache-flume-1.5.0.1-rc1/
> > > 
> > > Maven staging repo:
> > https://repository.apache.org/content/repositories/orgapacheflume-1004/
> > > 
> > > The tag to be voted on:
> > https://git-wip-us.apache.org/repos/asf?p=flume.git;a=commit;h=ceda6aa1126a01370641caf729d8b1dd6d80aa61
> > > 
> > > Flume's KEYS file containing PGP keys we use to sign the release:
> > > http://www.apache.org/dist/flume/KEYS
> > > 
> > > 
> > > Thanks,
> > > Hari
> > > 
> > 
> > 
> > 
> > 
> > --
> > thanks
> > ashish
> > 
> > Blog: http://www.ashishpaliwal.com/blog
> > My Photo Galleries: http://www.pbase.com/ashishpaliwal
> > 
> 
> 
> -- 
> CONFIDENTIALITY NOTICE
> NOTICE: This message is intended for the use of the individual or entity to 
> which it is addressed and may contain information that is confidential, 
> privileged and exempt from disclosure under applicable law. If the reader 
> of this message is not the intended recipient, you are hereby notified that 
> any printing, copying, dissemination, distribution, disclosure or 
> forwarding of this communication is strictly prohibited. If you have 
> received this communication in error, please contact the sender immediately 
> and delete it from your system. Thank You.
> 
> 




ApacheCon CFP closes June 25

2014-06-13 Thread Arvind Prabhakar
Dear Flume enthusiast,

As you may be aware, ApacheCon will be held this year in Budapest, on
November 17-23. (See http://apachecon.eu for more info.)

The Call For Papers for that conference is still open, but will be
closing soon. We need you talk proposals, to represent Flume at
ApacheCon. We need all kinds of talks - deep technical talks, hands-on
tutorials, introductions for beginners, or case studies about the
awesome stuff you're doing with Flume.

Please consider submitting a proposal, at
http://events.linuxfoundation.org//events/apachecon-europe/program/cfp

Thanks,
Arvind Prabhakar