Re: Scala no-parenthesis methods on DataStream

Hi, I see what you mean and I would also feel that they could have parentheses? On the other hand, the methods are really side-effect free, they don’t modify the original stream in any way, they just just create a new “shuffle operator” that will affect operations performed on this shuffled stre

[jira] [Created] (FLINK-3247) Kafka Connector unusable with quickstarts - shading issue

Stephan Ewen created FLINK-3247: --- Summary: Kafka Connector unusable with quickstarts - shading issue Key: FLINK-3247 URL: https://issues.apache.org/jira/browse/FLINK-3247 Project: Flink Issue T

Scala no-parenthesis methods on DataStream

Hi all! I just noticed that all Scala DataStream methods like "rebalance", "broadcast", "shuffle", etc are defined without parenthesis. I am a bit puzzled about this. Even though these methods do not modify the DataStream object on which they are called, they define for example a distributed shuf

[jira] [Created] (FLINK-3246) Consolidate maven project names with *-parent suffix

Stephan Ewen created FLINK-3246: --- Summary: Consolidate maven project names with *-parent suffix Key: FLINK-3246 URL: https://issues.apache.org/jira/browse/FLINK-3246 Project: Flink Issue Type:

Re: web-dashboard Bower dependencies

Hi! I agree, fuzzy versions are not good here. Rebuilding from the code should lead to deterministic results, and not pull updates automagically without a developer explicitly updating a dependency version. If you want, replace the fuzzy versions by fix ones. Until then, I would simply reset chan

Re: Dependency on non-existent org.scalamacros:quasiquotes_2.11:

I concur. Already had "import org.apache.flink.streaming.api.scala._”, and just tried adding "import org.apache.flink.api.scala._”. Same issue. Prez Cannady p: 617 500 3378 e: revp...@opencorrelate.org GH: https://github.com/opencorrelate

[jira] [Created] (FLINK-3245) KMeans Data Generator writes not the same centroids as it was used for the dataset

Kay created FLINK-3245: -- Summary: KMeans Data Generator writes not the same centroids as it was used for the dataset Key: FLINK-3245 URL: https://issues.apache.org/jira/browse/FLINK-3245 Project: Flink

Re: Dependency on non-existent org.scalamacros:quasiquotes_2.11:

Hi, I think it’s more complicated than a missing import statement (the code has the correct import statement). I’ll look into it. Cheers, Aljoscha > On 17 Jan 2016, at 13:32, Stephan Ewen wrote: > > Hi! > > I think this no Scala version issue, you probably miss an import statement: > > "impor

Re: Dependency on non-existent org.scalamacros:quasiquotes_2.11:

Hi! I think this no Scala version issue, you probably miss an import statement: "import org.apache.flink.streaming.api.scala._" or "import org.apache.flink.api.scala._" See also here: http://flink.apache.org/faq.html#in-scala-api-i-get-an-error-about-implicit-values-and-evidence-parameters Gree