Mailing-List: contact dev-help@streams.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@streams.incubator.apache.org
Received-SPF: pass (nike.apache.org: domain of ryanebanks@gmail.com designates
 209.85.214.169 as permitted sender)
MIME-Version: 1.0
In-Reply-To: 
 <CAHYFERBwJDu73P4VCMfBEGJGfAyqEvJEb7aDKQfPxSz7D69sEQ@mail.gmail.com>
References: 
 <CAHYFERBwJDu73P4VCMfBEGJGfAyqEvJEb7aDKQfPxSz7D69sEQ@mail.gmail.com>
Date: Tue, 16 Sep 2014 11:32:29 -0500
Message-ID: 
 <CAK8vTf8RZjy4AN29yubSyFEqfwH9Un2WTyG0gcJi6LSr5B-C6A@mail.gmail.com>
Subject: Re: About RSS provider
From: Ryan Ebanks <ryanebanks@gmail.com>
To: dev@streams.incubator.apache.org
Content-Type: multipart/alternative; boundary=e89a8f92410e2da3390503314cc3

--e89a8f92410e2da3390503314cc3
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

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=C3=ADn 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 t=
o
> the other examples, and I thought it would be a good place for me to star=
t
> poking around and pushing some changes.
> Thanks in advance!
>
>
> Renato M.
> [1]
>
> https://github.com/renato2099/streams-rss/blob/master/src/main/java/org/a=
pache/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 M=
B,
> 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(RssStreamPr=
ovider.java:140)
> ~[classes/:na]
> at
>
> org.apache.streams.local.tasks.StreamsProviderTask.run(StreamsProviderTas=
k.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.jav=
a: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(RssStreamProvid=
erTask.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.jav=
a:615)
> at java.lang.Thread.run(Thread.java:745)
>

--e89a8f92410e2da3390503314cc3--