Worked on the apache/beam repository to enhance streaming system adaptability and reliability in distributed environments. Developed a dynamic runtime selection mechanism for the streaming engine harness, enabling seamless switching between FanOutStreamingEngineWorkerHarness and SingleSourceWorkerHarness based on job connectivity type. This approach, implemented in Java and leveraging Dataflow and gRPC, allowed the system to respond to changing network conditions through configuration updates without redeployment. Additionally, introduced connectivity type tracking for endpoint consumption logic, ensuring accurate differentiation between CLOUDPATH and DIRECTPATH endpoints. Updated the unit testing framework to validate these changes, improving data routing reliability and simplifying backend processing logic.