1 ... 140141142143144145146 ... 215

	Topics (7518)	Replies	Last Post	Views
	checkpoint持久化问题 by chen310	2	by nobleyd
	Command: Flink savepoint -d reported an error。 by pengchenglins@163.co...	5	by 赢峰
	test by 蒋德祥	1	by zhao liang
	求问为什么KafkaDynamicSource 在批模式下不能运行 by wxpcc	1	by Shengkai Fang
	rowtime的时区问题 by ゞ野蠻遊戲χ	1	by Shengkai Fang
	flink 1.12 插入 hive 表找不到 .staging_xxxx 文件 by macdoor	0	by macdoor
	flink-1.12 注册udf问题 by kcz	1	by kcz
	请教flink的处理性能，关于cpu的 by x2009438	0	by x2009438
	Flink 操作hive 一些疑问 by Jacob	3	by Rui Li
	关于iterative Job的检查点问题 by nobleyd	0	by nobleyd
	Can flink kafka producer dynamically discover new parititons after expansion？ by ぐ绿み翼う	0	by ぐ绿み翼う
	Can flink kafka producer dynamically discover new parititons after expansion？ by ぐ绿み翼う	0	by ぐ绿み翼う
	flink1.10.1/1.11.1 使用sql 进行group 和 时间窗口 操作后 状态越来越大 by 鱼子酱	22	by Storm☀️
	Flink读取kafka没有报错也没有数据输出，Kafka消费端有数据，谢谢 by Appleyuchi	2	by Appleyuchi
	Flink TaskManager失败的日志关键词 by nobleyd	2	by r pp
	Flink-1.11.1流写filesystem分区提交问题 by amenhub@163.com	5	by zhuxiaoshang
	flink1.10.1分析程序启动后org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: java.util.concurrent.TimeoutException by bigdata	0	by bigdata
	pyflink1.12 使用connector read.query参数报错 by 肖越	4	by 肖越
	yarn.provided.lib.dirs在flink1.11 yarn提交不生效 by datayangl	3	by Yang Wang
	flink-1.11.1 setMinPauseBetweenCheckpoints不生效 by nicygan	3	by nicygan
	flink应用起来后flink.streaming.runtime.tasks.StreamTaskException: Cannot instantiate user function. by bigdata	1	by nobleyd
	flink.client.program.ProgramInvocationException: The main method caused an error: Unable to instantiate java compiler by bigdata	1	by 冯嘉伟
	DynamicTableSource中Filter push down by jy l	0	by jy l
	DynamicTableSource中Filter push down by automths	0	by automths
	flink on yarn启动失败 by magichuang	2	by magichuang
	proctime in yaml ,sql-cli start throws exception by su_jun@cjspd.com	0	by su_jun@cjspd.com
	pyflink query 语句执行获取数据速度很慢，where子句不过滤数据么？ by 肖越	1	by r pp
	flink1.11.2写hive分区表，hive识别不到分区 by kingdomad	8	by admin
	flink1.10.1在idea执行dml时候报错Error during disposal of stream operator. java.lang.NullPointerException by bigdata	0	by bigdata
	flink 1.11.2 创建hive表的问题 by 曹武	1	by Rui Li
	dml执行报错Error during disposal of stream operator. java.lang.NullPointerException by bigdata	0	by bigdata
	pyflink query 语句执行获取数据速度很慢，where子句不过滤数据么？ by 肖越	0	by 肖越
	dml执行报错Error during disposal of stream operator. java.lang.NullPointerException by bigdata	0	by bigdata
	flink sql cdc流（1.11.2），双流join长时间运行后，试着取消job后，再从从checkpoint处恢复运行，报outofmemorry, tm的参数配置也没有变过，rocksdb后端。 这个可能原因是啥？运行的时候没报，为啥恢复的时间报了？ by jindy_liu	0	by jindy_liu
	pyflink 1.12 是不支持 通过sql 直接向数据库获取数据的操作么？ 没看到相关接口 by 肖越	2	by 肖越

1 ... 140141142143144145146 ... 215

Free forum by Nabble

Edit this page