Ufuk Celebi created FLINK-7666:
--
Summary: ContinuousFileReaderOperator swallows chained watermarks
Key: FLINK-7666
URL: https://issues.apache.org/jira/browse/FLINK-7666
Project: Flink
Issue Type
Ufuk Celebi created FLINK-7665:
--
Summary: Use wait/notify in ContinuousFileReaderOperator
Key: FLINK-7665
URL: https://issues.apache.org/jira/browse/FLINK-7665
Project: Flink
Issue Type: Improve
Till Rohrmann created FLINK-7664:
Summary: Replace FlinkFutureException by CompletionException
Key: FLINK-7664
URL: https://issues.apache.org/jira/browse/FLINK-7664
Project: Flink
Issue Type:
Till Rohrmann created FLINK-7663:
Summary: Allow AbstractRestHandler to handle bad requests
Key: FLINK-7663
URL: https://issues.apache.org/jira/browse/FLINK-7663
Project: Flink
Issue Type: Bu
Ok, thank you all for the clarification.
@Stephan: I'm using Kafka 0.10, I guess the problem I had then was actually
unrelated to specific Kafka version
Federico D'Ambrosio
Il 21 set 2017 16:30, "Stephan Ewen" ha scritto:
> +1
>
> @ Frederico: I think Aljoscha is right - Flink only executes Ka
Stephan Ewen created FLINK-7662:
---
Summary: Remove unnecessary packaged licenses
Key: FLINK-7662
URL: https://issues.apache.org/jira/browse/FLINK-7662
Project: Flink
Issue Type: Improvement
+1
@ Frederico: I think Aljoscha is right - Flink only executes Kafka client
code, which is Scala independent from 0.9 on. Do you use Kafka 0.8 still?
On Wed, Sep 20, 2017 at 10:00 PM, Aljoscha Krettek
wrote:
> Hi Federico,
>
> As far as I know, the Kafka client code has been rewritten in Java
zhijiang created FLINK-7661:
---
Summary: Add credit field in PartitionRequest message
Key: FLINK-7661
URL: https://issues.apache.org/jira/browse/FLINK-7661
Project: Flink
Issue Type: Sub-task
