Skip to content

Commit 6de0c35

Browse files
Copilotdevstress
andcommitted
WI1: Fix Flink health check endpoint in Day01 exercises
- Changed endpoint from /api/v1/health to /v1/overview in Exercise1 and Exercise2 - Verified builds succeed with no warnings - Tested endpoint returns valid cluster status Co-authored-by: devstress <[email protected]>
1 parent 6e463f6 commit 6de0c35

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

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
@@ -677,7 +677,7 @@ static async Task WaitForFlinkHealthyAsync()
677677
try
678678
{
679679
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");
681681

682682
if (response.IsSuccessStatusCode)
683683
{

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
@@ -680,7 +680,7 @@ static async Task WaitForFlinkHealthyAsync()
680680
try
681681
{
682682
using var httpClient = new System.Net.Http.HttpClient { Timeout = TimeSpan.FromSeconds(3) };
683-
var response = await httpClient.GetAsync($"{FlinkJobManagerUrl}/api/v1/health");
683+
var response = await httpClient.GetAsync($"{FlinkJobManagerUrl}/v1/overview");
684684

685685
if (response.IsSuccessStatusCode)
686686
{

0 commit comments

Comments
 (0)