manager端口不能访问：KeeperException$NoNodeException: KeeperErrorCode = NoNode for /otter/channel/3

以你之姓@ 2022-07-12 10:39 132阅读 0赞

HTTP ERROR 500  
  
  
Problem accessing /channelList.htm. Reason:  
  
  
    Failed to invoke Valve\[\#2/3, level 3\]: com.alibaba.citrus.turbine.pipeline.valve.PerformTemplateScreenValve\#75eef270:PerformTemplateScreenValve  
Caused by:  
  
  
com.alibaba.citrus.service.pipeline.PipelineException: Failed to invoke Valve\[\#2/3, level 3\]: com.alibaba.citrus.turbine.pipeline.valve.PerformTemplateScreenValve\#75eef270:PerformTemplateScreenValve  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:161)  
 at com.alibaba.citrus.turbine.pipeline.valve.PerformActionValve.invoke(PerformActionValve.java:73)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invoke(PipelineImpl.java:210)  
 at com.alibaba.citrus.service.pipeline.impl.valve.ChooseValve.invoke(ChooseValve.java:98)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invoke(PipelineImpl.java:210)  
 at com.alibaba.citrus.service.pipeline.impl.valve.LoopValve.invokeBody(LoopValve.java:105)  
 at com.alibaba.citrus.service.pipeline.impl.valve.LoopValve.invoke(LoopValve.java:83)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.turbine.pipeline.valve.CheckCsrfTokenValve.invoke(CheckCsrfTokenValve.java:123)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.otter.manager.web.webx.valve.AuthContextValve.invoke(AuthContextValve.java:117)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.turbine.pipeline.valve.AnalyzeURLValve.invoke(AnalyzeURLValve.java:126)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.turbine.pipeline.valve.SetLoggingContextValve.invoke(SetLoggingContextValve.java:66)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.turbine.pipeline.valve.PrepareForTurbineValve.invoke(PrepareForTurbineValve.java:52)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invoke(PipelineImpl.java:210)  
 at com.alibaba.citrus.webx.impl.WebxControllerImpl.service(WebxControllerImpl.java:43)  
 at com.alibaba.citrus.webx.impl.WebxRootControllerImpl.handleRequest(WebxRootControllerImpl.java:53)  
 at com.alibaba.citrus.webx.support.AbstractWebxRootController.service(AbstractWebxRootController.java:165)  
 at com.alibaba.citrus.webx.servlet.WebxFrameworkFilter.doFilter(WebxFrameworkFilter.java:152)  
 at com.alibaba.citrus.webx.servlet.FilterBean.doFilter(FilterBean.java:147)  
 at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1307)  
 at com.alibaba.citrus.webx.servlet.SetLoggingContextFilter.doFilter(SetLoggingContextFilter.java:61)  
 at com.alibaba.citrus.webx.servlet.FilterBean.doFilter(FilterBean.java:147)  
 at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1307)  
 at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:453)  
 at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:137)  
 at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:559)  
 at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:231)  
 at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1072)  
 at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:382)  
 at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:193)  
 at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1006)  
 at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:135)  
 at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116)  
 at org.eclipse.jetty.server.Server.handle(Server.java:365)  
 at org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:485)  
 at org.eclipse.jetty.server.AbstractHttpConnection.headerComplete(AbstractHttpConnection.java:926)  
 at org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.headerComplete(AbstractHttpConnection.java:988)  
 at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:635)  
 at org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:235)  
 at org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82)  
 at org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:627)  
 at org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:51)  
 at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608)  
 at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543)  
 at java.lang.Thread.run(Thread.java:745)  
Caused by: com.alibaba.citrus.webx.WebxException: Failed to execute screen: ChannelList  
 at com.alibaba.citrus.turbine.pipeline.valve.PerformScreenValve.performScreenModule(PerformScreenValve.java:126)  
 at com.alibaba.citrus.turbine.pipeline.valve.PerformScreenValve.invoke(PerformScreenValve.java:74)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 ... 51 more  
Caused by: org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /otter/channel/3/1/process  
 at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47)  
 at com.alibaba.otter.shared.common.utils.zookeeper.ZkClientx.retryUntilConnected(ZkClientx.java:785)  
 at com.alibaba.otter.shared.common.utils.zookeeper.ZkClientx.getChildren(ZkClientx.java:511)  
 at com.alibaba.otter.shared.common.utils.zookeeper.ZkClientx.getChildren(ZkClientx.java:507)  
 at com.alibaba.otter.shared.arbitrate.impl.ArbitrateViewServiceImpl.listProcesses(ArbitrateViewServiceImpl.java:99)  
 at com.alibaba.otter.manager.biz.statistics.stage.impl.ProcessStatServiceImpl.listRealtimeProcessStat(ProcessStatServiceImpl.java:49)  
 at com.alibaba.otter.manager.web.home.module.screen.ChannelList.execute(ChannelList.java:94)  
 at com.alibaba.otter.manager.web.home.module.screen.ChannelList

FastClassByCGLIB

586d24fe.invoke(<generated>)  
 at net.sf.cglib.reflect.FastMethod.invoke(FastMethod.java:53)  
 at com.alibaba.citrus.service.moduleloader.impl.adapter.MethodInvoker.invoke(MethodInvoker.java:70)  
 at com.alibaba.citrus.service.moduleloader.impl.adapter.DataBindingAdapter.executeAndReturn(DataBindingAdapter.java:41)  
 at com.alibaba.citrus.turbine.pipeline.valve.PerformScreenValve.performScreenModule(PerformScreenValve.java:111)  
 at com.alibaba.citrus.turbine.pipeline.valve.PerformScreenValve.invoke(PerformScreenValve.java:74)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.turbine.pipeline.valve.PerformActionValve.invoke(PerformActionValve.java:73)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invoke(PipelineImpl.java:210)  
 at com.alibaba.citrus.service.pipeline.impl.valve.ChooseValve.invoke(ChooseValve.java:98)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invoke(PipelineImpl.java:210)  
 at com.alibaba.citrus.service.pipeline.impl.valve.LoopValve.invokeBody(LoopValve.java:105)  
 at com.alibaba.citrus.service.pipeline.impl.valve.LoopValve.invoke(LoopValve.java:83)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.turbine.pipeline.valve.CheckCsrfTokenValve.invoke(CheckCsrfTokenValve.java:123)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.otter.manager.web.webx.valve.AuthContextValve.invoke(AuthContextValve.java:117)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.turbine.pipeline.valve.AnalyzeURLValve.invoke(AnalyzeURLValve.java:126)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.turbine.pipeline.valve.SetLoggingContextValve.invoke(SetLoggingContextValve.java:66)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.turbine.pipeline.valve.PrepareForTurbineValve.invoke(PrepareForTurbineValve.java:52)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invokeNext(PipelineImpl.java:157)  
 at com.alibaba.citrus.service.pipeline.impl.PipelineImpl$PipelineContextImpl.invoke(PipelineImpl.java:210)  
 at com.alibaba.citrus.webx.impl.WebxControllerImpl.service(WebxControllerImpl.java:43)  
 at com.alibaba.citrus.webx.impl.WebxRootControllerImpl.handleRequest(WebxRootControllerImpl.java:53)  
 at com.alibaba.citrus.webx.support.AbstractWebxRootController.service(AbstractWebxRootController.java:165)  
 at com.alibaba.citrus.webx.servlet.WebxFrameworkFilter.doFilter(WebxFrameworkFilter.java:152)  
 at com.alibaba.citrus.webx.servlet.FilterBean.doFilter(FilterBean.java:147)  
 at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1307)  
 at com.alibaba.citrus.webx.servlet.SetLoggingContextFilter.doFilter(SetLoggingContextFilter.java:61)  
 at com.alibaba.citrus.webx.servlet.FilterBean.doFilter(FilterBean.java:147)  
 at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1307)  
 at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:453)  
 at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:137)  
 at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:559)  
 at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:231)  
 at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1072)  
 at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:382)  
 at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:193)  
 at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1006)  
 at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:135)  
 at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116)  
 at org.eclipse.jetty.server.Server.handle(Server.java:365)  
 at org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:485)  
 at org.eclipse.jetty.server.AbstractHttpConnection.headerComplete(AbstractHttpConnection.java:926)  
 at org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.headerComplete(AbstractHttpConnection.java:988)  
 at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:635)  
 at org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:235)  
 at org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82)  
 at org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:627)  
 at org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:51)  
 at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608)  
 at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543)  
 at java.lang.Thread.run(Thread.java:745)  
Powered by Jetty://  
  
  
  
  
  
  
  
  
otter会在zookeeper存储一些节点信息，更换zookeeper后，需要复制节点数据，或者删除数据库中的channel、pipeline等表的数据内容  
删除原来的元数据库并重新创建  
具体如下：  
mysql -u root -p   
mysql> use 元数据库名;  
mysql> drop 元数据库名;  
mysql>create database 元数据库名;  
mysql> use 元数据库名;  
  
  
  
  
  
  
sql语句：  
CREATE TABLE \`ALARM\_RULE\` (  
  \`ID\` bigint(20) unsigned NOT NULL AUTO\_INCREMENT,  
  \`MONITOR\_NAME\` varchar(1024) DEFAULT NULL,  
  \`RECEIVER\_KEY\` varchar(1024) DEFAULT NULL,  
  \`STATUS\` varchar(32) DEFAULT NULL,  
  \`PIPELINE\_ID\` bigint(20) NOT NULL,  
  \`DESCRIPTION\` varchar(256) DEFAULT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  \`MATCH\_VALUE\` varchar(1024) DEFAULT NULL,  
  \`PARAMETERS\` text DEFAULT NULL,  
  PRIMARY KEY (\`ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`AUTOKEEPER\_CLUSTER\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`CLUSTER\_NAME\` varchar(200) NOT NULL,  
  \`SERVER\_LIST\` varchar(1024) NOT NULL,  
  \`DESCRIPTION\` varchar(200) DEFAULT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`CANAL\` (  
  \`ID\` bigint(20) unsigned NOT NULL AUTO\_INCREMENT,  
  \`NAME\` varchar(200) DEFAULT NULL,  
  \`DESCRIPTION\` varchar(200) DEFAULT NULL,  
  \`PARAMETERS\` text DEFAULT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  UNIQUE KEY \`CANALUNIQUE\` (\`NAME\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`CHANNEL\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`NAME\` varchar(200) NOT NULL,  
  \`DESCRIPTION\` varchar(200) DEFAULT NULL,  
  \`PARAMETERS\` text DEFAULT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  UNIQUE KEY \`CHANNELUNIQUE\` (\`NAME\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`COLUMN\_PAIR\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`SOURCE\_COLUMN\` varchar(200) DEFAULT NULL,  
  \`TARGET\_COLUMN\` varchar(200) DEFAULT NULL,  
  \`DATA\_MEDIA\_PAIR\_ID\` bigint(20) NOT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  KEY \`idx\_DATA\_MEDIA\_PAIR\_ID\` (\`DATA\_MEDIA\_PAIR\_ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`COLUMN\_PAIR\_GROUP\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`DATA\_MEDIA\_PAIR\_ID\` bigint(20) NOT NULL,  
  \`COLUMN\_PAIR\_CONTENT\` text DEFAULT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  KEY \`idx\_DATA\_MEDIA\_PAIR\_ID\` (\`DATA\_MEDIA\_PAIR\_ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`DATA\_MEDIA\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`NAME\` varchar(200) NOT NULL,  
  \`NAMESPACE\` varchar(200) NOT NULL,  
  \`PROPERTIES\` varchar(1000) NOT NULL,  
  \`DATA\_MEDIA\_SOURCE\_ID\` bigint(20) NOT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  UNIQUE KEY \`DATAMEDIAUNIQUE\` (\`NAME\`,\`NAMESPACE\`,\`DATA\_MEDIA\_SOURCE\_ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`DATA\_MEDIA\_PAIR\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`PULLWEIGHT\` bigint(20) DEFAULT NULL,  
  \`PUSHWEIGHT\` bigint(20) DEFAULT NULL,  
  \`RESOLVER\` text DEFAULT NULL,  
  \`FILTER\` text DEFAULT NULL,  
  \`SOURCE\_DATA\_MEDIA\_ID\` bigint(20) DEFAULT NULL,  
  \`TARGET\_DATA\_MEDIA\_ID\` bigint(20) DEFAULT NULL,  
  \`PIPELINE\_ID\` bigint(20) NOT NULL,  
  \`COLUMN\_PAIR\_MODE\` varchar(20) DEFAULT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  KEY \`idx\_PipelineID\` (\`PIPELINE\_ID\`,\`ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`DATA\_MEDIA\_SOURCE\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`NAME\` varchar(200) NOT NULL,  
  \`TYPE\` varchar(20) NOT NULL,  
  \`PROPERTIES\` varchar(1000) NOT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  UNIQUE KEY \`DATAMEDIASOURCEUNIQUE\` (\`NAME\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`DELAY\_STAT\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`DELAY\_TIME\` int(21) NOT NULL,  
  \`DELAY\_NUMBER\` bigint(20) NOT NULL,  
  \`PIPELINE\_ID\` bigint(20) NOT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  KEY \`idx\_PipelineID\_GmtModified\_ID\` (\`PIPELINE\_ID\`,\`GMT\_MODIFIED\`,\`ID\`),  
  KEY \`idx\_Pipeline\_GmtCreate\` (\`PIPELINE\_ID\`,\`GMT\_CREATE\`),  
  KEY \`idx\_GmtCreate\_id\` (\`GMT\_CREATE\`,\`ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`LOG\_RECORD\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`NID\` varchar(200) DEFAULT NULL,  
  \`CHANNEL\_ID\` varchar(200) NOT NULL,  
  \`PIPELINE\_ID\` varchar(200) NOT NULL,  
  \`TITLE\` varchar(1000) DEFAULT NULL,  
  \`MESSAGE\` text DEFAULT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  KEY \`pipeline\_id\_record\` (\`PIPELINE\_ID\`),  
  KEY \`logRecord\_pipelineId\` (\`PIPELINE\_ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`NODE\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`NAME\` varchar(200) NOT NULL,  
  \`IP\` varchar(200) NOT NULL,  
  \`PORT\` bigint(20) NOT NULL,  
  \`DESCRIPTION\` varchar(200) DEFAULT NULL,  
  \`PARAMETERS\` text DEFAULT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  UNIQUE KEY \`NODEUNIQUE\` (\`NAME\`,\`IP\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`PIPELINE\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`NAME\` varchar(200) NOT NULL,  
  \`DESCRIPTION\` varchar(200) DEFAULT NULL,  
  \`PARAMETERS\` text DEFAULT NULL,  
  \`CHANNEL\_ID\` bigint(20) NOT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  UNIQUE KEY \`PIPELINEUNIQUE\` (\`NAME\`,\`CHANNEL\_ID\`),  
  KEY \`idx\_ChannelID\` (\`CHANNEL\_ID\`,\`ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`PIPELINE\_NODE\_RELATION\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`NODE\_ID\` bigint(20) NOT NULL,  
  \`PIPELINE\_ID\` bigint(20) NOT NULL,  
  \`LOCATION\` varchar(20) NOT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  KEY \`idx\_PipelineID\` (\`PIPELINE\_ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`SYSTEM\_PARAMETER\` (  
  \`ID\` bigint(20) unsigned NOT NULL,  
  \`VALUE\` text DEFAULT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`)  
) ENGINE=InnoDB DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`TABLE\_HISTORY\_STAT\` (  
  \`ID\` bigint(20) unsigned NOT NULL AUTO\_INCREMENT,  
  \`FILE\_SIZE\` bigint(20) DEFAULT NULL,  
  \`FILE\_COUNT\` bigint(20) DEFAULT NULL,  
  \`INSERT\_COUNT\` bigint(20) DEFAULT NULL,  
  \`UPDATE\_COUNT\` bigint(20) DEFAULT NULL,  
  \`DELETE\_COUNT\` bigint(20) DEFAULT NULL,  
  \`DATA\_MEDIA\_PAIR\_ID\` bigint(20) DEFAULT NULL,  
  \`PIPELINE\_ID\` bigint(20) DEFAULT NULL,  
  \`START\_TIME\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`END\_TIME\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  KEY \`idx\_DATA\_MEDIA\_PAIR\_ID\_END\_TIME\` (\`DATA\_MEDIA\_PAIR\_ID\`,\`END\_TIME\`),  
  KEY \`idx\_GmtCreate\_id\` (\`GMT\_CREATE\`,\`ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`TABLE\_STAT\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`FILE\_SIZE\` bigint(20) NOT NULL,  
  \`FILE\_COUNT\` bigint(20) NOT NULL,  
  \`INSERT\_COUNT\` bigint(20) NOT NULL,  
  \`UPDATE\_COUNT\` bigint(20) NOT NULL,  
  \`DELETE\_COUNT\` bigint(20) NOT NULL,  
  \`DATA\_MEDIA\_PAIR\_ID\` bigint(20) NOT NULL,  
  \`PIPELINE\_ID\` bigint(20) NOT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  KEY \`idx\_PipelineID\_DataMediaPairID\` (\`PIPELINE\_ID\`,\`DATA\_MEDIA\_PAIR\_ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`THROUGHPUT\_STAT\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`TYPE\` varchar(20) NOT NULL,  
  \`NUMBER\` bigint(20) NOT NULL,  
  \`SIZE\` bigint(20) NOT NULL,  
  \`PIPELINE\_ID\` bigint(20) NOT NULL,  
  \`START\_TIME\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`END\_TIME\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  KEY \`idx\_PipelineID\_Type\_GmtCreate\_ID\` (\`PIPELINE\_ID\`,\`TYPE\`,\`GMT\_CREATE\`,\`ID\`),  
  KEY \`idx\_PipelineID\_Type\_EndTime\_ID\` (\`PIPELINE\_ID\`,\`TYPE\`,\`END\_TIME\`,\`ID\`),  
  KEY \`idx\_GmtCreate\_id\` (\`GMT\_CREATE\`,\`ID\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE \`USER\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`USERNAME\` varchar(20) NOT NULL,  
  \`PASSWORD\` varchar(20) NOT NULL,  
  \`AUTHORIZETYPE\` varchar(20) NOT NULL,  
  \`DEPARTMENT\` varchar(20) NOT NULL,  
  \`REALNAME\` varchar(20) NOT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  UNIQUE KEY \`USERUNIQUE\` (\`USERNAME\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
CREATE TABLE  \`DATA\_MATRIX\` (  
  \`ID\` bigint(20) NOT NULL AUTO\_INCREMENT,  
  \`GROUP\_KEY\` varchar(200) DEFAULT NULL,  
  \`MASTER\` varchar(200) DEFAULT NULL,  
  \`SLAVE\` varchar(200) DEFAULT NULL,  
  \`DESCRIPTION\` varchar(200) DEFAULT NULL,  
  \`GMT\_CREATE\` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00',  
  \`GMT\_MODIFIED\` timestamp NOT NULL DEFAULT CURRENT\_TIMESTAMP ON UPDATE CURRENT\_TIMESTAMP,  
  PRIMARY KEY (\`ID\`),  
  KEY \`GROUPKEY\` (\`GROUP\_KEY\`)  
) ENGINE=InnoDB AUTO\_INCREMENT=1 DEFAULT CHARSET=utf8;  
  
  
  
  
insert into USER(ID,USERNAME,PASSWORD,AUTHORIZETYPE,DEPARTMENT,REALNAME,GMT\_CREATE,GMT\_MODIFIED) values(null,'admin','801fc357a5a74743894a','ADMIN','admin','admin',now(),now());  
insert into USER(ID,USERNAME,PASSWORD,AUTHORIZETYPE,DEPARTMENT,REALNAME,GMT\_CREATE,GMT\_MODIFIED) values(null,'guest','471e02a154a2121dc577','OPERATOR','guest','guest',now(),now());