Justin created FLINK-29489: ------------------------------ Summary: Display issue when querying complex, deeply nested fields Key: FLINK-29489 URL: https://issues.apache.org/jira/browse/FLINK-29489 Project: Flink Issue Type: Bug Reporter: Justin Attachments: FlinkQueries.txt, flink-screenshot1.jpg, flink-screenshot2.jpg
Using Flink 1.15, I’m observing some strange behavior when querying fields that have complex, deeply nested fields. The attached file, FlinkQueries.txt, has two create table statements. In the first table, I create a Flink table on top of the `tfmsStatusOutput` field. I have no issues querying this field using the SQL client or Java API. The second table, I create a Flink table on top of the `fltdOutput` field. This field is more complex and has deeply nested fields. Using the SQL client, when I run a simple bounded query such as `SELECT * FROM TBL2 LIMIT 1;` I get a stack trace dump in my display window and when I press any key on my keyboard it returns to the result window as if it's waiting for the results. Those are screenshots (flink-screenshot1 and flink-screenshot2). Using the Java API, I experience something similar. It looks like it is going to return something good: Starting the SELECT... Job has been submitted with JobID 0b38a2c51e8357e5fef471b38ac839d0 +----+--------------------------------+--------------------------------+--------------------------------+ | op | fltdOutput | but then it starts spitting out some form of diagnostics that doesn’t make much sense: /* 1 */public final class GeneratedCastExecutor$45 implements org.apache.flink.table.data.utils.CastExecutor { /* 2 */java.lang.StringBuilder builder$46 = new java.lang.StringBuilder(); /* 3 */java.lang.StringBuilder builder$50 = new java.lang.StringBuilder(); /* 4 */java.lang.StringBuilder builder$55 = new java.lang.StringBuilder(); … /* 845 */java.lang.StringBuilder builder$7642 = new java.lang.StringBuilder(); /* 846 */java.lang.StringBuilder builder$7654 = new java.lang.StringBuilder(); /* 847 */java.lang.StringBuilder builder$7664 = new java.lang.StringBuilder(); /* 848 */java.lang.StringBuilder builder$7672 = new java.lang.StringBuilder(); /* 849 */public GeneratedCastExecutor$45() { /* 850 */} /* 851 */@Override public Object cast(Object _myInputObj) throws org.apache.flink.table.api.TableException { /* 852 */org.apache.flink.table.data.RowData _myInput = ((org.apache.flink.table.data.RowData)(_myInputObj)); /* 853 */boolean _myInputIsNull = _myInputObj == null; /* 854 */boolean isNull$0; /* 855 */org.apache.flink.table.data.binary.BinaryStringData result$1; /* 856 */boolean isNull$2; /* 857 */org.apache.flink.table.data.binary.BinaryStringData result$3; /* 858 */boolean isNull$4; etc… I couldn't find anything in the task manager logs. -- This message was sent by Atlassian Jira (v8.20.10#820010)