Skip to content

Commit 6196bb3

Browse files
committed
ice: Fix watch not decoding object keys from SQS messages
1 parent a537c44 commit 6196bb3

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

ice/src/main/java/com/altinity/ice/cli/internal/cmd/InsertWatch.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,8 @@
1414
import com.fasterxml.jackson.databind.JsonNode;
1515
import com.fasterxml.jackson.databind.ObjectMapper;
1616
import java.io.IOException;
17+
import java.net.URLDecoder;
18+
import java.nio.charset.StandardCharsets;
1719
import java.time.Duration;
1820
import java.util.Arrays;
1921
import java.util.Collection;
@@ -197,7 +199,8 @@ private static Collection<String> filter(List<Message> messages, Collection<Matc
197199
for (JsonNode record : root.path("Records")) {
198200
String eventName = record.path("eventName").asText();
199201
String bucketName = record.at("/s3/bucket/name").asText();
200-
String objectKey = record.at("/s3/object/key").asText();
202+
String objectKey =
203+
URLDecoder.decode(record.at("/s3/object/key").asText(), StandardCharsets.UTF_8);
201204
var target = String.format("s3://%s/%s", bucketName, objectKey);
202205
// s3:ObjectCreated:{Put,Post,Copy,CompleteMultipartUpload}
203206
if (eventName.startsWith("ObjectCreated:")) {

0 commit comments

Comments
 (0)