Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6090#discussion_r194452740
--- Diff:
flink-libraries/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/LocalExecutorITCase.java
---
@@ -145,6 +146,68 @@ public void testTableSchema() throws Exception {
assertEquals(expectedTableSchema, actualTableSchema);
}
+ @Test(timeout = 30_000L)
+ public void testScalarUDF() throws Exception {
--- End diff --
The full integration test were needed for the beginning but now we should
work more with dedicated unit tests. Maybe extend one existing ITCase with a
function and check for the general correctness in a new test class.
---