Mailing-List: contact dev-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
MIME-Version: 1.0
In-Reply-To: <55683206.2070305@informatik.hu-berlin.de>
References: <55683206.2070305@informatik.hu-berlin.de>
From: =?UTF-8?Q?M=C3=A1rton_Balassi?= <balassi.marton@gmail.com>
Date: Fri, 29 May 2015 11:55:13 +0200
Message-ID: 
 <CAKADb_OcvOHfauZUyRNwagbYuhdEJFzNu+ytGrx7TNJvVJ=N1A@mail.gmail.com>
Subject: Re: Bug in flink-connector-kafka ?
To: dev@flink.apache.org
Content-Type: multipart/alternative; boundary=089e011777af2e06d10517357a67

--089e011777af2e06d10517357a67
Content-Type: text/plain; charset=UTF-8

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

--089e011777af2e06d10517357a67--