TiBigData

TiBigData copied to clipboard

sunxiaoguang

- [ ] #129 - [ ] design doc - [ ] test plan ......

sunxiaoguang

DDL ``` CREATE TABLE if not exists table_a ( `user_id` BIGINT NULL COMMENT '', `id` BIGINT NULL COMMENT '', `position_id` BIGINT NULL COMMENT '', `status` STRING NULL COMMENT '', `transaction_id`...

pyscala

Unable to start Trino after using PrestoSQL-TiDB-Connector

6

I followed this doc to build the connector and the build finished successfully. https://github.com/tidb-incubator/TiBigData/tree/master/prestosql my tidb plugin folder content as blew: ``` root@trino-worker01:/home/trino/trino-server-361/etc/catalog# ls -l /home/trino/trino-server-361/plugin/tidb/ total 38940 -rw-r--r-- 1...

myheartsgoon

Any plans to publish TiDB Flink connector to Maven Central Repository?

8

Hi there, Integrating TiDB with Flink is a great idea, as Flink is superb in real-time computing and TiDB is suitable for quick data access. However, I found that the...

kylemeow

Presto query error: getConnectorPlanOptimizers()

3

Hi there, I was testing TiBigData recently and successfully compiled. But when I used Presto to query, the following error was reported: io.tidb.bigdata.prestodb.tidb.optimization.TiDBPlanOptimizerProvider.getConnectorPlanOptimizers()Ljava/util/Set; Is there anyone konws what happend and...

7A6A78

presto 查询tidb 日期错误

14

你好 这边使用tidb驱动出现的问题，如下图 CREATE TABLE `receiving` ( `receiving_id` int(11) NOT NULL, `expected_date` date NOT NULL DEFAULT '0000-00-00', UNIQUE KEY `udx_receiving_id` (`receiving_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin; 使用presto tidb驱动查询 和使用mysql驱动查询  

wangfeigithub

Timestamp format must be yyyy-mm-dd hh:mm:ss[.fffffffff]

4

public class TidbAlarmClearUp { public static void main(String[] args) throws Exception { //运行job String jobName = TidbAlarmClearUp.class.getSimpleName(); // set up the streaming execution environment StreamExecutionEnvironment bsEnv = StreamExecutionEnvironment.getExecutionEnvironment(); EnvironmentSettings bsSettings...

lookhua

Table db.table no longer exists in TiDB

1

使用tibigdata整合flink读取数据时，程序出现 java.lang.IllegalStateException: Table `db`.`table` no longer exists in TiDB at io.tidb.bigdata.tidb.ClientSession.lambda$getTableMust$0(ClientSession.java:181) ~[flink-tidb-connector-1.13-0.0.5-SNAPSHOT.jar:?] at java.util.Optional.orElseThrow(Optional.java:290) ~[?:1.8.0_281] at io.tidb.bigdata.tidb.ClientSession.getTableMust(ClientSession.java:178) ~[flink-tidb-connector-1.13-0.0.5-SNAPSHOT.jar:?] at io.tidb.bigdata.tidb.ClientSession.getTableMust(ClientSession.java:173) ~[flink-tidb-connector-1.13-0.0.5-SNAPSHOT.jar:?] at io.tidb.bigdata.tidb.ClientSession.request(ClientSession.java:290) ~[flink-tidb-connector-1.13-0.0.5-SNAPSHOT.jar:?] at io.tidb.bigdata.tidb.RecordSetInternal.(RecordSetInternal.java:61) ~[flink-tidb-connector-1.13-0.0.5-SNAPSHOT.jar:?] at io.tidb.bigdata.flink.connector.source.reader.TiDBSourceReader.tryMoveToNextSplit(TiDBSourceReader.java:122) ~[flink-tidb-connector-1.13-0.0.5-SNAPSHOT.jar:?]...

juecong

Optimize tidb-core module API

3

## What is the purpose of the change Reduce the number of RPC getTable calls. ## Brief change log 1. add a new field named titableinfo in `io.tidb.bigdata.tidb.handle.TableHandleInternal` to storead...

humengyu2012