You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by Ralph Goers <ra...@dslextreme.com> on 2016/02/01 17:22:32 UTC
Flume build hangs and fails in Kafka channel
I am trying to run the Flume build on my MacBook Pro and it is hanging running the tests for the Kafka file channel. A portion of the stack trace is below. After 15 minutes of waiting the build just terminates with no errors - it just emits
[ERROR] Failed to execute goal org.apache.maven.plugins:maven-surefire-plugin:2.12.3:test (default-test) on project flume-kafka-channel: ExecutionException; nested exception is java.util.concurrent.ExecutionException: java.lang.RuntimeException: The forked VM terminated without saying properly goodbye. VM crash or System.exit called ? -> [Help 1]
Any idea why this might be happening?
Ralph
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x00000007004286a8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
at java.util.concurrent.ExecutorCompletionService.take(ExecutorCompletionService.java:193)
at org.apache.flume.channel.kafka.TestKafkaChannel.wait(TestKafkaChannel.java:413)
at org.apache.flume.channel.kafka.TestKafkaChannel.writeAndVerify(TestKafkaChannel.java:291)
at org.apache.flume.channel.kafka.TestKafkaChannel.doTestSuccessRollback(TestKafkaChannel.java:104)
at org.apache.flume.channel.kafka.TestKafkaChannel.testSuccessInterleave(TestKafkaChannel.java:88)
Re: Flume build hangs and fails in Kafka channel
Posted by Hari Shreedharan <hs...@apache.org>.
I am not sure - I have not really hit this before. I think you could
just @Ignore the test for now - I will take a look at it this week
sometime and see what the issue is.
On Mon, Feb 1, 2016 at 11:35 AM, Ralph Goers <ra...@dslextreme.com> wrote:
> Any suggestions on how to debug it? I am adding some new components for my own use that I will probably give back but I want to make sure I am not breaking anything, so I really need a clean build before I get started.
>
> Ralph
>
>> On Feb 1, 2016, at 12:17 PM, Hari Shreedharan <hs...@apache.org> wrote:
>>
>> Looks like the test is just waiting for something to happen - looks
>> like the test is not working as expected. I don't see this, but this
>> indicates the test is flakey.
>>
>> On Mon, Feb 1, 2016 at 8:22 AM, Ralph Goers <ra...@dslextreme.com> wrote:
>>> I am trying to run the Flume build on my MacBook Pro and it is hanging running the tests for the Kafka file channel. A portion of the stack trace is below. After 15 minutes of waiting the build just terminates with no errors - it just emits
>>>
>>> [ERROR] Failed to execute goal org.apache.maven.plugins:maven-surefire-plugin:2.12.3:test (default-test) on project flume-kafka-channel: ExecutionException; nested exception is java.util.concurrent.ExecutionException: java.lang.RuntimeException: The forked VM terminated without saying properly goodbye. VM crash or System.exit called ? -> [Help 1]
>>>
>>> Any idea why this might be happening?
>>>
>>> Ralph
>>>
>>> java.lang.Thread.State: WAITING (parking)
>>> at sun.misc.Unsafe.park(Native Method)
>>> - parking to wait for <0x00000007004286a8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
>>> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
>>> at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
>>> at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
>>> at java.util.concurrent.ExecutorCompletionService.take(ExecutorCompletionService.java:193)
>>> at org.apache.flume.channel.kafka.TestKafkaChannel.wait(TestKafkaChannel.java:413)
>>> at org.apache.flume.channel.kafka.TestKafkaChannel.writeAndVerify(TestKafkaChannel.java:291)
>>> at org.apache.flume.channel.kafka.TestKafkaChannel.doTestSuccessRollback(TestKafkaChannel.java:104)
>>> at org.apache.flume.channel.kafka.TestKafkaChannel.testSuccessInterleave(TestKafkaChannel.java:88)
>>
>
>
Re: Flume build hangs and fails in Kafka channel
Posted by Ralph Goers <ra...@dslextreme.com>.
Any suggestions on how to debug it? I am adding some new components for my own use that I will probably give back but I want to make sure I am not breaking anything, so I really need a clean build before I get started.
Ralph
> On Feb 1, 2016, at 12:17 PM, Hari Shreedharan <hs...@apache.org> wrote:
>
> Looks like the test is just waiting for something to happen - looks
> like the test is not working as expected. I don't see this, but this
> indicates the test is flakey.
>
> On Mon, Feb 1, 2016 at 8:22 AM, Ralph Goers <ra...@dslextreme.com> wrote:
>> I am trying to run the Flume build on my MacBook Pro and it is hanging running the tests for the Kafka file channel. A portion of the stack trace is below. After 15 minutes of waiting the build just terminates with no errors - it just emits
>>
>> [ERROR] Failed to execute goal org.apache.maven.plugins:maven-surefire-plugin:2.12.3:test (default-test) on project flume-kafka-channel: ExecutionException; nested exception is java.util.concurrent.ExecutionException: java.lang.RuntimeException: The forked VM terminated without saying properly goodbye. VM crash or System.exit called ? -> [Help 1]
>>
>> Any idea why this might be happening?
>>
>> Ralph
>>
>> java.lang.Thread.State: WAITING (parking)
>> at sun.misc.Unsafe.park(Native Method)
>> - parking to wait for <0x00000007004286a8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
>> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
>> at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
>> at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
>> at java.util.concurrent.ExecutorCompletionService.take(ExecutorCompletionService.java:193)
>> at org.apache.flume.channel.kafka.TestKafkaChannel.wait(TestKafkaChannel.java:413)
>> at org.apache.flume.channel.kafka.TestKafkaChannel.writeAndVerify(TestKafkaChannel.java:291)
>> at org.apache.flume.channel.kafka.TestKafkaChannel.doTestSuccessRollback(TestKafkaChannel.java:104)
>> at org.apache.flume.channel.kafka.TestKafkaChannel.testSuccessInterleave(TestKafkaChannel.java:88)
>
Re: Flume build hangs and fails in Kafka channel
Posted by Hari Shreedharan <hs...@apache.org>.
Looks like the test is just waiting for something to happen - looks
like the test is not working as expected. I don't see this, but this
indicates the test is flakey.
On Mon, Feb 1, 2016 at 8:22 AM, Ralph Goers <ra...@dslextreme.com> wrote:
> I am trying to run the Flume build on my MacBook Pro and it is hanging running the tests for the Kafka file channel. A portion of the stack trace is below. After 15 minutes of waiting the build just terminates with no errors - it just emits
>
> [ERROR] Failed to execute goal org.apache.maven.plugins:maven-surefire-plugin:2.12.3:test (default-test) on project flume-kafka-channel: ExecutionException; nested exception is java.util.concurrent.ExecutionException: java.lang.RuntimeException: The forked VM terminated without saying properly goodbye. VM crash or System.exit called ? -> [Help 1]
>
> Any idea why this might be happening?
>
> Ralph
>
> java.lang.Thread.State: WAITING (parking)
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000007004286a8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
> at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
> at java.util.concurrent.ExecutorCompletionService.take(ExecutorCompletionService.java:193)
> at org.apache.flume.channel.kafka.TestKafkaChannel.wait(TestKafkaChannel.java:413)
> at org.apache.flume.channel.kafka.TestKafkaChannel.writeAndVerify(TestKafkaChannel.java:291)
> at org.apache.flume.channel.kafka.TestKafkaChannel.doTestSuccessRollback(TestKafkaChannel.java:104)
> at org.apache.flume.channel.kafka.TestKafkaChannel.testSuccessInterleave(TestKafkaChannel.java:88)