Talha Naeem
05/31/2024, 4:17 AMkapa.ai
05/31/2024, 4:17 AMTEMPORAL_WORKER_PORTS parameter in Airbyte worker configurations defines the local ports that the Airbyte Worker pod uses to connect to various Job pods. Specifically, ports 9001 - 9040 are exposed by default in the Helm Chart for Kubernetes deployments ([source](https://docs.airbyte.com/operator-guides/configuring-airbyte#worker-1)). ### Role of TEMPORAL_WORKER_PORTS 1. Port Allocation: The TEMPORAL_WORKER_PORTS parameter specifies the range of ports that the Airbyte Worker can use to communicate with job pods. This is crucial for the worker to manage and execute tasks effectively. 2. Configuration Locations: This parameter can be defined in both the .env file and the deployment.yaml of the Airbyte worker. The ports specified in these configurations determine the pool of ports available for the worker to use ([source](https://discuss.airbyte.io/t/4074)). ### How Airbyte Uses These Ports - Job Execution: When a job is initiated, the Airbyte Worker uses one of the ports from the specified range to establish a connection with the job pod. This allows for the execution and management of the job. - Concurrency Management: The number of ports available in the TEMPORAL_WORKER_PORTS range can impact the number of concurrent jobs that can be run. If the number of available ports is less than the number of concurrent jobs, it can lead to job hang-ups or failures ([source](https://discuss.airbyte.io/t/1077)). ### Scaling with Temporal Ports - Concurrency Scaling: To scale the number of concurrent jobs, you need to ensure that the TEMPORAL_WORKER_PORTS range is sufficiently large to accommodate the maximum number of concurrent workers (MAX_*_WORKERS). If the port range is too small, it will limit the number of jobs that can run concurrently, thus affecting the scalability of the system ([source](https://discuss.airbyte.io/t/1077)). For more detailed information on how Airbyte scales workflow orchestration with Temporal, you can refer to the blog post on [How we scale workflow orchestration with Temporal](https://airbyte.com/blog/scale-workflow-orchestration-with-temporal). If you have further questions or need more detailed configuration guidance, you might find additional insights in the [Scaling data pipelines on Kubernetes](https://airbyte.com/blog/scaling-data-pipelines-kubernetes) blog post.Talha Naeem
05/31/2024, 4:25 AMTalha Naeem
05/31/2024, 4:26 AMkapa.ai
05/31/2024, 4:26 AMTalha Naeem
05/31/2024, 4:26 AMkapa.ai
05/31/2024, 4:27 AMfetchSize can impact performance, although in some tests, dynamic fetchSize did not show a noticeable impact (Source: [Forum Post: MySQL source connector performance](https://discuss.airbyte.io/t/1092)). In summary, while network performance metrics are important, they might not always be the primary factor affecting sync performance. It is crucial to also consider instance resource utilization and connector configurations. For more detailed guidance, you can refer to the Airbyte documentation and community forums: - [Airbyte Documentation](https://docs.airbyte.com/) - [Airbyte Community Forums](https://discuss.airbyte.io/) If you have specific performance issues or need further assistance, sharing detailed sync logs and metrics can help the community and support team provide more targeted advice.