I just run it in my IDE.
sunfulin 于2020年3月2日周一 下午9:04写道：
>
>
> Hi,
> Yep, I am using 1.10
> Did you submit the job in the cluster or just run it in your IDE? Because
> I can also run it successfully in my IDE, but cannot run it through cluster
> by a shading jar. So I think maybe the problem is
Hi,
Yep, I am using 1.10
Did you submit the job in the cluster or just run it in your IDE? Because I can
also run it successfully in my IDE, but cannot run it through cluster by a
shading jar. So I think maybe the problem is related with maven jar classpath.
But not sure about that.
If y
Hi fulin,
I cannot reproduce your exception on current master using your SQLs. I
searched the error message, it seems that this issue[1] is similar with
yours, but it seems that current compile util does not have this issue.
BTW, do you using 1.10?
[1] https://issues.apache.org/jira/browse/FLINK
create table lscsp_sc_order_all (
amount varchar ,
argType varchar,
balance varchar,
branchNo varchar ,
businessType varchar ,
channelType varchar ,
counterOrderNo varchar ,
counterRegisteredDate varchar,
custAsset varchar ,
customerNumber varchar,
customerType varc
Could you also provide us the DDL for lscsp_sc_order_all
and dim_app_cust_info ?
sunfulin 于2020年3月1日周日 下午9:22写道：
>
> *CREATE TABLE **realtime_product_sell *(
> sor_pty_id *varchar*,
> entrust_date *varchar*,
> entrust_time *varchar*,
> product_code *varchar *,
> business_type *varchar
CREATE TABLE realtime_product_sell (
sor_pty_id varchar,
entrust_date varchar,
entrust_time varchar,
product_code varchar ,
business_type varchar ,
balance double ,
cust_name varchar ,
open_comp_name varchar ,
open_comp_id varchar ,
org_name varchar ,
org_id varchar ,
com
The UDF looks good. Could you also paste your DDL? Then we can produce your
bug easily.
sunfulin 于2020年3月1日周日 下午6:39写道：
> Below is the code. The function trans origin field timeStr "2020-03-01
> 12:01:00.234" to target timeStr accroding to dayTag.
>
> *public class *ts2Date *extends *ScalarFunct
Could you show how your UDF `ts2Date` is implemented?
sunfulin 于2020年3月1日周日 下午6:05写道：
> Hi, Benchao,
> Thanks for the reply.
>
> Could you provide us more information?
> 1. what planner are you using? blink or legacy planner?
> I am using Blink Planner. Not test with legacy planner because my pr
