Skip To Main Content
getRuntime Context on Muck Rack

getRuntime Context

As seen in: cnblogs.com, CSDN
Is this you? As a journalist, you can create a free Muck Rack account to customize your profile, list your contact preferences, and upload a portfolio of your best work. Claim your profile
Back to getRuntime Context’s profile

Articles by getRuntime Context

Flink 中kafka broker缩容导致Task一直重启

|
By Enablecommit OnCheckpoints, getRuntime Context, offsetCommit Mode, Abstract PartitionDiscoverer.discoverPartitions
| CSDN
Flink版本 1.12.2 Kafka 客户端 2.4.1 在公司的Flink平台运行了一个读Kafka计算DAU的流程序，由于公司Kafka的缩容，直接导致了该程序一直在重启，重启了一个小时都还没恢复（具体的所容操作是下掉了四台kafka broker，而当时flink配置了12台kafka broker），当时具体的现场如下： JobManaer上的日志如下： 2023-10-07 10:02:52.975 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: TableSourceScan(table=[[default_catalog, default_database, ubt_start, watermark=[-(LOCALTIMESTAMP, 1000:INTERVAL SECOND)]]]) (34/64) (e33d9ad0196a71e8eb551c181eb779b5) switched from RUNNING to FAILED on...
Open in Who Shared Issue with article?

基于chunjun纯钧的增量数据同步问题排查【博客园-实习小生】 - 实习小生 - 博客园

|
By return constructor.newInstance, getRuntime Context
| cnblogs.com
chunjun的官网文档对增量同步已经做出了一定的说明 纯钧官方 根据文档我编写了一个SQL脚本 create table `source` ( `sfzh` STRING COMMENT '', `xm` STRING COMMENT '', `xb` STRING COMMENT '', `xbdm` STRING COMMENT '', `jzdz` STRING COMMENT '', `fzrq` DATE COMMENT '', `dsc_biz_record_id` STRING COMMENT '' ) with ( 'connector' = 'mysql-x', 'url' = 'jdbc:mysql://:/?useSSL=false&useInformationSchema=true&nullCatalogMeansCurrent=true', 'table-name' = '', 'username' = '', 'password' = '', 'scan.fetch-size' = '1024', 'scan.increment.column' =...
Open in Who Shared Issue with article?
Show More