Hello,
I am currently working on a compilation unit translating AsterixDB's AQL
into runnable Scala code for Flink's Scala API. During code generation I
discovered some things that are quite hard to work around. I am still
working with Flink version 0.8, so some of the problems I have might
alread
Okay. Great!
Please re-open the jira in case the issue hasn't been resolved.
Cheers!
Sachin
-- Sachin Goel
Computer Science, IIT Delhi
m. +91-9871457685
On Tue, Oct 13, 2015 at 4:00 PM, Flavio Pompermaier
wrote:
> I ensured that I was using the latest version and I showed to program to
> Fabia
The FlinkKafkaConsumer takes the two arguments --bootstrap.servers (kafka
servers) and --zookeeper.connect (zookeeper servers). Then it seems to
resolve Kafka brokers from zookeeper, and uses those host names to consume
kafka. But it also connects to the given bootstrap servers to fetch some
metada
I ensured that I was using the latest version and I showed to program to
Fabian right now.
The stack trace is:
Caused by: java.lang.RuntimeException: Bug in Hybrid Hash Join: Request to
spill a partition with less than two buffers.
at
org.apache.flink.runtime.operators.hash.HashPartition.spillPart
