# Howto test a batch source with the new Source framework

DevFeed: [Howto test a batch source with the new Source framework](<https://devfeed.tech/articles/howto-test-a-batch-source-with-the-new-source-framework-48473.md>)

Original publisher: [Read original article](<https://flink.apache.org/2023/05/12/howto-test-a-batch-source-with-the-new-source-framework/>)

Published: 2023-05-12T08:00:00Z

Content type: tutorial

Language: en

Sources: [Apache Flink® -- Stateful Computations over Data Streams on Apache Flink](<https://devfeed.tech/sources/apache-flink-stateful-computations-over-data-streams-on-apache-flink.md>)

Topics: [flink](<https://devfeed.tech/topics/flink.md>), [Testing](<https://devfeed.tech/topics/testing.md>), [Integration testing](<https://devfeed.tech/topics/integration-testing.md>), [Unit testing](<https://devfeed.tech/topics/unit-testing.md>), [Apache Cassandra](<https://devfeed.tech/topics/cassandra.md>)

Tags: [article](<https://devfeed.tech/tags/article.md>), [cassandra](<https://devfeed.tech/tags/cassandra.md>), [flink](<https://devfeed.tech/tags/flink.md>), [howto](<https://devfeed.tech/tags/howto.md>), [integration](<https://devfeed.tech/tags/integration.md>), [integration-testing](<https://devfeed.tech/tags/integration-testing.md>), [streaming](<https://devfeed.tech/tags/streaming.md>), [testing](<https://devfeed.tech/tags/testing.md>), [unit-testing](<https://devfeed.tech/tags/unit-testing.md>)

## AI overview

A tutorial on testing a batch source built with Apache Flink's new Source framework. It covers unit testing serializers and low-level processing, then integration testing with Flink's JUnit 5 source test framework and a backend test environment.

## Source excerpt

Introduction # The Flink community has designed a new Source framework based on FLIP-27 lately. This article is the continuation of the howto create a batch source with the new Source framework article . Now it is time to test the created source ! As the previous article, this one was built while implementing the Flink batch source for Cassandra. Unit testing the source # Testing the serializers # Example Cassandra SplitSerializer and SplitEnumeratorStateSerializer