Skip to content

K
kettle_yuejuan_new
Commit 4b6ab3c0 by zsy
Options

zsy

parent c331f9d8
Showing with 672 additions and 564 deletions
.idea/inspectionProfiles/Project_Default.xml 0 → 100644
<component name="InspectionProjectProfileManager">
<profile version="1.0">
<option name="myName" value="Project Default" />
<inspection_tool class="JavaDoc" enabled="true" level="WARNING" enabled_by_default="true">
<option name="TOP_LEVEL_CLASS_OPTIONS">
<value>
<option name="ACCESS_JAVADOC_REQUIRED_FOR" value="none" />
<option name="REQUIRED_TAGS" value="" />
</value>
</option>
<option name="INNER_CLASS_OPTIONS">
<value>
<option name="ACCESS_JAVADOC_REQUIRED_FOR" value="none" />
<option name="REQUIRED_TAGS" value="" />
</value>
</option>
<option name="METHOD_OPTIONS">
<value>
<option name="ACCESS_JAVADOC_REQUIRED_FOR" value="none" />
<option name="REQUIRED_TAGS" value="@return@param@throws or @exception" />
</value>
</option>
<option name="FIELD_OPTIONS">
<value>
<option name="ACCESS_JAVADOC_REQUIRED_FOR" value="none" />
<option name="REQUIRED_TAGS" value="" />
</value>
</option>
<option name="IGNORE_DEPRECATED" value="false" />
<option name="IGNORE_JAVADOC_PERIOD" value="true" />
<option name="IGNORE_DUPLICATED_THROWS" value="false" />
<option name="IGNORE_POINT_TO_ITSELF" value="false" />
<option name="myAdditionalJavadocTags" value="date" />
</inspection_tool>
</profile>
</component>
\ No newline at end of file
.idea/vcs.xml
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<project version="4"> <project version="4">
<component name="GitSharedSettings">
<option name="FORCE_PUSH_PROHIBITED_PATTERNS">
<list>
<option value="dev" />
</list>
</option>
</component>
<component name="VcsDirectoryMappings"> <component name="VcsDirectoryMappings">
<mapping directory="" vcs="Git" /> <mapping directory="" vcs="Git" />
</component> </component>
......
monitor_intelligent_test/union_yuejuan_monitor/transfer/source/bus_exam_question_del_log.ktr
<transformation> <transformation>
<info> <info>
<name>bus_exam_question_del_log</name> <name>bus_exam_question_del_log</name>
<description /> <description/>
<extended_description /> <extended_description/>
<trans_version /> <trans_version/>
<trans_type>Normal</trans_type> <trans_type>Normal</trans_type>
<directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory> <directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory>
<parameters> <parameters>
</parameters> </parameters>
<log> <log>
<trans-log-table> <trans-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<size_limit_lines /> <size_limit_lines/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -40,37 +40,37 @@ ...@@ -40,37 +40,37 @@
<id>LINES_READ</id> <id>LINES_READ</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_READ</name> <name>LINES_READ</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_WRITTEN</id> <id>LINES_WRITTEN</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_WRITTEN</name> <name>LINES_WRITTEN</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_UPDATED</id> <id>LINES_UPDATED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_UPDATED</name> <name>LINES_UPDATED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_INPUT</id> <id>LINES_INPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_INPUT</name> <name>LINES_INPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_OUTPUT</id> <id>LINES_OUTPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_OUTPUT</name> <name>LINES_OUTPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_REJECTED</id> <id>LINES_REJECTED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_REJECTED</name> <name>LINES_REJECTED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>ERRORS</id> <id>ERRORS</id>
...@@ -124,11 +124,11 @@ ...@@ -124,11 +124,11 @@
</field> </field>
</trans-log-table> </trans-log-table>
<perf-log-table> <perf-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -206,10 +206,10 @@ ...@@ -206,10 +206,10 @@
</field> </field>
</perf-log-table> </perf-log-table>
<channel-log-table> <channel-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -272,10 +272,10 @@ ...@@ -272,10 +272,10 @@
</field> </field>
</channel-log-table> </channel-log-table>
<step-log-table> <step-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -348,10 +348,10 @@ ...@@ -348,10 +348,10 @@
</field> </field>
</step-log-table> </step-log-table>
<metrics-log-table> <metrics-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -400,9 +400,9 @@ ...@@ -400,9 +400,9 @@
</metrics-log-table> </metrics-log-table>
</log> </log>
<maxdate> <maxdate>
<connection /> <connection/>
<table /> <table/>
<field /> <field/>
<offset>0.0</offset> <offset>0.0</offset>
<maxdiff>0.0</maxdiff> <maxdiff>0.0</maxdiff>
</maxdate> </maxdate>
...@@ -413,7 +413,7 @@ ...@@ -413,7 +413,7 @@
<feedback_shown>Y</feedback_shown> <feedback_shown>Y</feedback_shown>
<feedback_size>50000</feedback_size> <feedback_size>50000</feedback_size>
<using_thread_priorities>Y</using_thread_priorities> <using_thread_priorities>Y</using_thread_priorities>
<shared_objects_file /> <shared_objects_file/>
<capture_step_performance>N</capture_step_performance> <capture_step_performance>N</capture_step_performance>
<step_performance_capturing_delay>1000</step_performance_capturing_delay> <step_performance_capturing_delay>1000</step_performance_capturing_delay>
<step_performance_capturing_size_limit>100</step_performance_capturing_size_limit> <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
...@@ -425,29 +425,37 @@ ...@@ -425,29 +425,37 @@
</slaveservers> </slaveservers>
<clusterschemas> <clusterschemas>
</clusterschemas> </clusterschemas>
<created_user /> <created_user/>
<created_date>2020/10/24 10:53:15.595</created_date> <created_date>2020/10/27 07:07:09.893</created_date>
<modified_user>admin</modified_user> <modified_user>admin</modified_user>
<modified_date>2020/10/16 13:17:21.532</modified_date> <modified_date>2020/10/27 07:10:20.352</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private> <is_key_private>N</is_key_private>
</info> </info>
<notepads> <notepads>
</notepads> </notepads>
<connection> <connection>
<name>intelligent_union_yuejuan_mongo_test</name> <name>intelligent_union_yuejuan_test_neiwang</name>
<server>mysql.dev.jtyjy.com</server> <server>192.168.2.244</server>
<type>MYSQL</type> <type>MYSQL</type>
<access>Native</access> <access>Native</access>
<database>union_yuejuan_mongo</database> <database>union_yuejuan_test</database>
<port>13306</port> <port>3306</port>
<username>dev</username> <username>dev</username>
<password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password> <password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password>
<servername /> <servername/>
<data_tablespace /> <data_tablespace/>
<index_tablespace /> <index_tablespace/>
<attributes> <attributes>
<attribute> <attribute>
<code>EXTRA_OPTION_MYSQL.defaultFetchSize</code>
<attribute>500</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.useCursorFetch</code>
<attribute>true</attribute>
</attribute>
<attribute>
<code>FORCE_IDENTIFIERS_TO_LOWERCASE</code> <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
<attribute>N</attribute> <attribute>N</attribute>
</attribute> </attribute>
...@@ -461,7 +469,7 @@ ...@@ -461,7 +469,7 @@
</attribute> </attribute>
<attribute> <attribute>
<code>PORT_NUMBER</code> <code>PORT_NUMBER</code>
<attribute>13306</attribute> <attribute>3306</attribute>
</attribute> </attribute>
<attribute> <attribute>
<code>PRESERVE_RESERVED_WORD_CASE</code> <code>PRESERVE_RESERVED_WORD_CASE</code>
...@@ -499,13 +507,13 @@ ...@@ -499,13 +507,13 @@
<step> <step>
<name>Text file output</name> <name>Text file output</name>
<type>TextFileOutput</type> <type>TextFileOutput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<separator> </separator> <separator> </separator>
<enclosure>"</enclosure> <enclosure>"</enclosure>
...@@ -516,9 +524,9 @@ ...@@ -516,9 +524,9 @@
<format>UNIX</format> <format>UNIX</format>
<compression>None</compression> <compression>None</compression>
<encoding>UTF-8</encoding> <encoding>UTF-8</encoding>
<endedLine /> <endedLine/>
<fileNameInField>N</fileNameInField> <fileNameInField>N</fileNameInField>
<fileNameField /> <fileNameField/>
<create_parent_folder>Y</create_parent_folder> <create_parent_folder>Y</create_parent_folder>
<file> <file>
<name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_exam_question_del_log</name> <name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_exam_question_del_log</name>
...@@ -535,12 +543,12 @@ ...@@ -535,12 +543,12 @@
<add_to_result_filenames>Y</add_to_result_filenames> <add_to_result_filenames>Y</add_to_result_filenames>
<pad>N</pad> <pad>N</pad>
<fast_dump>N</fast_dump> <fast_dump>N</fast_dump>
<splitevery /> <splitevery/>
</file> </file>
<fields> <fields>
</fields> </fields>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -556,15 +564,15 @@ ...@@ -556,15 +564,15 @@
<step> <step>
<name>bus_exam_question_del_log</name> <name>bus_exam_question_del_log</name>
<type>TableInput</type> <type>TableInput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<connection>intelligent_union_yuejuan_mongo_test</connection> <connection>intelligent_union_yuejuan_test_neiwang</connection>
<sql>select <sql>select
id, id,
exam_id, exam_id,
...@@ -574,14 +582,14 @@ question_config_id, ...@@ -574,14 +582,14 @@ question_config_id,
create_time, create_time,
record_id record_id
from bus_exam_question_del_log from bus_exam_question_del_log
where create_time>'${start_time1}' and create_time&lt;='${end_time1}';</sql> where create_time&gt;'${start_time1}' and create_time&lt;='${end_time1}';</sql>
<limit>0</limit> <limit>0</limit>
<lookup /> <lookup/>
<execute_each_row>N</execute_each_row> <execute_each_row>N</execute_each_row>
<variables_active>Y</variables_active> <variables_active>Y</variables_active>
<lazy_conversion_active>N</lazy_conversion_active> <lazy_conversion_active>N</lazy_conversion_active>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -599,5 +607,5 @@ where create_time>'${start_time1}' and create_time&lt;='${end_time1}';</sql> ...@@ -599,5 +607,5 @@ where create_time>'${start_time1}' and create_time&lt;='${end_time1}';</sql>
<slave-step-copy-partition-distribution> <slave-step-copy-partition-distribution>
</slave-step-copy-partition-distribution> </slave-step-copy-partition-distribution>
<slave_transformation>N</slave_transformation> <slave_transformation>N</slave_transformation>
<attributes /> <attributes/>
</transformation> </transformation>
monitor_intelligent_test/union_yuejuan_monitor/transfer/source/bus_marking_judgment_task.ktr
<transformation> <transformation>
<info> <info>
<name>bus_marking_judgment_task</name> <name>bus_marking_judgment_task</name>
<description /> <description/>
<extended_description /> <extended_description/>
<trans_version /> <trans_version/>
<trans_type>Normal</trans_type> <trans_type>Normal</trans_type>
<directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory> <directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory>
<parameters> <parameters>
</parameters> </parameters>
<log> <log>
<trans-log-table> <trans-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<size_limit_lines /> <size_limit_lines/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -40,37 +40,37 @@ ...@@ -40,37 +40,37 @@
<id>LINES_READ</id> <id>LINES_READ</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_READ</name> <name>LINES_READ</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_WRITTEN</id> <id>LINES_WRITTEN</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_WRITTEN</name> <name>LINES_WRITTEN</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_UPDATED</id> <id>LINES_UPDATED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_UPDATED</name> <name>LINES_UPDATED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_INPUT</id> <id>LINES_INPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_INPUT</name> <name>LINES_INPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_OUTPUT</id> <id>LINES_OUTPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_OUTPUT</name> <name>LINES_OUTPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_REJECTED</id> <id>LINES_REJECTED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_REJECTED</name> <name>LINES_REJECTED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>ERRORS</id> <id>ERRORS</id>
...@@ -124,11 +124,11 @@ ...@@ -124,11 +124,11 @@
</field> </field>
</trans-log-table> </trans-log-table>
<perf-log-table> <perf-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -206,10 +206,10 @@ ...@@ -206,10 +206,10 @@
</field> </field>
</perf-log-table> </perf-log-table>
<channel-log-table> <channel-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -272,10 +272,10 @@ ...@@ -272,10 +272,10 @@
</field> </field>
</channel-log-table> </channel-log-table>
<step-log-table> <step-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -348,10 +348,10 @@ ...@@ -348,10 +348,10 @@
</field> </field>
</step-log-table> </step-log-table>
<metrics-log-table> <metrics-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -400,9 +400,9 @@ ...@@ -400,9 +400,9 @@
</metrics-log-table> </metrics-log-table>
</log> </log>
<maxdate> <maxdate>
<connection /> <connection/>
<table /> <table/>
<field /> <field/>
<offset>0.0</offset> <offset>0.0</offset>
<maxdiff>0.0</maxdiff> <maxdiff>0.0</maxdiff>
</maxdate> </maxdate>
...@@ -413,7 +413,7 @@ ...@@ -413,7 +413,7 @@
<feedback_shown>Y</feedback_shown> <feedback_shown>Y</feedback_shown>
<feedback_size>50000</feedback_size> <feedback_size>50000</feedback_size>
<using_thread_priorities>Y</using_thread_priorities> <using_thread_priorities>Y</using_thread_priorities>
<shared_objects_file /> <shared_objects_file/>
<capture_step_performance>N</capture_step_performance> <capture_step_performance>N</capture_step_performance>
<step_performance_capturing_delay>1000</step_performance_capturing_delay> <step_performance_capturing_delay>1000</step_performance_capturing_delay>
<step_performance_capturing_size_limit>100</step_performance_capturing_size_limit> <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
...@@ -425,29 +425,37 @@ ...@@ -425,29 +425,37 @@
</slaveservers> </slaveservers>
<clusterschemas> <clusterschemas>
</clusterschemas> </clusterschemas>
<created_user /> <created_user/>
<created_date>2020/10/24 10:53:15.615</created_date> <created_date>2020/10/27 07:07:09.920</created_date>
<modified_user>admin</modified_user> <modified_user>admin</modified_user>
<modified_date>2020/10/21 11:46:32.487</modified_date> <modified_date>2020/10/27 07:10:10.315</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private> <is_key_private>N</is_key_private>
</info> </info>
<notepads> <notepads>
</notepads> </notepads>
<connection> <connection>
<name>intelligent_union_yuejuan_mongo_test</name> <name>intelligent_union_yuejuan_test_neiwang</name>
<server>mysql.dev.jtyjy.com</server> <server>192.168.2.244</server>
<type>MYSQL</type> <type>MYSQL</type>
<access>Native</access> <access>Native</access>
<database>union_yuejuan_mongo</database> <database>union_yuejuan_test</database>
<port>13306</port> <port>3306</port>
<username>dev</username> <username>dev</username>
<password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password> <password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password>
<servername /> <servername/>
<data_tablespace /> <data_tablespace/>
<index_tablespace /> <index_tablespace/>
<attributes> <attributes>
<attribute> <attribute>
<code>EXTRA_OPTION_MYSQL.defaultFetchSize</code>
<attribute>500</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.useCursorFetch</code>
<attribute>true</attribute>
</attribute>
<attribute>
<code>FORCE_IDENTIFIERS_TO_LOWERCASE</code> <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
<attribute>N</attribute> <attribute>N</attribute>
</attribute> </attribute>
...@@ -461,7 +469,7 @@ ...@@ -461,7 +469,7 @@
</attribute> </attribute>
<attribute> <attribute>
<code>PORT_NUMBER</code> <code>PORT_NUMBER</code>
<attribute>13306</attribute> <attribute>3306</attribute>
</attribute> </attribute>
<attribute> <attribute>
<code>PRESERVE_RESERVED_WORD_CASE</code> <code>PRESERVE_RESERVED_WORD_CASE</code>
...@@ -499,13 +507,13 @@ ...@@ -499,13 +507,13 @@
<step> <step>
<name>Text file output</name> <name>Text file output</name>
<type>TextFileOutput</type> <type>TextFileOutput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<separator> </separator> <separator> </separator>
<enclosure>"</enclosure> <enclosure>"</enclosure>
...@@ -516,9 +524,9 @@ ...@@ -516,9 +524,9 @@
<format>UNIX</format> <format>UNIX</format>
<compression>None</compression> <compression>None</compression>
<encoding>UTF-8</encoding> <encoding>UTF-8</encoding>
<endedLine /> <endedLine/>
<fileNameInField>N</fileNameInField> <fileNameInField>N</fileNameInField>
<fileNameField /> <fileNameField/>
<create_parent_folder>Y</create_parent_folder> <create_parent_folder>Y</create_parent_folder>
<file> <file>
<name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_marking_judgment_task</name> <name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_marking_judgment_task</name>
...@@ -535,12 +543,12 @@ ...@@ -535,12 +543,12 @@
<add_to_result_filenames>Y</add_to_result_filenames> <add_to_result_filenames>Y</add_to_result_filenames>
<pad>N</pad> <pad>N</pad>
<fast_dump>N</fast_dump> <fast_dump>N</fast_dump>
<splitevery /> <splitevery/>
</file> </file>
<fields> <fields>
</fields> </fields>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -556,15 +564,15 @@ ...@@ -556,15 +564,15 @@
<step> <step>
<name>bus_marking_judgment_task</name> <name>bus_marking_judgment_task</name>
<type>TableInput</type> <type>TableInput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<connection>intelligent_union_yuejuan_mongo_test</connection> <connection>intelligent_union_yuejuan_test_neiwang</connection>
<sql>select <sql>select
id, id,
question_config_id, question_config_id,
...@@ -578,12 +586,12 @@ modify_id, ...@@ -578,12 +586,12 @@ modify_id,
modify_time modify_time
from bus_marking_judgment_task;</sql> from bus_marking_judgment_task;</sql>
<limit>0</limit> <limit>0</limit>
<lookup /> <lookup/>
<execute_each_row>N</execute_each_row> <execute_each_row>N</execute_each_row>
<variables_active>Y</variables_active> <variables_active>Y</variables_active>
<lazy_conversion_active>N</lazy_conversion_active> <lazy_conversion_active>N</lazy_conversion_active>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -601,5 +609,5 @@ from bus_marking_judgment_task;</sql> ...@@ -601,5 +609,5 @@ from bus_marking_judgment_task;</sql>
<slave-step-copy-partition-distribution> <slave-step-copy-partition-distribution>
</slave-step-copy-partition-distribution> </slave-step-copy-partition-distribution>
<slave_transformation>N</slave_transformation> <slave_transformation>N</slave_transformation>
<attributes /> <attributes/>
</transformation> </transformation>
monitor_intelligent_test/union_yuejuan_monitor/transfer/source/bus_marking_person.ktr
<transformation> <transformation>
<info> <info>
<name>bus_marking_person</name> <name>bus_marking_person</name>
<description /> <description/>
<extended_description /> <extended_description/>
<trans_version /> <trans_version/>
<trans_type>Normal</trans_type> <trans_type>Normal</trans_type>
<directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory> <directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory>
<parameters> <parameters>
</parameters> </parameters>
<log> <log>
<trans-log-table> <trans-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<size_limit_lines /> <size_limit_lines/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -40,37 +40,37 @@ ...@@ -40,37 +40,37 @@
<id>LINES_READ</id> <id>LINES_READ</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_READ</name> <name>LINES_READ</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_WRITTEN</id> <id>LINES_WRITTEN</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_WRITTEN</name> <name>LINES_WRITTEN</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_UPDATED</id> <id>LINES_UPDATED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_UPDATED</name> <name>LINES_UPDATED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_INPUT</id> <id>LINES_INPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_INPUT</name> <name>LINES_INPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_OUTPUT</id> <id>LINES_OUTPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_OUTPUT</name> <name>LINES_OUTPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_REJECTED</id> <id>LINES_REJECTED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_REJECTED</name> <name>LINES_REJECTED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>ERRORS</id> <id>ERRORS</id>
...@@ -124,11 +124,11 @@ ...@@ -124,11 +124,11 @@
</field> </field>
</trans-log-table> </trans-log-table>
<perf-log-table> <perf-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -206,10 +206,10 @@ ...@@ -206,10 +206,10 @@
</field> </field>
</perf-log-table> </perf-log-table>
<channel-log-table> <channel-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -272,10 +272,10 @@ ...@@ -272,10 +272,10 @@
</field> </field>
</channel-log-table> </channel-log-table>
<step-log-table> <step-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -348,10 +348,10 @@ ...@@ -348,10 +348,10 @@
</field> </field>
</step-log-table> </step-log-table>
<metrics-log-table> <metrics-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -400,9 +400,9 @@ ...@@ -400,9 +400,9 @@
</metrics-log-table> </metrics-log-table>
</log> </log>
<maxdate> <maxdate>
<connection /> <connection/>
<table /> <table/>
<field /> <field/>
<offset>0.0</offset> <offset>0.0</offset>
<maxdiff>0.0</maxdiff> <maxdiff>0.0</maxdiff>
</maxdate> </maxdate>
...@@ -413,7 +413,7 @@ ...@@ -413,7 +413,7 @@
<feedback_shown>Y</feedback_shown> <feedback_shown>Y</feedback_shown>
<feedback_size>50000</feedback_size> <feedback_size>50000</feedback_size>
<using_thread_priorities>Y</using_thread_priorities> <using_thread_priorities>Y</using_thread_priorities>
<shared_objects_file /> <shared_objects_file/>
<capture_step_performance>N</capture_step_performance> <capture_step_performance>N</capture_step_performance>
<step_performance_capturing_delay>1000</step_performance_capturing_delay> <step_performance_capturing_delay>1000</step_performance_capturing_delay>
<step_performance_capturing_size_limit>100</step_performance_capturing_size_limit> <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
...@@ -425,29 +425,37 @@ ...@@ -425,29 +425,37 @@
</slaveservers> </slaveservers>
<clusterschemas> <clusterschemas>
</clusterschemas> </clusterschemas>
<created_user /> <created_user/>
<created_date>2020/10/24 10:53:15.629</created_date> <created_date>2020/10/27 07:07:09.947</created_date>
<modified_user>admin</modified_user> <modified_user>admin</modified_user>
<modified_date>2020/10/22 16:49:25.841</modified_date> <modified_date>2020/10/27 07:09:59.725</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private> <is_key_private>N</is_key_private>
</info> </info>
<notepads> <notepads>
</notepads> </notepads>
<connection> <connection>
<name>intelligent_union_yuejuan_mongo_test</name> <name>intelligent_union_yuejuan_test_neiwang</name>
<server>mysql.dev.jtyjy.com</server> <server>192.168.2.244</server>
<type>MYSQL</type> <type>MYSQL</type>
<access>Native</access> <access>Native</access>
<database>union_yuejuan_mongo</database> <database>union_yuejuan_test</database>
<port>13306</port> <port>3306</port>
<username>dev</username> <username>dev</username>
<password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password> <password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password>
<servername /> <servername/>
<data_tablespace /> <data_tablespace/>
<index_tablespace /> <index_tablespace/>
<attributes> <attributes>
<attribute> <attribute>
<code>EXTRA_OPTION_MYSQL.defaultFetchSize</code>
<attribute>500</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.useCursorFetch</code>
<attribute>true</attribute>
</attribute>
<attribute>
<code>FORCE_IDENTIFIERS_TO_LOWERCASE</code> <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
<attribute>N</attribute> <attribute>N</attribute>
</attribute> </attribute>
...@@ -461,7 +469,7 @@ ...@@ -461,7 +469,7 @@
</attribute> </attribute>
<attribute> <attribute>
<code>PORT_NUMBER</code> <code>PORT_NUMBER</code>
<attribute>13306</attribute> <attribute>3306</attribute>
</attribute> </attribute>
<attribute> <attribute>
<code>PRESERVE_RESERVED_WORD_CASE</code> <code>PRESERVE_RESERVED_WORD_CASE</code>
...@@ -499,13 +507,13 @@ ...@@ -499,13 +507,13 @@
<step> <step>
<name>Text file output</name> <name>Text file output</name>
<type>TextFileOutput</type> <type>TextFileOutput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<separator> </separator> <separator> </separator>
<enclosure>"</enclosure> <enclosure>"</enclosure>
...@@ -516,9 +524,9 @@ ...@@ -516,9 +524,9 @@
<format>UNIX</format> <format>UNIX</format>
<compression>None</compression> <compression>None</compression>
<encoding>UTF-8</encoding> <encoding>UTF-8</encoding>
<endedLine /> <endedLine/>
<fileNameInField>N</fileNameInField> <fileNameInField>N</fileNameInField>
<fileNameField /> <fileNameField/>
<create_parent_folder>Y</create_parent_folder> <create_parent_folder>Y</create_parent_folder>
<file> <file>
<name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_marking_person</name> <name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_marking_person</name>
...@@ -535,12 +543,12 @@ ...@@ -535,12 +543,12 @@
<add_to_result_filenames>Y</add_to_result_filenames> <add_to_result_filenames>Y</add_to_result_filenames>
<pad>N</pad> <pad>N</pad>
<fast_dump>N</fast_dump> <fast_dump>N</fast_dump>
<splitevery /> <splitevery/>
</file> </file>
<fields> <fields>
</fields> </fields>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -556,15 +564,15 @@ ...@@ -556,15 +564,15 @@
<step> <step>
<name>bus_marking_person</name> <name>bus_marking_person</name>
<type>TableInput</type> <type>TableInput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<connection>intelligent_union_yuejuan_mongo_test</connection> <connection>intelligent_union_yuejuan_test_neiwang</connection>
<sql>select <sql>select
id, id,
exam_id, exam_id,
...@@ -579,14 +587,14 @@ create_time, ...@@ -579,14 +587,14 @@ create_time,
modify_id, modify_id,
modify_time modify_time
from bus_marking_person from bus_marking_person
where (create_time>'${start_time1}' and create_time&lt;='${end_time1}') or (modify_time>'${start_time1}' and modify_time&lt;='${end_time1}');</sql> where (create_time&gt;'${start_time1}' and create_time&lt;='${end_time1}') or (modify_time&gt;'${start_time1}' and modify_time&lt;='${end_time1}');</sql>
<limit>0</limit> <limit>0</limit>
<lookup /> <lookup/>
<execute_each_row>N</execute_each_row> <execute_each_row>N</execute_each_row>
<variables_active>Y</variables_active> <variables_active>Y</variables_active>
<lazy_conversion_active>N</lazy_conversion_active> <lazy_conversion_active>N</lazy_conversion_active>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -604,5 +612,5 @@ where (create_time>'${start_time1}' and create_time&lt;='${end_time1}') or (modi ...@@ -604,5 +612,5 @@ where (create_time>'${start_time1}' and create_time&lt;='${end_time1}') or (modi
<slave-step-copy-partition-distribution> <slave-step-copy-partition-distribution>
</slave-step-copy-partition-distribution> </slave-step-copy-partition-distribution>
<slave_transformation>N</slave_transformation> <slave_transformation>N</slave_transformation>
<attributes /> <attributes/>
</transformation> </transformation>
monitor_intelligent_test/union_yuejuan_monitor/transfer/source/bus_marking_task_config.ktr
<transformation> <transformation>
<info> <info>
<name>bus_marking_task_config</name> <name>bus_marking_task_config</name>
<description /> <description/>
<extended_description /> <extended_description/>
<trans_version /> <trans_version/>
<trans_type>Normal</trans_type> <trans_type>Normal</trans_type>
<directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory> <directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory>
<parameters> <parameters>
</parameters> </parameters>
<log> <log>
<trans-log-table> <trans-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<size_limit_lines /> <size_limit_lines/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -40,37 +40,37 @@ ...@@ -40,37 +40,37 @@
<id>LINES_READ</id> <id>LINES_READ</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_READ</name> <name>LINES_READ</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_WRITTEN</id> <id>LINES_WRITTEN</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_WRITTEN</name> <name>LINES_WRITTEN</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_UPDATED</id> <id>LINES_UPDATED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_UPDATED</name> <name>LINES_UPDATED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_INPUT</id> <id>LINES_INPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_INPUT</name> <name>LINES_INPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_OUTPUT</id> <id>LINES_OUTPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_OUTPUT</name> <name>LINES_OUTPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_REJECTED</id> <id>LINES_REJECTED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_REJECTED</name> <name>LINES_REJECTED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>ERRORS</id> <id>ERRORS</id>
...@@ -124,11 +124,11 @@ ...@@ -124,11 +124,11 @@
</field> </field>
</trans-log-table> </trans-log-table>
<perf-log-table> <perf-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -206,10 +206,10 @@ ...@@ -206,10 +206,10 @@
</field> </field>
</perf-log-table> </perf-log-table>
<channel-log-table> <channel-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -272,10 +272,10 @@ ...@@ -272,10 +272,10 @@
</field> </field>
</channel-log-table> </channel-log-table>
<step-log-table> <step-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -348,10 +348,10 @@ ...@@ -348,10 +348,10 @@
</field> </field>
</step-log-table> </step-log-table>
<metrics-log-table> <metrics-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -400,9 +400,9 @@ ...@@ -400,9 +400,9 @@
</metrics-log-table> </metrics-log-table>
</log> </log>
<maxdate> <maxdate>
<connection /> <connection/>
<table /> <table/>
<field /> <field/>
<offset>0.0</offset> <offset>0.0</offset>
<maxdiff>0.0</maxdiff> <maxdiff>0.0</maxdiff>
</maxdate> </maxdate>
...@@ -413,7 +413,7 @@ ...@@ -413,7 +413,7 @@
<feedback_shown>Y</feedback_shown> <feedback_shown>Y</feedback_shown>
<feedback_size>50000</feedback_size> <feedback_size>50000</feedback_size>
<using_thread_priorities>Y</using_thread_priorities> <using_thread_priorities>Y</using_thread_priorities>
<shared_objects_file /> <shared_objects_file/>
<capture_step_performance>N</capture_step_performance> <capture_step_performance>N</capture_step_performance>
<step_performance_capturing_delay>1000</step_performance_capturing_delay> <step_performance_capturing_delay>1000</step_performance_capturing_delay>
<step_performance_capturing_size_limit>100</step_performance_capturing_size_limit> <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
...@@ -425,29 +425,37 @@ ...@@ -425,29 +425,37 @@
</slaveservers> </slaveservers>
<clusterschemas> <clusterschemas>
</clusterschemas> </clusterschemas>
<created_user /> <created_user/>
<created_date>2020/10/24 10:53:15.642</created_date> <created_date>2020/10/27 07:07:09.971</created_date>
<modified_user>admin</modified_user> <modified_user>admin</modified_user>
<modified_date>2020/10/21 11:45:52.870</modified_date> <modified_date>2020/10/27 07:09:53.105</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private> <is_key_private>N</is_key_private>
</info> </info>
<notepads> <notepads>
</notepads> </notepads>
<connection> <connection>
<name>intelligent_union_yuejuan_mongo_test</name> <name>intelligent_union_yuejuan_test_neiwang</name>
<server>mysql.dev.jtyjy.com</server> <server>192.168.2.244</server>
<type>MYSQL</type> <type>MYSQL</type>
<access>Native</access> <access>Native</access>
<database>union_yuejuan_mongo</database> <database>union_yuejuan_test</database>
<port>13306</port> <port>3306</port>
<username>dev</username> <username>dev</username>
<password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password> <password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password>
<servername /> <servername/>
<data_tablespace /> <data_tablespace/>
<index_tablespace /> <index_tablespace/>
<attributes> <attributes>
<attribute> <attribute>
<code>EXTRA_OPTION_MYSQL.defaultFetchSize</code>
<attribute>500</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.useCursorFetch</code>
<attribute>true</attribute>
</attribute>
<attribute>
<code>FORCE_IDENTIFIERS_TO_LOWERCASE</code> <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
<attribute>N</attribute> <attribute>N</attribute>
</attribute> </attribute>
...@@ -461,7 +469,7 @@ ...@@ -461,7 +469,7 @@
</attribute> </attribute>
<attribute> <attribute>
<code>PORT_NUMBER</code> <code>PORT_NUMBER</code>
<attribute>13306</attribute> <attribute>3306</attribute>
</attribute> </attribute>
<attribute> <attribute>
<code>PRESERVE_RESERVED_WORD_CASE</code> <code>PRESERVE_RESERVED_WORD_CASE</code>
...@@ -499,13 +507,13 @@ ...@@ -499,13 +507,13 @@
<step> <step>
<name>Text file output</name> <name>Text file output</name>
<type>TextFileOutput</type> <type>TextFileOutput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<separator> </separator> <separator> </separator>
<enclosure>"</enclosure> <enclosure>"</enclosure>
...@@ -516,9 +524,9 @@ ...@@ -516,9 +524,9 @@
<format>UNIX</format> <format>UNIX</format>
<compression>None</compression> <compression>None</compression>
<encoding>UTF-8</encoding> <encoding>UTF-8</encoding>
<endedLine /> <endedLine/>
<fileNameInField>N</fileNameInField> <fileNameInField>N</fileNameInField>
<fileNameField /> <fileNameField/>
<create_parent_folder>Y</create_parent_folder> <create_parent_folder>Y</create_parent_folder>
<file> <file>
<name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_marking_task_config</name> <name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_marking_task_config</name>
...@@ -535,12 +543,12 @@ ...@@ -535,12 +543,12 @@
<add_to_result_filenames>Y</add_to_result_filenames> <add_to_result_filenames>Y</add_to_result_filenames>
<pad>N</pad> <pad>N</pad>
<fast_dump>N</fast_dump> <fast_dump>N</fast_dump>
<splitevery /> <splitevery/>
</file> </file>
<fields> <fields>
</fields> </fields>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -556,15 +564,15 @@ ...@@ -556,15 +564,15 @@
<step> <step>
<name>bus_marking_task_config</name> <name>bus_marking_task_config</name>
<type>TableInput</type> <type>TableInput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<connection>intelligent_union_yuejuan_mongo_test</connection> <connection>intelligent_union_yuejuan_test_neiwang</connection>
<sql>select <sql>select
id, id,
exam_id, exam_id,
...@@ -583,12 +591,12 @@ modify_id, ...@@ -583,12 +591,12 @@ modify_id,
modify_time modify_time
from bus_marking_task_config;</sql> from bus_marking_task_config;</sql>
<limit>0</limit> <limit>0</limit>
<lookup /> <lookup/>
<execute_each_row>N</execute_each_row> <execute_each_row>N</execute_each_row>
<variables_active>Y</variables_active> <variables_active>Y</variables_active>
<lazy_conversion_active>N</lazy_conversion_active> <lazy_conversion_active>N</lazy_conversion_active>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -606,5 +614,5 @@ from bus_marking_task_config;</sql> ...@@ -606,5 +614,5 @@ from bus_marking_task_config;</sql>
<slave-step-copy-partition-distribution> <slave-step-copy-partition-distribution>
</slave-step-copy-partition-distribution> </slave-step-copy-partition-distribution>
<slave_transformation>N</slave_transformation> <slave_transformation>N</slave_transformation>
<attributes /> <attributes/>
</transformation> </transformation>
monitor_intelligent_test/union_yuejuan_monitor/transfer/source/bus_marking_teacher_task.ktr
<transformation> <transformation>
<info> <info>
<name>bus_marking_teacher_task</name> <name>bus_marking_teacher_task</name>
<description /> <description/>
<extended_description /> <extended_description/>
<trans_version /> <trans_version/>
<trans_type>Normal</trans_type> <trans_type>Normal</trans_type>
<directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory> <directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory>
<parameters> <parameters>
</parameters> </parameters>
<log> <log>
<trans-log-table> <trans-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<size_limit_lines /> <size_limit_lines/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -40,37 +40,37 @@ ...@@ -40,37 +40,37 @@
<id>LINES_READ</id> <id>LINES_READ</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_READ</name> <name>LINES_READ</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_WRITTEN</id> <id>LINES_WRITTEN</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_WRITTEN</name> <name>LINES_WRITTEN</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_UPDATED</id> <id>LINES_UPDATED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_UPDATED</name> <name>LINES_UPDATED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_INPUT</id> <id>LINES_INPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_INPUT</name> <name>LINES_INPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_OUTPUT</id> <id>LINES_OUTPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_OUTPUT</name> <name>LINES_OUTPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_REJECTED</id> <id>LINES_REJECTED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_REJECTED</name> <name>LINES_REJECTED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>ERRORS</id> <id>ERRORS</id>
...@@ -124,11 +124,11 @@ ...@@ -124,11 +124,11 @@
</field> </field>
</trans-log-table> </trans-log-table>
<perf-log-table> <perf-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -206,10 +206,10 @@ ...@@ -206,10 +206,10 @@
</field> </field>
</perf-log-table> </perf-log-table>
<channel-log-table> <channel-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -272,10 +272,10 @@ ...@@ -272,10 +272,10 @@
</field> </field>
</channel-log-table> </channel-log-table>
<step-log-table> <step-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -348,10 +348,10 @@ ...@@ -348,10 +348,10 @@
</field> </field>
</step-log-table> </step-log-table>
<metrics-log-table> <metrics-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -400,9 +400,9 @@ ...@@ -400,9 +400,9 @@
</metrics-log-table> </metrics-log-table>
</log> </log>
<maxdate> <maxdate>
<connection /> <connection/>
<table /> <table/>
<field /> <field/>
<offset>0.0</offset> <offset>0.0</offset>
<maxdiff>0.0</maxdiff> <maxdiff>0.0</maxdiff>
</maxdate> </maxdate>
...@@ -413,7 +413,7 @@ ...@@ -413,7 +413,7 @@
<feedback_shown>Y</feedback_shown> <feedback_shown>Y</feedback_shown>
<feedback_size>50000</feedback_size> <feedback_size>50000</feedback_size>
<using_thread_priorities>Y</using_thread_priorities> <using_thread_priorities>Y</using_thread_priorities>
<shared_objects_file /> <shared_objects_file/>
<capture_step_performance>N</capture_step_performance> <capture_step_performance>N</capture_step_performance>
<step_performance_capturing_delay>1000</step_performance_capturing_delay> <step_performance_capturing_delay>1000</step_performance_capturing_delay>
<step_performance_capturing_size_limit>100</step_performance_capturing_size_limit> <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
...@@ -425,29 +425,37 @@ ...@@ -425,29 +425,37 @@
</slaveservers> </slaveservers>
<clusterschemas> <clusterschemas>
</clusterschemas> </clusterschemas>
<created_user /> <created_user/>
<created_date>2020/10/24 10:53:15.653</created_date> <created_date>2020/10/27 07:07:09.990</created_date>
<modified_user>admin</modified_user> <modified_user>admin</modified_user>
<modified_date>2020/10/21 11:46:50.720</modified_date> <modified_date>2020/10/26 16:55:17.785</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private> <is_key_private>N</is_key_private>
</info> </info>
<notepads> <notepads>
</notepads> </notepads>
<connection> <connection>
<name>intelligent_union_yuejuan_mongo_test</name> <name>intelligent_union_yuejuan_test_neiwang</name>
<server>mysql.dev.jtyjy.com</server> <server>192.168.2.244</server>
<type>MYSQL</type> <type>MYSQL</type>
<access>Native</access> <access>Native</access>
<database>union_yuejuan_mongo</database> <database>union_yuejuan_test</database>
<port>13306</port> <port>3306</port>
<username>dev</username> <username>dev</username>
<password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password> <password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password>
<servername /> <servername/>
<data_tablespace /> <data_tablespace/>
<index_tablespace /> <index_tablespace/>
<attributes> <attributes>
<attribute> <attribute>
<code>EXTRA_OPTION_MYSQL.defaultFetchSize</code>
<attribute>500</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.useCursorFetch</code>
<attribute>true</attribute>
</attribute>
<attribute>
<code>FORCE_IDENTIFIERS_TO_LOWERCASE</code> <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
<attribute>N</attribute> <attribute>N</attribute>
</attribute> </attribute>
...@@ -461,7 +469,7 @@ ...@@ -461,7 +469,7 @@
</attribute> </attribute>
<attribute> <attribute>
<code>PORT_NUMBER</code> <code>PORT_NUMBER</code>
<attribute>13306</attribute> <attribute>3306</attribute>
</attribute> </attribute>
<attribute> <attribute>
<code>PRESERVE_RESERVED_WORD_CASE</code> <code>PRESERVE_RESERVED_WORD_CASE</code>
...@@ -499,13 +507,13 @@ ...@@ -499,13 +507,13 @@
<step> <step>
<name>Text file output</name> <name>Text file output</name>
<type>TextFileOutput</type> <type>TextFileOutput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<separator> </separator> <separator> </separator>
<enclosure>"</enclosure> <enclosure>"</enclosure>
...@@ -516,9 +524,9 @@ ...@@ -516,9 +524,9 @@
<format>UNIX</format> <format>UNIX</format>
<compression>None</compression> <compression>None</compression>
<encoding>UTF-8</encoding> <encoding>UTF-8</encoding>
<endedLine /> <endedLine/>
<fileNameInField>N</fileNameInField> <fileNameInField>N</fileNameInField>
<fileNameField /> <fileNameField/>
<create_parent_folder>Y</create_parent_folder> <create_parent_folder>Y</create_parent_folder>
<file> <file>
<name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_marking_teacher_task</name> <name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_marking_teacher_task</name>
...@@ -535,12 +543,12 @@ ...@@ -535,12 +543,12 @@
<add_to_result_filenames>Y</add_to_result_filenames> <add_to_result_filenames>Y</add_to_result_filenames>
<pad>N</pad> <pad>N</pad>
<fast_dump>N</fast_dump> <fast_dump>N</fast_dump>
<splitevery /> <splitevery/>
</file> </file>
<fields> <fields>
</fields> </fields>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -556,15 +564,15 @@ ...@@ -556,15 +564,15 @@
<step> <step>
<name>bus_marking_teacher_task</name> <name>bus_marking_teacher_task</name>
<type>TableInput</type> <type>TableInput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<connection>intelligent_union_yuejuan_mongo_test</connection> <connection>intelligent_union_yuejuan_test_neiwang</connection>
<sql>select <sql>select
id, id,
question_config_id, question_config_id,
...@@ -580,12 +588,12 @@ modify_id, ...@@ -580,12 +588,12 @@ modify_id,
modify_time modify_time
from bus_marking_teacher_task;</sql> from bus_marking_teacher_task;</sql>
<limit>0</limit> <limit>0</limit>
<lookup /> <lookup/>
<execute_each_row>N</execute_each_row> <execute_each_row>N</execute_each_row>
<variables_active>Y</variables_active> <variables_active>Y</variables_active>
<lazy_conversion_active>N</lazy_conversion_active> <lazy_conversion_active>N</lazy_conversion_active>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -603,5 +611,5 @@ from bus_marking_teacher_task;</sql> ...@@ -603,5 +611,5 @@ from bus_marking_teacher_task;</sql>
<slave-step-copy-partition-distribution> <slave-step-copy-partition-distribution>
</slave-step-copy-partition-distribution> </slave-step-copy-partition-distribution>
<slave_transformation>N</slave_transformation> <slave_transformation>N</slave_transformation>
<attributes /> <attributes/>
</transformation> </transformation>
monitor_intelligent_test/union_yuejuan_monitor/transfer/source/bus_objective_question_config.ktr
<transformation> <transformation>
<info> <info>
<name>bus_objective_question_config</name> <name>bus_objective_question_config</name>
<description /> <description/>
<extended_description /> <extended_description/>
<trans_version /> <trans_version/>
<trans_type>Normal</trans_type> <trans_type>Normal</trans_type>
<directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory> <directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory>
<parameters> <parameters>
</parameters> </parameters>
<log> <log>
<trans-log-table> <trans-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<size_limit_lines /> <size_limit_lines/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -40,37 +40,37 @@ ...@@ -40,37 +40,37 @@
<id>LINES_READ</id> <id>LINES_READ</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_READ</name> <name>LINES_READ</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_WRITTEN</id> <id>LINES_WRITTEN</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_WRITTEN</name> <name>LINES_WRITTEN</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_UPDATED</id> <id>LINES_UPDATED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_UPDATED</name> <name>LINES_UPDATED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_INPUT</id> <id>LINES_INPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_INPUT</name> <name>LINES_INPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_OUTPUT</id> <id>LINES_OUTPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_OUTPUT</name> <name>LINES_OUTPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_REJECTED</id> <id>LINES_REJECTED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_REJECTED</name> <name>LINES_REJECTED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>ERRORS</id> <id>ERRORS</id>
...@@ -124,11 +124,11 @@ ...@@ -124,11 +124,11 @@
</field> </field>
</trans-log-table> </trans-log-table>
<perf-log-table> <perf-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -206,10 +206,10 @@ ...@@ -206,10 +206,10 @@
</field> </field>
</perf-log-table> </perf-log-table>
<channel-log-table> <channel-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -272,10 +272,10 @@ ...@@ -272,10 +272,10 @@
</field> </field>
</channel-log-table> </channel-log-table>
<step-log-table> <step-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -348,10 +348,10 @@ ...@@ -348,10 +348,10 @@
</field> </field>
</step-log-table> </step-log-table>
<metrics-log-table> <metrics-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -400,9 +400,9 @@ ...@@ -400,9 +400,9 @@
</metrics-log-table> </metrics-log-table>
</log> </log>
<maxdate> <maxdate>
<connection /> <connection/>
<table /> <table/>
<field /> <field/>
<offset>0.0</offset> <offset>0.0</offset>
<maxdiff>0.0</maxdiff> <maxdiff>0.0</maxdiff>
</maxdate> </maxdate>
...@@ -413,7 +413,7 @@ ...@@ -413,7 +413,7 @@
<feedback_shown>Y</feedback_shown> <feedback_shown>Y</feedback_shown>
<feedback_size>50000</feedback_size> <feedback_size>50000</feedback_size>
<using_thread_priorities>Y</using_thread_priorities> <using_thread_priorities>Y</using_thread_priorities>
<shared_objects_file /> <shared_objects_file/>
<capture_step_performance>N</capture_step_performance> <capture_step_performance>N</capture_step_performance>
<step_performance_capturing_delay>1000</step_performance_capturing_delay> <step_performance_capturing_delay>1000</step_performance_capturing_delay>
<step_performance_capturing_size_limit>100</step_performance_capturing_size_limit> <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
...@@ -425,29 +425,37 @@ ...@@ -425,29 +425,37 @@
</slaveservers> </slaveservers>
<clusterschemas> <clusterschemas>
</clusterschemas> </clusterschemas>
<created_user /> <created_user/>
<created_date>2020/10/24 10:53:15.662</created_date> <created_date>2020/10/27 07:07:10.012</created_date>
<modified_user>admin</modified_user> <modified_user>admin</modified_user>
<modified_date>2020/10/16 13:42:22.378</modified_date> <modified_date>2020/10/26 16:41:36.265</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private> <is_key_private>N</is_key_private>
</info> </info>
<notepads> <notepads>
</notepads> </notepads>
<connection> <connection>
<name>intelligent_union_yuejuan_mongo_test</name> <name>intelligent_union_yuejuan_test_neiwang</name>
<server>mysql.dev.jtyjy.com</server> <server>192.168.2.244</server>
<type>MYSQL</type> <type>MYSQL</type>
<access>Native</access> <access>Native</access>
<database>union_yuejuan_mongo</database> <database>union_yuejuan_test</database>
<port>13306</port> <port>3306</port>
<username>dev</username> <username>dev</username>
<password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password> <password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password>
<servername /> <servername/>
<data_tablespace /> <data_tablespace/>
<index_tablespace /> <index_tablespace/>
<attributes> <attributes>
<attribute> <attribute>
<code>EXTRA_OPTION_MYSQL.defaultFetchSize</code>
<attribute>500</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.useCursorFetch</code>
<attribute>true</attribute>
</attribute>
<attribute>
<code>FORCE_IDENTIFIERS_TO_LOWERCASE</code> <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
<attribute>N</attribute> <attribute>N</attribute>
</attribute> </attribute>
...@@ -461,7 +469,7 @@ ...@@ -461,7 +469,7 @@
</attribute> </attribute>
<attribute> <attribute>
<code>PORT_NUMBER</code> <code>PORT_NUMBER</code>
<attribute>13306</attribute> <attribute>3306</attribute>
</attribute> </attribute>
<attribute> <attribute>
<code>PRESERVE_RESERVED_WORD_CASE</code> <code>PRESERVE_RESERVED_WORD_CASE</code>
...@@ -499,13 +507,13 @@ ...@@ -499,13 +507,13 @@
<step> <step>
<name>Text file output</name> <name>Text file output</name>
<type>TextFileOutput</type> <type>TextFileOutput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<separator> </separator> <separator> </separator>
<enclosure>"</enclosure> <enclosure>"</enclosure>
...@@ -516,9 +524,9 @@ ...@@ -516,9 +524,9 @@
<format>UNIX</format> <format>UNIX</format>
<compression>None</compression> <compression>None</compression>
<encoding>UTF-8</encoding> <encoding>UTF-8</encoding>
<endedLine /> <endedLine/>
<fileNameInField>N</fileNameInField> <fileNameInField>N</fileNameInField>
<fileNameField /> <fileNameField/>
<create_parent_folder>Y</create_parent_folder> <create_parent_folder>Y</create_parent_folder>
<file> <file>
<name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_objective_question_config</name> <name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_objective_question_config</name>
...@@ -535,12 +543,12 @@ ...@@ -535,12 +543,12 @@
<add_to_result_filenames>Y</add_to_result_filenames> <add_to_result_filenames>Y</add_to_result_filenames>
<pad>N</pad> <pad>N</pad>
<fast_dump>N</fast_dump> <fast_dump>N</fast_dump>
<splitevery /> <splitevery/>
</file> </file>
<fields> <fields>
</fields> </fields>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -556,15 +564,15 @@ ...@@ -556,15 +564,15 @@
<step> <step>
<name>bus_objective_question_config</name> <name>bus_objective_question_config</name>
<type>TableInput</type> <type>TableInput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<connection>intelligent_union_yuejuan_mongo_test</connection> <connection>intelligent_union_yuejuan_test_neiwang</connection>
<sql>select <sql>select
id, id,
exam_id, exam_id,
...@@ -583,14 +591,14 @@ create_time, ...@@ -583,14 +591,14 @@ create_time,
modify_id, modify_id,
modify_time modify_time
from bus_objective_question_config from bus_objective_question_config
where (create_time>'${start_time1}' and create_time&lt;='${end_time1}') or (modify_time>'${start_time1}' and modify_time&lt;='${end_time1}');</sql> where (create_time&gt;'${start_time1}' and create_time&lt;='${end_time1}') or (modify_time&gt;'${start_time1}' and modify_time&lt;='${end_time1}');</sql>
<limit>0</limit> <limit>0</limit>
<lookup /> <lookup/>
<execute_each_row>N</execute_each_row> <execute_each_row>N</execute_each_row>
<variables_active>Y</variables_active> <variables_active>Y</variables_active>
<lazy_conversion_active>N</lazy_conversion_active> <lazy_conversion_active>N</lazy_conversion_active>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -608,5 +616,5 @@ where (create_time>'${start_time1}' and create_time&lt;='${end_time1}') or (modi ...@@ -608,5 +616,5 @@ where (create_time>'${start_time1}' and create_time&lt;='${end_time1}') or (modi
<slave-step-copy-partition-distribution> <slave-step-copy-partition-distribution>
</slave-step-copy-partition-distribution> </slave-step-copy-partition-distribution>
<slave_transformation>N</slave_transformation> <slave_transformation>N</slave_transformation>
<attributes /> <attributes/>
</transformation> </transformation>
monitor_intelligent_test/union_yuejuan_monitor/transfer/source/bus_subjective_question_config.ktr
<transformation> <transformation>
<info> <info>
<name>bus_subjective_question_config</name> <name>bus_subjective_question_config</name>
<description /> <description/>
<extended_description /> <extended_description/>
<trans_version /> <trans_version/>
<trans_type>Normal</trans_type> <trans_type>Normal</trans_type>
<directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory> <directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory>
<parameters> <parameters>
</parameters> </parameters>
<log> <log>
<trans-log-table> <trans-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<size_limit_lines /> <size_limit_lines/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -40,37 +40,37 @@ ...@@ -40,37 +40,37 @@
<id>LINES_READ</id> <id>LINES_READ</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_READ</name> <name>LINES_READ</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_WRITTEN</id> <id>LINES_WRITTEN</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_WRITTEN</name> <name>LINES_WRITTEN</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_UPDATED</id> <id>LINES_UPDATED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_UPDATED</name> <name>LINES_UPDATED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_INPUT</id> <id>LINES_INPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_INPUT</name> <name>LINES_INPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_OUTPUT</id> <id>LINES_OUTPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_OUTPUT</name> <name>LINES_OUTPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_REJECTED</id> <id>LINES_REJECTED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_REJECTED</name> <name>LINES_REJECTED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>ERRORS</id> <id>ERRORS</id>
...@@ -124,11 +124,11 @@ ...@@ -124,11 +124,11 @@
</field> </field>
</trans-log-table> </trans-log-table>
<perf-log-table> <perf-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -206,10 +206,10 @@ ...@@ -206,10 +206,10 @@
</field> </field>
</perf-log-table> </perf-log-table>
<channel-log-table> <channel-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -272,10 +272,10 @@ ...@@ -272,10 +272,10 @@
</field> </field>
</channel-log-table> </channel-log-table>
<step-log-table> <step-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -348,10 +348,10 @@ ...@@ -348,10 +348,10 @@
</field> </field>
</step-log-table> </step-log-table>
<metrics-log-table> <metrics-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -400,9 +400,9 @@ ...@@ -400,9 +400,9 @@
</metrics-log-table> </metrics-log-table>
</log> </log>
<maxdate> <maxdate>
<connection /> <connection/>
<table /> <table/>
<field /> <field/>
<offset>0.0</offset> <offset>0.0</offset>
<maxdiff>0.0</maxdiff> <maxdiff>0.0</maxdiff>
</maxdate> </maxdate>
...@@ -413,7 +413,7 @@ ...@@ -413,7 +413,7 @@
<feedback_shown>Y</feedback_shown> <feedback_shown>Y</feedback_shown>
<feedback_size>50000</feedback_size> <feedback_size>50000</feedback_size>
<using_thread_priorities>Y</using_thread_priorities> <using_thread_priorities>Y</using_thread_priorities>
<shared_objects_file /> <shared_objects_file/>
<capture_step_performance>N</capture_step_performance> <capture_step_performance>N</capture_step_performance>
<step_performance_capturing_delay>1000</step_performance_capturing_delay> <step_performance_capturing_delay>1000</step_performance_capturing_delay>
<step_performance_capturing_size_limit>100</step_performance_capturing_size_limit> <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
...@@ -425,29 +425,37 @@ ...@@ -425,29 +425,37 @@
</slaveservers> </slaveservers>
<clusterschemas> <clusterschemas>
</clusterschemas> </clusterschemas>
<created_user /> <created_user/>
<created_date>2020/10/24 10:53:15.738</created_date> <created_date>2020/10/27 07:07:10.183</created_date>
<modified_user>admin</modified_user> <modified_user>admin</modified_user>
<modified_date>2020/10/16 13:17:06.225</modified_date> <modified_date>2020/10/26 16:54:52.689</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private> <is_key_private>N</is_key_private>
</info> </info>
<notepads> <notepads>
</notepads> </notepads>
<connection> <connection>
<name>intelligent_union_yuejuan_mongo_test</name> <name>intelligent_union_yuejuan_test_neiwang</name>
<server>mysql.dev.jtyjy.com</server> <server>192.168.2.244</server>
<type>MYSQL</type> <type>MYSQL</type>
<access>Native</access> <access>Native</access>
<database>union_yuejuan_mongo</database> <database>union_yuejuan_test</database>
<port>13306</port> <port>3306</port>
<username>dev</username> <username>dev</username>
<password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password> <password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password>
<servername /> <servername/>
<data_tablespace /> <data_tablespace/>
<index_tablespace /> <index_tablespace/>
<attributes> <attributes>
<attribute> <attribute>
<code>EXTRA_OPTION_MYSQL.defaultFetchSize</code>
<attribute>500</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.useCursorFetch</code>
<attribute>true</attribute>
</attribute>
<attribute>
<code>FORCE_IDENTIFIERS_TO_LOWERCASE</code> <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
<attribute>N</attribute> <attribute>N</attribute>
</attribute> </attribute>
...@@ -461,7 +469,7 @@ ...@@ -461,7 +469,7 @@
</attribute> </attribute>
<attribute> <attribute>
<code>PORT_NUMBER</code> <code>PORT_NUMBER</code>
<attribute>13306</attribute> <attribute>3306</attribute>
</attribute> </attribute>
<attribute> <attribute>
<code>PRESERVE_RESERVED_WORD_CASE</code> <code>PRESERVE_RESERVED_WORD_CASE</code>
...@@ -499,13 +507,13 @@ ...@@ -499,13 +507,13 @@
<step> <step>
<name>Text file output</name> <name>Text file output</name>
<type>TextFileOutput</type> <type>TextFileOutput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<separator> </separator> <separator> </separator>
<enclosure>"</enclosure> <enclosure>"</enclosure>
...@@ -516,9 +524,9 @@ ...@@ -516,9 +524,9 @@
<format>UNIX</format> <format>UNIX</format>
<compression>None</compression> <compression>None</compression>
<encoding>UTF-8</encoding> <encoding>UTF-8</encoding>
<endedLine /> <endedLine/>
<fileNameInField>N</fileNameInField> <fileNameInField>N</fileNameInField>
<fileNameField /> <fileNameField/>
<create_parent_folder>Y</create_parent_folder> <create_parent_folder>Y</create_parent_folder>
<file> <file>
<name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_subjective_question_config</name> <name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/bus_subjective_question_config</name>
...@@ -535,12 +543,12 @@ ...@@ -535,12 +543,12 @@
<add_to_result_filenames>Y</add_to_result_filenames> <add_to_result_filenames>Y</add_to_result_filenames>
<pad>N</pad> <pad>N</pad>
<fast_dump>N</fast_dump> <fast_dump>N</fast_dump>
<splitevery /> <splitevery/>
</file> </file>
<fields> <fields>
</fields> </fields>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -556,15 +564,15 @@ ...@@ -556,15 +564,15 @@
<step> <step>
<name>bus_subjective_question_config</name> <name>bus_subjective_question_config</name>
<type>TableInput</type> <type>TableInput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<connection>intelligent_union_yuejuan_mongo_test</connection> <connection>intelligent_union_yuejuan_test_neiwang</connection>
<sql>select <sql>select
id, id,
exam_subject_relation_id, exam_subject_relation_id,
...@@ -586,14 +594,14 @@ modify_time, ...@@ -586,14 +594,14 @@ modify_time,
create_id, create_id,
create_time create_time
from bus_subjective_question_config from bus_subjective_question_config
where (create_time>'${start_time1}' and create_time&lt;='${end_time1}') or (modify_time>'${start_time1}' and modify_time&lt;='${end_time1}');</sql> where (create_time&gt;'${start_time1}' and create_time&lt;='${end_time1}') or (modify_time&gt;'${start_time1}' and modify_time&lt;='${end_time1}');</sql>
<limit>0</limit> <limit>0</limit>
<lookup /> <lookup/>
<execute_each_row>N</execute_each_row> <execute_each_row>N</execute_each_row>
<variables_active>Y</variables_active> <variables_active>Y</variables_active>
<lazy_conversion_active>N</lazy_conversion_active> <lazy_conversion_active>N</lazy_conversion_active>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -611,5 +619,5 @@ where (create_time>'${start_time1}' and create_time&lt;='${end_time1}') or (modi ...@@ -611,5 +619,5 @@ where (create_time>'${start_time1}' and create_time&lt;='${end_time1}') or (modi
<slave-step-copy-partition-distribution> <slave-step-copy-partition-distribution>
</slave-step-copy-partition-distribution> </slave-step-copy-partition-distribution>
<slave_transformation>N</slave_transformation> <slave_transformation>N</slave_transformation>
<attributes /> <attributes/>
</transformation> </transformation>
monitor_intelligent_test/union_yuejuan_monitor/transfer/source/dic_question_type.ktr
<transformation> <transformation>
<info> <info>
<name>dic_question_type</name> <name>dic_question_type</name>
<description /> <description/>
<extended_description /> <extended_description/>
<trans_version /> <trans_version/>
<trans_type>Normal</trans_type> <trans_type>Normal</trans_type>
<directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory> <directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory>
<parameters> <parameters>
</parameters> </parameters>
<log> <log>
<trans-log-table> <trans-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<size_limit_lines /> <size_limit_lines/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -40,37 +40,37 @@ ...@@ -40,37 +40,37 @@
<id>LINES_READ</id> <id>LINES_READ</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_READ</name> <name>LINES_READ</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_WRITTEN</id> <id>LINES_WRITTEN</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_WRITTEN</name> <name>LINES_WRITTEN</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_UPDATED</id> <id>LINES_UPDATED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_UPDATED</name> <name>LINES_UPDATED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_INPUT</id> <id>LINES_INPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_INPUT</name> <name>LINES_INPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_OUTPUT</id> <id>LINES_OUTPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_OUTPUT</name> <name>LINES_OUTPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_REJECTED</id> <id>LINES_REJECTED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_REJECTED</name> <name>LINES_REJECTED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>ERRORS</id> <id>ERRORS</id>
...@@ -124,11 +124,11 @@ ...@@ -124,11 +124,11 @@
</field> </field>
</trans-log-table> </trans-log-table>
<perf-log-table> <perf-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -206,10 +206,10 @@ ...@@ -206,10 +206,10 @@
</field> </field>
</perf-log-table> </perf-log-table>
<channel-log-table> <channel-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -272,10 +272,10 @@ ...@@ -272,10 +272,10 @@
</field> </field>
</channel-log-table> </channel-log-table>
<step-log-table> <step-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -348,10 +348,10 @@ ...@@ -348,10 +348,10 @@
</field> </field>
</step-log-table> </step-log-table>
<metrics-log-table> <metrics-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -400,9 +400,9 @@ ...@@ -400,9 +400,9 @@
</metrics-log-table> </metrics-log-table>
</log> </log>
<maxdate> <maxdate>
<connection /> <connection/>
<table /> <table/>
<field /> <field/>
<offset>0.0</offset> <offset>0.0</offset>
<maxdiff>0.0</maxdiff> <maxdiff>0.0</maxdiff>
</maxdate> </maxdate>
...@@ -413,7 +413,7 @@ ...@@ -413,7 +413,7 @@
<feedback_shown>Y</feedback_shown> <feedback_shown>Y</feedback_shown>
<feedback_size>50000</feedback_size> <feedback_size>50000</feedback_size>
<using_thread_priorities>Y</using_thread_priorities> <using_thread_priorities>Y</using_thread_priorities>
<shared_objects_file /> <shared_objects_file/>
<capture_step_performance>N</capture_step_performance> <capture_step_performance>N</capture_step_performance>
<step_performance_capturing_delay>1000</step_performance_capturing_delay> <step_performance_capturing_delay>1000</step_performance_capturing_delay>
<step_performance_capturing_size_limit>100</step_performance_capturing_size_limit> <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
...@@ -425,29 +425,37 @@ ...@@ -425,29 +425,37 @@
</slaveservers> </slaveservers>
<clusterschemas> <clusterschemas>
</clusterschemas> </clusterschemas>
<created_user /> <created_user/>
<created_date>2020/10/24 10:53:15.752</created_date> <created_date>2020/10/27 07:07:10.205</created_date>
<modified_user>admin</modified_user> <modified_user>admin</modified_user>
<modified_date>2020/10/20 14:54:12.622</modified_date> <modified_date>2020/10/26 16:55:51.092</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private> <is_key_private>N</is_key_private>
</info> </info>
<notepads> <notepads>
</notepads> </notepads>
<connection> <connection>
<name>intelligent_union_yuejuan_mongo_test</name> <name>intelligent_union_yuejuan_test_neiwang</name>
<server>mysql.dev.jtyjy.com</server> <server>192.168.2.244</server>
<type>MYSQL</type> <type>MYSQL</type>
<access>Native</access> <access>Native</access>
<database>union_yuejuan_mongo</database> <database>union_yuejuan_test</database>
<port>13306</port> <port>3306</port>
<username>dev</username> <username>dev</username>
<password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password> <password>Encrypted 2be98afc80ec284a486009d41f2c3fd89</password>
<servername /> <servername/>
<data_tablespace /> <data_tablespace/>
<index_tablespace /> <index_tablespace/>
<attributes> <attributes>
<attribute> <attribute>
<code>EXTRA_OPTION_MYSQL.defaultFetchSize</code>
<attribute>500</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.useCursorFetch</code>
<attribute>true</attribute>
</attribute>
<attribute>
<code>FORCE_IDENTIFIERS_TO_LOWERCASE</code> <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
<attribute>N</attribute> <attribute>N</attribute>
</attribute> </attribute>
...@@ -461,7 +469,7 @@ ...@@ -461,7 +469,7 @@
</attribute> </attribute>
<attribute> <attribute>
<code>PORT_NUMBER</code> <code>PORT_NUMBER</code>
<attribute>13306</attribute> <attribute>3306</attribute>
</attribute> </attribute>
<attribute> <attribute>
<code>PRESERVE_RESERVED_WORD_CASE</code> <code>PRESERVE_RESERVED_WORD_CASE</code>
...@@ -499,13 +507,13 @@ ...@@ -499,13 +507,13 @@
<step> <step>
<name>Text file output</name> <name>Text file output</name>
<type>TextFileOutput</type> <type>TextFileOutput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<separator> </separator> <separator> </separator>
<enclosure>"</enclosure> <enclosure>"</enclosure>
...@@ -516,9 +524,9 @@ ...@@ -516,9 +524,9 @@
<format>UNIX</format> <format>UNIX</format>
<compression>None</compression> <compression>None</compression>
<encoding>UTF-8</encoding> <encoding>UTF-8</encoding>
<endedLine /> <endedLine/>
<fileNameInField>N</fileNameInField> <fileNameInField>N</fileNameInField>
<fileNameField /> <fileNameField/>
<create_parent_folder>Y</create_parent_folder> <create_parent_folder>Y</create_parent_folder>
<file> <file>
<name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/dic_question_type</name> <name>/home/gpadmin/gpfdist/intelligent_monitor/union_yuejuan/dic_question_type</name>
...@@ -535,12 +543,12 @@ ...@@ -535,12 +543,12 @@
<add_to_result_filenames>Y</add_to_result_filenames> <add_to_result_filenames>Y</add_to_result_filenames>
<pad>N</pad> <pad>N</pad>
<fast_dump>N</fast_dump> <fast_dump>N</fast_dump>
<splitevery /> <splitevery/>
</file> </file>
<fields> <fields>
</fields> </fields>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -556,29 +564,29 @@ ...@@ -556,29 +564,29 @@
<step> <step>
<name>dic_question_type</name> <name>dic_question_type</name>
<type>TableInput</type> <type>TableInput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<connection>intelligent_union_yuejuan_mongo_test</connection> <connection>intelligent_union_yuejuan_test_neiwang</connection>
<sql>select <sql>select
id, id,
name, name,
create_time, create_time,
modify_time modify_time
from dic_question_type from dic_question_type
where (create_time>'${start_time1}' and create_time&lt;='${end_time1}') or (modify_time>'${start_time1}' and modify_time&lt;='${end_time1}');</sql> where (create_time&gt;'${start_time1}' and create_time&lt;='${end_time1}') or (modify_time&gt;'${start_time1}' and modify_time&lt;='${end_time1}');</sql>
<limit>0</limit> <limit>0</limit>
<lookup /> <lookup/>
<execute_each_row>N</execute_each_row> <execute_each_row>N</execute_each_row>
<variables_active>Y</variables_active> <variables_active>Y</variables_active>
<lazy_conversion_active>N</lazy_conversion_active> <lazy_conversion_active>N</lazy_conversion_active>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -596,5 +604,5 @@ where (create_time>'${start_time1}' and create_time&lt;='${end_time1}') or (modi ...@@ -596,5 +604,5 @@ where (create_time>'${start_time1}' and create_time&lt;='${end_time1}') or (modi
<slave-step-copy-partition-distribution> <slave-step-copy-partition-distribution>
</slave-step-copy-partition-distribution> </slave-step-copy-partition-distribution>
<slave_transformation>N</slave_transformation> <slave_transformation>N</slave_transformation>
<attributes /> <attributes/>
</transformation> </transformation>
monitor_intelligent_test/union_yuejuan_monitor/transfer/source/set_variables.ktr
<transformation> <transformation>
<info> <info>
<name>set_variables</name> <name>set_variables</name>
<description /> <description/>
<extended_description /> <extended_description/>
<trans_version /> <trans_version/>
<trans_type>Normal</trans_type> <trans_type>Normal</trans_type>
<directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory> <directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/source</directory>
<parameters> <parameters>
</parameters> </parameters>
<log> <log>
<trans-log-table> <trans-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<size_limit_lines /> <size_limit_lines/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -40,37 +40,37 @@ ...@@ -40,37 +40,37 @@
<id>LINES_READ</id> <id>LINES_READ</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_READ</name> <name>LINES_READ</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_WRITTEN</id> <id>LINES_WRITTEN</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_WRITTEN</name> <name>LINES_WRITTEN</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_UPDATED</id> <id>LINES_UPDATED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_UPDATED</name> <name>LINES_UPDATED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_INPUT</id> <id>LINES_INPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_INPUT</name> <name>LINES_INPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_OUTPUT</id> <id>LINES_OUTPUT</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_OUTPUT</name> <name>LINES_OUTPUT</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>LINES_REJECTED</id> <id>LINES_REJECTED</id>
<enabled>Y</enabled> <enabled>Y</enabled>
<name>LINES_REJECTED</name> <name>LINES_REJECTED</name>
<subject /> <subject/>
</field> </field>
<field> <field>
<id>ERRORS</id> <id>ERRORS</id>
...@@ -124,11 +124,11 @@ ...@@ -124,11 +124,11 @@
</field> </field>
</trans-log-table> </trans-log-table>
<perf-log-table> <perf-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<interval /> <interval/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -206,10 +206,10 @@ ...@@ -206,10 +206,10 @@
</field> </field>
</perf-log-table> </perf-log-table>
<channel-log-table> <channel-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -272,10 +272,10 @@ ...@@ -272,10 +272,10 @@
</field> </field>
</channel-log-table> </channel-log-table>
<step-log-table> <step-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -348,10 +348,10 @@ ...@@ -348,10 +348,10 @@
</field> </field>
</step-log-table> </step-log-table>
<metrics-log-table> <metrics-log-table>
<connection /> <connection/>
<schema /> <schema/>
<table /> <table/>
<timeout_days /> <timeout_days/>
<field> <field>
<id>ID_BATCH</id> <id>ID_BATCH</id>
<enabled>Y</enabled> <enabled>Y</enabled>
...@@ -400,9 +400,9 @@ ...@@ -400,9 +400,9 @@
</metrics-log-table> </metrics-log-table>
</log> </log>
<maxdate> <maxdate>
<connection /> <connection/>
<table /> <table/>
<field /> <field/>
<offset>0.0</offset> <offset>0.0</offset>
<maxdiff>0.0</maxdiff> <maxdiff>0.0</maxdiff>
</maxdate> </maxdate>
...@@ -413,7 +413,7 @@ ...@@ -413,7 +413,7 @@
<feedback_shown>Y</feedback_shown> <feedback_shown>Y</feedback_shown>
<feedback_size>50000</feedback_size> <feedback_size>50000</feedback_size>
<using_thread_priorities>Y</using_thread_priorities> <using_thread_priorities>Y</using_thread_priorities>
<shared_objects_file /> <shared_objects_file/>
<capture_step_performance>N</capture_step_performance> <capture_step_performance>N</capture_step_performance>
<step_performance_capturing_delay>1000</step_performance_capturing_delay> <step_performance_capturing_delay>1000</step_performance_capturing_delay>
<step_performance_capturing_size_limit>100</step_performance_capturing_size_limit> <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
...@@ -425,8 +425,8 @@ ...@@ -425,8 +425,8 @@
</slaveservers> </slaveservers>
<clusterschemas> <clusterschemas>
</clusterschemas> </clusterschemas>
<created_user /> <created_user/>
<created_date>2020/10/24 10:53:15.761</created_date> <created_date>2020/10/27 07:07:10.229</created_date>
<modified_user>admin</modified_user> <modified_user>admin</modified_user>
<modified_date>2020/10/19 14:44:26.519</modified_date> <modified_date>2020/10/19 14:44:26.519</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
...@@ -443,9 +443,9 @@ ...@@ -443,9 +443,9 @@
<port>5432</port> <port>5432</port>
<username>yuejuan</username> <username>yuejuan</username>
<password>Encrypted 2be98afc86aa7f2e4cb00bb75d487aed4</password> <password>Encrypted 2be98afc86aa7f2e4cb00bb75d487aed4</password>
<servername /> <servername/>
<data_tablespace /> <data_tablespace/>
<index_tablespace /> <index_tablespace/>
<attributes> <attributes>
<attribute> <attribute>
<code>FORCE_IDENTIFIERS_TO_LOWERCASE</code> <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
...@@ -495,13 +495,13 @@ ...@@ -495,13 +495,13 @@
<step> <step>
<name>gp_time_interval</name> <name>gp_time_interval</name>
<type>TableInput</type> <type>TableInput</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<connection>intelligent_monitor_test_greenplum_neiwang</connection> <connection>intelligent_monitor_test_greenplum_neiwang</connection>
<sql>select <sql>select
...@@ -515,12 +515,12 @@ from union_yuejuan_source_process.gp_time_interval ...@@ -515,12 +515,12 @@ from union_yuejuan_source_process.gp_time_interval
where status=0 where status=0
order by start_time desc limit 1) a;</sql> order by start_time desc limit 1) a;</sql>
<limit>0</limit> <limit>0</limit>
<lookup /> <lookup/>
<execute_each_row>N</execute_each_row> <execute_each_row>N</execute_each_row>
<variables_active>N</variables_active> <variables_active>N</variables_active>
<lazy_conversion_active>N</lazy_conversion_active> <lazy_conversion_active>N</lazy_conversion_active>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -536,31 +536,31 @@ order by start_time desc limit 1) a;</sql> ...@@ -536,31 +536,31 @@ order by start_time desc limit 1) a;</sql>
<step> <step>
<name>设置变量</name> <name>设置变量</name>
<type>SetVariable</type> <type>SetVariable</type>
<description /> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
<custom_distribution /> <custom_distribution/>
<copies>1</copies> <copies>1</copies>
<partitioning> <partitioning>
<method>none</method> <method>none</method>
<schema_name /> <schema_name/>
</partitioning> </partitioning>
<fields> <fields>
<field> <field>
<field_name>utc_start_time</field_name> <field_name>utc_start_time</field_name>
<variable_name>utc_start_time</variable_name> <variable_name>utc_start_time</variable_name>
<variable_type>PARENT_JOB</variable_type> <variable_type>PARENT_JOB</variable_type>
<default_value /> <default_value/>
</field> </field>
<field> <field>
<field_name>utc_end_time</field_name> <field_name>utc_end_time</field_name>
<variable_name>utc_end_time</variable_name> <variable_name>utc_end_time</variable_name>
<variable_type>PARENT_JOB</variable_type> <variable_type>PARENT_JOB</variable_type>
<default_value /> <default_value/>
</field> </field>
</fields> </fields>
<use_formatting>Y</use_formatting> <use_formatting>Y</use_formatting>
<attributes /> <attributes/>
<cluster_schema /> <cluster_schema/>
<remotesteps> <remotesteps>
<input> <input>
</input> </input>
...@@ -578,5 +578,5 @@ order by start_time desc limit 1) a;</sql> ...@@ -578,5 +578,5 @@ order by start_time desc limit 1) a;</sql>
<slave-step-copy-partition-distribution> <slave-step-copy-partition-distribution>
</slave-step-copy-partition-distribution> </slave-step-copy-partition-distribution>
<slave_transformation>N</slave_transformation> <slave_transformation>N</slave_transformation>
<attributes /> <attributes/>
</transformation> </transformation>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment