Re: Re: How to add flink dependency in pom

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 收件人："

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

Re: How to add flink dependency in pom

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

[jira] [Created] (FLINK-5400) Add accessor to folding states in RuntimeContext

Xiaogang Shi created FLINK-5400: --- Summary: Add accessor to folding states in RuntimeContext Key: FLINK-5400 URL: https://issues.apache.org/jira/browse/FLINK-5400 Project: Flink Issue Type: Bug

Re: How to add flink dependency in pom

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

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}