[BEAM-12698] Some binary operations on DeferredSeries don't work

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Not A Problem
• Affects Version/s: 2.31.0
• Fix Version/s: Missing
• Component/s: dsl-dataframe

Language

Python

• Assignee: Unassigned
• Reporter: Yunfeng Zhang
• Created: 30/Jul/21 20:27
• Updated: 13/Jan/22 21:49
• Resolved: 14/Sep/21 19:19

Description

I get an error when trying to multiply two columns of a deferred dataframe:

ib.collect(df.A.mul(df.B))

TypeError: can't multiply sequence by non-int of type 'str' [while running '[35]: ComputedExpression[mul_Series_140480471782160]/[ComputedExpression[mul_Series_140480471782160]]:140480472023312/FlatMap(evaluate)/FlatMap(evaluate)']

 

Similarly, adding a scalar also doesn't work:

ib.collect(df.A.add(1))

TypeError: can only concatenate str (not "int") to str [while running '[39]: ComputedExpression[add_Series_140480422551952]/[ComputedExpression[get_column_Series_140480422552144], ComputedExpression[add_Series_140480422551952]]:140480472568336/FlatMap(evaluate)/FlatMap(evaluate)']

But adding two columns work.