Skip to content

Commit 17f27d3

Browse files
authored
Appreciate column prefix when given for ended_at (#2231)
Signed-off-by: Minkyu Park <minkyu.park.200@gmail.com> Signed-off-by: Minkyu Park <minkyu.park.200@gmail.com>
1 parent 003ab99 commit 17f27d3

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

api/src/main/java/marquez/db/mappers/RunMapper.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ public Run map(@NonNull ResultSet results, @NonNull StatementContext context)
6868
columnNames.contains(columnPrefix + Columns.STARTED_AT)
6969
? timestampOrNull(results, columnPrefix + Columns.STARTED_AT)
7070
: null,
71-
columnNames.contains(Columns.ENDED_AT)
71+
columnNames.contains(columnPrefix + Columns.ENDED_AT)
7272
? timestampOrNull(results, columnPrefix + Columns.ENDED_AT)
7373
: null,
7474
durationMs.orElse(null),

0 commit comments

Comments
 (0)