帅平
Flink应用开发系列（三十九）Table API & SQL介绍
Dinky 使用可以在实际的开发中极大的增加我们的开发效率。这里的Table API 和SQL 在Flink中其实介绍的都是一个东西，也就是把数据进行结构化，然后当作是数据库表一样的操作。唯一不同的是Table AP...
Rae
热文Dinky 实时计算平台系列（二十一）FlinkSql作业开发之FlinkSql-cdc + kafka
Dinky 实时计算平台系列（十九）FlinkSql作业开发之FlinkSql-Kafka》和《Dinky 实时计算平台系列（二十）FlinkSql作业开发之FlinkSql-cdc》。本文的话，我们结合下mysql...
Dinky 实时计算平台系列（二十）FlinkSql作业开发之FlinkSql-cdc
Dinky 实时计算平台系列（十九）FlinkSql作业开发之FlinkSql-Kafka》我们介绍了flinksql中kafka的connector，在实际的业务中我们还会涉及到的有mysql的cdc，本文的话我们...
热文Dinky 实时计算平台系列（十九）FlinkSql作业开发之FlinkSql-Kafka
Dinky 实时计算平台系列（十八）FlinkSql作业开发之快速演示》我们在Dinky中进行了一个简单的演示开发，从现在开始，我们切合实际情况，做一些flink多数据源的connector方面的开发，本文主要演示的...
Dinky 实时计算平台系列（十八）FlinkSql作业开发之快速演示
Dinky平台上开发一个flinksql的作业。下面直接开始.1）首先创建一个作业这里我们创建一个名为test2的作业，此时就会在右侧打开一个新的黑框。如下图：2）在黑框里面编写sql这里我们使用官方的案例来演示下，...
Dinky中创建catalog报错：Table (or view) default_database.tbl_contract_detail already exists in Catalog
Dinky执行Flinksql的时候报错了，提示：table.catalog.exceptions.TableAlreadyExistException：Table (or view) default_datab.....
Dinky 实时计算平台系列（十七）Dinky数据开发之FlinkSql作业保存点
Dinky的flinksql数据开发编辑器的右侧，还有一个比较重要的功能就是保存点，如下图：这个保存点不是用来配置的，它是一系列的记录。当我们在调试这个作业的时候，我们通过该cancel命令停止作业的时候，会自动生成...
热文Dinky 实时计算平台系列（十六）Dinky数据开发之FlinkSql作业执行配置
在flinksql的作业编辑器右侧除了作业配置之外，还有执行配置，如下图：这个执行配置里面只有4个选项吻别是预览结果，打印流，最大行数，自动停止。这个执行配置在我们调试作业的阶段，建议所有的选项都打开，方便查看调试的...
热文Dinky 实时计算平台系列（十五）Dinky数据开发之FlinkSql作业基础模式
Dinky 实时计算平台系列（十四）Dinky数据开发之FlinkSql作业执行模式》我们介绍了flinksql相关的作业模式。我们还是再来看下这个编辑器界面，如下图：在上图右侧的部分，我们圈起来的部分这里有很多的配...
热文Dinky 实时计算平台系列（十四）Dinky数据开发之FlinkSql作业执行模式
Dinky中的作业。也介绍了这里的黑框是用来编写实际代码的，编写完成之后，我们需要调试，需要验证，那么就需要对应的执行环境，不同的执行环境就对应不同的执行模式。本文的话，我们介绍下Dinky中FlinkSql作业的执...
Dinky 实时计算平台系列（十三）Dinky数据开发之作业编辑快捷键
Dinky 实时计算平台系列（十二）Dinky数据开发之作业概述》我们介绍了Dinky作业的相关概念，在最后我们看到有一个编辑器区域，如下图：这个区域里面就是专门用来编写代码的，这里编写代码其实和我们日常使用其他编辑...
Dinky 实时计算平台系列（十二）Dinky数据开发之作业概述
Dinky数据开发之作业概述。这里的作业指的是什么呢？在使用java进行flink编程的时候，我们经常会把一套相同业务的逻辑放到一个job里面进行编写，例如这套业务的逻辑是实现把mysql的数据导入到另外一个mysq...
Dinky添加集群配置管理的时候报错：NoClassDefFoundError: org/apache/hadoop/yarn/conf/YarnConfiguration
Dinky上添加的是集群配置管理，添加完毕之后，报错了，提示：Handler dispatch failed; nested exception is java.lang.NoClassDefFoundError.....
