Skip to content

Commit d86c30f

Browse files
Copilotdevstress
andcommitted
Fix FlinkJobManagerUrl to use discovered dynamic port
FlinkJobManagerUrl was hardcoded to http://localhost:8081/ but Aspire uses dynamic ports. Changed to use the discovered flinkRestApi value which contains the correct dynamic port mapping. This fixes the Flink health check failures in Day01 exercises. Co-authored-by: devstress <30769729+devstress@users.noreply.github.com>
1 parent 4042593 commit d86c30f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

LearningCourse/LearningCourse.IntegrationTests/LearningCourseTestBase.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -392,7 +392,7 @@ private static async Task WaitForInfrastructureReadyAsync(DateTime appHostStartT
392392
GrafanaHostEndpoint = grafanaEndpoint;
393393
FlinkRestApiEndpoint = flinkRestApi;
394394
FlinkJobGatewayUrl = "http://localhost:8080/"; // Fixed port for JobGateway (not dynamic)
395-
FlinkJobManagerUrl = "http://localhost:8081/"; // Fixed port for JobManager (configured in Aspire)
395+
FlinkJobManagerUrl = flinkRestApi; // Use discovered dynamic port from 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)