apache / incubator-streampark

Make stream processing easier! Easy-to-use streaming application development framework and operation platform.
https://streampark.apache.org/
Apache License 2.0
3.91k stars 1.01k forks source link

[Bug] Failed to update savepoint status #4134

Open succw opened 1 week ago

succw commented 1 week ago

Search before asking

Java Version

1.8.

Scala Version

2.11.x

StreamPark Version

2.1.1

Flink Version

1.17.1

deploy mode

None

What happened

From version 2.1.1 to 2.1.5 update

Error Exception

### The error may exist in class path resource [mapper/core/SavepointMapper.xml]
### The error may involve defaultParameterMap
### The error occurred while setting parameters
### SQL: update t_flink_savepoint         set latest = 0         where app_id = ?
### Cause: org.postgresql.util.PSQLException: ERROR: column "latest" is of type boolean but expression is of type integer
  Hint: You will need to rewrite or cast the expression.
  Position: 47
]

---

UPDATE t_flink_savepoint
SET latest = CAST(0 AS BOOLEAN)  -- Explicitly cast 0 to BOOLEAN
WHERE app_id = ?;

Screenshots

No response

Are you willing to submit PR?

Code of Conduct