hi, gen.
近期内应该就会发布，应该是五一左右就会发布1.13的版本。
Best,
Shengkai
gen 于2021年4月27日周二 下午8:57写道：
> hi, Shengkai
> 非常感谢你的解答， 解决了困扰我几天的问题。
> 按照你的建议 ，我使用 今天（2021-4-27） 主干版本，运行正常，发现确实是已经修复的。
> 我之前使用的版本是 1.12.2。
>
>
> 目前最新的release版本是1.12.2 ，应该还没有包含这个修复。不知道你是否了解 1.13的发布计划。
>
>
>
> --
> Sent from:
hi, Shengkai
非常感谢你的解答， 解决了困扰我几天的问题。
按照你的建议 ，我使用 今天（2021-4-27） 主干版本，运行正常，发现确实是已经修复的。
我之前使用的版本是 1.12.2。
目前最新的release版本是1.12.2 ，应该还没有包含这个修复。不知道你是否了解 1.13的发布计划。
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Hi gen
我在1.13分支上验证了下你的case，发现能够跑通。建议cp下那个patch到自己的分支，再验证下。
Best,
Shengkai
Shengkai Fang 于2021年4月27日周二 上午11:46写道：
> 请问你使用的是哪个版本？ 这个似乎是一个已知的修复的bug[1]
>
> [1] https://github.com/apache/flink/pull/15548
>
> gen 于2021年4月27日周二 上午9:40写道：
>
>> Hi, all
>>
>> 请教下为什么 无法通过t.* 将 自定义函数返回的嵌套字段查出来。
>>
>>
请问你使用的是哪个版本？ 这个似乎是一个已知的修复的bug[1]
[1] https://github.com/apache/flink/pull/15548
gen 于2021年4月27日周二 上午9:40写道：
> Hi, all
>
> 请教下为什么 无法通过t.* 将 自定义函数返回的嵌套字段查出来。
>
> tEnv.executeSql(
> """
> | SELECT t.* FROM (
> | SELECT EvtParser(request) as t FROM parsed_nginx_log
>
Hi, all
请教下为什么 无法通过t.* 将 自定义函数返回的嵌套字段查出来。
tEnv.executeSql(
"""
| SELECT t.* FROM (
| SELECT EvtParser(request) as t FROM parsed_nginx_log
| )
|""".stripMargin)
自定义函数 EvtParser
@DataTypeHint("ROW")
def eval(line: String) = {...}
详细代码
class
目前无法通过t.* 将嵌套的字段查询出来。
val schema = tEnv.executeSql(
"""
| SELECT t.* FROM (
| SELECT EvtParser(request) as t FROM parsed_nginx_log
| )
|""".stripMargin).getTableSchema
其中自定义函数 EvtParser 定义如下。
@DataTypeHint("ROW")
def eval(line: String) = {
