Update Flink job configuration to use port 8099

[LeahMalul]

No description provided.

[greptile-apps]

Greptile Overview

Greptile Summary

This PR updates the Flink job configuration in the Docker Compose file to use port 8099 instead of 8091. The change affects the sensor anomaly processing service's JobManager container, updating both the port mapping and the Flink client connection command. This modification resolves a potential port conflict with the existing pushgateway service which uses port 9091. The change is consistent across both the external port mapping (8099:8099) and the Flink run command (-m localhost:8099), ensuring the job submission client can properly connect to the JobManager's RPC interface.

Important Files Changed

Filename	Score	Overview
docker-compose.yml	5/5	Updated Flink JobManager port from 8091 to 8099 and corresponding client connection string

Confidence score: 5/5

• This PR is safe to merge with minimal risk as it only changes port configuration
• Score reflects a simple port change with consistent updates across configuration and connection strings
• No files require special attention

Sequence Diagram

sequenceDiagram
    participant User
    participant "Docker Compose" as DC
    participant "Flink JobManager" as JM
    participant "Flink TaskManager" as TM
    participant "Sensor Anomaly Pro" as SAP
    participant Kafka
    participant "Sensor Data" as SD

    User->>DC: "docker-compose up"
    Note over DC: "Starting services with updated port configuration"
    
    DC->>SAP: "Start sensor anomaly analysis container"
    SAP->>SAP: "Generate sensor anomaly reports"
    
    DC->>JM: "Start Flink JobManager on port 8099"
    Note over JM: "Updated from default port to 8099"
    JM->>JM: "Initialize job manager with RPC address"
    
    DC->>TM: "Start Flink TaskManager"
    TM->>JM: "Connect to JobManager at port 8099"
    Note over TM: "Using updated port configuration"
    
    JM->>SAP: "Check for generated reports"
    SAP-->>JM: "Reports ready"
    
    JM->>JM: "Submit Flink job for sensor anomaly processing"
    JM->>TM: "Distribute processing tasks"
    
    SD->>Kafka: "Publish sensor data to 'sensors' topic"
    TM->>Kafka: "Consume sensor data"
    TM->>TM: "Process anomaly detection"
    TM->>Kafka: "Publish results to 'sensor_anomalies' and 'sensor_zone_stats' topics"
    
    Note over JM,TM: "Flink cluster now running on port 8099"

Loading

[greptile-apps]

_{1 file reviewed, no comments}

_{Edit Code Review Agent Settings | Greptile}