flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi <balassi.mar...@gmail.com>
Subject Re: Bug in flink-connector-kafka ?
Date Fri, 29 May 2015 09:55:13 GMT
Thanks, good catch. Could you open the JIRA please and assign it to me?
Fixing it asap as we would like to cut a release candidate today. :)

On Fri, May 29, 2015 at 11:31 AM, Matthias J. Sax <
mjsax@informatik.hu-berlin.de> wrote:

> Hi,
>
> the classes KafkaITCase.java and KafkaLocalSystemTime.java have an wrong
> package statement.
>
> They are in package "org.apache.flink.streaming.kafka" and
> "org.apache.flink.streaming.kafka.util" respectily, but the package
> statements are
> > package org.apache.flink.streaming.connectors.kafka;
> and
> > package org.apache.flink.streaming.connectors.kafka.util;
>
> Not sure why the build succeeds. However, I remember a similar issues
> that was resolved a few weeks ago
> https://github.com/apache/flink/pull/437
>
> I guess, that breaking up the connector module into sub-modules
> introduces this bug.
>
> Shall I open an JIRA for it or just open a pull request with a fix for
> it? Or is anyone else taking care of it?
>
>
> -Matthias
>
>
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message