Skip to content

Commit 363cec4

Browse files
Copilotdevstress
andcommitted
Change JobGateway port from 8080 to 8086 for standardization
Updated JobGateway port from 8080 to 8086 across all configuration files, test files, and exercise solutions to standardize the port for the JobGateway service. Changes: - JobGateway launchSettings.json: applicationUrl changed to 8086 - JobGateway appsettings.json: BaseUrl changed to 8086 - AppHost configuration: WithHttpEndpoint port changed to 8086 - All test files and exercise solutions updated to use 8086 - Comments and documentation updated to reflect new port Co-authored-by: devstress <[email protected]>
1 parent 0a8a666 commit 363cec4

File tree

39 files changed

+57
-57
lines changed

39 files changed

+57
-57
lines changed

FlinkDotNet/FlinkDotNet.JobGateway/Properties/launchSettings.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
"environmentVariables": {
77
"ASPNETCORE_ENVIRONMENT": "Development"
88
},
9-
"applicationUrl": "http://localhost:8080"
9+
"applicationUrl": "http://localhost:8086"
1010
}
1111
}
1212
}

FlinkDotNet/FlinkDotNet.JobGateway/appsettings.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
}
1717
},
1818
"FlinkJobGateway": {
19-
"BaseUrl": "http://localhost:8080/",
19+
"BaseUrl": "http://localhost:8086/",
2020
"HttpTimeout": "00:05:00",
2121
"MaxRetries": 3,
2222
"RetryDelay": "00:00:01",

LearningCourse/Day01-Kafka-Flink-Data-Pipeline/Exercise-Solutions/Exercise1-StringCapitalize/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ static class Program
3939
Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
4040

4141
private static string FlinkGatewayUrl =>
42-
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
42+
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
4343

4444
private static string FlinkJobManagerUrl =>
4545
Environment.GetEnvironmentVariable("FLINK_JOBMANAGER_URL") ?? "http://localhost:8081";

LearningCourse/Day01-Kafka-Flink-Data-Pipeline/Exercise-Solutions/Exercise2-BackupAggregator/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ static class Program
3232
// Flink Gateway configuration
3333
// Lazy evaluation - reads env var when first accessed, not at class load time
3434
private static string FlinkGatewayUrl =>
35-
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
35+
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
3636

3737
private static string FlinkJobManagerUrl =>
3838
Environment.GetEnvironmentVariable("FLINK_JOBMANAGER_URL") ?? "http://localhost:8081";

LearningCourse/Day03-AI-Stream-Processing/Exercise-Solutions/Exercise31/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ class Program
2626
Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
2727

2828
private static string FlinkGatewayUrl =>
29-
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
29+
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
3030

3131
private const string RegistrationTopic = "ai-model-registrations";
3232
private const string ValidationTopic = "ai-model-validations";

LearningCourse/Day03-AI-Stream-Processing/Exercise-Solutions/Exercise32/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ public class Program
2929
Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
3030

3131
private static string FlinkGatewayUrl =>
32-
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
32+
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
3333

3434
public static async Task Main(string[] args)
3535
{

LearningCourse/Day03-AI-Stream-Processing/Exercise-Solutions/Exercise33/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ class Program
3333
Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
3434

3535
private static string FlinkGatewayUrl =>
36-
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
36+
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
3737

3838
private const string InputTopic = "fraud-transactions-input";
3939
private const string PredictionsTopic = "fraud-model-predictions";

LearningCourse/Day03-AI-Stream-Processing/Exercise-Solutions/Exercise34/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ class Program
3232
Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
3333

3434
private static string FlinkGatewayUrl =>
35-
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
35+
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
3636

3737
private const string InputTopic = "mlnet-transactions-input";
3838
private const string OutputTopic = "mlnet-fraud-predictions-output";

LearningCourse/Day04-Production-Backpressure/Exercise-Solutions/Exercise41/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ class Program
3232
Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
3333

3434
private static string FlinkGatewayUrl =>
35-
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
35+
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
3636

3737
private const string InputTopic = "streaming-requests-input";
3838
private const string OutputTopic = "streaming-sessions-output";

LearningCourse/Day04-Production-Backpressure/Exercise-Solutions/Exercise42/Program.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ class Program
3232
Environment.GetEnvironmentVariable("KAFKA_FLINK_BOOTSTRAP_SERVERS") ?? "kafka:9092";
3333

3434
private static string FlinkGatewayUrl =>
35-
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8080";
35+
Environment.GetEnvironmentVariable("FLINK_JOB_GATEWAY_URL") ?? "http://localhost:8086";
3636

3737
// Kafka topics for multi-tier pipeline
3838
private const string ClientRequestsTopic = "client-requests-input";

0 commit comments

Comments
 (0)