flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: How to add flink dependency in pom
Date Thu, 29 Dec 2016 21:10:44 GMT
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 case. This and more testing utils
are included in the following dependency:

<dependency>
   <groupId>org.apache.flink</groupId>
   <artifactId>flink-test-utils_2.10</artifactId>
   <version>${project.version}</version>
   <scope>test</scope>
</dependency>

You can also have a look at Flink's own integration tests in the flink-test
[2] Maven module.

Hope this helps,
Fabian

[1]
https://github.com/apache/flink/blob/master/flink-test-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 <chenliang6136@gmail.com>:

> 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:
>
> <dependency>
>  <groupId>org.apache.flink</groupId>
>  <artifactId>flink-clients_2.10</artifactId>
>  <version>${project.version}</version>
>  <scope>provided</scope>
> </dependency>
>
> <dependency>
>  <groupId>org.apache.flink</groupId>
>  <artifactId>flink-core</artifactId>
>  <version>${project.version}</version>
>  <type>test-jar</type>
>  <scope>test</scope>
> </dependency>
>
> *any other dependency need to be added ?*
>
>
> Regards
> Liang
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message