diff --git a/__tests__/workers/cdc/primary.ts b/__tests__/workers/cdc/primary.ts
index c4af488c2f..062dab18a2 100644
--- a/__tests__/workers/cdc/primary.ts
+++ b/__tests__/workers/cdc/primary.ts
@@ -5126,6 +5126,213 @@ describe('user company approved', () => {
       expect(experiences.every((exp) => exp.verified)).toBe(true);
     });
   });
+
+  describe('links experiences by customCompanyName', () => {
+    beforeEach(async () => {
+      await saveFixtures(con, User, usersFixture);
+      await con.getRepository(Company).save({
+        id: 'comp1',
+        name: 'Test Company',
+        altName: 'Test Alt Name',
+        image: 'https://example.com/image.png',
+        domains: ['testcompany.com'],
+        createdAt: new Date(),
+        updatedAt: new Date(),
+      });
+    });
+
+    it('should link experience with matching customCompanyName (exact match)', async () => {
+      const experience = await con.getRepository(UserExperienceWork).save({
+        userId: '1',
+        companyId: null,
+        customCompanyName: 'Test Company',
+        title: 'Software Engineer',
+        startedAt: new Date('2020-01-01'),
+        verified: false,
+        type: UserExperienceType.Work,
+      });
+
+      const after: ChangeObject<ObjectType> = { ...base, companyId: 'comp1' };
+      await expectSuccessfulBackground(
+        worker,
+        mockChangeMessage<ObjectType>({
+          after,
+          before: null,
+          op: 'c',
+          table: 'user_company',
+        }),
+      );
+
+      const updatedExperience = await con
+        .getRepository(UserExperienceWork)
+        .findOneBy({ id: experience.id });
+      expect(updatedExperience?.companyId).toBe('comp1');
+    });
+
+    it('should link experience with matching customCompanyName (case insensitive)', async () => {
+      const experience = await con.getRepository(UserExperienceWork).save({
+        userId: '1',
+        companyId: null,
+        customCompanyName: 'TEST COMPANY',
+        title: 'Software Engineer',
+        startedAt: new Date('2020-01-01'),
+        verified: false,
+        type: UserExperienceType.Work,
+      });
+
+      const after: ChangeObject<ObjectType> = { ...base, companyId: 'comp1' };
+      await expectSuccessfulBackground(
+        worker,
+        mockChangeMessage<ObjectType>({
+          after,
+          before: null,
+          op: 'c',
+          table: 'user_company',
+        }),
+      );
+
+      const updatedExperience = await con
+        .getRepository(UserExperienceWork)
+        .findOneBy({ id: experience.id });
+      expect(updatedExperience?.companyId).toBe('comp1');
+    });
+
+    it('should link experience with matching altName (case insensitive)', async () => {
+      const experience = await con.getRepository(UserExperienceWork).save({
+        userId: '1',
+        companyId: null,
+        customCompanyName: 'test alt name',
+        title: 'Software Engineer',
+        startedAt: new Date('2020-01-01'),
+        verified: false,
+        type: UserExperienceType.Work,
+      });
+
+      const after: ChangeObject<ObjectType> = { ...base, companyId: 'comp1' };
+      await expectSuccessfulBackground(
+        worker,
+        mockChangeMessage<ObjectType>({
+          after,
+          before: null,
+          op: 'c',
+          table: 'user_company',
+        }),
+      );
+
+      const updatedExperience = await con
+        .getRepository(UserExperienceWork)
+        .findOneBy({ id: experience.id });
+      expect(updatedExperience?.companyId).toBe('comp1');
+    });
+
+    it('should not link experience with non-matching customCompanyName', async () => {
+      const experience = await con.getRepository(UserExperienceWork).save({
+        userId: '1',
+        companyId: null,
+        customCompanyName: 'Some Other Company',
+        title: 'Software Engineer',
+        startedAt: new Date('2020-01-01'),
+        verified: false,
+        type: UserExperienceType.Work,
+      });
+
+      const after: ChangeObject<ObjectType> = { ...base, companyId: 'comp1' };
+      await expectSuccessfulBackground(
+        worker,
+        mockChangeMessage<ObjectType>({
+          after,
+          before: null,
+          op: 'c',
+          table: 'user_company',
+        }),
+      );
+
+      const updatedExperience = await con
+        .getRepository(UserExperienceWork)
+        .findOneBy({ id: experience.id });
+      expect(updatedExperience?.companyId).toBeNull();
+    });
+
+    it('should not overwrite experience that already has a companyId', async () => {
+      await con.getRepository(Company).save({
+        id: 'comp2',
+        name: 'Other Company',
+        image: 'https://example.com/image2.png',
+        domains: ['othercompany.com'],
+        createdAt: new Date(),
+        updatedAt: new Date(),
+      });
+
+      const experience = await con.getRepository(UserExperienceWork).save({
+        userId: '1',
+        companyId: 'comp2',
+        customCompanyName: 'Test Company',
+        title: 'Software Engineer',
+        startedAt: new Date('2020-01-01'),
+        verified: false,
+        type: UserExperienceType.Work,
+      });
+
+      const after: ChangeObject<ObjectType> = { ...base, companyId: 'comp1' };
+      await expectSuccessfulBackground(
+        worker,
+        mockChangeMessage<ObjectType>({
+          after,
+          before: null,
+          op: 'c',
+          table: 'user_company',
+        }),
+      );
+
+      const updatedExperience = await con
+        .getRepository(UserExperienceWork)
+        .findOneBy({ id: experience.id });
+      expect(updatedExperience?.companyId).toBe('comp2');
+    });
+
+    it('should only link experiences for the same user', async () => {
+      const experience1 = await con.getRepository(UserExperienceWork).save({
+        userId: '1',
+        companyId: null,
+        customCompanyName: 'Test Company',
+        title: 'Software Engineer',
+        startedAt: new Date('2020-01-01'),
+        verified: false,
+        type: UserExperienceType.Work,
+      });
+
+      const experience2 = await con.getRepository(UserExperienceWork).save({
+        userId: '2',
+        companyId: null,
+        customCompanyName: 'Test Company',
+        title: 'Software Engineer',
+        startedAt: new Date('2020-01-01'),
+        verified: false,
+        type: UserExperienceType.Work,
+      });
+
+      const after: ChangeObject<ObjectType> = { ...base, companyId: 'comp1' };
+      await expectSuccessfulBackground(
+        worker,
+        mockChangeMessage<ObjectType>({
+          after,
+          before: null,
+          op: 'c',
+          table: 'user_company',
+        }),
+      );
+
+      const updatedExperience1 = await con
+        .getRepository(UserExperienceWork)
+        .findOneBy({ id: experience1.id });
+      expect(updatedExperience1?.companyId).toBe('comp1');
+
+      const updatedExperience2 = await con
+        .getRepository(UserExperienceWork)
+        .findOneBy({ id: experience2.id });
+      expect(updatedExperience2?.companyId).toBeNull();
+    });
+  });
 });
 
 describe('bookmark change', () => {
diff --git a/src/workers/cdc/primary.ts b/src/workers/cdc/primary.ts
index 8745f6705a..1cc4bd731f 100644
--- a/src/workers/cdc/primary.ts
+++ b/src/workers/cdc/primary.ts
@@ -165,6 +165,7 @@ import { UserExperience } from '../../entity/user/experiences/UserExperience';
 import { UserExperienceType } from '../../entity/user/experiences/types';
 import { cio, identifyUserOpportunities } from '../../cio';
 import { enrichCompanyForExperience } from '../../common/companyEnrichment';
+import { Company } from '../../entity/Company';
 
 const isFreeformPostLongEnough = (
   freeform: ChangeMessage<FreeformPost>,
@@ -1206,6 +1207,29 @@ const onUserCompanyCompanyChange = async (
     await con
       .getRepository(UserExperienceWork)
       .update({ userId, companyId: companyId! }, { verified: true });
+
+    // Link experiences that have matching customCompanyName but no companyId yet
+    const company = await con
+      .getRepository(Company)
+      .findOneBy({ id: companyId! });
+    if (company) {
+      const companyNames = [company.name.toLowerCase()];
+      if (company.altName) {
+        companyNames.push(company.altName.toLowerCase());
+      }
+
+      await con
+        .getRepository(UserExperience)
+        .createQueryBuilder()
+        .update()
+        .set({ companyId: companyId! })
+        .where('userId = :userId', { userId })
+        .andWhere('companyId IS NULL')
+        .andWhere('LOWER("customCompanyName") IN (:...companyNames)', {
+          companyNames,
+        })
+        .execute();
+    }
   }
 };