Merge pull request #351 from devstress/copilot/debug-flink-cluster-issue

devstress · web-flow · commit 1314faa7b1c8 · 2025-10-27T22:32:51.000Z
Fix Day01 test failures: Flink health check endpoint, script configuration, dynamic port discovery, JobGateway port standardization, test validation, and Kafka connectivity
diff --git a/FlinkDotNet/FlinkDotNet.JobGateway/Properties/launchSettings.json b/FlinkDotNet/FlinkDotNet.JobGateway/Properties/launchSettings.json
@@ -6,7 +6,7 @@
       "environmentVariables": {
         "ASPNETCORE_ENVIRONMENT": "Development"
       },
-      "applicationUrl": "http://localhost:61388"
+      "applicationUrl": "http://localhost:8086"
     }
   }
 }
diff --git a/FlinkDotNet/FlinkDotNet.JobGateway/appsettings.json b/FlinkDotNet/FlinkDotNet.JobGateway/appsettings.json
@@ -16,7 +16,7 @@
     }
   },
   "FlinkJobGateway": {
-    "BaseUrl": "http://localhost:8080/",
+    "BaseUrl": "http://localhost:8086/",
     "HttpTimeout": "00:05:00",
     "MaxRetries": 3,
     "RetryDelay": "00:00:01",
diff --git a/LearningCourse/Day01-Kafka-Flink-Data-Pipeline/Exercise-Solutions/Exercise1-StringCapitalize/Program.cs b/LearningCourse/Day01-Kafka-Flink-Data-Pipeline/Exercise-Solutions/Exercise1-StringCapitalize/Program.cs
@@ -39,7 +39,7 @@ static class Program
             Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
         private static string FlinkGatewayUrl =>
-            Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+            Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
         private static string FlinkJobManagerUrl =>
             Environment.GetEnvironmentVariable("FLINK_JOBMANAGER_URL") ?? "http://localhost:8081";
@@ -677,7 +677,7 @@ static async Task WaitForFlinkHealthyAsync()
                 try
                 {
                     using var httpClient = new System.Net.Http.HttpClient { Timeout = TimeSpan.FromSeconds(2) };
-                    var response = await httpClient.GetAsync($"{FlinkJobManagerUrl}/api/v1/health");
+                    var response = await httpClient.GetAsync($"{FlinkJobManagerUrl}/v1/overview");
                     
                     if (response.IsSuccessStatusCode)
                     {
diff --git a/LearningCourse/Day01-Kafka-Flink-Data-Pipeline/Exercise-Solutions/Exercise2-BackupAggregator/Program.cs b/LearningCourse/Day01-Kafka-Flink-Data-Pipeline/Exercise-Solutions/Exercise2-BackupAggregator/Program.cs
@@ -32,7 +32,7 @@ static class Program
         // Flink Gateway configuration
         // Lazy evaluation - reads env var when first accessed, not at class load time
         private static string FlinkGatewayUrl =>
-            Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+            Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
         private static string FlinkJobManagerUrl =>
             Environment.GetEnvironmentVariable("FLINK_JOBMANAGER_URL") ?? "http://localhost:8081";
@@ -680,7 +680,7 @@ static async Task WaitForFlinkHealthyAsync()
                 try
                 {
                     using var httpClient = new System.Net.Http.HttpClient { Timeout = TimeSpan.FromSeconds(3) };
-                    var response = await httpClient.GetAsync($"{FlinkJobManagerUrl}/api/v1/health");
+                    var response = await httpClient.GetAsync($"{FlinkJobManagerUrl}/v1/overview");
 
                     if (response.IsSuccessStatusCode)
                     {
diff --git a/LearningCourse/Day03-AI-Stream-Processing/Exercise-Solutions/Exercise31/Program.cs b/LearningCourse/Day03-AI-Stream-Processing/Exercise-Solutions/Exercise31/Program.cs
@@ -26,7 +26,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     private const string RegistrationTopic = "ai-model-registrations";
     private const string ValidationTopic = "ai-model-validations";
diff --git a/LearningCourse/Day03-AI-Stream-Processing/Exercise-Solutions/Exercise32/Program.cs b/LearningCourse/Day03-AI-Stream-Processing/Exercise-Solutions/Exercise32/Program.cs
@@ -29,7 +29,7 @@ public class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
     
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     public static async Task Main(string[] args)
     {
diff --git a/LearningCourse/Day03-AI-Stream-Processing/Exercise-Solutions/Exercise33/Program.cs b/LearningCourse/Day03-AI-Stream-Processing/Exercise-Solutions/Exercise33/Program.cs
@@ -33,7 +33,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     private const string InputTopic = "fraud-transactions-input";
     private const string PredictionsTopic = "fraud-model-predictions";
diff --git a/LearningCourse/Day03-AI-Stream-Processing/Exercise-Solutions/Exercise34/Program.cs b/LearningCourse/Day03-AI-Stream-Processing/Exercise-Solutions/Exercise34/Program.cs
@@ -32,7 +32,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     private const string InputTopic = "mlnet-transactions-input";
     private const string OutputTopic = "mlnet-fraud-predictions-output";
diff --git a/LearningCourse/Day04-Production-Backpressure/Exercise-Solutions/Exercise41/Program.cs b/LearningCourse/Day04-Production-Backpressure/Exercise-Solutions/Exercise41/Program.cs
@@ -32,7 +32,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     private const string InputTopic = "streaming-requests-input";
     private const string OutputTopic = "streaming-sessions-output";
diff --git a/LearningCourse/Day04-Production-Backpressure/Exercise-Solutions/Exercise42/Program.cs b/LearningCourse/Day04-Production-Backpressure/Exercise-Solutions/Exercise42/Program.cs
@@ -32,7 +32,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for multi-tier pipeline
     private const string ClientRequestsTopic = "client-requests-input";
diff --git a/LearningCourse/Day04-Production-Backpressure/Exercise-Solutions/Exercise43/Program.cs b/LearningCourse/Day04-Production-Backpressure/Exercise-Solutions/Exercise43/Program.cs
@@ -30,7 +30,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     private const string LoadInputTopic = "performance-load-input";
     private const string LatencyMeasurementsTopic = "performance-latency-measurements";
diff --git a/LearningCourse/Day04-Production-Backpressure/Exercise-Solutions/Exercise45/Program.cs b/LearningCourse/Day04-Production-Backpressure/Exercise-Solutions/Exercise45/Program.cs
@@ -30,7 +30,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     private const string InputTopic = "backpressure-input";
     private const string OutputTopic = "backpressure-output";
diff --git a/LearningCourse/Day05-Enterprise-Observability/Exercise-Solutions/Exercise51/Program.cs b/LearningCourse/Day05-Enterprise-Observability/Exercise-Solutions/Exercise51/Program.cs
@@ -35,7 +35,7 @@ static class Program
             Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
         private static string FlinkGatewayUrl =>
-            Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+            Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
         static async Task Main(string[] args)
         {
diff --git a/LearningCourse/Day07-Advanced-Windows-Joins/Exercise-Solutions/Exercise71/Program.cs b/LearningCourse/Day07-Advanced-Windows-Joins/Exercise-Solutions/Exercise71/Program.cs
@@ -29,7 +29,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for multi-stream join
     private const string OrdersTopic = "orders";
diff --git a/LearningCourse/Day07-Advanced-Windows-Joins/Exercise-Solutions/Exercise72/Program.cs b/LearningCourse/Day07-Advanced-Windows-Joins/Exercise-Solutions/Exercise72/Program.cs
@@ -30,7 +30,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics
     private const string TransactionsTopic = "fraud-transactions";
diff --git a/LearningCourse/Day07-Advanced-Windows-Joins/Exercise-Solutions/Exercise73/Program.cs b/LearningCourse/Day07-Advanced-Windows-Joins/Exercise-Solutions/Exercise73/Program.cs
@@ -30,7 +30,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for IoT sensors
     private const string TemperatureTopic = "sensor-temperature";
diff --git a/LearningCourse/Day07-Advanced-Windows-Joins/Exercise-Solutions/Exercise74/Program.cs b/LearningCourse/Day07-Advanced-Windows-Joins/Exercise-Solutions/Exercise74/Program.cs
@@ -30,7 +30,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for windowing optimization demonstration
     private const string EventStreamTopic = "high-volume-events";
diff --git a/LearningCourse/Day08-Stress-Testing/Exercise-Solutions/Exercise81/Program.cs b/LearningCourse/Day08-Stress-Testing/Exercise-Solutions/Exercise81/Program.cs
@@ -28,7 +28,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for stress testing
     private const string StressTestTopic = "stress-test-events";
diff --git a/LearningCourse/Day08-Stress-Testing/Exercise-Solutions/Exercise82/Program.cs b/LearningCourse/Day08-Stress-Testing/Exercise-Solutions/Exercise82/Program.cs
@@ -28,7 +28,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for backpressure testing
     private const string InputTopic = "backpressure-input";
diff --git a/LearningCourse/Day08-Stress-Testing/Exercise-Solutions/Exercise83/Program.cs b/LearningCourse/Day08-Stress-Testing/Exercise-Solutions/Exercise83/Program.cs
@@ -28,7 +28,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for benchmarking
     private const string BenchmarkInputTopic = "benchmark-input";
diff --git a/LearningCourse/Day08-Stress-Testing/Exercise-Solutions/Exercise84/Program.cs b/LearningCourse/Day08-Stress-Testing/Exercise-Solutions/Exercise84/Program.cs
@@ -28,7 +28,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for resource monitoring
     private const string ResourceInputTopic = "resource-monitor-input";
diff --git a/LearningCourse/Day09-Exactly-Once-Semantics/Exercise-Solutions/Exercise91/Program.cs b/LearningCourse/Day09-Exactly-Once-Semantics/Exercise-Solutions/Exercise91/Program.cs
@@ -29,7 +29,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for banking transactions
     private const string PaymentTransactionsTopic = "payment-transactions";
diff --git a/LearningCourse/Day09-Exactly-Once-Semantics/Exercise-Solutions/Exercise92/Program.cs b/LearningCourse/Day09-Exactly-Once-Semantics/Exercise-Solutions/Exercise92/Program.cs
@@ -29,7 +29,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for e-commerce order processing
     private const string OrdersTopic = "ecommerce-orders";
diff --git a/LearningCourse/Day09-Exactly-Once-Semantics/Exercise-Solutions/Exercise93/Program.cs b/LearningCourse/Day09-Exactly-Once-Semantics/Exercise-Solutions/Exercise93/Program.cs
@@ -29,7 +29,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for real-time analytics
     private const string EventStreamTopic = "analytics-events";
diff --git a/LearningCourse/Day09-Exactly-Once-Semantics/Exercise-Solutions/Exercise94/Program.cs b/LearningCourse/Day09-Exactly-Once-Semantics/Exercise-Solutions/Exercise94/Program.cs
@@ -29,7 +29,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for advanced patterns
     private const string HighVolumeTopic = "high-volume-events";
diff --git a/LearningCourse/Day10-Performance-Optimization-Scaling/Exercise-Solutions/Exercise101/Program.cs b/LearningCourse/Day10-Performance-Optimization-Scaling/Exercise-Solutions/Exercise101/Program.cs
@@ -26,7 +26,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
 
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics
     private const string InputTopic = "resource-optimization-input";
diff --git a/LearningCourse/Day10-Performance-Optimization-Scaling/Exercise-Solutions/Exercise102/Program.cs b/LearningCourse/Day10-Performance-Optimization-Scaling/Exercise-Solutions/Exercise102/Program.cs
@@ -27,7 +27,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
 
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics - 8 partitions for load distribution testing
     private const string InputTopic = "horizontal-scaling-input";
diff --git a/LearningCourse/Day13-Advanced-Streaming-Patterns/Exercise-Solutions/Exercise131/Program.cs b/LearningCourse/Day13-Advanced-Streaming-Patterns/Exercise-Solutions/Exercise131/Program.cs
@@ -29,7 +29,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for event sourcing
     private const string CommandsTopic = "order-commands";
diff --git a/LearningCourse/Day13-Advanced-Streaming-Patterns/Exercise-Solutions/Exercise132/Program.cs b/LearningCourse/Day13-Advanced-Streaming-Patterns/Exercise-Solutions/Exercise132/Program.cs
@@ -30,7 +30,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for CQRS pattern
     private const string CommandsTopic = "banking-commands";
diff --git a/LearningCourse/Day13-Advanced-Streaming-Patterns/Exercise-Solutions/Exercise133/Program.cs b/LearningCourse/Day13-Advanced-Streaming-Patterns/Exercise-Solutions/Exercise133/Program.cs
@@ -30,7 +30,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for saga pattern
     private const string SagaCommandsTopic = "saga-commands";
diff --git a/LearningCourse/Day13-Advanced-Streaming-Patterns/Exercise-Solutions/Exercise134/Program.cs b/LearningCourse/Day13-Advanced-Streaming-Patterns/Exercise-Solutions/Exercise134/Program.cs
@@ -30,7 +30,7 @@ class Program
         Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
         
     private static string FlinkGatewayUrl =>
-        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+        Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 
     // Kafka topics for CEP pattern
     private const string SecurityEventsTopic = "security-events";
diff --git a/LearningCourse/Day15-Capstone-Project/Exercise-Solutions/Exercise151/Program.cs b/LearningCourse/Day15-Capstone-Project/Exercise-Solutions/Exercise151/Program.cs
@@ -6,7 +6,7 @@
 
 // Environment variables for service discovery (set by test infrastructure)
 var kafkaBootstrapServers = Environment.GetEnvironmentVariable("KAFKA_BOOTSTRAP_SERVERS") ?? "localhost:9093";
-var flinkGatewayUrl = Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+var flinkGatewayUrl = Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 var redisConnectionString = Environment.GetEnvironmentVariable("REDIS_ENDPOINT") ?? "localhost:6379";
 
 Log.Logger = new LoggerConfiguration()
diff --git a/LearningCourse/Day15-Capstone-Project/Exercise-Solutions/Exercise154/Program.cs b/LearningCourse/Day15-Capstone-Project/Exercise-Solutions/Exercise154/Program.cs
@@ -7,7 +7,7 @@
 
 // Environment variables for service discovery
 var kafkaBootstrapServers = Environment.GetEnvironmentVariable("KAFKA_BOOTSTRAP_SERVERS") ?? "localhost:9093";
-var flinkGatewayUrl = Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
+var flinkGatewayUrl = Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
 var redisConnectionString = Environment.GetEnvironmentVariable("REDIS_ENDPOINT") ?? "localhost:6379";
 
 Log.Logger = new LoggerConfiguration()
diff --git a/LearningCourse/LearningCourse.Common/AspireServiceDiscovery.cs b/LearningCourse/LearningCourse.Common/AspireServiceDiscovery.cs
@@ -102,7 +102,7 @@ public static string GetFlinkGatewayUrl()
             return envValue;
         }
 
-        // Flink Gateway typically uses fixed port 8080
-        return "http://localhost:8080";
+        // Flink Gateway typically uses fixed port 8086
+        return "http://localhost:8086";
     }
 }
diff --git a/LearningCourse/LearningCourse.Common/DockerInfrastructure.cs b/LearningCourse/LearningCourse.Common/DockerInfrastructure.cs
diff --git a/LearningCourse/LearningCourse.IntegrationTests/Day01Tests.cs b/LearningCourse/LearningCourse.IntegrationTests/Day01Tests.cs
diff --git a/LearningCourse/LearningCourse.IntegrationTests/Day05Tests.cs b/LearningCourse/LearningCourse.IntegrationTests/Day05Tests.cs
diff --git a/LearningCourse/LearningCourse.IntegrationTests/LearningCourseTestBase.cs b/LearningCourse/LearningCourse.IntegrationTests/LearningCourseTestBase.cs
diff --git a/LocalTesting/LocalTesting.FlinkSqlAppHost/Ports.cs b/LocalTesting/LocalTesting.FlinkSqlAppHost/Ports.cs
diff --git a/LocalTesting/LocalTesting.FlinkSqlAppHost/Program.cs b/LocalTesting/LocalTesting.FlinkSqlAppHost/Program.cs
diff --git a/LocalTesting/LocalTesting.IntegrationTests/AspireValidationTest.cs b/LocalTesting/LocalTesting.IntegrationTests/AspireValidationTest.cs
diff --git a/LocalTesting/run-learningcourse-nobuild.sh b/LocalTesting/run-learningcourse-nobuild.sh
diff --git a/LocalTesting/run-learningcourse.cmd b/LocalTesting/run-learningcourse.cmd
diff --git a/LocalTesting/run-learningcourse.sh b/LocalTesting/run-learningcourse.sh

Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,7 @@`
`6`	`6`	`"environmentVariables": {`
`7`	`7`	`"ASPNETCORE_ENVIRONMENT": "Development"`
`8`	`8`	`},`
`9`		`- "applicationUrl": "http://localhost:61388"`
	`9`	`+ "applicationUrl": "http://localhost:8086"`
`10`	`10`	`}`
`11`	`11`	`}`
`12`	`12`	`}`
Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,7 @@`
`16`	`16`	`}`
`17`	`17`	`},`
`18`	`18`	`"FlinkJobGateway": {`
`19`		`- "BaseUrl": "http://localhost:8080/",`
	`19`	`+ "BaseUrl": "http://localhost:8086/",`
`20`	`20`	`"HttpTimeout": "00:05:00",`
`21`	`21`	`"MaxRetries": 3,`
`22`	`22`	`"RetryDelay": "00:00:01",`
Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,7 @@ static class Program`
`39`	`39`	`Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";`
`40`	`40`
`41`	`41`	`private static string FlinkGatewayUrl =>`
`42`		`- Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";`
	`42`	`+ Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";`
`43`	`43`
`44`	`44`	`private static string FlinkJobManagerUrl =>`
`45`	`45`	`Environment.GetEnvironmentVariable("FLINK_JOBMANAGER_URL") ?? "http://localhost:8081";`
`@@ -677,7 +677,7 @@ static async Task WaitForFlinkHealthyAsync()`
`677`	`677`	`try`
`678`	`678`	`{`
`679`	`679`	`using var httpClient = new System.Net.Http.HttpClient { Timeout = TimeSpan.FromSeconds(2) };`
`680`		`- var response = await httpClient.GetAsync($"{FlinkJobManagerUrl}/api/v1/health");`
	`680`	`+ var response = await httpClient.GetAsync($"{FlinkJobManagerUrl}/v1/overview");`
`681`	`681`
`682`	`682`	`if (response.IsSuccessStatusCode)`
`683`	`683`	`{`
Original file line number	Diff line number	Diff line change
`@@ -29,7 +29,7 @@ public class Program`
`29`	`29`	`Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";`
`30`	`30`
`31`	`31`	`private static string FlinkGatewayUrl =>`
`32`		`- Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";`
	`32`	`+ Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";`
`33`	`33`
`34`	`34`	`public static async Task Main(string[] args)`
`35`	`35`	`{`