Skip to content

Commit 8fdd358

Browse files
Copilotdevstress
andcommitted
[WI18] Fix FlinkJobManagerUrl to use fixed port 8081 instead of dynamic Docker port
Root cause: FlinkJobManagerUrl was being set from Docker discovery (flinkRestApi) - Docker discovery returns dynamic ports (e.g., 127.0.0.1:32769) - Aspire now configured to use fixed port 8081 for JobManager - Should use fixed port directly instead of discovering from Docker Changes: - Changed FlinkJobManagerUrl from flinkRestApi to "http://localhost:8081/" - Matches Aspire configuration with fixed port 8081 - Ensures FLINK_JOBMANAGER_URL environment variable passed to exercises uses consistent endpoint This fixes Day01 health check failures by using the correct fixed JobManager port. Co-authored-by: devstress <30769729+devstress@users.noreply.github.com>
1 parent 25c7781 commit 8fdd358

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

LearningCourse/LearningCourse.IntegrationTests/LearningCourseTestBase.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -391,8 +391,8 @@ private static async Task WaitForInfrastructureReadyAsync(DateTime appHostStartT
391391
PrometheusHostEndpoint = prometheusEndpoint;
392392
GrafanaHostEndpoint = grafanaEndpoint;
393393
FlinkRestApiEndpoint = flinkRestApi;
394-
FlinkJobGatewayUrl = "http://localhost:8080/"; // Fixed port for JobGateway (not dynamic like JobManager)
395-
FlinkJobManagerUrl = flinkRestApi; // Dynamic Docker port for Flink JobManager health checks
394+
FlinkJobGatewayUrl = "http://localhost:8080/"; // Fixed port for JobGateway (not dynamic)
395+
FlinkJobManagerUrl = "http://localhost:8081/"; // Fixed port for JobManager (configured in Aspire)
396396

397397
var savedTime = (maxWait - stopwatch.Elapsed).TotalSeconds;
398398
TestContext.WriteLine($"✅ All required infrastructure ready after {stopwatch.Elapsed.TotalSeconds:F1}s (saved {savedTime:F1}s with optimized polling)");

0 commit comments

Comments
 (0)