Skip to content

Commit 4b2927f

Browse files
committed
check if both perands hav null indices before applying the block identity join logic
1 parent 7fdb7b7 commit 4b2927f

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

bigframes/dataframe.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2288,8 +2288,13 @@ def _assign_scalar(self, label: str, value: Union[int, float, str]) -> DataFrame
22882288
def _assign_series_join_on_index(
22892289
self, label: str, series: bigframes.series.Series
22902290
) -> DataFrame:
2291+
# Only use block_identity_join for null indices
2292+
use_block_identity_join = (
2293+
self._block.index.nlevels == 0 and series._block.index.nlevels == 0
2294+
)
2295+
22912296
block, (get_column_left, get_column_right) = self._block.join(
2292-
series._block, how="left", block_identity_join=True
2297+
series._block, how="left", block_identity_join=use_block_identity_join
22932298
)
22942299

22952300
column_ids = [

0 commit comments

Comments
 (0)