fix tests

apache · Aug 12, 2021 · a3351fa · a3351fa
1 parent d466870
commit a3351fa
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/flink-python/pyflink/fn_execution/beam/beam_operations_fast.pxd b/flink-python/pyflink/fn_execution/beam/beam_operations_fast.pxd
@@ -47,7 +47,6 @@ cdef class IntermediateOutputProcessor(OutputProcessor):
 cdef class FunctionOperation(Operation):
     cdef OutputProcessor _output_processor
     cdef bint _is_python_coder
-    cdef StreamCoderImpl _value_coder_impl
     cdef object process_element
     cdef object operation
     cdef object operation_cls

diff --git a/flink-python/pyflink/fn_execution/beam/beam_operations_fast.pyx b/flink-python/pyflink/fn_execution/beam/beam_operations_fast.pyx
@@ -111,7 +111,7 @@ cdef class FunctionOperation(Operation):
             self._output_processor = NetworkOutputProcessor(consumer)
 
             _value_coder_impl = consumer.windowed_coder.wrapped_value_coder.get_impl()._value_coder
-            if isinstance(self._value_coder_impl, FlinkLengthPrefixCoderBeamWrapper):
+            if isinstance(_value_coder_impl, FlinkLengthPrefixCoderBeamWrapper):
                 self._is_python_coder = False
             else:
                 self._is_python_coder = True