littleeleventhwolf opened a new issue, #7892:
URL: https://github.com/apache/hudi/issues/7892
**Describe the problem you faced**
When using join or union to query the same table in flink sql, source uid (
"uid_streaming_source_TABLENAME") collision occurs .
**To Reproduce**
Case 1:
```sql
SELECT sum(a.field1), count(b.field2)
FROM (
SELECT field1, dim1, join_key, group_key FROM TABLENAME WHERE dim1 =
'xxx'
) a
LEFT JOIN (
SELECT field2, dim2, join_key, group_key FROM TABLENAME WHERE dim2 =
'yyy'
) b
ON a.join_key = b.join_key
GROUP BY a.group_key
```
Case 2:
```sql
SELECT sum(agg1), count(agg2)
FROM (
SELECT 0 as agg1, sum(field2) as agg2, field3 as group_key FROM
TABLENAME WHERE dim1 = 'xxx'
UNION ALL
SELECT sum(field1) as agg1, 0 as agg2, field4 as group_key FROM
TABLENAME WHERE dim2 = 'yyy'
GROUP BY group key
```
**Expected behavior**
Solve the source uid collision.
**Environment Description**
* Hudi version : 0.9.0
* Flink version : 1.12.2
--
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]
