streams-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ryan Ebanks <ryaneba...@gmail.com>
Subject Re: About RSS provider
Date Tue, 16 Sep 2014 16:32:29 GMT
Hey Renato,

It looks like you discovered a bug.  At line 140 in RssStreamProvider it is
attempting to cast a LinkedConcurrentQueue to a StreamsResult set.  If
you're looking to contribute this would be a great place to start.  I
created a ticket, https://issues.apache.org/jira/browse/STREAMS-173.
 Please create unit tests to prove you fixed the problem and issue a pull
request referencing this ticket number.

I am hoping in the next 2 weeks to have some documentation up on the
website on how to get started contributing, and some user guides.  But
until then, don't hesitate to ask questions on the list serve.

-Ryan Ebanks

On Mon, Sep 15, 2014 at 5:17 PM, Renato MarroquĂ­n Mogrovejo <
renatoj.marroquin@gmail.com> wrote:

> Hi guys,
>
> It's me again :)
> So I am trying to create a simple example of using Streams but for
> consuming RSS [1]. But I am getting this beautiful stack trace.
> I know that the RSS doesn't have the changes that Steve has been making to
> the other examples, and I thought it would be a good place for me to start
> poking around and pushing some changes.
> Thanks in advance!
>
>
> Renato M.
> [1]
>
> https://github.com/renato2099/streams-rss/blob/master/src/main/java/org/apache/streams/examples/rss/RssTest.java
>
>
> 00:05:59.016 [main] DEBUG o.a.s.l.builders.LocalStreamBuilder - Attaching
> shutdown handler
> 00:05:59.030 [pool-3-thread-1] DEBUG
> o.a.s.l.t.LocalStreamProcessMonitorThread - [monitor] Used Memory: 20.0 MB,
> Max: 954.7 MB
> 00:05:59.044 [main] INFO  o.a.s.l.builders.LocalStreamBuilder - Started
> stream with 2 components
> 00:05:59.067 [pool-2-thread-4] ERROR o.a.s.l.tasks.StreamsProviderTask -
> Error in processing provider stream
> java.lang.ClassCastException: java.util.concurrent.ConcurrentLinkedQueue
> cannot be cast to org.apache.streams.core.StreamsResultSet
> at
>
> org.apache.streams.rss.provider.RssStreamProvider.readCurrent(RssStreamProvider.java:140)
> ~[classes/:na]
> at
>
> org.apache.streams.local.tasks.StreamsProviderTask.run(StreamsProviderTask.java:148)
> ~[streams-runtime-local-0.1-SNAPSHOT.jar:0.1-SNAPSHOT]
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> [na:1.7.0_67]
> at java.util.concurrent.FutureTask.run(FutureTask.java:262) [na:1.7.0_67]
> at
>
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> [na:1.7.0_67]
> at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> [na:1.7.0_67]
> at java.lang.Thread.run(Thread.java:745) [na:1.7.0_67]
> 00:05:59.067 [pool-2-thread-4] DEBUG o.a.s.l.tasks.StreamsProviderTask -
> Complete Provider Task execution for RssStreamProvider
> 00:05:59.077 [pool-1-thread-2] INFO  o.a.s.rss.provider.RssEventProcessor -
> Terminating!
> 00:05:59.475 [pool-1-thread-1] INFO  o.a.s.rss.provider.RssStreamProvider -
> Connected: http://www.thelocal.ch/feeds/rss.php
> java.lang.NullPointerException
> at
>
> org.apache.streams.rss.provider.RssStreamProviderTask.run(RssStreamProviderTask.java:62)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at java.util.concurrent.FutureTask.run(FutureTask.java:262)
> at
>
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at
>
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message