diff --git a/controllers/constants/constants.go b/controllers/constants/constants.go
index 706db213f..c8e3695c7 100644
--- a/controllers/constants/constants.go
+++ b/controllers/constants/constants.go
@@ -51,7 +51,7 @@ const (
 	EnvTestConsole = "TEST_CONSOLE"
 )
 
-var LokiIndexFields = []string{"SrcK8S_Namespace", "SrcK8S_OwnerName", "SrcK8S_Type", "DstK8S_Namespace", "DstK8S_OwnerName", "DstK8S_Type", "K8S_FlowLayer", "FlowDirection"}
+var LokiIndexFields = []string{"SrcK8S_Namespace", "SrcK8S_OwnerName", "SrcOwnerType", "SrcK8S_Type", "DstK8S_Namespace", "DstK8S_OwnerName", "DstOwnerType", "DstK8S_Type", "K8S_FlowLayer", "FlowDirection"}
 var LokiConnectionIndexFields = []string{"_RecordType"}
 var LokiZoneIndexFields = []string{"SrcK8S_Zone", "DstK8S_Zone"}
 var FlowCollectorName = types.NamespacedName{Name: "cluster"}
diff --git a/controllers/flp/flp_test.go b/controllers/flp/flp_test.go
index f2e6295af..e7b7fcd90 100644
--- a/controllers/flp/flp_test.go
+++ b/controllers/flp/flp_test.go
@@ -650,9 +650,11 @@ func TestConfigMapShouldDeserializeAsJSONWithLokiManual(t *testing.T) {
 	assert.EqualValues([]string{
 		"SrcK8S_Namespace",
 		"SrcK8S_OwnerName",
+		"SrcOwnerType",
 		"SrcK8S_Type",
 		"DstK8S_Namespace",
 		"DstK8S_OwnerName",
+		"DstOwnerType",
 		"DstK8S_Type",
 		"K8S_FlowLayer",
 		"FlowDirection",
@@ -706,9 +708,11 @@ func TestConfigMapShouldDeserializeAsJSONWithLokiStack(t *testing.T) {
 	assert.EqualValues([]string{
 		"SrcK8S_Namespace",
 		"SrcK8S_OwnerName",
+		"SrcOwnerType",
 		"SrcK8S_Type",
 		"DstK8S_Namespace",
 		"DstK8S_OwnerName",
+		"DstOwnerType",
 		"DstK8S_Type",
 		"K8S_FlowLayer",
 		"FlowDirection",