mvn archetype:generate \-DarchetypeGroupId=org.apache.flink \-DarchetypeArtifactId=flink-quickstart-java \-DarchetypeVersion=1.9.0 \-DgroupId=wiki-edits \-DartifactId=wiki-edits \-Dversion=0.1 \-Dpack

今天遇到了某字段为string类型，但是里面存放了数字，null（空值），‘’（空串）在进行条件过滤时，出现了问题，现在进行一下简单的总结：数据准备：use default;create table test0613 asselect '1' as codeunion allselect '0' as codeunion allselect null as codeunion allselect

开心跑完我的小HQL，在校验数据的时候，发现数据明明存在，但是没有关联成功，最终发现关联的字段会有NUL值存在。针对这种情况，我找到了两种解决方案：方案一：不让NULL出现。1、新建表的时候，将NULL处用其他内容替换，这样底层存储的就是替换后的内容。CREATE TABLE aa (id int,name STRING)WITH SERDEP...

官网下载地址：https://www.oracle.com/database/technologies/oracle-database-software-downloads.html两个都需要下载下载后，将两个文件解压，点击setup.exe安装可能会报如下错误：解决方法第一步：控制面板>所有控制面板项>管理工具>服务>SERVER...

官网下载地址：https://www.oracle.com/database/technologies/oracle-database-software-downloads.html两个都需要下载下载后，将两个文件解压，点击setup.exe安装可能会报如下错误：解决方法第一步：控制面板>所有控制面板项>管理工具>服务>SERVER...

[2019-06-27 11:18:54,006] {bash_operator.py:110} INFO - Exception in thread "main" org.apache.spark.sql.catalyst.errors.package$TreeNodeException: execute, tree:[2019-06-27 11:18:54,006] {bash_operat.

错误的代码def main(args: Array[String]): Unit = {SparkSession.builder().appName("Test DF").config("config.option", "some-value").getOrCreate()//import implicit DF,DSimport spark.im

可以使用该方法运行所有原始数据库操作。

在使用flinkTableAPI开发的时候，执行SQL，使用insert overwrite时，提示DynamicTableSink of table 'default_catalog.default_database.xx' implements the SupportsOverwrite interface.这时我们需要在pom.xml文件中添加如下依赖，就可以解决：<dependenc

MongoDB MapReduce 查看MongoDB集合的所有字段