[FLINK-36284] StreamTableEnvironment#toDataStream(Table table, Class<T> targetClass) is not suitable for setting targetClass as a class generated by Avro. - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Improvement
Status: Closed
Priority: Blocker
Resolution: Fixed
Affects Version/s: None
Fix Version/s: 2.0-preview
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / API
Labels:
- pull-request-available

Description

This issue can be fired by updating the testAvroToAvro method in the org.apache.flink.table.runtime.batch.AvroTypesITCase class.

@Test
public void testAvroToAvro() {
    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
    StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);

    DataStream<User> ds = testData(env);
    // before: using deprecated method
    // Table t = tEnv.fromDataStream(ds, selectFields(ds));
    // after: using recommended new method
    Table t = tEnv.fromDataStream(ds);
    Table result = t.select($("*"));

    // before: using deprecated method
    // List<User> results =
    //        CollectionUtil.iteratorToList(
    //                DataStreamUtils.collect(tEnv.toAppendStream(result, User.class)));
    // after: using recommended new method
    List<User> results =
        CollectionUtil.iteratorToList(
                DataStreamUtils.collect(tEnv.toDataStream(result, User.class)));
    List<User> expected = Arrays.asList(USER_1, USER_2, USER_3);
    assertThat(results).isEqualTo(expected);
}