Re: Query regarding using storm topology in Flink

Hi Samiksha Could you post here what dependencies are you using. It looks like you could be using outdated dependencies, or making unnecessary references to an already imported dependency. Rgds, Vitor Vieira @notvitor 2016-03-08 22:06 GMT-03:00 Sharma, Samiksha

Re: [ANNOUNCE] Flink 1.0.0 has been released

Congratulations! Very nice work, very interesting features. One question regarding CEP: do you think it's feasible to define pattern over window of 1 month or even more? Is there some deep explanation regarding how this partial states are saved? I mean events that create "funnel" might be

[jira] [Created] (FLINK-3593) DistinctITCase is failing

Vasia Kalavri created FLINK-3593: Summary: DistinctITCase is failing Key: FLINK-3593 URL: https://issues.apache.org/jira/browse/FLINK-3593 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3592) Update setup quickstart

Ufuk Celebi created FLINK-3592: -- Summary: Update setup quickstart Key: FLINK-3592 URL: https://issues.apache.org/jira/browse/FLINK-3592 Project: Flink Issue Type: Improvement

RE: [ANNOUNCE] Flink 1.0.0 has been released

Hi, Do you have also a linkedin post that I could share - or should I make a blogpost in which I take this announcement? Dr. Radu Tudoran Research Engineer - Big Data Expert IT R Division HUAWEI TECHNOLOGIES Duesseldorf GmbH European Research Center Riesstrasse 25, 80992 München E-mail:

Re: Tuple performance and the curious JIT compiler

@Fabian: That is my bad, but I think we should be still on time. Pinged Uli just to make sure. Proposal from Gabor and Jira from me are coming soon. On Tue, Mar 8, 2016 at 11:43 AM, Fabian Hueske wrote: > Hi Gabor, > > I did not find any Flink proposals for this year's GSoC

[ANNOUNCE] Flink 1.0.0 has been released

Hi everyone! As you might have noticed, Apache Flink 1.0.0 has been released and announced! You can read more about the release at the ASF blog and the Flink blog - https://blogs.apache.org/foundation/entry/the_apache_software_foundation_announces88 -

[jira] [Created] (FLINK-3591) Replace Quickstart K-Means Example by Streaming Example

Aljoscha Krettek created FLINK-3591: --- Summary: Replace Quickstart K-Means Example by Streaming Example Key: FLINK-3591 URL: https://issues.apache.org/jira/browse/FLINK-3591 Project: Flink

Re: Release 1.0 Migration Guide

I copied the document to our Wiki now that the release is out: https://cwiki.apache.org/confluence/display/FLINK/Migration+Guide%3A+0.10.x+to+1.0.x https://cwiki.apache.org/confluence/display/FLINK/Stability+Annotations On Thu, Mar 3, 2016 at 11:32 AM, Vasiliki Kalavri

[jira] [Created] (FLINK-3590) JDBC Format tests don't hide derby logs

Chesnay Schepler created FLINK-3590: --- Summary: JDBC Format tests don't hide derby logs Key: FLINK-3590 URL: https://issues.apache.org/jira/browse/FLINK-3590 Project: Flink Issue Type:

[jira] [Created] (FLINK-3588) Add a streaming (exactly-once) JDBC connector

Chesnay Schepler created FLINK-3588: --- Summary: Add a streaming (exactly-once) JDBC connector Key: FLINK-3588 URL: https://issues.apache.org/jira/browse/FLINK-3588 Project: Flink Issue

Re: Tuple performance and the curious JIT compiler

Hi! I am planning to do GSoC and I would like to work on the serializers. More specifically I would like to implement code generation. I am planning to send the first draft of the proposal to the mailing list early next week. If everything is going well, that will include some preliminary

[jira] [Created] (FLINK-3587) Bump Calcite version to 1.7.0-SNAPSHOT

Vasia Kalavri created FLINK-3587: Summary: Bump Calcite version to 1.7.0-SNAPSHOT Key: FLINK-3587 URL: https://issues.apache.org/jira/browse/FLINK-3587 Project: Flink Issue Type: Improvement

Fwd: Estimated time of r 1.0

Hello, I am building a new startup. We are at the architecture stage for the alpha version of the product. Our architecture: The streaming server (hopefully Flink) is pulling messages from a data flow queue (RabbitMQ or AWS IOT broker), processing the data (Pattern matching, geographical

Re: Tuple performance and the curious JIT compiler

Ah, very good, that makes sense! I would guess that this performance difference could probably be seen at various points where generic serializers and comparators are used (also for Comparable, Writable) or where the TupleSerializer delegates to a sequence of other TypeSerializers. I guess