feat(ingestion/doris): apache doris connector

[acrylJonny]

No description provided.

[codecov]

❌ 3 Tests Failed:

Tests completed	Failed	Passed	Skipped
10585	3	10582	64

View the top 3 failed test(s) by shortest run time

tests.integration.doris.test_doris::test_doris_test_connection[config_dict0-True]

Stack Traces | 0.001s run time

docker_compose_runner = <function docker_compose_runner.<locals>.run at 0x7f4c52c1fec0>
pytestconfig = <_pytest.config.Config object at 0x7f4d31b67e90>
test_resources_dir = PosixPath('.../tests/integration/doris')

    @pytest.fixture(scope="module")
    def doris_runner(docker_compose_runner, pytestconfig, test_resources_dir):
        with docker_compose_runner(
            test_resources_dir / "docker-compose.yml", "doris"
        ) as docker_services:
            # Wait for Doris FE to be ready
            print("Waiting for Doris FE to start...")
            try:
>               wait_for_port(
                    docker_services,
                    "testdoris-fe",
                    DORIS_PORT,
                    timeout=400,  # Longer timeout for CI (includes image pull)
                    checker=lambda: is_doris_up("testdoris"),
                )

.../integration/doris/test_doris.py:44: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
.../datahub/testing/docker_utils.py:36: in wait_for_port
    docker_services.wait_until_responsive(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = Services(_docker_compose=DockerComposeExecutor(_compose_command='docker compose --parallel -1', _compose_files=[PosixP....../integration/doris/docker-compose.yml')], _compose_project_name='pytest4939-doris'), _services={})
check = <function doris_runner.<locals>.<lambda> at 0x7f4c52cdd300>
timeout = 400, pause = 0.5, clock = <built-in function perf_counter>

    def wait_until_responsive(
        self,
        check: Any,
        timeout: float,
        pause: float,
        clock: Any = timeit.default_timer,
    ) -> None:
        """Wait until a service is responsive."""
    
        ref = clock()
        now = ref
        while (now - ref) < timeout:
            if check():
                return
            time.sleep(pause)
            now = clock()
    
>       raise Exception("Timeout reached while waiting on service!")
E       Exception: Timeout reached while waiting on service!

venv/lib/python3.11.../site-packages/pytest_docker/plugin.py:120: Exception

tests.integration.doris.test_doris::test_doris_test_connection[config_dict1-False]

Stack Traces | 0.001s run time

docker_compose_runner = <function docker_compose_runner.<locals>.run at 0x7f4c52c1fec0>
pytestconfig = <_pytest.config.Config object at 0x7f4d31b67e90>
test_resources_dir = PosixPath('.../tests/integration/doris')

    @pytest.fixture(scope="module")
    def doris_runner(docker_compose_runner, pytestconfig, test_resources_dir):
        with docker_compose_runner(
            test_resources_dir / "docker-compose.yml", "doris"
        ) as docker_services:
            # Wait for Doris FE to be ready
            print("Waiting for Doris FE to start...")
            try:
>               wait_for_port(
                    docker_services,
                    "testdoris-fe",
                    DORIS_PORT,
                    timeout=400,  # Longer timeout for CI (includes image pull)
                    checker=lambda: is_doris_up("testdoris"),
                )

.../integration/doris/test_doris.py:44: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
.../datahub/testing/docker_utils.py:36: in wait_for_port
    docker_services.wait_until_responsive(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = Services(_docker_compose=DockerComposeExecutor(_compose_command='docker compose --parallel -1', _compose_files=[PosixP....../integration/doris/docker-compose.yml')], _compose_project_name='pytest4939-doris'), _services={})
check = <function doris_runner.<locals>.<lambda> at 0x7f4c52cdd300>
timeout = 400, pause = 0.5, clock = <built-in function perf_counter>

    def wait_until_responsive(
        self,
        check: Any,
        timeout: float,
        pause: float,
        clock: Any = timeit.default_timer,
    ) -> None:
        """Wait until a service is responsive."""
    
        ref = clock()
        now = ref
        while (now - ref) < timeout:
            if check():
                return
            time.sleep(pause)
            now = clock()
    
>       raise Exception("Timeout reached while waiting on service!")
E       Exception: Timeout reached while waiting on service!

venv/lib/python3.11.../site-packages/pytest_docker/plugin.py:120: Exception

tests.integration.doris.test_doris::test_doris_ingest[doris_to_file.yml-doris_mces_golden.json]

Stack Traces | 468s run time

docker_compose_runner = <function docker_compose_runner.<locals>.run at 0x7f4c52c1fec0>
pytestconfig = <_pytest.config.Config object at 0x7f4d31b67e90>
test_resources_dir = PosixPath('.../tests/integration/doris')

    @pytest.fixture(scope="module")
    def doris_runner(docker_compose_runner, pytestconfig, test_resources_dir):
        with docker_compose_runner(
            test_resources_dir / "docker-compose.yml", "doris"
        ) as docker_services:
            # Wait for Doris FE to be ready
            print("Waiting for Doris FE to start...")
            try:
>               wait_for_port(
                    docker_services,
                    "testdoris-fe",
                    DORIS_PORT,
                    timeout=400,  # Longer timeout for CI (includes image pull)
                    checker=lambda: is_doris_up("testdoris"),
                )

.../integration/doris/test_doris.py:44: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
.../datahub/testing/docker_utils.py:36: in wait_for_port
    docker_services.wait_until_responsive(
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = Services(_docker_compose=DockerComposeExecutor(_compose_command='docker compose --parallel -1', _compose_files=[PosixP....../integration/doris/docker-compose.yml')], _compose_project_name='pytest4939-doris'), _services={})
check = <function doris_runner.<locals>.<lambda> at 0x7f4c52cdd300>
timeout = 400, pause = 0.5, clock = <built-in function perf_counter>

    def wait_until_responsive(
        self,
        check: Any,
        timeout: float,
        pause: float,
        clock: Any = timeit.default_timer,
    ) -> None:
        """Wait until a service is responsive."""
    
        ref = clock()
        now = ref
        while (now - ref) < timeout:
            if check():
                return
            time.sleep(pause)
            now = clock()
    
>       raise Exception("Timeout reached while waiting on service!")
E       Exception: Timeout reached while waiting on service!

venv/lib/python3.11.../site-packages/pytest_docker/plugin.py:120: Exception

View the full list of 1 ❄️ flaky test(s)

Verify nested domains test functionalities cypress/e2e/domains/nested_domains.js::cypress/e2e/domains/nested_domains.js

Flake rate in main: 57.14% (Passed 60 times, Failed 80 times)

Stack Traces | 15.4s run time

2025-11-24T20:34:31.829Z
Timed out retrying after 10000ms: Expected to find content: 'Add Documentation' but never did.

To view more test analytics, go to the Test Analytics Dashboard
_{📋 Got 3 mins? Take this short survey to help us improve Test Analytics.}

[codecov]

Bundle Report

Changes will increase total bundle size by 3.58kB (0.01%) ⬆️. This is within the configured threshold ✅

Detailed changes

Bundle name	Size	Change
datahub-react-web-esm	28.71MB	3.58kB (0.01%) ⬆️

Affected Assets, Files, and Routes:

view changes for bundle: datahub-react-web-esm

Assets Changed:

Asset Name	Size Change	Total Size	Change (%)
assets/index-*.js	3.58kB	19.08MB	0.02%

Files in assets/index-*.js:

• ./src/app/ingest/source/builder/RecipeForm/doris.ts → Total Size: 1.22kB

• ./src/app/ingestV2/source/builder/sources.json → Total Size: 34.19kB

• ./src/app/ingestV2/source/builder/RecipeForm/constants.ts → Total Size: 10.12kB

• ./src/app/ingest/source/builder/sources.json → Total Size: 35.03kB

• ./src/app/ingest/source/builder/RecipeForm/constants.ts → Total Size: 11.46kB

• ./src/app/ingestV2/source/builder/RecipeForm/doris.ts → Total Size: 1.2kB

[alwaysmeticulous]

✅ Meticulous spotted 0 visual differences across 998 screens tested: view results.

Meticulous evaluated ~8 hours of user flows against your PR.

_{Expected differences? Click here. Last updated for commit 5531931. This comment will update as new commits are pushed.}