goutamadwant opened a new pull request, #11538:
URL: https://github.com/apache/seatunnel/pull/11538
### Purpose of this pull request
Closes #9764.
This draft adds the local-only first slice of Zeta debug mode as `--dry-run
sample`.
- runs the configured source and transform chain with a bounded row sample
- prints source and transform schemas and sample rows
- replaces configured sinks before sink factory creation and save-mode
handling
- disables checkpoints and uses source parallelism 1 for deterministic
per-source limits
- rejects cluster, async, restore, and savepoint execution for sample mode
- keeps sink DDL preview out of this slice until a no-write preview contract
is agreed
### Does this PR introduce _any_ user-facing change?
Yes.
Users can run a local sample preview with:
```shell
bin/seatunnel.sh --master local --config config/v2.batch.config.template
--dry-run sample --sample-limit 10
```
The command reads up to the configured number of rows from each source and
runs the transform chain without creating the configured sink or writing to the
target system. Source reads are real and may access external systems.
### How was this patch tested?
Added coverage for:
- CLI parsing, defaults, validation, and local execution
- replacement of configured sinks before sink runtime creation
- bounded source collection and normal completion
- bounded output reporting across a multi-transform chain
- a local FakeSource job confirming that the configured InMemory sink is not
used
Verified with:
```shell
./mvnw -pl seatunnel-core/seatunnel-starter -Dtest=ClientCommandArgsTest test
./mvnw -pl seatunnel-engine/seatunnel-engine-client
-Dtest=MultipleTableJobConfigParserTest test
./mvnw -pl seatunnel-engine/seatunnel-engine-server
-Dtest=SeaTunnelSourceCollectorDryRunSampleTest,TransformFlowLifeCycleDryRunSampleTest
test
./mvnw -pl
seatunnel-engine/seatunnel-engine-common,seatunnel-engine/seatunnel-engine-core,seatunnel-engine/seatunnel-engine-server,seatunnel-engine/seatunnel-engine-client,seatunnel-core/seatunnel-starter
-DskipTests package
```
### Check list
* [ ] If any new Jar binary package adding in your PR, please add License
Notice according
[New License
Guide](https://github.com/apache/seatunnel/blob/dev/docs/en/developer/new-license.md)
* [x] If necessary, please update the documentation to describe the new
feature. https://github.com/apache/seatunnel/tree/dev/docs
* [ ] If necessary, please update `incompatible-changes.md` to describe the
incompatibility caused by this PR.
* [ ] If you are contributing the connector code, please check that the
following files are updated:
1. Update
[plugin-mapping.properties](https://github.com/apache/seatunnel/blob/dev/plugin-mapping.properties)
and add new connector information in it
2. Update the pom file of
[seatunnel-dist](https://github.com/apache/seatunnel/blob/dev/seatunnel-dist/pom.xml)
3. Add ci label in
[label-scope-conf](https://github.com/apache/seatunnel/blob/dev/.github/workflows/labeler/label-scope-conf.yml)
4. Add e2e testcase in
[seatunnel-e2e](https://github.com/apache/seatunnel/tree/dev/seatunnel-e2e/)
5. Update connector
[plugin_config](https://github.com/apache/seatunnel/blob/dev/config/plugin_config)
No new binary dependency, incompatible change, or connector plugin change is
included.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
