pache 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}
>
>> >
>
> test-jar
>
>> >
>
> test
>
>> >
>
>> >
>> > *any other dependency need to be added ?*
>> >
>> >
>> > Regards
>> > Liang
>> >
>>
>
>
>
> --
> Regards
> Liang
--
View this message in context:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/How-to-add-flink-dependency-in-pom-tp15125p15134.html
Sent from the Apache Flink Mailing List archive. mailing list archive at
Nabble.com.
hi,Liang
I think ,u can directly run the below example in ur project,if ur project had
all the dependencies which it needs.
I always directly debug the tests to follow the flink execution flow
hzyuemeng1
发件人:Liang Chen
发送时间:2016-12-30 15:28
主题:Re: How to add flink dependency in pom
收件人
Hi
Can i do like this :
To directly run the below example in my project through adding flink's pom
dependency?
Thanks.
Regards
Liang
---
object WordCount {
def main(args: Array[String]) {
val params: ParameterTool = ParameterTool.fromArgs(args)
// set up
Hi Fabian
Thanks for your help, these info make sense, will try it.
Regards
Liang
2016-12-30 5:10 GMT+08:00 Fabian Hueske :
> Hi,
>
> I assume you have implemented a Flink InputFormat that reads data from
> CarbonData and you would like to have an integration test for this
> InputFormat which r
Hi,
I assume you have implemented a Flink InputFormat that reads data from
CarbonData and you would like to have an integration test for this
InputFormat which runs on Apache Flink.
Flink includes test utils that start a Flink mini cluster in a single JVM
[1] which might be useful for your use cas
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}