flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zentol <...@git.apache.org>
Subject [GitHub] flink pull request: [FLINK-3311] Add a connector for streaming dat...
Date Thu, 18 Feb 2016 13:09:18 GMT
Github user zentol commented on the pull request:

    https://github.com/apache/flink/pull/1660#issuecomment-185711495
  
    Full stack trace (on Windows, will try them on Linux later on)
    
    ```
    -------------------------------------------------------
     T E S T S
    -------------------------------------------------------
    Running org.apache.flink.connectors.cassandra.CassandraConnectorTest
    0    [main] ERROR org.apache.cassandra.service.StartupChecks  - cassandra.jmx.local.port
missing from cassandra-env.sh, unable to start local JMX service.
    72992 [main] ERROR org.apache.flink.connectors.cassandra.CassandraConnectorTest  -
    --------------------------------------------------------------------------------
    Test runtimeExceptionCreateQuery(org.apache.flink.connectors.cassandra.CassandraConnectorTest)
failed with:
    org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
            at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply$mcV$sp(JobManager.scala:714)
            at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:660)
            at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:660)
            at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
            at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
            at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
            at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)
            at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
            at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
            at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
            at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
            at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
    Caused by: java.lang.RuntimeException: It is allowed to create table only with parallelism
of 1
            at org.apache.flink.connectors.cassandra.streaming.BaseCassandraSink.open(BaseCassandraSink.java:87)
            at org.apache.flink.connectors.cassandra.streaming.CassandraSink.open(CassandraSink.java:55)
            at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:38)
            at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:91)
            at org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:313)
            at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:213)
            at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
            at java.lang.Thread.run(Thread.java:745)
    
    ================================================================================
    73514 [main] ERROR org.apache.flink.connectors.cassandra.CassandraConnectorTest  -
    --------------------------------------------------------------------------------
    Test clazzNotSet(org.apache.flink.connectors.cassandra.CassandraConnectorTest) failed
with:
    java.lang.NullPointerException: Clazz cannot be null
            at com.google.common.base.Preconditions.checkNotNull(Preconditions.java:226)
            at org.apache.flink.connectors.cassandra.streaming.CassandraMapperSink.<init>(CassandraMapperSink.java:66)
            at org.apache.flink.connectors.cassandra.streaming.CassandraMapperSink.<init>(CassandraMapperSink.java:54)
            at org.apache.flink.connectors.cassandra.CassandraConnectorTest$4.<init>(CassandraConnectorTest.java:207)
            at org.apache.flink.connectors.cassandra.CassandraConnectorTest.clazzNotSet(CassandraConnectorTest.java:207)
            at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
            at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
            at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
            at java.lang.reflect.Method.invoke(Method.java:483)
            at org.junit.internal.runners.TestMethod.invoke(TestMethod.java:68)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl$PowerMockJUnit44MethodRunner.runTestMethod(PowerMockJUnit44RunnerDelegateImpl.java:310)
            at org.junit.internal.runners.MethodRoadie$2.run(MethodRoadie.java:88)
            at org.junit.internal.runners.MethodRoadie.runBeforesThenTestThenAfters(MethodRoadie.java:96)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl$PowerMockJUnit44MethodRunner.executeTest(PowerMockJUnit44RunnerDelegateImpl.java:294)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit47RunnerDelegateImpl$PowerMockJUnit47MethodRunner.executeTestInSuper(PowerMockJUnit47RunnerDelegateImpl.java:127)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit47RunnerDelegateImpl$PowerMockJUnit47MethodRunner.access$100(PowerMockJUnit47RunnerDelegateImpl.java:59)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit47RunnerDelegateImpl$PowerMockJUnit47MethodRunner$LastRuleTestExecutorStatement.evaluate(PowerMockJUnit47RunnerDelegateImpl.java:148)
            at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit47RunnerDelegateImpl$PowerMockJUnit47MethodRunner.executeTest(PowerMockJUnit47RunnerDelegateImpl.java:91)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl$PowerMockJUnit44MethodRunner.runBeforesThenTestThenAfters(PowerMockJUnit44RunnerDelegateImpl.java:282)
            at org.junit.internal.runners.MethodRoadie.runTest(MethodRoadie.java:86)
            at org.junit.internal.runners.MethodRoadie.run(MethodRoadie.java:49)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl.invokeTestMethod(PowerMockJUnit44RunnerDelegateImpl.java:207)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl.runMethods(PowerMockJUnit44RunnerDelegateImpl.java:146)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl$1.run(PowerMockJUnit44RunnerDelegateImpl.java:120)
            at org.junit.internal.runners.ClassRoadie.runUnprotected(ClassRoadie.java:33)
            at org.junit.internal.runners.ClassRoadie.runProtected(ClassRoadie.java:45)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl.run(PowerMockJUnit44RunnerDelegateImpl.java:118)
            at org.powermock.modules.junit4.common.internal.impl.JUnit4TestSuiteChunkerImpl.run(JUnit4TestSuiteChunkerImpl.java:104)
            at org.powermock.modules.junit4.common.internal.impl.AbstractCommonPowerMockRunner.run(AbstractCommonPowerMockRunner.java:53)
            at org.powermock.modules.junit4.PowerMockRunner.run(PowerMockRunner.java:53)
            at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:283)
            at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:173)
            at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:153)
            at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:128)
            at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203)
            at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155)
            at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
    
    ================================================================================
    org.apache.flink.api.common.NonSerializableUserCodeException: User-defined object org.apache.flink.connectors.cassandra.CassandraConnectorTest$7@797a9c58
(org.apache.flink.connectors.cassandra.CassandraConnectorTest$7) contains non-serializable
field this$0 = org.apache.flink.connectors.cassandra.CassandraConnectorTest@41c6c920
            at org.apache.flink.api.common.operators.util.UserCodeObjectWrapper.<init>(UserCodeObjectWrapper.java:86)
            at org.apache.flink.api.common.operators.GenericDataSinkBase.<init>(GenericDataSinkBase.java:70)
            at org.apache.flink.api.java.operators.DataSink.translateToDataFlow(DataSink.java:219)
            at org.apache.flink.api.java.operators.OperatorTranslation.translate(OperatorTranslation.java:66)
            at org.apache.flink.api.java.operators.OperatorTranslation.translateToPlan(OperatorTranslation.java:51)
            at org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:994)
            at org.apache.flink.api.java.ExecutionEnvironment.createProgramPlan(ExecutionEnvironment.java:961)
            at org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:84)
            at org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:855)
            at org.apache.flink.api.java.DataSet.count(DataSet.java:395)
            at org.apache.flink.connectors.cassandra.CassandraConnectorTest.batch(CassandraConnectorTest.java:290)
            at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
            at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
            at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
            at java.lang.reflect.Method.invoke(Method.java:483)
            at org.junit.internal.runners.TestMethod.invoke(TestMethod.java:68)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl$PowerMockJUnit44MethodRunner.runTestMethod(PowerMockJUnit44RunnerDelegateImpl.java:310)
            at org.junit.internal.runners.MethodRoadie$2.run(MethodRoadie.java:88)
            at org.junit.internal.runners.MethodRoadie.runBeforesThenTestThenAfters(MethodRoadie.java:96)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl$PowerMockJUnit44MethodRunner.executeTest(PowerMockJUnit44RunnerDelegateImpl.java:294)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit47RunnerDelegateImpl$PowerMockJUnit47MethodRunner.executeTestInSuper(PowerMockJUnit47RunnerDelegateImpl.java:127)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit47RunnerDelegateImpl$PowerMockJUnit47MethodRunner.access$100(PowerMockJUnit47RunnerDelegateImpl.java:59)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit47RunnerDelegateImpl$PowerMockJUnit47MethodRunner$LastRuleTestExecutorStatement.evaluate(PowerMockJUnit47RunnerDelegateImpl.java:148)
            at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit47RunnerDelegateImpl$PowerMockJUnit47MethodRunner.executeTest(PowerMockJUnit47RunnerDelegateImpl.java:91)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl$PowerMockJUnit44MethodRunner.runBeforesThenTestThenAfters(PowerMockJUnit44RunnerDelegateImpl.java:282)
            at org.junit.internal.runners.MethodRoadie.runTest(MethodRoadie.java:86)
            at org.junit.internal.runners.MethodRoadie.run(MethodRoadie.java:49)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl.invokeTestMethod(PowerMockJUnit44RunnerDelegateImpl.java:207)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl.runMethods(PowerMockJUnit44RunnerDelegateImpl.java:146)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl$1.run(PowerMockJUnit44RunnerDelegateImpl.java:120)
            at org.junit.internal.runners.ClassRoadie.runUnprotected(ClassRoadie.java:33)
            at org.junit.internal.runners.ClassRoadie.runProtected(ClassRoadie.java:45)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl.run(PowerMockJUnit44RunnerDelegateImpl.java:118)
            at org.powermock.modules.junit4.common.internal.impl.JUnit4TestSuiteChunkerImpl.run(JUnit4TestSuiteChunkerImpl.java:104)
            at org.powermock.modules.junit4.common.internal.impl.AbstractCommonPowerMockRunner.run(AbstractCommonPowerMockRunner.java:53)
            at org.powermock.modules.junit4.PowerMockRunner.run(PowerMockRunner.java:53)
            at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:283)
            at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:173)
            at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:153)
            at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:128)
            at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203)
            at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155)
            at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
    151605 [main] ERROR org.apache.flink.connectors.cassandra.CassandraConnectorTest  -
    --------------------------------------------------------------------------------
    Test queryNotSet(org.apache.flink.connectors.cassandra.CassandraConnectorTest) failed
with:
    java.lang.IllegalArgumentException: insertQuery not set
            at org.apache.flink.connectors.cassandra.streaming.BaseCassandraSink.checkNullOrEmpty(BaseCassandraSink.java:127)
            at org.apache.flink.connectors.cassandra.streaming.CassandraSink.<init>(CassandraSink.java:49)
            at org.apache.flink.connectors.cassandra.streaming.CassandraSink.<init>(CassandraSink.java:44)
            at org.apache.flink.connectors.cassandra.CassandraConnectorTest$1.<init>(CassandraConnectorTest.java:146)
            at org.apache.flink.connectors.cassandra.CassandraConnectorTest.queryNotSet(CassandraConnectorTest.java:146)
            at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
            at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
            at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
            at java.lang.reflect.Method.invoke(Method.java:483)
            at org.junit.internal.runners.TestMethod.invoke(TestMethod.java:68)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl$PowerMockJUnit44MethodRunner.runTestMethod(PowerMockJUnit44RunnerDelegateImpl.java:310)
            at org.junit.internal.runners.MethodRoadie$2.run(MethodRoadie.java:88)
            at org.junit.internal.runners.MethodRoadie.runBeforesThenTestThenAfters(MethodRoadie.java:96)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl$PowerMockJUnit44MethodRunner.executeTest(PowerMockJUnit44RunnerDelegateImpl.java:294)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit47RunnerDelegateImpl$PowerMockJUnit47MethodRunner.executeTestInSuper(PowerMockJUnit47RunnerDelegateImpl.java:127)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit47RunnerDelegateImpl$PowerMockJUnit47MethodRunner.access$100(PowerMockJUnit47RunnerDelegateImpl.java:59)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit47RunnerDelegateImpl$PowerMockJUnit47MethodRunner$LastRuleTestExecutorStatement.evaluate(PowerMockJUnit47RunnerDelegateImpl.java:148)
            at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:55)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit47RunnerDelegateImpl$PowerMockJUnit47MethodRunner.executeTest(PowerMockJUnit47RunnerDelegateImpl.java:91)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl$PowerMockJUnit44MethodRunner.runBeforesThenTestThenAfters(PowerMockJUnit44RunnerDelegateImpl.java:282)
            at org.junit.internal.runners.MethodRoadie.runTest(MethodRoadie.java:86)
            at org.junit.internal.runners.MethodRoadie.run(MethodRoadie.java:49)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl.invokeTestMethod(PowerMockJUnit44RunnerDelegateImpl.java:207)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl.runMethods(PowerMockJUnit44RunnerDelegateImpl.java:146)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl$1.run(PowerMockJUnit44RunnerDelegateImpl.java:120)
            at org.junit.internal.runners.ClassRoadie.runUnprotected(ClassRoadie.java:33)
            at org.junit.internal.runners.ClassRoadie.runProtected(ClassRoadie.java:45)
            at org.powermock.modules.junit4.internal.impl.PowerMockJUnit44RunnerDelegateImpl.run(PowerMockJUnit44RunnerDelegateImpl.java:118)
            at org.powermock.modules.junit4.common.internal.impl.JUnit4TestSuiteChunkerImpl.run(JUnit4TestSuiteChunkerImpl.java:104)
            at org.powermock.modules.junit4.common.internal.impl.AbstractCommonPowerMockRunner.run(AbstractCommonPowerMockRunner.java:53)
            at org.powermock.modules.junit4.PowerMockRunner.run(PowerMockRunner.java:53)
            at org.apache.maven.surefire.junit4.JUnit4Provider.execute(JUnit4Provider.java:283)
            at org.apache.maven.surefire.junit4.JUnit4Provider.executeWithRerun(JUnit4Provider.java:173)
            at org.apache.maven.surefire.junit4.JUnit4Provider.executeTestSet(JUnit4Provider.java:153)
            at org.apache.maven.surefire.junit4.JUnit4Provider.invoke(JUnit4Provider.java:128)
            at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:203)
            at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:155)
            at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:103)
    
    ================================================================================
    244441 [main] ERROR org.apache.flink.connectors.cassandra.CassandraConnectorTest  -
    --------------------------------------------------------------------------------
    Test cassandraSink(org.apache.flink.connectors.cassandra.CassandraConnectorTest) failed
with:
    org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
            at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply$mcV$sp(JobManager.scala:714)
            at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:660)
            at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$7.apply(JobManager.scala:660)
            at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
            at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
            at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
            at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:401)
            at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
            at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
            at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
            at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
            at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
    Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried
for query failed (tried: /127.0.0.1:9042 (com.datastax.driver.core.OperationTimedOutException:
[/127.0.0.1:9042] Operation timed out))
            at com.datastax.driver.core.exceptions.NoHostAvailableException.copy(NoHostAvailableException.java:84)
            at com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
            at com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:214)
            at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:52)
            at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:36)
            at org.apache.flink.connectors.cassandra.streaming.BaseCassandraSink.open(BaseCassandraSink.java:85)
            at org.apache.flink.connectors.cassandra.streaming.CassandraSink.open(CassandraSink.java:55)
            at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:38)
            at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:91)
            at org.apache.flink.streaming.runtime.tasks.StreamTask.openAllOperators(StreamTask.java:313)
            at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:213)
            at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
            at java.lang.Thread.run(Thread.java:745)
    Caused by: com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried
for query failed (tried: /127.0.0.1:9042 (com.datastax.driver.core.OperationTimedOutException:
[/127.0.0.1:9042] Operation timed out))
            at com.datastax.driver.core.RequestHandler.reportNoMoreHosts(RequestHandler.java:217)
            at com.datastax.driver.core.RequestHandler.access$1000(RequestHandler.java:44)
            at com.datastax.driver.core.RequestHandler$SpeculativeExecution.sendRequest(RequestHandler.java:276)
            at com.datastax.driver.core.RequestHandler$SpeculativeExecution$1.run(RequestHandler.java:374)
            at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
            at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
            ... 1 more
    
    ================================================================================
    264078 [cluster1-reconnection-0] ERROR com.datastax.driver.core.ControlConnection  - [Control
connection] Cannot connect to any host, scheduling retry in 1000 milliseconds
    265081 [cluster1-reconnection-0] ERROR com.datastax.driver.core.ControlConnection  - [Control
connection] Cannot connect to any host, scheduling retry in 2000 milliseconds
    267092 [cluster1-reconnection-0] ERROR com.datastax.driver.core.ControlConnection  - [Control
connection] Cannot connect to any host, scheduling retry in 4000 milliseconds
    
    Results :
    
    Tests run: 0, Failures: 0, Errors: 0, Skipped: 0
    
    [INFO] ------------------------------------------------------------------------
    [INFO] BUILD FAILURE
    [INFO] ------------------------------------------------------------------------
    [INFO] Total time: 05:43 min
    [INFO] Finished at: 2016-02-18T14:08:10+01:00
    [INFO] Final Memory: 46M/354M
    [INFO] ------------------------------------------------------------------------
    [ERROR] Failed to execute goal org.apache.maven.plugins:maven-surefire-plugin:2.18.1:test
(default-test) on project flink-connector-cassandra_2.10: Execution default-test of goal org.apache.maven.plugins:maven-surefire-plugin:2.18.1:test
failed: The forked VM terminated without properly saying goodbye. VM crash or System.exit
called?
    [ERROR] Command was cmd.exe /X /C ""C:\Program Files\Java\jdk1.8.0_25\jre\bin\java" -Xms256m
-Xmx800m -Dlog4j.configuration=log4j-test.properties -Dmvn.forkNumber=1 -XX:-UseGCOverheadLimit
-jar C:\Users\Zento\Documents\GitHub\flink\flink-streaming-connectors\flink-connector-cassandra\target\surefire\surefirebooter756588088901854568.jar
C:\Users\Zento\Documents\GitHub\flink\flink-streaming-connectors\flink-connector-cassandra\target\surefire\surefire4750169912072982325tmp
C:\Users\Zento\Documents\GitHub\flink\flink-streaming-connectors\flink-connector-cassandra\target\surefire\surefire_05539510900491680087tmp"
    [ERROR] -> [Help 1]
    [ERROR]
    [ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
    [ERROR] Re-run Maven using the -X switch to enable full debug logging.
    [ERROR]
    [ERROR] For more information about the errors and possible solutions, please read the
following articles:
    [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/PluginExecutionException
    
    ```


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message