Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-12698

Some binary operations on DeferredSeries don't work

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Not A Problem
    • 2.31.0
    • Missing
    • dsl-dataframe
    • None

    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.

      Attachments

        Activity

          People

            Unassigned Unassigned
            zywind Yunfeng Zhang
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: