Re: How to add flink dependency in pom

My problem is solved, thanks. Regards Liang Liang Chen-2 wrote > Hi > > Can i do like this : > To directly run the below example in my project through adding flink's pom > dependency? > Thanks. > > Regards > Liang > > --- &

Re: How to add flink dependency in pom

tils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/ > MultipleProgramsTestBase.java > [2] https://github.com/apache/flink/tree/master/flink-tests > > 2016-12-29 17:06 GMT+01:00 Liang Chen : > > > Hi > > > > I am from Apache CarbonData commun

Re: How to add flink dependency in pom

est- > utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/ > MultipleProgramsTestBase.java > [2] https://github.com/apache/flink/tree/master/flink-tests > > 2016-12-29 17:06 GMT+01:00 Liang Chen : > > > Hi > > > > I am from Apache CarbonData community. > > I pl

How to add flink dependency in pom

Hi I am from Apache CarbonData community. I plan to do some integration test, take CarbonData as Flink's source/sink. Please help and guide, how to add all flink dependency: org.apache.flink flink-clients_2.10 ${project.version} provided org.apache.flink flink-core ${project.version}

Does flink support groupByKey([numTasks])

Hi Now i am considering migrate Sparkstreaming case to Flink for comparing performance. Does flink support groupByKey([numTasks]) ,When called on a dataset of (K, V) pairs, returns a dataset of (K, Iterable) pairs. If it is not exist, how to use groupBy() to implement the same function? --

Re: [jira](FLINK-2493) Simplify names of example program JARs

Thanks for everyone's input. For keeping java and scala examples separately, will take proposal 1 to change POM. meanwhile,will make "flink-streaming-examples and flink-storm-compatibility-example" changes too according to mbalassi's suggestion. *One question: * As per pom.xml of scala/storm/strea

Re: [DISCUSSION] Release current master as 0.9.1 (mod few changes)

Agree. keep major version stability and compatibility, always being considered as first. -- View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSSION-Release-current-master-as-0-9-1-mod-few-changes-tp7679p7680.html Sent from the Apache Flink Maili

Re: [jira](FLINK-2493) Simplify names of example program JARs

Sorry,made you confusion. I meant, may only use scala to write machine learning examples in future. (java doesn't include these examples). --- Can you explain what you mean by "BTW, my personal opinion: current

Re: [jira](FLINK-2493) Simplify names of example program JARs

Ya,If takes proposal 2, the the name overlap is one issue from java and scala examples. Your suggestion sounds good,gives different package for java and scala examples. but drops the subpackages, i have some different points: there are many examples use the similar directory structure such as:stor

[jira](FLINK-2493) Simplify names of example program JARs

Summary:Simplify names of example program JARs Key:FLINK-2493, URL:https://issues.apache.org/jira/browse/FLINK-2493 Issue Type: Improvement Components:Examples Propose to simplify the name to "examples/ConnectedComponents.jar" rather than examples/flink-java-examples-0.10-SNAPSHOT-ConnectedCompone