Fix Day01 test failures: Flink health check endpoint, script configuration, dynamic port discovery, JobGateway port standardization, test validation, and Kafka connectivity

FlinkDotNet/FlinkDotNet.JobGateway/Properties/launchSettings.json

@@ -6,7 +6,7 @@
       "environmentVariables": {
         "ASPNETCORE_ENVIRONMENT": "Development"
       },
-      "applicationUrl": "http://localhost:61388"
+      "applicationUrl": "http://localhost:8086"
     }
   }
 }

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",

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)
                     {

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)
                     {

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";

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)
     {

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";

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";

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";

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";

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";

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";

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)
         {

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";

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";

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";

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";

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";

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";

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";

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";

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";

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";

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";

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";

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";

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";

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";

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";

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";

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";

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()

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()

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";
     }
 }