[
https://issues.apache.org/jira/browse/FLINK-19746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
appleyuchi updated FLINK-19746:
-------------------------------
Description:
I know the solution for my following question,
So it's not asking for support to debug code.
[completed code|https://paste.ubuntu.com/p/Mw5tJSmDCs/]:
when I use the function *as* in my code,
||relevant code||log||
|tEnv.registerDataStream("Orders", orderA,"user,product,amount");|ok|
|tEnv.createTemporaryView("Orders",
orderA,$("user,product,amount"));|user,product,amount is not a field of type
PojoType<Order, fields = [amount: Integer, product: String, user: Long]>.
Expected: amount, product, user}|
---------------------------------------------------------------------------------------------------------------
registerDataStream is deprecated,
so the best way is to use createTemporaryView.
Question:
why the support for AS is deleted when createTemporaryView is used?
was:
*I know the solution for my following question,
So it's not asking for support.*
completed code:
https://paste.ubuntu.com/p/Mw5tJSmDCs/
when I use the function *as* in my code,
I can only use.
// tEnv.createTemporaryView("Orders", orderA,$("user,product,amount"));
tEnv.registerDataStream("Orders", orderA,"user,product,amount");
I can Not use:
tEnv.createTemporaryView("Orders", orderA,$("user,product,amount"));
// tEnv.registerDataStream("Orders", orderA,"user,product,amount");
error log:
user,product,amount is not a field of type PojoType<Order, fields = [amount:
Integer, product: String, user: Long]>. Expected: amount, product, user}
---------------------------------------------------------------------------------------------------------------
registerDataStream is deprecated,
so the best way is to use createTemporaryView.
Question:
why the support for AS is deleted when createTemporaryView is used?
> Why delete support for "as" function
> ------------------------------------
>
> Key: FLINK-19746
> URL: https://issues.apache.org/jira/browse/FLINK-19746
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.11.0
> Reporter: appleyuchi
> Priority: Major
>
> I know the solution for my following question,
> So it's not asking for support to debug code.
> [completed code|https://paste.ubuntu.com/p/Mw5tJSmDCs/]:
> when I use the function *as* in my code,
> ||relevant code||log||
> |tEnv.registerDataStream("Orders", orderA,"user,product,amount");|ok|
> |tEnv.createTemporaryView("Orders",
> orderA,$("user,product,amount"));|user,product,amount is not a field of type
> PojoType<Order, fields = [amount: Integer, product: String, user: Long]>.
> Expected: amount, product, user}|
> ---------------------------------------------------------------------------------------------------------------
> registerDataStream is deprecated,
> so the best way is to use createTemporaryView.
> Question:
> why the support for AS is deleted when createTemporaryView is used?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
