flink wordcount demo job
二分法demo
# 1.python实现 ```python from math import floor arr = [1, 2, 3, 4, 5, 6, 8, 9, 10, 11] left = 0 right = len(arr)-1 res = 7 while (left res): right = mid ......
网页聊天框demo
## 效果图 ![](https://img2023.cnblogs.com/blog/1480764/202309/1480764-20230904163413620-546403069.png) ## css 代码 ``` body { background-color: gray; } .ch ......
k8s安装etcd出现Job for etcd.service failed......"journalctl -xe" for details.
### 错误如下 ![image](https://img2023.cnblogs.com/blog/2045410/202309/2045410-20230903205418854-1623317359.png) **先按照提示,输入 `journalctl -xe` 看一些详细信息** ![im ......
vue组件切换_demo
项目参考:36_动态组件_哔哩哔哩_bilibili 项目结构: App.vue <template> <component :is="Component"></component> <button @click="switchHandle">switch Component</button> </ ......
vue3入门_demo
新建项目参考:Vue vscode 创建 vue 项目流程【超详细】_vue vscode 创建 vue 项目流程【超详细】_怎么用vscode写vue_一颗不甘坠落的流_一颗不甘坠落的流星的博客-CSDN博客 项目结构: App.vue <template> <Main></Main> </tem ......
一个CSS动画的demo
.lineBarDis { height: 8px; background-image: linear-gradient(to right, #011c72 0%, #c7ced2 100%); animation: myAnimation 1.5s infinite; /* 设置动画为2秒钟的时间 ......
拖拽demo
<!DOCTYPE html><html> <head> <meta charset="utf-8"> <title></title> <script src="js/echarts.5.4.3.js"></script> </head> <body> <div id="main" draggabl ......
com.xxl.job.core.log.XxlJobFileAppender : 没有那个文件或目录
异常信息如下: 2023-08-31 19:52:39.627 ERROR 18321 [rCallbackThread] com.xxl.job.core.log.XxlJobFileAppender : 没有那个文件或目录 java.io.IOException: 没有那个文件或目录 at ja ......
sqlsugar 增删改查 demo
1.sqlsugar 增删改查 demo entity query: var getAll = db.Queryable().ToList(); var getAll2 = db.Queryable().Select(x => x.CreateTime.Date).ToList(); var get ......
Flink SQL 数据类型
Flink SQL 为用户提供了一系列丰富的原始数据类型。 数据类型 | Apache Flink https://nightlies.apache.org/flink/flink-docs-master/zh/docs/dev/table/types/ 翻译 搜索 复制 ......
Flink-读Kafka写Hive表
1. 目标 使用Flink读取Kafka数据并实时写入Hive表。 2. 环境配置 EMR环境:Hadoop 3.3.3, Hive 3.1.3, Flink 1.16.0 根据官网描述: https://nightlies.apache.org/flink/flink-docs-release-1 ......
Flink的3中API
DataStream/DataSet/Table API是Apache Flink提供的三种不同的API,用于处理不同类型的数据和实现不同的计算模型。 1. DataStream API:DataStream API是基于流式数据的API,用于处理连续不断到达的数据流。它适用于实时数据处理和流式计算 ......
c#在MVC Api(.net framework)当中使用Swagger,以及Demo下载
Demo下载地址。 主要的步骤就是创建项目,通过nuget 添加Swashbuckle包,然后在SwaggerConfig当中进行相关的配置。 具体的步骤,可以参考下面的链接: https://www.cnblogs.com/94pm/p/8046580.html https://blog.csdn ......
flink用户自定义连接器(http连接器)
1、Flink用户自定义连接器(Table API Connectors)学习总结_flink自定义连接器_董可伦的博客-CSDN博客 2、官网介绍: https://nightlies.apache.org/flink/flink-docs-release-1.17/zh/docs/dev/tab ......
flink的源码编译方法
1、下载flink源码 2、修改整数限制numUnapprovedLicenses 改成100(在pom.xml文件) 3、执行编译命令 ./mvnw clean package -DskipTests 4、如果只想名义子工程 拷贝根目录的mvnw执行脚本到对应子目录,然后再执行./mvnw cle ......
junit_demo
参考:JUnit5单元测试框架的使用教程与简单实例_junit5使用_pan_junbiao的博客-CSDN博客 Junit单元测试例子demo_twentyfour4ever的博客-CSDN博客 目录结构 pom.xml <project xmlns="http://maven.apache.or ......
Flink 1.12.2样例
### pom.xml ```xml sample-project org.myproject.bigdata 1.0-SNAPSHOT 4.0.0 JavaFlink-112 1.8 1.8 1.12.2 UTF-8 org.apache.flink flink-java ${flink.vers ......
Job System 初探
作者:i_dovelemon 日期:2023-08-24 主题:Fiber, Atomic Operation, MPMC Queue, Multiple thread, Job system 引言 现代 CPU 是多核处理器,为了充分利用 CPU 多核处理的特性,游戏引擎会大量使用多线程 (mul ......
k8s核心资源Job&&CronJob调度pod
一、Job与CronJob概念与与原理解读 Job 控制器用于管理 Pod 对象运行一次性任务,比方说我们对数据库备份,可以直接在 k8s 上启动一个 mysqldump 备份程序,也可以启动一个 pod,这个 pod 专门用来备份用的,备份结束 pod 就可以终止了,不需要重启,而是将 Pod 对 ......
pdfjs-dist v2.11.338写个react demo
app.jsx ```jsx import './App.css' import * as pdfjs from "pdfjs-dist"; import "pdfjs-dist/web/pdf_viewer.css"; import { useEffect, useRef, useState } ......
Warning: /root/software/sqoop/../hcatalog does not exist! HCatalog jobs will fail. Please set $HCAT_HOME to the root of your HCatalog installation.问题的解决
# 问题描述 ![](https://img2023.cnblogs.com/blog/2808014/202308/2808014-20230825110459231-452577103.png) # 问题解决 进入到sqoop/bin的文件目录下: ![](https://img2023.cnb ......
Springboot K8s Job 一次性任务 如何禁用端口监听
+ 问题:SpringBoot一次性任务执行时,也会默认监听服务端口,当使用k8s job运行时,可能多个pod执行存在端口冲突 + 解决办法:命令行禁用SpringBoot一次性任务启动时端口占用 ``` java -cp ./XXX -Dspring.config.location=/home/ ......
flask接收json,开启服务demo
# demo ```python from flask import Flask, render_template, request, jsonify app = Flask(__name__) @app.route('/', methods=['GET', 'POST']) def index() ......
NSQ demo
Docker docker pull nsqio/nsq nsqd nsqd 是接收、队列和向客户端传递消息的守护进程。它可以独立运行,但通常在具有nsqlookupd实例的集群中进行配置(这种情况下,他将会发布主题和频道以便发现) 配置及api:https://nsq.io/componen ......
a start job is running for udev wait for complete device initialization
# a start job is running for udev wait for complete device initialization reference: ``` diff /etc/init.d/systemd-udevd +systemctl mask systemd-udev-s ......
hibernate_demo
参考:ORM hibernate入门Demo(无敌详细版) - Old-凯 - 博客园 (cnblogs.com) hmb.xml:Hibernate框架之hbm.xml映射文件(详解)_hibernate映射文件详解_hestyle的博客-CSDN博客 新建testdb数据库,创建tb_users ......
FastApi-1-结合sql 增/查demo
[TOC](目录) # FastAPI学习记录 fastapi已经学习有一段时间,今天抽时间简单整理下。 **官网介绍:** FastAPI 是一个用于构建 API 的现代、快速(高性能)的 web 框架,使用 Python 3.6+ 并基于标准的 Python 类型提示。 - 快速:可与 Node ......
tk的一个布局demo
# 效果 ![](https://img2023.cnblogs.com/blog/3005444/202308/3005444-20230819174404343-1933435526.png) # 代码 ```python import tkinter as tk from tkinter im ......
python监控redis demo
下载aioredis 为了提升性能我们使用一部redis ```python pip install aioredis ``` demo: ```python import asyncio import aioredis # 每隔10s获取redis信息 async def monitor_redi ......