Skip to content

Commit 2bf107f

Browse files
Copilotdevstress
andcommitted
[WI16] Fix Flink JobManager discovery - Use broader container name filter
Root cause: Docker container name filter was too strict - Previous filter: "name=flink-jobmanager" only matched exact substring - Aspire container names may have different patterns/prefixes - Filter failed to find containers, returning no endpoint Changes: - Updated GetFlinkRestApiEndpointAsync() to use broader filter: "name=flink" - Matches any container with "flink" in name, then validates port 8081 mapping - Added diagnostic logging showing all Flink containers found - More resilient discovery working with Aspire's container naming This fixes Day01 health check failures by correctly discovering Flink JobManager endpoint. Co-authored-by: devstress <30769729+devstress@users.noreply.github.com>
1 parent 830ab97 commit 2bf107f

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

LearningCourse/LearningCourse.Common/DockerInfrastructure.cs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -363,8 +363,10 @@ public static async Task<string> GetFlinkRestApiEndpointAsync()
363363
{
364364
try
365365
{
366-
var flinkContainers = await RunDockerCommandAsync("ps --filter name=flink-jobmanager --format {{.Ports}}");
367-
Console.WriteLine($"🔍 Flink JobManager port mappings: {flinkContainers.Trim()}");
366+
// Use broader filter to match any Flink container (Aspire may use different naming patterns)
367+
// Then validate by checking for port 8081 mapping (Flink JobManager REST API)
368+
var flinkContainers = await RunDockerCommandAsync("ps --filter name=flink --format {{.Ports}}");
369+
Console.WriteLine($"🔍 All Flink container port mappings: {flinkContainers.Trim()}");
368370

369371
// Log docker ps after discovering Flink ports
370372
await LogDockerPsAsync("After Flink REST API Discovery");

0 commit comments

Comments
 (0)