(phoenix-adapters) branch main updated: Align DynamoDB Streams userIdentity.principalId with AWS spec

[vjasani]

This is an automated email from the ASF dual-hosted git repository.

virajjasani pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/phoenix-adapters.git


The following commit(s) were added to refs/heads/main by this push:
     new 8da7f63  Align DynamoDB Streams userIdentity.principalId with AWS spec
8da7f63 is described below

commit 8da7f639a7c845019a8002d235faa5b8afac73e8
Author: Viraj Jasani <vjas...@apache.org>
AuthorDate: Mon May 18 10:17:59 2026 -0700

    Align DynamoDB Streams userIdentity.principalId with AWS spec
---
 DDB_API_REFERENCE.md                                                  | 2 +-
 .../main/java/org/apache/phoenix/ddb/service/GetRecordsService.java   | 2 +-
 .../src/test/java/org/apache/phoenix/ddb/GetRecordsTTLExpiryIT.java   | 4 ++--
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/DDB_API_REFERENCE.md b/DDB_API_REFERENCE.md
index 375ef15..a77158d 100644
--- a/DDB_API_REFERENCE.md
+++ b/DDB_API_REFERENCE.md
@@ -1562,7 +1562,7 @@ Reads change records from a shard using a shard iterator.
       },
       "userIdentity": {
         "Type": "Service",
-        "PrincipalId": "phoenix/hbase"
+        "PrincipalId": "dynamodb.amazonaws.com"
       }
     }
   ],
diff --git 
a/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/GetRecordsService.java
 
b/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/GetRecordsService.java
index e5070a2..f41ebb1 100644
--- 
a/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/GetRecordsService.java
+++ 
b/phoenix-ddb-rest/src/main/java/org/apache/phoenix/ddb/service/GetRecordsService.java
@@ -46,7 +46,7 @@ public class GetRecordsService {
     private static final String NEW_IMAGE = "NEW_IMAGE";
     private static final String NEW_AND_OLD_IMAGES = "NEW_AND_OLD_IMAGES";
     private static final String SERVICE = "Service";
-    private static final String PRINCIPAL_ID = "phoenix/hbase";
+    private static final String PRINCIPAL_ID = "dynamodb.amazonaws.com";
 
     /**
      * Notes:
diff --git 
a/phoenix-ddb-rest/src/test/java/org/apache/phoenix/ddb/GetRecordsTTLExpiryIT.java
 
b/phoenix-ddb-rest/src/test/java/org/apache/phoenix/ddb/GetRecordsTTLExpiryIT.java
index be7b403..e0d9da2 100644
--- 
a/phoenix-ddb-rest/src/test/java/org/apache/phoenix/ddb/GetRecordsTTLExpiryIT.java
+++ 
b/phoenix-ddb-rest/src/test/java/org/apache/phoenix/ddb/GetRecordsTTLExpiryIT.java
@@ -300,7 +300,7 @@ public class GetRecordsTTLExpiryIT extends 
GetRecordsBaseTest  {
                     null, null);
             Assert.assertEquals(1, daughterRecordsAfterCompaction.size());
             
Assert.assertNotNull(daughterRecordsAfterCompaction.get(0).userIdentity());
-            Assert.assertEquals("phoenix/hbase", 
daughterRecordsAfterCompaction.get(0).userIdentity().principalId());
+            Assert.assertEquals("dynamodb.amazonaws.com", 
daughterRecordsAfterCompaction.get(0).userIdentity().principalId());
             Assert.assertEquals("Service", 
daughterRecordsAfterCompaction.get(0).userIdentity().type());
         }
 
@@ -401,7 +401,7 @@ public class GetRecordsTTLExpiryIT extends 
GetRecordsBaseTest  {
         records = 
TestUtils.getRecordsFromShardWithLimit(phoenixDBStreamsClientV2, 
phoenixStreamArn, parentShard, TRIM_HORIZON, null,null);
         Assert.assertEquals(1, records.size());
         Assert.assertNotNull(records.get(0).userIdentity());
-        Assert.assertEquals("phoenix/hbase", 
records.get(0).userIdentity().principalId());
+        Assert.assertEquals("dynamodb.amazonaws.com", 
records.get(0).userIdentity().principalId());
         Assert.assertEquals("Service", records.get(0).userIdentity().type());
         EnvironmentEdgeManager.reset();
     }