afedulov opened a new pull request #17215:
URL: https://github.com/apache/flink/pull/17215
Running the `HybridSourceE2ETest` fails with:
```
Test
org.apache.flink.tests.util.kafka.HybridSourceE2ETest.testSourceSingleSplit
failed with:
org.apache.flink.api.common.functions.InvalidTypesException: The return type
of function 'Tested Source' could not be determined automatically, due to type
erasure. You can give type information hints by using the returns(...) method
on the result of the transformation call, or by letting your function implement
the 'ResultTypeQueryable' interface.
at
org.apache.flink.api.dag.Transformation.getOutputType(Transformation.java:496)
...
Caused by: org.apache.flink.api.common.functions.InvalidTypesException: Type
of TypeVariable 'T' in 'class
org.apache.flink.connector.base.source.hybrid.HybridSource' could not be
determined. This is most likely a type erasure problem. The type extraction
currently supports types with generic variables only in cases where all
variables in the return type can be deduced from the input type(s). Otherwise
the type has to be specified explicitly using type information.
at
org.apache.flink.api.java.typeutils.TypeExtractor.createTypeInfoWithTypeHierarchy(TypeExtractor.java:923)
```
P.S.: The reason for the introduction of the
`ConnectorTestingWithExternalExtension` vs `ConnectorTestingExtension` is to
allow testing connectors that do not necessarily require an external system
(testcontainer) - for instance for testing the `FileSource`.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
