how can handles Any , All query on flink

how can handles Any , All query on flink Example SELECT model, price FROM Laptop WHERE price > ALL (SELECT price FROM PC); Example on any SELECT DISTINCT maker FROM Product WHERE model > ANY (SELECT model FROM PC); -- View this message in context: http://apache-f

Re: Hostname resolution error impacting data local computing

Hi, I dug deeply into Java source code, and it comes down to a native call to getByHostAddr, for which I only found C implementations for Windows and Solaris. Frankly, I don't know what's going on on our Linux machines here, deep down there will be a call to getnameinfo I presume. I could not yet

Re: Channel to path could not be opened, temporary files missing?

Thanks a lot Stephan, as far as we observed the error, it always occurred in an iteration later than the first one (mostly iteration 2). I filed a bug report here: https://issues.apache.org/jira/browse/FLINK-2334 . And thanks for pointing out th

Re: Hostname resolution error impacting data local computing

Hey! Thanks for reporting this. We added the warning when we spoiled some of our own experiments with faulty DNS configurations. I am not sure what could be done in this case. Do you know the reason why the java dns reverse resolution works differently from nslookup in that case? BTW:There shoul

Hostname resolution error impacting data local computing

Hi everyone, I'm currently testing data local computing of Flink on XtreemFS (I'm one of the developers). We have implemented our adapter using the hadoop FileSystem interface and all works well. However upon closer inspection, I found that only remote splits are assigned, which is strange, as Xtr

Re: Channel to path could not be opened, temporary files missing?

Can you verify that this always happens in an iteration later than the first one? It may be that the cached build-side files are accidentally removed too early. Can you file a bug report for this? Please make sure you add the stack trace and the suspicion that cached build partitions are deleted t