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
>
> ---
>
> object WordCount {
>
> def main(ar
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
