SteNicholas commented on a change in pull request #13983:
URL: https://github.com/apache/flink/pull/13983#discussion_r531542160
##########
File path: flink-python/pyflink/datastream/data_stream.py
##########
@@ -123,7 +124,7 @@ def set_max_parallelism(self, max_parallelism: int) ->
'DataStream':
self._j_data_stream.setMaxParallelism(max_parallelism)
return self
- def get_type(self) -> TypeInformation:
+ def get_type(self) -> WrapperTypeInfo:
Review comment:
@dianfu Because type checker of PyFlink cause this change. I didn't want
to change `TypeInformation` to `WrapperTypeInfo`. IMO, the basic type is
`WrapperTypeInfo` not `TypeInformation `.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
