# DTStack/chunjun

A data integration framework

Repository: https://github.com/DTStack/chunjun
Canonical: https://ross.abutalabs.com/products/chunjun
Homepage: https://dtstack.github.io/chunjun/
Language: Java
License: Apache-2.0
License Family: permissive
Topics: flink, bigdata, data-integration, framework, java
Last push: 2025-12-02T10:52:15+00:00

## Health v2 (maintenance only)
Score: 54/100 (v2, computed 2026-09-02T17:46:02.011165+00:00)
- activity 55, release rhythm 27, longevity 100
- inputs: {"age_days": 3074, "days_push": 274, "days_rel": 274, "gap_med": null, "n_releases_24m": 1}
- flags: none
- formula: round(0.45*activity + 0.35*rhythm + 0.20*longevity); archived -> min(score, 10)

## Adoption (not part of the score)
Stars 4099, forks 1683 (observed 2026-08-28T04:08:35.511561+00:00)

## What it is
ChunJun (formerly FlinkX) is a distributed, batch-and-stream data integration framework built on Apache Flink. It synchronizes and computes data across 20+ heterogeneous data sources using configurable JSON templates or Flink SQL-compatible scripts, with a pluggable reader/writer/lookup architecture.

## Use cases
- sync data between mysql and hive
- real-time cdc collection from relational databases
- incremental data synchronization between heterogeneous sources
- run flink sql based etl jobs on yarn or kubernetes
- migrate data between oracle and sqlserver
- store and monitor dirty data during sync jobs
- resume failed data sync tasks from checkpoints

## When to choose
- you need batch and streaming data sync in one framework on Flink
- you must move data across many different databases and storage systems
- you want Flink SQL-compatible task configuration
- you need checkpoint-based resumable sync and dirty data handling

## When to avoid
- you need a lightweight single-node ETL tool without a Flink cluster
- your data sources are not among the supported plugins and you cannot write Java plugins
- you want a fully managed cloud ETL service rather than self-operated infrastructure

## Facets
- artifact type: framework
- maturity: active
- function: etl, streaming, data-science, plugin-system, monitoring
- domain: big-data, databases
- platform: jvm, cross-platform
- tags: flink, data-integration, data-synchronization, batch-streaming, heterogeneous-data-sources, cdc, apache-flink, data-engineering, automation, docker, kubernetes

## Member repositories
- DTStack/chunjun (main) score 54

## Provenance
- Observed fields: from GitHub, fetched 2026-08-28T04:08:35.511561+00:00.
- Health v2: computed from the inputs above; adoption is never an input.
- Inferred fields (summary, facets, guidance): AI-extracted, prompt v1, taxonomy v1, on 2026-08-29T18:23:17.242331+00:00, confidence not recorded.
  - readme: https://github.com/DTStack/chunjun (fetched 2026-08-28T04:08:35.511561+00:00, sha e08f2a0c1f59)
  - homepage: https://dtstack.github.io/chunjun/ (fetched 2026-08-29T09:14:50.158905+00:00, sha 731a0f966c71)
- Data as of 2026-08-30T08:39:29.467469+00:00.