*IntelliJ reports the following:*
*Cannot download sources*
Sources not found for:
org.apache.flink:flink-streaming-scala:1.0-SNAPSHOT
Would it be possible to publish sources for this artifact?
--
*Alex Rovner*
*Director, Data Engineering *
*o:* 646.759.0052
* <http://www.magnetic.com/>*
; 01/05/2016 21:44:09 Source: Custom Source -> Map(1/1) switched to
>> DEPLOYING
>> 01/05/2016 21:44:09 Source: Custom Source -> Map(1/1) switched to
>> RUNNING
>>
>> By the way, in order to print the stream, you have to call counts.print()
>> instead of pr
ld no longer occur.
>
> Cheers,
> Till
>
> On Tue, Jan 5, 2016 at 1:31 AM, Alex Rovner
> wrote:
>
>> Hello Flinkers!
>>
>> The below program produces the following error when running locally. I am
>> building the program using maven, using 0.10.0
quot;);
properties.setProperty("group.id", "test");
val stream = env
.addSource(new FlinkKafkaConsumer082[String]("topic", new
SimpleStringSchema(), properties))
val counts = stream.map(f=>f.split(","))
print(counts)
env.execute()
}
--
*Alex Rovner*
*Director, Data Engineering *
*o:* 646.759.0052
* <http://www.magnetic.com/>*
cond or so) and limit any throughput a lot because they involve
> many smaller messages and add even more latency (roundtrip between nodes,
> rather than one way).
>
>
> Hope that this answers your question, let me know if you have more
> questions!
>
> Greetings,
> Step
tical experience though.
Thanks
*Alex Rovner*
*Director, Data Engineering *
*o:* 646.759.0052
* <http://www.magnetic.com/>*
