Dinky is a real-time data development platform based on Apache Flink, enabling agile data development, deployment and operation.
1.0.1 is a BUG repair version, no database upgrade changes, can be directly upgraded
About SCALA version: The release version uses Scala-2.12. If your environment must use Scala-2.11, please compile it yourself. Please refer to Compile Deployment and change the scala-2.12 in the profile. for scala-2.11
add jar
with s3rs
voluntary agreementdecimal
data type exceeds 38 digits (more than 38 digits will be converted to string)add file
cannot be parsedFlinkSQL environment
listEXECUTE JAR
task DEMOThe changes from version 0.7 to version 1.0 are relatively large, and there are some incompatible changes. Users using version 0.7 cannot directly upgrade to version 1.0. It is recommended to redeploy version 1.0.
${}
to #{}
_CURRENT_DATE_
are removed and replaced by expression variablesdlink_catalog
to dinky_catalog
Feature:
Fix:
Optimization & Improve:
Document:
Contributors
@aiwenmo @gaoyan1998 @izouxv @JiaLiangC @kylinmac @leechor @yangzehan @yqwoe @zackyoungh
@aiwenmo @drgnchan @gaoyan1998 @gitfortian @gitjxm @leechor @leeoo @Logout-y @MaoMiMao @Pandas886 @yangzehan @YardStrong @zackyoungh @Zzm0809
Fix: [Fix-2739] Fix bug that complete the missing path in auto.sh's CLASS_PATH [Fix-2740] Fixed issue of re-rendering task list after publishing or offline [Fix] Fix flink 1.18 set operator not work and configure null error [Fix] Fix the bug of save_point_strategy in submission history [Fix] Fix the bug of print flink table [Fix] Fix the bug of create view to ddl catalog [Fix] Fix flink application not throw exception [Fix] Fix the alert option is incorrect [Fix] Fix the bug of job life cycle [Fix-2754] Fix the YAML of K8s form in the cluster is not displayed [Fix-2756] Fix the devops job list duration formate error [Fix-2777] Fix flink dag tooltip [Fix-2782]Fix checkpoint path not found [Fix] Fix the locations bug in pushing task to DolphinScheduler [Fix-2806] The job parameters are not effective when the set parameters key and value contain single quotes [Fix-2811] Upgrade jmx_prometheus_javaagent to 0.20.0 to fix some CVE [Fix-2814] Fix checkpoint overview error [Fix] Fix Flink catalog does not take effect with add_jar [Fix] Fix some devops bug [Fix-2832] Fix h2 driver no default packaging problem [Fix] Fix sql bug [Fix] Fixed jobInstance was always in the running state [Fix-2843] Fix Yarn Application mode submission task failed and lack of log printing [Fix] Fix the bug of udf in h2 [Fix-2823] Fix jobconfig cannot render yarn prejob cluster [Fix] Fix URL misspelling causing the request to fail [Fix-2855] Fix savepoint table params bug [Fix-2776] Fix multi user login with the same token value insert error
Optimization & Improve: [Improve] Improve extract yaml from execute pipeline command [Optimization] Add key width for job configure item [Optimization] Add dinky port configure in PrintNetSink [Improve] Improve query catalog tree [Optimization-2773] Optimize the data source directory tree has two scroll bars [Optimization-2822] Optimize metrics page tips [Optimization] Optimize Flink on yarn app submit [Optimization] Optimize explainer class use user builder for result [Optimization] Optimize document management [Optimization] Implement operator with SPI [Improve] Improve document form layout [Optimization-2757] Optimize Flink instance render type [Optimization-2755] Optimize datasource detail search box [Optimization] Add resource implement for DinkyClassLoader
Document: [Document] Improve the cluster instance list document for the registration center [Document] Improve the alert document for the registration center [Document] Improve the git project document for the registration center [Document] Improve the k8s document for the quick start [Document] Modify domain name [Document] Improve documents in registration center and authentication center [Document] Improve documents in developer guide [Document] Add parameter description in CDCSOURCE and example for debezium.* [Document-2830] Update download [Document] Modify document struct
Contributors: @aiwenmo @gaoyan1998 @gitfortian @leeoo @leechor @stdnt-xiao @yangzehan @zackyoungh @Zzm0809
Dinky is a data development platform based on Apache Flink, which enables agile data development and deployment.
Dinky 1.0 is a refactored version that restructures existing functions, adds several enterprise-level functions, and fixes some limitations of 0.7. Currently, it is not possible to directly upgrade from 0.7 to 1.0. An upgrade plan will be provided in the future.
Its main functions are as follows:
Feature: [Feature-2370][connect] Add jdbc scan filter in flink-connector-jdbc-1.16 [Feature-2381][udf] AGGTABLE supports udtaf in Flink 1.16
Fix: [Fix][udf] Fix UDF's submission to submission with Checkpoint failed [Fix-2392][metadata] Fix listColumnsSortByPK infinite recursion
Optimization & Improve: [Optimization-2361][web] Optimize the display of job which unable to obtain the latest status [Optimization][core] Optimize flink task query use enum value
Contributors: @aiwenmo @Wintle @zackyoungh
Feature: [Feature-1930][client] Analyze custom functions from Flink SQL [Feature-2126][connector] Add SQLServer Simple Connector in Flink 1.16 [Feature][cdc] Doris auto create table in CDCSOURCE task
Fix: [Fix][metadata] Fix the issue of no data type when MySQL automatically generates DDL statements [Fix][cdc] Fix issues with CDCSOURCE [Fix-1958][cdc] Fix data misalignment occurs after synchronizing data hen PK do not declare at the table head [Fix-2087][UDF] Fix udf cannot run on flink1.16 and flink 1.17 [Fix][metadata] Fix clickhouse Nullable columns [Fix-2147][metadata] Fix missing precision and scale when generating MySql DDL [Fix][metadata] Fix mssql tinyint Type conversion error [Fix-2176][admin] Fix unknown jobid bug [Fix-2108][admin] Fix updating the savepoint policy of the job during checkpoint recovery
Optimization & Improve: [Optimization][cdc] Optimize CDCSOURCE in Flink 1.16 [Optimization-2089][flink] Upgrade Flink version
Contributors: @aiwenmo @HamaWhiteGG @leeoo @LiuHao0606 @seawenc @tan-zhuo @xiaofan2022 @zhengwenhao2017
Feature: [Feature-1709][core] Support use FlinkSQL CTE to preview data [Feature-1774][flink] Support Apache Flink 1.17
Fix: [Fix-797][web] Fix no fragment parameters were passed when getting lineage [Fix-1731][gateway] Fix deploy flink k8s session error [Fix-1787][metadata] Fix error in automatic table creation using CDCSOURCE Mysql field unsigned type problem [Fix-1805][admin] Fix NPE occurred when publishing the job [Fix][cdcsource] Fix data sending and receiving issues with synchronizing multiple Sinks in CDCSOURCE [Fix][SqlSegment] Fix the issue of SQL configuration parsing failure in specific scenarios [Fix-1784][admin] Fix task is deleted but task instances and history are not deleted consecutively [Fix-1849][client] Fix CDCSOURCE kafkaSink transactionalIdPrefix NullPointerException [Fix-1847][metadata] Fix postgreSql get DDL script error [Fix][metadata] Fix generating MySQL DDL statements without quotes for normal default values
Optimization & Improve: [Optimization-1715][admin] Optimize job monitor reconnect [Optimization-1776][core,metadata] Fix typo [Optimization-1657][client] Optimize MysqlJsonDebeziumDeserializationSchema use shaded lib in flink 1.13 [Optimization][client] Support scan.incremental.snapshot.chunk.size [Optimization][client] Analyze lineage from the original relNode, not the optimized relNode, and add unit tests [Optimization-1851][flink] Upgrade all versions of Flink to the latest version
Contributors: @aiwenmo @AntChen27 @cygnusdark @HamaWhiteGG @LiuHao0606
Feature: [Feature-1593] Add CDCSOURCE support sink catalog [Feature-1608] Support get task lineage by taskid with openapi [Feature-1641] Add Flink row level permissions [Feature-1647] Yarn session support applicationId and resource manager config [Feature-1547] Flink Jar support alert
Fix: [Fix-1615] Fix submit task error but return succeed when using dolphinscheduler [Fix-1624] Fix lineage api in data explore module returns empty result [Fix-1652] Fix the task using the FlinkSQLEnv cannot obtain lineage [Fix-1662] Fix OpenApi notLoginException [Fix] Fix wrong Python type [Fix-1672] Fix failed to get metadata due to jdbc session timeout in CDCSOURCE [Fix-1638] Fix dlink web could not correct display Boolean type data [Fix-1686] Fix ZipFile got wrong in K8s native app mode
Optimization & Improve: [Optimization-1631] Optimize auto.sh and remove useless files [Optimization-1666] Add job reconnecting status and optimize job monitor [Optimization-1682] Optimize setting named tinyInt1isBit for mysql metadata
Contributors: @aiwenmo @liaotian1005