starrocks-connector-for-apache-flink

starrocks-connector-for-apache-flink copied to clipboard

## What type of PR is this： - [ ] BugFix - [ ] Feature ## Which issues of this PR fixes ： https://github.com/StarRocks/starrocks-connector-for-apache-flink/issues/323 Fixes # ## Problem Summary(Required) ：...

renzhimin7

renzhimin7

Bug in using streamload to synchronize data to starrocks through seatunnel

2

### Steps to reproduce the behavior (Required) 1. source engine : GreenPlum 2. seatunnel config info: { "sink": [{ "base-url": "jdbc:mysql://x.x.x.x:19030/dwd", "password": "xxx", "database": "dwd", "batch_max_rows": 64000, "max_retries": 10, "batch_max_bytes":...

cyd257666

## What type of PR is this： - [x] BugFix - [ ] Feature - [ ] Enhancement - [ ] Refactor - [ ] UT - [ ] Doc...

Jin-H

flink-connector-starrocks 读取json字段异常，空指针？

2

com.starrocks flink-connector-starrocks 1.2.3_flink-1.14_2.11 在类中报空指针（desc.getType()）异常，json字段的类型获取不到 public static StarRocksSchema genSchema(List tscanColumnDescs) { StarRocksSchema schema = new StarRocksSchema(); tscanColumnDescs.stream().forEach(desc -> schema.put( new Column(desc.getName(), desc.getType().name(), "", 0, 0)) ); return schema; } 需修改为以下代码，当字符串来处理： public...

TonyHowardPark

Snapshot state failed by prepare

1

有哪位同学遇到Snapshot state failed by prepare的问题吗，是不是哪里设置的不对，求教 2023-05-12 09:40:03 org.apache.flink.runtime.JobException: Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=15, backoffTimeMS=30000) at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:252) at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:242) at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:233) at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:684) at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:444)...

fly-shark

[Feature] Starrocks source should support obtaining JSON fields

3

Starrocks source should support obtaining JSON fields,at least.JSON type fields should be able to be obtained in string format.

wmtbnbo

[Enhancement] look function support partial cache

4

I found that the current connector supports the lookup function, but the implementation is to fully scan the table data and store it in the memory. If the table data...

Jin-H

public class StarRocksSourceCommonFunc { ... public static Map genColumnMap(TableSchema flinkSchema) ... } 可将TableSchema更换为org.apache.flink.table.api.Schema

aesirteam

有计划支持catalog的api吗

1

zouchangzhen