Alan Sheinberg created FLINK-39679:
--------------------------------------
Summary: Error with implicit casting
Key: FLINK-39679
URL: https://issues.apache.org/jira/browse/FLINK-39679
Project: Flink
Issue Type: Sub-task
Reporter: Alan Sheinberg
```
@Test
public void testLongScalarNoCast() {
tEnv.createTemporarySystemFunction("func", new GreetingLongScalar());
tEnv.executeSql("CREATE VIEW Names(name) AS VALUES ('Bob'), ('Alice'),
('Bob')");
final List<Row> results =
executeSql("SELECT * FROM func(TABLE Names PARTITION BY name, 100)");
final List<Row> expectedRows =
Arrays.asList(
Row.ofKind(RowKind.INSERT, "Bob", "Hello 100!"),
Row.ofKind(RowKind.INSERT, "Alice", "Hello 100!"),
Row.ofKind(RowKind.INSERT, "Bob", "Hello 100!"));
assertThat(results).containsSequence(expectedRows);
}
/** A PTF that takes an int argument and returns a greeting. */
public static class GreetingLongScalar extends ProcessTableFunction<String> {
public void eval(
@ArgumentHint(ArgumentTrait.SET_SEMANTIC_TABLE) Row input,
long arg) {
collect("Hello " + arg + "!");
}
}
```
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
