Comments (2)
The solution of PROCTIME()
is the same as LOCALTIMESTAMP
, it is enhanced in the getColumnOrigins(Calc rel...)
method. LOCALTIMESTAMP
has been processed, so the lineage of PROCTIME()
can be directly parsed out.
But when PROCTIME()
is the first field, the obtained blood relationship will be confused. Therefore, add the computeIndexWithOffset
method to calculate the correct source table number RelMdColumnOrigins
, and this method is called by RelMdColumnOrigins.getColumnOrigins(Calc, RelMetadataQuery, int)
from flink-sql-lineage.
test case:
"CREATE TABLE ST (\n"
+" make_time as PROCTIME(),\n "
+ " a STRING,\n"
+ " b STRING\n"
+ ") WITH (\n"
+ " 'connector' = 'kafka',\n" +
" 'topic' = 'user_behavior',\n" +
" 'properties.bootstrap.servers' = '192.168.24.129:9092',\n" +
" 'properties.group.id' = 'testGroup',\n" +
" 'scan.startup.mode' = 'earliest-offset',\n" +
" 'format' = 'json'"
+ ");\n"
+ "CREATE TABLE TT (\n"
+ " make_time TIMESTAMP(3), \n "
+ " A STRING,\n"
+ " B STRING\n"
+ ") WITH (\n"
+ " 'connector' = 'print'\n"
+ ");\n"
+ "insert into TT(make_time,A,B) select make_time,a,b from ST";
from flink-sql-lineage.
Related Issues (20)
- 作业级别血缘实现方案探讨
- 血缘解析 使用UUID()时血缘解析 血缘关系错误 flink版本1.14 HOT 1
- [Feature]Create a universal lineage component for front-end
- mvn clean package出现错误“Failed to run task: 'yarn install' failed” HOT 1
- Exception when running LineageServerApplication
- 前端bug:DDL界面无法输入
- The transform of lineage result is null when parsing UDAF
- Error when parsing UDAF which the number of input and udf argument is equal
- parsing multi-tier udf error
- CROSS JOIN UNNEST 血缘解析报错,可能要扩展 RelMdColumnOrigins.getColumnOrigins 方法实现,大佬有空支持下。 HOT 3
- Execute SQL: USE Flink16_memory.`default` 执行异常
- 语法中如果有window tvf会返回空 HOT 1
- main 分支测试报错 HOT 2
- [Bug]Flink cep sql column lineage parse error
- UDTF 函数使用别名时解析异常 HOT 5
- 支持带CREATE VIEW 视图流的血缘解析吗? HOT 1
- flinksql lineage result missed one column
- 为什么UT跑的都是报错呢?比如testJdbcCatalog 用例 HOT 1
- Support Flink 1.17 HOT 1
- Push lineage-flink package to the Maven Repository
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from flink-sql-lineage.