Repository: incubator-gobblin Updated Branches: refs/heads/master 0afdc45c3 -> 35b894c2c
[GOBBLIN-335] Increase blob size of mysql Closes #2189 from autumnust/master Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/35b894c2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/35b894c2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/35b894c2 Branch: refs/heads/master Commit: 35b894c2cce2bcb4b0a347403f5f7048da3a3385 Parents: 0afdc45 Author: Lei Sun <[email protected]> Authored: Wed Dec 6 13:54:12 2017 -0800 Committer: Hung Tran <[email protected]> Committed: Wed Dec 6 13:54:12 2017 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/gobblin/metastore/MysqlStateStore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/35b894c2/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java ---------------------------------------------------------------------- diff --git a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java index 3e2b928..9756507 100644 --- a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java +++ b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java @@ -104,7 +104,7 @@ public class MysqlStateStore<T extends State> implements StateStore<T> { "CREATE TABLE IF NOT EXISTS $TABLE$ (store_name varchar(100) CHARACTER SET latin1 not null," + "table_name varchar(667) CHARACTER SET latin1 not null," + " modified_time timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP," - + " state mediumblob, primary key(store_name, table_name))"; + + " state longblob, primary key(store_name, table_name))"; private final String UPSERT_JOB_STATE_SQL; private final String SELECT_JOB_STATE_SQL;
