Muhammet Orazov
Muhammet Orazov
Hello all, I have a data source partitioned as _/base/path/year/month/day/state/_. And I want to run Scalding job for one week of data only for a specific state. Reading a week...
## What is the purpose of the change Migrate `test_streaming_sql.sh` bash based end-to-end tests to docker based FlinkContainers framework. ## Brief change log - Add Java ITCase using FlinkContainers for...
## What is the purpose of the change Integrates Python Wheels build into the GitHub Actions (GHA) nightly workflow. ## Brief change log - Adds Python Wheels GHA workflow, `template.python-wheels-ci.yml`...
## What is the purpose of the change Migrates S3 related ITCases and E2E tests to use Minio test container. ## Brief change log - Removes `S3TestCredentials` class from S3...
## Situation There are many issues reported by the `lintr`. They should be addressed so that the codebase keeps consistent style. ## Acceptance Criteria - Lintr issues are addressed -...
https://issues.apache.org/jira/browse/FLINK-35129 - Adds option for checkpoint cycle parameter - Commits PG offsets on every multiple of checkpoint cycle - Updates docs with new parameter definition - [TODO] Adds unit &...
## What is the purpose of the change Migrate `test_tpch.sh` bash based end-to-end tests to docker based FlinkContainers framework. ## Brief change log * Add Java ITCase using FlinkContainers for...
https://issues.apache.org/jira/browse/FLINK-35490 Junit4 to Junit5 migration of `flink-cdc-connect/flink-cdc-source-connectors` module. Reference document: [Junit5 Migration Guide](https://docs.google.com/document/d/1514Wa_aNB9bJUen4xm5uiuXOooOJTtXqS_Jqk9KJitU). - All the unit and integration tests should work as expected
### What is the purpose of the change - [JUnit5 Migration] Module: [flink-connector-kafka](https://github.com/apache/flink-connector-kafka), [FLINK-25538](https://issues.apache.org/jira/browse/FLINK-25538). ### Brief change log - Updated Junit4 test packages to Junit5 test packages. - This pull...