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 :

Query regarding using storm topology in Flink

Hi, I am trying to run locally a storm topology in flink using the flink-storm library , but I get the following error Exception in thread "main" java.lang.NoClassDefFoundError: scala/concurrent/ExecutionContext at org.apache.flink.storm.api.FlinkLocalCluster.(FlinkLocalCluster.java:54) at

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 separate

[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 Components:

[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 Component

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&D 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 in JIRA (should be >

[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 - http://flink.apache.org/news/2016/03/08/relea

[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 I

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 wrote: > Thanks Ufuk! I'l

[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: Impro

[jira] [Created] (FLINK-3589) Allow setting Operator parallelism to default value

Greg Hogan created FLINK-3589: - Summary: Allow setting Operator parallelism to default value Key: FLINK-3589 URL: https://issues.apache.org/jira/browse/FLINK-3589 Project: Flink Issue Type: Impro

[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 Type:

Re: Tuple performance and the curious JIT compiler

Hi Gabor, I did not find any Flink proposals for this year's GSoC in JIRA (should be labeled with gsoc2016). I am also not sure if any of the Flink committers signed up as a GSoC mentor. Maybe it is still time to do that but as it looks right now there are no GSoC projects offered by Flink. Best,

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 benchmar

[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

Re: Estimated time of r 1.0

Hi, I have good news :-) Flink 1.0.0 will be announced today. Cheers, Fabian 2016-03-08 10:59 GMT+01:00 Saar Bar : > 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)

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 wind

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 creati