Re: Powered by Flink

Thanks, Slim. I have just updated the wiki page with this entries. On Tue, Apr 5, 2016 at 10:20 AM, Slim Baltagi wrote: > Hi > > The following are missing in the ‘Powered by Flink’ list: > >- *king.com * > > https://blogs.apache.org/foundation/entry/the_apache_software_

Re: Powered by Flink

Hi The following are missing in the ‘Powered by Flink’ list: king.com https://blogs.apache.org/foundation/entry/the_apache_software_foundation_announces88 Otto Group http://data-artisans.com/how-we-selected-apache-flink-at-otto-group/

[RESULT] [VOTE] Release Apache Flink 1.0.1 (RC1)

This vote has passed with 3 binding +1 votes. Thanks to everyone who contributed and tested the release candidate. +1s: Robert Metzger (binding) Aljoscha Krettek (binding) Ufuk Celebi (binding) There are no 0s or -1s. I'll finalize and package this release asap. – Ufuk On Mon, Apr 4, 2016 at

[jira] [Created] (FLINK-3706) YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable

Aljoscha Krettek created FLINK-3706: --- Summary: YARNSessionCapacitySchedulerITCase.testNonexistingQueue unstable Key: FLINK-3706 URL: https://issues.apache.org/jira/browse/FLINK-3706 Project: Flink

[jira] [Created] (FLINK-3705) Provide explanation for Hadoop dependencies and how to configure it

Ufuk Celebi created FLINK-3705: -- Summary: Provide explanation for Hadoop dependencies and how to configure it Key: FLINK-3705 URL: https://issues.apache.org/jira/browse/FLINK-3705 Project: Flink

Re: Powered by Flink

Hi everyone, I would like to bring the "Powered by Flink" wiki page [1] to the attention of Flink user's who recently joined the Flink community. The list tracks which organizations are using Flink. If your company / university / research institute / ... is using Flink but the name is not yet list

Re: Table API / SQL Queries and Code Generation

Hi Gábor, the code generation in the Table API is in a very early stage and contains not much optimization logic so far. Currently we extend the functionality to support the most important SQL operations. It will need some time until we can further optimize the generated code (e.g. for tracki

Table API / SQL Queries and Code Generation

Hi! During this summer I plan to introduce runtime code generation in the serializers [1] to improve the performance of Flink. As Stephan Ewen pointed in Table API / SQL effort code generation will also be used to generate functions and data types. In order to share as much code as possible and a

Re: returns method in scala api

Thank you! I'm implementing now using implicit parameters. 2016-04-05 7:14 GMT+02:00 Chiwan Park : > Note that you should use `createTypeInfomation[T]` method in > `org.apache.flink.api.scala` package object to create `TypeInformation` for > Scala specific types such as case classes or tuples. >

[jira] [Created] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable

Robert Metzger created FLINK-3704: - Summary: JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable Key: FLINK-3704 URL: https://issues.apache.org/jira/browse/FLINK-3704

Re: Failing Test

Thanks, the actual problem is that the ActorSystem gets shutdown. This breaks the testing code. Should be fixed once https://github.com/apache/flink/pull/1852 is merged. On Tue, Apr 5, 2016 at 12:25 PM, Matthias J. Sax wrote: > Happened again after your fix: > https://travis-ci.org/apache/flink/j

[jira] [Created] (FLINK-3703) Add sequence matching semantics to discard matched events

Till Rohrmann created FLINK-3703: Summary: Add sequence matching semantics to discard matched events Key: FLINK-3703 URL: https://issues.apache.org/jira/browse/FLINK-3703 Project: Flink Issue

[jira] [Created] (FLINK-3702) DataStream API PojoFieldAccessor doesn't support nested POJOs

Robert Metzger created FLINK-3702: - Summary: DataStream API PojoFieldAccessor doesn't support nested POJOs Key: FLINK-3702 URL: https://issues.apache.org/jira/browse/FLINK-3702 Project: Flink

[jira] [Created] (FLINK-3701) Cant call execute after first execution

Nikolaas Steenbergen created FLINK-3701: --- Summary: Cant call execute after first execution Key: FLINK-3701 URL: https://issues.apache.org/jira/browse/FLINK-3701 Project: Flink Issue Typ

[jira] [Created] (FLINK-3700) Replace Guava Preconditions class with Flink Preconditions

Stephan Ewen created FLINK-3700: --- Summary: Replace Guava Preconditions class with Flink Preconditions Key: FLINK-3700 URL: https://issues.apache.org/jira/browse/FLINK-3700 Project: Flink Issue

Re: [DISCUSS] Allowed Lateness in Flink

By the way. The way I see to fixing this is extending WindowAssigner with an "isEventTime()" method and then allow accumulating/lateness in the WindowOperator only if this is true. But it seems a but hacky because it special cases event-time. But then again, maybe we need to special case it ... O

Re: Failing Test

Happened again after your fix: https://travis-ci.org/apache/flink/jobs/120620482 -Matthias On 04/01/2016 08:57 PM, Maximilian Michels wrote: > Fixed with the resolution of https://issues.apache.org/jira/browse/FLINK-3689. > > On Fri, Apr 1, 2016 at 12:40 PM, Maximilian Michels wrote: >> Hi Mat

[DISCUSS] Allowed Lateness in Flink

Hi Folks, as part of my effort to improve the windowing in Flink [1] I also thought about lateness, accumulating/discarding and window cleanup. I have some ideas on this but I would love to get feedback from the community as I think that these things are important for everyone doing event-time wind

Re: Apache Flink <=> Apache Ignite integration

Hi Raul! Concerning the source connector and position marker: Great idea! The FlinkKafkaConsumer uses pretty much the same trick - the offset-per-partition is used to filter during replays. Greetings, Stephan On Tue, Apr 5, 2016 at 2:24 AM, Raul Kripalani wrote: > On Mon, Apr 4, 2016 at 3:54

[jira] [Created] (FLINK-3699) Allow per-job Kerberos authentication

Stefano Baghino created FLINK-3699: -- Summary: Allow per-job Kerberos authentication Key: FLINK-3699 URL: https://issues.apache.org/jira/browse/FLINK-3699 Project: Flink Issue Type: Improvem