ignite-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Anton Vinogradov (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (IGNITE-3303) Apache Flink Integration - Flink source to run a continuous query against one or multiple caches
Date Thu, 06 Oct 2016 15:27:20 GMT

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

Anton Vinogradov edited comment on IGNITE-3303 at 10/6/16 3:27 PM:
-------------------------------------------------------------------

Saikat, 
sorry for delay.

I've checked latest pullrequest and still see testFlinkIgniteSourceWithLargeBatch failing.
{noformat}
"test-runner-#180%flink.FlinkIgniteSourceSelfTest%" #319 prio=5 os_prio=0 tid=0x00000000297c7800
nid=0xb1c waiting on condition [0x0000000028c4d000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000077b3826d0> (a scala.concurrent.impl.Promise$CompletionLatch)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328)
	at scala.concurrent.impl.Promise$DefaultPromise.tryAwait(Promise.scala:208)
	at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:218)
	at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
	at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
	at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
	at scala.concurrent.Await$.result(package.scala:107)
	at scala.concurrent.Await.result(package.scala)
	at org.apache.flink.runtime.client.JobClient.submitJobAndWait(JobClient.java:133)
	at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:423)
	at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:409)
	at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:401)
	at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:107)
	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1170)
	at org.apache.ignite.source.flink.FlinkIgniteSourceSelfTest.checkIgniteSource(FlinkIgniteSourceSelfTest.java:162)
	at org.apache.ignite.source.flink.FlinkIgniteSourceSelfTest.testFlinkIgniteSourceWithLargeBatch(FlinkIgniteSourceSelfTest.java:99)
	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:498)
	at junit.framework.TestCase.runTest(TestCase.java:176)
	at org.apache.ignite.testframework.junits.GridAbstractTest.runTestInternal(GridAbstractTest.java:1768)
	at org.apache.ignite.testframework.junits.GridAbstractTest.access$000(GridAbstractTest.java:118)
	at org.apache.ignite.testframework.junits.GridAbstractTest$4.run(GridAbstractTest.java:1706)
	at java.lang.Thread.run(Thread.java:745)
{noformat}

I see the same failure at previous log. 
Did you reproduced and checked failure I've filed before?
My os is Win 7, hope it helps to reproduce and fix. Let me know in case additions info required.


was (Author: avinogradov):
Saikat, 
sorry for delay.

I've checked latest pullrequest and still see testFlinkIgniteSourceWithLargeBatch failing.
{noformat}
"test-runner-#180%flink.FlinkIgniteSourceSelfTest%" #319 prio=5 os_prio=0 tid=0x00000000297c7800
nid=0xb1c waiting on condition [0x0000000028c4d000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000077b3826d0> (a scala.concurrent.impl.Promise$CompletionLatch)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328)
	at scala.concurrent.impl.Promise$DefaultPromise.tryAwait(Promise.scala:208)
	at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:218)
	at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
	at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
	at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
	at scala.concurrent.Await$.result(package.scala:107)
	at scala.concurrent.Await.result(package.scala)
	at org.apache.flink.runtime.client.JobClient.submitJobAndWait(JobClient.java:133)
	at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:423)
	at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:409)
	at org.apache.flink.runtime.minicluster.FlinkMiniCluster.submitJobAndWait(FlinkMiniCluster.scala:401)
	at org.apache.flink.streaming.api.environment.LocalStreamEnvironment.execute(LocalStreamEnvironment.java:107)
	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1170)
	at org.apache.ignite.source.flink.FlinkIgniteSourceSelfTest.checkIgniteSource(FlinkIgniteSourceSelfTest.java:162)
	at org.apache.ignite.source.flink.FlinkIgniteSourceSelfTest.testFlinkIgniteSourceWithLargeBatch(FlinkIgniteSourceSelfTest.java:99)
	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:498)
	at junit.framework.TestCase.runTest(TestCase.java:176)
	at org.apache.ignite.testframework.junits.GridAbstractTest.runTestInternal(GridAbstractTest.java:1768)
	at org.apache.ignite.testframework.junits.GridAbstractTest.access$000(GridAbstractTest.java:118)
	at org.apache.ignite.testframework.junits.GridAbstractTest$4.run(GridAbstractTest.java:1706)
	at java.lang.Thread.run(Thread.java:745)
{noformat}

I see the same failure at previous log. 
Did you reproduced and checked failure I've filed before.
My os is Win 7, hope it helps to reproduce and fix. Let me know in case additions info required.

> Apache Flink Integration - Flink source to run a continuous query against one or multiple
caches
> ------------------------------------------------------------------------------------------------
>
>                 Key: IGNITE-3303
>                 URL: https://issues.apache.org/jira/browse/IGNITE-3303
>             Project: Ignite
>          Issue Type: New Feature
>          Components: streaming
>            Reporter: Saikat Maitra
>            Assignee: Saikat Maitra
>         Attachments: testFlinkIgniteSourceWithLargeBatch.log
>
>
> Apache Flink integration 
> +++ *Ignite as a bidirectional Connector* +++
> As a Flink source => run a continuous query against one or multiple
> caches [4].
> Related discussion : http://apache-ignite-developers.2346864.n4.nabble.com/Apache-Flink-lt-gt-Apache-Ignite-integration-td8163.html



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message