@@ -1696,7 +1696,7 @@ def test_sync_drop_table_map_event_table_schema(self):
1696
1696
1697
1697
event = self .stream .fetchone ()
1698
1698
self .assertIsInstance (event , TableMapEvent )
1699
- self .assertEqual (event .table_obj .data ["columns" ][0 ].name , None )
1699
+ self .assertEqual (event .table_obj .data ["columns" ][0 ].name , "name" )
1700
1700
self .assertEqual (len (column_schemas ), 0 )
1701
1701
1702
1702
def test_sync_column_drop_event_table_schema (self ):
@@ -1727,9 +1727,9 @@ def test_sync_column_drop_event_table_schema(self):
1727
1727
self .assertEqual (len (event .table_obj .data ["columns" ]), 3 )
1728
1728
self .assertEqual (column_schemas [0 ][0 ], "drop_column1" )
1729
1729
self .assertEqual (column_schemas [1 ][0 ], "drop_column3" )
1730
- self .assertEqual (event .table_obj .data ["columns" ][0 ].name , None )
1731
- self .assertEqual (event .table_obj .data ["columns" ][1 ].name , None )
1732
- self .assertEqual (event .table_obj .data ["columns" ][2 ].name , None )
1730
+ self .assertEqual (event .table_obj .data ["columns" ][0 ].name , "drop_column1" )
1731
+ self .assertEqual (event .table_obj .data ["columns" ][1 ].name , "drop_column2" )
1732
+ self .assertEqual (event .table_obj .data ["columns" ][2 ].name , "drop_column3" )
1733
1733
1734
1734
def tearDown (self ):
1735
1735
self .execute ("SET GLOBAL binlog_row_metadata='MINIMAL';" )
0 commit comments