주식회사 누리아이티

지문카드 및 정보자산 2차 인증 보안SW 전문기업(작지만 강한 회사, 기술력이 강한 회사, 소수 정예 회사)

이상금융거래 탐지/차단을 위한 Fraud Detector 관리

댓글 0

▶ BaroSolution/BaroFDS

2020. 2. 25.

1. Fraud Detector 설치

 

Fraud Detector 설치는 컴파일 후 생성된 flume-ng-jdbc-sink-2.0.jar 파일을 $FLUME_HOME/lib 디렉토리에 다음과 같이 복사하면 된다.

 

[root] /home/flume-ng-sink/target > cp flume-ng-jdbc-sink-2.0.jar $FLUME_HOME/lib/.

 

 

2. 환경 변수 설정

 

Fraud Detector를 기동하려면 환경설정 파일인 flume-env.sh에 다음과 같이 환경 변수들을 정의해야 한다.

 

변수

설명

비고

FLUME_HOME

Apache Flume이 설치된 디렉토리를 지정하는 변수

 

FLUME_CLASSPATH

Apache Flume Library 디렉토리를 지정하는 변수

 

JAVA_HOME

JDK가 설치된 디렉토리를 지정하는 변수

 

CLASSPATH

Java 프로그램을 컴파일(javac)이나 실행(java)할 때나 관련된 클래스를 지정하는 변수

 

LANG

동일한 언어를 지원하는 데 필요한 로케일을 지정하는 변수

 

PATH

$FLUME_HOME/bin, $JAVA_HOME/bin PATH에 반드시 포함되어야 한다.

 

 

 

 

 

[root] /home/apache-flume-1.6.0-bin/server > vi flume-env.sh

# Licensed to the Apache Software Foundation (ASF) under one

# or more contributor license agreements.  See the NOTICE file

# distributed with this work for additional information

# regarding copyright ownership.  The ASF licenses this file

# to you under the Apache License, Version 2.0 (the

# "License"); you may not use this file except in compliance

# with the License.  You may obtain a copy of the License at

#

#     http://www.apache.org/licenses/LICENSE-2.0

#

# Unless required by applicable law or agreed to in writing, software

# distributed under the License is distributed on an "AS IS" BASIS,

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

# See the License for the specific language governing permissions and

# limitations under the License.

 

# If this file is placed at FLUME_CONF_DIR/flume-env.sh, it will be sourced

# during Flume startup.

 

# Give Flume more memory and pre-allocate, enable remote monitoring via JMX

#JAVA_OPTS="-Xms100m -Xmx200m -Dcom.sun.management.jmxremote"

JAVA_OPTS="-XX:MaxDirectMemorySize=128m"

 

# Note that the Flume conf directory is always included in the classpath.

FLUME_HOME=/home/apache-flume-1.6.0-bin

FLUME_CLASSPATH=$FLUME_HOME/lib

 

# Java variables can be set here

JAVA_HOME=/usr/lib/jvm/jre-1.7.0-openjdk.x86_64

CLASSPATH=$CLASSPATH:$FLUME_CLASSPATH:$JAVA_HOME/lib:

 

# Enviroment variables can be set here.

LANG=ko_KR.euckr

#LANG=ko_KR.utf8

PATH=$PATH:$FLUME_HOME/bin:$JAVA_HOME/bin:/etc/alternatives

 

 

3. Log4j 속성 설정

 

log4j는 프로그램을 작성하는 도중에 로그를 남기기 위해 사용되는 자바 기반 로깅 유틸리티이다. 디버그용 도구로 주로 사용되고 있다.

 

log4j의 최근 버전에 의하면 높은 등급에서 낮은 등급으로의 6개 로그 레벨(FATAL, ERROR, WARN, INFO, DEBUG, TRACE)을 가지고 있다. 설정 파일에 대상별(자바에서는 패키지)로 레벨을 지정이 가능하고 그 등급 이상의 로그만 저장하는 방식이다.

 

[root] /home/apache-flume-1.6.0-bin/server > vi log4j.properties

#

# Licensed to the Apache Software Foundation (ASF) under one

# or more contributor license agreements.  See the NOTICE file

# distributed with this work for additional information

# regarding copyright ownership.  The ASF licenses this file

# to you under the Apache License, Version 2.0 (the

# "License"); you may not use this file except in compliance

# with the License.  You may obtain a copy of the License at

#

#  http://www.apache.org/licenses/LICENSE-2.0

#

# Unless required by applicable law or agreed to in writing,

# software distributed under the License is distributed on an

# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

# KIND, either express or implied.  See the License for the

# specific language governing permissions and limitations

# under the License.

#

 

# Define some default values that can be overridden by system properties.

#

# For testing, it may also be convenient to specify

# -Dflume.root.logger=DEBUG,console when launching flume.

 

#flume.root.logger=DEBUG,console

flume.root.logger=INFO,LOGFILE

flume.log.dir=./logs

flume.log.file=flume.log

 

log4j.logger.org.apache.flume.lifecycle = INFO

log4j.logger.org.jboss = WARN

log4j.logger.org.mortbay = INFO

log4j.logger.org.apache.avro.ipc.NettyTransceiver = WARN

log4j.logger.org.apache.hadoop = INFO

 

# Define the root logger to the system property "flume.root.logger".

log4j.rootLogger=${flume.root.logger}

 

 

# Stock log4j rolling file appender

# Default log rotation configuration

log4j.appender.LOGFILE=org.apache.log4j.RollingFileAppender

log4j.appender.LOGFILE.MaxFileSize=100MB

log4j.appender.LOGFILE.MaxBackupIndex=10

log4j.appender.LOGFILE.File=${flume.log.dir}/${flume.log.file}

log4j.appender.LOGFILE.layout=org.apache.log4j.PatternLayout

log4j.appender.LOGFILE.layout.ConversionPattern=%d{dd MMM yyyy HH:mm:ss,SSS} %-5p [%t] (%C.%M:%L) %x - %m%n

 

 

# Warning: If you enable the following appender it will fill up your disk if you don't have a cleanup job!

# This uses the updated rolling file appender from log4j-extras that supports a reliable time-based rolling policy.

# See http://logging.apache.org/log4j/companions/extras/apidocs/org/apache/log4j/rolling/TimeBasedRollingPolicy.html

# Add "DAILY" to flume.root.logger above if you want to use this

log4j.appender.DAILY=org.apache.log4j.rolling.RollingFileAppender

log4j.appender.DAILY.rollingPolicy=org.apache.log4j.rolling.TimeBasedRollingPolicy

log4j.appender.DAILY.rollingPolicy.ActiveFileName=${flume.log.dir}/${flume.log.file}

log4j.appender.DAILY.rollingPolicy.FileNamePattern=${flume.log.dir}/${flume.log.file}.%d{yyyy-MM-dd}

log4j.appender.DAILY.layout=org.apache.log4j.PatternLayout

log4j.appender.DAILY.layout.ConversionPattern=%d{dd MMM yyyy HH:mm:ss,SSS} %-5p [%t] (%C.%M:%L) %x - %m%n

 

 

# console

# Add "console" to flume.root.logger above if you want to use this

log4j.appender.console=org.apache.log4j.ConsoleAppender

log4j.appender.console.target=System.err

log4j.appender.console.layout=org.apache.log4j.PatternLayout

log4j.appender.console.layout.ConversionPattern=%d (%t) [%p - %l] %m%n

 

 

4. Fraud Dtector 속성 설정

 

Fraud Detector JDBCSink를 사용하려면 환경설정 파일인 flume.conf에 다음과 같이 Property들을 정의해야 한다.

 

[root] /home/apache-flume-1.6.0-bin/master > vi flume.conf

# Licensed to the Apache Software Foundation (ASF) under one

# or more contributor license agreements.  See the NOTICE file

# distributed with this work for additional information

# regarding copyright ownership.  The ASF licenses this file

# to you under the Apache License, Version 2.0 (the

# "License"); you may not use this file except in compliance

# with the License.  You may obtain a copy of the License at

#

#  http://www.apache.org/licenses/LICENSE-2.0

#

# Unless required by applicable law or agreed to in writing,

# software distributed under the License is distributed on an

# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

# KIND, either express or implied.  See the License for the

# specific language governing permissions and limitations

# under the License.

 

# The configuration file needs to define the sources,

# the channels and the sinks.

# Sources, channels and sinks are defined per agent,

# in this case called 'agent'

 

master1.sources = master1

master1.channels = mem-channel-100 mem-channel-200 mem-channel-300 mem-channel-400 mem-channel-500 mem-channel-600 mem-channel-700

master1.sinks = jdbc-sink-100 jdbc-sink-200 jdbc-sink-300 jdbc-sink-400 jdbc-sink-500 jdbc-sink-600 jdbc-sink-700

 

# For each one of the sources, the type is defined

master1.sources.master1.type = avro

master1.sources.master1.bind = 1.234.83.169

master1.sources.master1.port = 61616

master1.sources.master1.restartThrottle = 100

master1.sources.master1.restart = true

#master1.sources.master1.restart = false

master1.sources.master1.batchSize = 100

 

# The channel can be defined as follows.

master1.sources.master1.channels = mem-channel-100 mem-channel-200 mem-channel-300 mem-channel-400 mem-channel-500 mem-channel-600 mem-channel-700

 

# Multiplexing Channel Selector

master1.sources.master1.selector.type = multiplexing

master1.sources.master1.selector.header = task_type

master1.sources.master1.selector.mapping.100 = mem-channel-100

master1.sources.master1.selector.mapping.200 = mem-channel-200

master1.sources.master1.selector.mapping.300 = mem-channel-300

master1.sources.master1.selector.mapping.400 = mem-channel-400

master1.sources.master1.selector.mapping.500 = mem-channel-500

master1.sources.master1.selector.mapping.600 = mem-channel-600

master1.sources.master1.selector.mapping.700 = mem-channel-700

#master1.sources.master1.selector.default = mem-channel-100

 

# Each sink's type must be defined

#master1.sinks.fileSink1.type = file_roll

#master1.sinks.fileSink1.sink.directory = /home/backup/flume

master1.sinks.jdbc-sink-100.type = org.apache.flume.sink.JDBCSink

master1.sinks.jdbc-sink-200.type = org.apache.flume.sink.JDBCSink

master1.sinks.jdbc-sink-300.type = org.apache.flume.sink.JDBCSink

master1.sinks.jdbc-sink-400.type = org.apache.flume.sink.JDBCSink

master1.sinks.jdbc-sink-500.type = org.apache.flume.sink.JDBCSink

master1.sinks.jdbc-sink-600.type = org.apache.flume.sink.JDBCSink

master1.sinks.jdbc-sink-700.type = org.apache.flume.sink.JDBCSink

 

# URL to connect to database

#master1.sinks.jdbc-sink-100.sink.jdbc.driver = sunje.sundb.jdbc.SundbDriver

#master1.sinks.jdbc-sink-100.sink.connection.url = jdbc:sundb://160.61.194.54:22581/700

master1.sinks.jdbc-sink-100.sink.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-100.sink.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

 

master1.sinks.jdbc-sink-200.sink.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-200.sink.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

 

master1.sinks.jdbc-sink-300.sink.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-300.sink.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

 

master1.sinks.jdbc-sink-400.sink.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-400.sink.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

 

master1.sinks.jdbc-sink-500.sink.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-500.sink.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

 

master1.sinks.jdbc-sink-600.sink.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-600.sink.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

 

master1.sinks.jdbc-sink-700.sink.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-700.sink.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

 

# Database connection properties

master1.sinks.jdbc-sink-100.sink.charset = euc-kr

#master1.sinks.jdbc-sink-100.sink.charset = utf-8

master1.sinks.jdbc-sink-100.sink.user = BaroFDS

master1.sinks.jdbc-sink-100.sink.password = BaroFDS

 

master1.sinks.jdbc-sink-200.sink.charset = euc-kr

master1.sinks.jdbc-sink-200.sink.user = BaroFDS

master1.sinks.jdbc-sink-200.sink.password = BaroFDS

 

master1.sinks.jdbc-sink-300.sink.charset = euc-kr

master1.sinks.jdbc-sink-300.sink.user = BaroFDS

master1.sinks.jdbc-sink-300.sink.password = BaroFDS

 

master1.sinks.jdbc-sink-400.sink.charset = euc-kr

master1.sinks.jdbc-sink-400.sink.user = BaroFDS

master1.sinks.jdbc-sink-400.sink.password = BaroFDS

 

master1.sinks.jdbc-sink-500.sink.charset = euc-kr

master1.sinks.jdbc-sink-500.sink.user = BaroFDS

master1.sinks.jdbc-sink-500.sink.password = BaroFDS

 

master1.sinks.jdbc-sink-600.sink.charset = euc-kr

master1.sinks.jdbc-sink-600.sink.user = BaroFDS

master1.sinks.jdbc-sink-600.sink.password = BaroFDS

 

master1.sinks.jdbc-sink-700.sink.charset = euc-kr

master1.sinks.jdbc-sink-700.sink.user = BaroFDS

master1.sinks.jdbc-sink-700.sink.password = BaroFDS

 

# Data format properties(json, keyvalue, xml, delimiter, string)

master1.sinks.jdbc-sink-100.sink.data.format = delimiter

master1.sinks.jdbc-sink-200.sink.data.format = delimiter

master1.sinks.jdbc-sink-300.sink.data.format = delimiter

master1.sinks.jdbc-sink-400.sink.data.format = delimiter

master1.sinks.jdbc-sink-500.sink.data.format = delimiter

master1.sinks.jdbc-sink-600.sink.data.format = delimiter

master1.sinks.jdbc-sink-700.sink.data.format = delimiter

 

# Data delimit properties(delimit)

master1.sinks.jdbc-sink-100.sink.data.delimiter = ,

master1.sinks.jdbc-sink-200.sink.data.delimiter = ,

master1.sinks.jdbc-sink-300.sink.data.delimiter = ,

master1.sinks.jdbc-sink-400.sink.data.delimiter = ,

master1.sinks.jdbc-sink-500.sink.data.delimiter = ,

master1.sinks.jdbc-sink-600.sink.data.delimiter = ,

master1.sinks.jdbc-sink-700.sink.data.delimiter = ,

 

# Data table properties

master1.sinks.jdbc-sink-100.sink.data.table = NF_COLLECT_LOG_100

master1.sinks.jdbc-sink-200.sink.data.table = NF_COLLECT_LOG_200

master1.sinks.jdbc-sink-300.sink.data.table = NF_COLLECT_LOG_300

master1.sinks.jdbc-sink-400.sink.data.table = NF_COLLECT_LOG_400

master1.sinks.jdbc-sink-500.sink.data.table = NF_COLLECT_LOG_500

master1.sinks.jdbc-sink-600.sink.data.table = NF_COLLECT_LOG_600

master1.sinks.jdbc-sink-700.sink.data.table = NF_COLLECT_LOG_700

 

# SQL properties(xml, delimit, string)

master1.sinks.jdbc-sink-100.sink.sql.statement = INSERT INTO NF_COLLECT_LOG_100 (LOG_DTTM,IP_ADDR,MAC_ADDR,MDM_TP,USER_ID) VALUES (?,LPAD(SPLIT_PART(?,'.',1),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',2),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',3),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',4),3,'0'),UPPER(REPLACE(REPLACE(?,':',''),'-','')),?,?)

master1.sinks.jdbc-sink-100.sink.sql.dataseq = 0,1,1,1,1,2,3,4

master1.sinks.jdbc-sink-100.sink.rule.dataseq = 0,4

 

master1.sinks.jdbc-sink-200.sink.sql.statement = INSERT INTO NF_COLLECT_LOG_200 (LOG_DTTM,IP_ADDR,CERT_CHG_CD,MDM_TP,USER_ID,CERT_SVC_CD) VALUES (?,LPAD(SPLIT_PART(?,'.',1),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',2),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',3),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',4),3,'0'),?,?,?,?)

master1.sinks.jdbc-sink-200.sink.sql.dataseq = 0,1,1,1,1,2,3,4,5

master1.sinks.jdbc-sink-200.sink.rule.dataseq = 0,4

 

master1.sinks.jdbc-sink-300.sink.sql.statement = INSERT INTO NF_COLLECT_LOG_300 (LOG_DTTM,IP_ADDR,HDD_SN,MDM_TP,USER_ID) VALUES (?,LPAD(SPLIT_PART(?,'.',1),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',2),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',3),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',4),3,'0'),?,?,?)

master1.sinks.jdbc-sink-300.sink.sql.dataseq = 0,1,1,1,1,2,3,4

master1.sinks.jdbc-sink-300.sink.rule.dataseq = 0,4

 

master1.sinks.jdbc-sink-400.sink.sql.statement = INSERT INTO NF_COLLECT_LOG_400 (LOG_DTTM,FOREIGN_YN,USER_ID) VALUES (?,?,?)

master1.sinks.jdbc-sink-400.sink.sql.dataseq = 0,1,2

master1.sinks.jdbc-sink-400.sink.rule.dataseq = 0,2

 

master1.sinks.jdbc-sink-500.sink.sql.statement = INSERT INTO NF_COLLECT_LOG_500 (LOG_DTTM,USER_ID,IP_ADDR,RCVG_FNS_CD,OUR_ANCO_TP_CD,RCVG_BNK_BRCH_CD,RCVG_ACNT_NO,TRD_AMT,RCVG_ACNT_NM,OTAM_ACNT_NM,OTAM_ACNT_NO,BKNG_TRD_STAT_CD,CHNL_TP_CD,MDM_CLASS_CD,ELEC_FN_MDM_TP_CD,ATM_MACH_NO) VALUES (?,?,LPAD(SPLIT_PART(?,'.',1),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',2),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',3),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',4),3,'0'),?,?,?,?,?,?,?,?,?,?,?,?,?)

master1.sinks.jdbc-sink-500.sink.sql.dataseq = 0,1,2,2,2,2,3,4,5,6,7,8,9,10,11,12,13,14,15

master1.sinks.jdbc-sink-500.sink.rule.dataseq = 0,1

 

master1.sinks.jdbc-sink-600.sink.sql.statement = INSERT INTO NF_COLLECT_LOG_600 (LOG_DTTM,DLV_DT,OTP_STAT_CD,USER_ID) VALUES (?,?,?,?)

master1.sinks.jdbc-sink-600.sink.sql.dataseq = 0,1,2,3

master1.sinks.jdbc-sink-600.sink.rule.dataseq = 0,3

 

master1.sinks.jdbc-sink-700.sink.sql.statement = INSERT INTO NF_COLLECT_LOG_700 (LOG_DTTM,REG_DT,USER_ID) VALUES (?,?,?)

master1.sinks.jdbc-sink-700.sink.sql.dataseq = 0,1,2

master1.sinks.jdbc-sink-700.sink.rule.dataseq = 0,2

 

# Data charset properties

#master1.sinks.jdbc-sink-100.sink.data.charset = utf-8,euc-kr

master1.sinks.jdbc-sink-100.sink.data.charset =

master1.sinks.jdbc-sink-200.sink.data.charset =

master1.sinks.jdbc-sink-300.sink.data.charset =

master1.sinks.jdbc-sink-400.sink.data.charset =

master1.sinks.jdbc-sink-500.sink.data.charset =

master1.sinks.jdbc-sink-600.sink.data.charset =

master1.sinks.jdbc-sink-700.sink.data.charset =

 

# UnitRule properties(Y or N)

master1.sinks.jdbc-sink-100.sink.unit.rule = Y

master1.sinks.jdbc-sink-200.sink.unit.rule = Y

master1.sinks.jdbc-sink-300.sink.unit.rule = Y

master1.sinks.jdbc-sink-400.sink.unit.rule = Y

master1.sinks.jdbc-sink-500.sink.unit.rule = Y

master1.sinks.jdbc-sink-600.sink.unit.rule = Y

master1.sinks.jdbc-sink-700.sink.unit.rule = Y

 

# UnitRule SQL statement properties

master1.sinks.jdbc-sink-100.sink.unit.rule.statement = SELECT UNITRULE_CODE, UNITRULE_UNION_SQL FROM NF_UNIT_RULE WHERE TASK_TYPE = ? AND USE_YN = 'Y' ORDER BY UNITRULE_CODE ASC

master1.sinks.jdbc-sink-200.sink.unit.rule.statement = SELECT UNITRULE_CODE, UNITRULE_UNION_SQL FROM NF_UNIT_RULE WHERE TASK_TYPE = ? AND USE_YN = 'Y' ORDER BY UNITRULE_CODE ASC

master1.sinks.jdbc-sink-300.sink.unit.rule.statement = SELECT UNITRULE_CODE, UNITRULE_UNION_SQL FROM NF_UNIT_RULE WHERE TASK_TYPE = ? AND USE_YN = 'Y' ORDER BY UNITRULE_CODE ASC

master1.sinks.jdbc-sink-400.sink.unit.rule.statement = SELECT UNITRULE_CODE, UNITRULE_UNION_SQL FROM NF_UNIT_RULE WHERE TASK_TYPE = ? AND USE_YN = 'Y' ORDER BY UNITRULE_CODE ASC

master1.sinks.jdbc-sink-500.sink.unit.rule.statement = SELECT UNITRULE_CODE, UNITRULE_UNION_SQL FROM NF_UNIT_RULE WHERE TASK_TYPE = ? AND USE_YN = 'Y' ORDER BY UNITRULE_CODE ASC

master1.sinks.jdbc-sink-600.sink.unit.rule.statement = SELECT UNITRULE_CODE, UNITRULE_UNION_SQL FROM NF_UNIT_RULE WHERE TASK_TYPE = ? AND USE_YN = 'Y' ORDER BY UNITRULE_CODE ASC

master1.sinks.jdbc-sink-700.sink.unit.rule.statement = SELECT UNITRULE_CODE, UNITRULE_UNION_SQL FROM NF_UNIT_RULE WHERE TASK_TYPE = ? AND USE_YN = 'Y' ORDER BY UNITRULE_CODE ASC

 

# UnitRule code update properties

master1.sinks.jdbc-sink-100.sink.unit.rule.code.update = UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')

master1.sinks.jdbc-sink-200.sink.unit.rule.code.update = UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')

master1.sinks.jdbc-sink-300.sink.unit.rule.code.update = UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')

master1.sinks.jdbc-sink-400.sink.unit.rule.code.update = UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')

master1.sinks.jdbc-sink-500.sink.unit.rule.code.update = UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')

master1.sinks.jdbc-sink-600.sink.unit.rule.code.update = UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')

master1.sinks.jdbc-sink-700.sink.unit.rule.code.update = UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')

 

# Rule set properties(Y or N)

master1.sinks.jdbc-sink-100.sink.rule.set = Y

master1.sinks.jdbc-sink-200.sink.rule.set = Y

master1.sinks.jdbc-sink-300.sink.rule.set = Y

master1.sinks.jdbc-sink-400.sink.rule.set = Y

master1.sinks.jdbc-sink-500.sink.rule.set = Y

master1.sinks.jdbc-sink-600.sink.rule.set = Y

master1.sinks.jdbc-sink-700.sink.rule.set = Y

 

# Rule set detector SQL Statement properties

master1.sinks.jdbc-sink-100.sink.rule.set.detect.stmt1 = SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1'

master1.sinks.jdbc-sink-100.sink.rule.set.detect.stmt2 = SELECT UNITRULE_CODE FROM VW_DOUBT_CURRENT WHERE USER_ID = ?

master1.sinks.jdbc-sink-100.sink.rule.set.detect.stmt3 = SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC

master1.sinks.jdbc-sink-100.sink.rule.set.fds.stmt = INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')

 

master1.sinks.jdbc-sink-200.sink.rule.set.detect.stmt1 = SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1'

master1.sinks.jdbc-sink-200.sink.rule.set.detect.stmt2 = SELECT UNITRULE_CODE FROM VW_DOUBT_CURRENT WHERE USER_ID = ?

master1.sinks.jdbc-sink-200.sink.rule.set.detect.stmt3 = SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC

master1.sinks.jdbc-sink-200.sink.rule.set.fds.stmt = INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')

 

master1.sinks.jdbc-sink-300.sink.rule.set.detect.stmt1 = SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1'

master1.sinks.jdbc-sink-300.sink.rule.set.detect.stmt2 = SELECT UNITRULE_CODE FROM VW_DOUBT_CURRENT WHERE USER_ID = ?

master1.sinks.jdbc-sink-300.sink.rule.set.detect.stmt3 = SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC

master1.sinks.jdbc-sink-300.sink.rule.set.fds.stmt = INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')

 

master1.sinks.jdbc-sink-400.sink.rule.set.detect.stmt1 = SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1'

master1.sinks.jdbc-sink-400.sink.rule.set.detect.stmt2 = SELECT UNITRULE_CODE FROM VW_DOUBT_CURRENT WHERE USER_ID = ?

master1.sinks.jdbc-sink-400.sink.rule.set.detect.stmt3 = SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC

master1.sinks.jdbc-sink-400.sink.rule.set.fds.stmt = INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')

 

master1.sinks.jdbc-sink-500.sink.rule.set.detect.stmt1 = SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1'

master1.sinks.jdbc-sink-500.sink.rule.set.detect.stmt2 = SELECT UNITRULE_CODE FROM VW_DOUBT_CURRENT WHERE USER_ID = ?

master1.sinks.jdbc-sink-500.sink.rule.set.detect.stmt3 = SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC

master1.sinks.jdbc-sink-500.sink.rule.set.fds.stmt = INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')

 

master1.sinks.jdbc-sink-600.sink.rule.set.detect.stmt1 = SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1'

master1.sinks.jdbc-sink-600.sink.rule.set.detect.stmt2 = SELECT UNITRULE_CODE FROM VW_DOUBT_CURRENT WHERE USER_ID = ?

master1.sinks.jdbc-sink-600.sink.rule.set.detect.stmt3 = SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC

master1.sinks.jdbc-sink-600.sink.rule.set.fds.stmt = INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')

 

master1.sinks.jdbc-sink-700.sink.rule.set.detect.stmt1 = SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1'

master1.sinks.jdbc-sink-700.sink.rule.set.detect.stmt2 = SELECT UNITRULE_CODE FROM VW_DOUBT_CURRENT WHERE USER_ID = ?

master1.sinks.jdbc-sink-700.sink.rule.set.detect.stmt3 = SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC

master1.sinks.jdbc-sink-700.sink.rule.set.fds.stmt = INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')

 

# Accidents registered properties

master1.sinks.jdbc-sink-100.sink.fraud.detect = N

master1.sinks.jdbc-sink-100.sink.fraud.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-100.sink.fraud.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-100.sink.fraud.charset = utf-8

master1.sinks.jdbc-sink-100.sink.fraud.user = BaroFDS

master1.sinks.jdbc-sink-100.sink.fraud.password = BaroFDS

master1.sinks.jdbc-sink-100.sink.fraud.sql.statemet =

master1.sinks.jdbc-sink-100.sink.sms.message =

master1.sinks.jdbc-sink-100.sink.sms.sql.statemet =

 

master1.sinks.jdbc-sink-200.sink.fraud.detect = N

master1.sinks.jdbc-sink-200.sink.fraud.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-200.sink.fraud.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-200.sink.fraud.charset = utf-8

master1.sinks.jdbc-sink-200.sink.fraud.user = BaroFDS

master1.sinks.jdbc-sink-200.sink.fraud.password = BaroFDS

master1.sinks.jdbc-sink-200.sink.fraud.sql.statemet =

master1.sinks.jdbc-sink-200.sink.sms.message =

master1.sinks.jdbc-sink-200.sink.sms.sql.statemet =

 

master1.sinks.jdbc-sink-300.sink.fraud.detect = N

master1.sinks.jdbc-sink-300.sink.fraud.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-300.sink.fraud.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-300.sink.fraud.charset = utf-8

master1.sinks.jdbc-sink-300.sink.fraud.user = BaroFDS

master1.sinks.jdbc-sink-300.sink.fraud.password = BaroFDS

master1.sinks.jdbc-sink-300.sink.fraud.sql.statemet =

master1.sinks.jdbc-sink-300.sink.sms.message =

master1.sinks.jdbc-sink-300.sink.sms.sql.statemet =

 

master1.sinks.jdbc-sink-400.sink.fraud.detect = N

master1.sinks.jdbc-sink-400.sink.fraud.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-400.sink.fraud.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-400.sink.fraud.charset = utf-8

master1.sinks.jdbc-sink-400.sink.fraud.user = BaroFDS

master1.sinks.jdbc-sink-400.sink.fraud.password = BaroFDS

master1.sinks.jdbc-sink-400.sink.fraud.sql.statemet =

master1.sinks.jdbc-sink-400.sink.sms.message =

master1.sinks.jdbc-sink-400.sink.sms.sql.statemet =

 

master1.sinks.jdbc-sink-500.sink.fraud.detect = N

master1.sinks.jdbc-sink-500.sink.fraud.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-500.sink.fraud.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-500.sink.fraud.charset = utf-8

master1.sinks.jdbc-sink-500.sink.fraud.user = BaroFDS

master1.sinks.jdbc-sink-500.sink.fraud.password = BaroFDS

master1.sinks.jdbc-sink-500.sink.fraud.sql.statemet =

master1.sinks.jdbc-sink-500.sink.sms.message =

master1.sinks.jdbc-sink-500.sink.sms.sql.statemet =

 

master1.sinks.jdbc-sink-600.sink.fraud.detect = N

master1.sinks.jdbc-sink-600.sink.fraud.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-600.sink.fraud.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-600.sink.fraud.charset = utf-8

master1.sinks.jdbc-sink-600.sink.fraud.user = BaroFDS

master1.sinks.jdbc-sink-600.sink.fraud.password = BaroFDS

master1.sinks.jdbc-sink-600.sink.fraud.sql.statemet =

master1.sinks.jdbc-sink-600.sink.sms.message =

master1.sinks.jdbc-sink-600.sink.sms.sql.statemet =

 

master1.sinks.jdbc-sink-700.sink.fraud.detect = N

master1.sinks.jdbc-sink-700.sink.fraud.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-700.sink.fraud.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-700.sink.fraud.charset = utf-8

master1.sinks.jdbc-sink-700.sink.fraud.user = BaroFDS

master1.sinks.jdbc-sink-700.sink.fraud.password = BaroFDS

master1.sinks.jdbc-sink-700.sink.fraud.sql.statemet =

master1.sinks.jdbc-sink-700.sink.sms.message =

master1.sinks.jdbc-sink-700.sink.sms.sql.statemet =

 

# BankSystem properties

master1.sinks.jdbc-sink-100.sink.cust.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-100.sink.cust.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-100.sink.cust.charset = utf-8

master1.sinks.jdbc-sink-100.sink.cust.user = BaroFDS

master1.sinks.jdbc-sink-100.sink.cust.password = BaroFDS

master1.sinks.jdbc-sink-100.sink.cust.sql.statemet =

 

master1.sinks.jdbc-sink-200.sink.cust.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-200.sink.cust.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-200.sink.cust.charset = utf-8

master1.sinks.jdbc-sink-200.sink.cust.user = BaroFDS

master1.sinks.jdbc-sink-200.sink.cust.password = BaroFDS

master1.sinks.jdbc-sink-200.sink.cust.sql.statemet =

 

master1.sinks.jdbc-sink-300.sink.cust.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-300.sink.cust.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-300.sink.cust.charset = utf-8

master1.sinks.jdbc-sink-300.sink.cust.user = BaroFDS

master1.sinks.jdbc-sink-300.sink.cust.password = BaroFDS

master1.sinks.jdbc-sink-300.sink.cust.sql.statemet =

 

master1.sinks.jdbc-sink-400.sink.cust.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-400.sink.cust.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-400.sink.cust.charset = utf-8

master1.sinks.jdbc-sink-400.sink.cust.user = BaroFDS

master1.sinks.jdbc-sink-400.sink.cust.password = BaroFDS

master1.sinks.jdbc-sink-400.sink.cust.sql.statemet =

 

master1.sinks.jdbc-sink-500.sink.cust.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-500.sink.cust.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-500.sink.cust.charset = utf-8

master1.sinks.jdbc-sink-500.sink.cust.user = BaroFDS

master1.sinks.jdbc-sink-500.sink.cust.password = BaroFDS

master1.sinks.jdbc-sink-500.sink.cust.sql.statemet =

 

master1.sinks.jdbc-sink-600.sink.cust.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-600.sink.cust.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-600.sink.cust.charset = utf-8

master1.sinks.jdbc-sink-600.sink.cust.user = BaroFDS

master1.sinks.jdbc-sink-600.sink.cust.password = BaroFDS

master1.sinks.jdbc-sink-600.sink.cust.sql.statemet =

 

master1.sinks.jdbc-sink-700.sink.cust.jdbc.driver = oracle.jdbc.OracleDriver

master1.sinks.jdbc-sink-700.sink.cust.connection.url = jdbc:oracle:thin:@1.234.83.169:1521:ORCL

master1.sinks.jdbc-sink-700.sink.cust.charset = utf-8

master1.sinks.jdbc-sink-700.sink.cust.user = BaroFDS

master1.sinks.jdbc-sink-700.sink.cust.password = BaroFDS

master1.sinks.jdbc-sink-700.sink.cust.sql.statemet =

 

# Specify the channel the sink should use

#master1.sinks.fileSink1.channel = mem-channel-100

master1.sinks.jdbc-sink-100.channel = mem-channel-100

master1.sinks.jdbc-sink-200.channel = mem-channel-200

master1.sinks.jdbc-sink-300.channel = mem-channel-300

master1.sinks.jdbc-sink-400.channel = mem-channel-400

master1.sinks.jdbc-sink-500.channel = mem-channel-500

master1.sinks.jdbc-sink-600.channel = mem-channel-600

master1.sinks.jdbc-sink-700.channel = mem-channel-700

 

# Each channel's type is defined.

master1.channels.mem-channel-100.type = memory

#master1.channels.mem-channel-100.type = file

master1.channels.mem-channel-100.checkpointDir = ./checkpoint_100

master1.channels.mem-channel-100.dataDirs = ./checkdata_100

 

master1.channels.mem-channel-200.type = memory

master1.channels.mem-channel-200.checkpointDir = ./checkpoint_200

master1.channels.mem-channel-200.dataDirs = ./checkdata_200

 

master1.channels.mem-channel-300.type = memory

master1.channels.mem-channel-300.checkpointDir = ./checkpoint_300

master1.channels.mem-channel-300.dataDirs = ./checkdata_300

 

master1.channels.mem-channel-400.type = memory

master1.channels.mem-channel-400.checkpointDir = ./checkpoint_400

master1.channels.mem-channel-400.dataDirs = ./checkdata_400

 

master1.channels.mem-channel-500.type = memory

master1.channels.mem-channel-500.checkpointDir = ./checkpoint_400

master1.channels.mem-channel-500.dataDirs = ./checkdata_400

 

master1.channels.mem-channel-600.type = memory

master1.channels.mem-channel-600.checkpointDir = ./checkpoint_400

master1.channels.mem-channel-600.dataDirs = ./checkdata_400

 

master1.channels.mem-channel-700.type = memory

master1.channels.mem-channel-700.checkpointDir = ./checkpoint_400

master1.channels.mem-channel-700.dataDirs = ./checkdata_400

 

# Other config values specific to each type of channel(sink or source)

# can be defined as well

# In this case, it specifies the capacity of the memory channel

master1.channels.mem-channel-100.capacity = 1080000

master1.channels.mem-channel-100.transactionCapacity = 10000

master1.channels.mem-channel-100.keep-alive = 3

 

master1.channels.mem-channel-200.capacity = 1080000

master1.channels.mem-channel-200.transactionCapacity = 10000

master1.channels.mem-channel-200.keep-alive = 3

 

master1.channels.mem-channel-300.capacity = 1080000

master1.channels.mem-channel-300.transactionCapacity = 10000

master1.channels.mem-channel-300.keep-alive = 3

 

master1.channels.mem-channel-400.capacity = 1080000

master1.channels.mem-channel-400.transactionCapacity = 10000

master1.channels.mem-channel-400.keep-alive = 3

 

master1.channels.mem-channel-500.capacity = 1080000

master1.channels.mem-channel-500.transactionCapacity = 10000

master1.channels.mem-channel-500.keep-alive = 3

 

master1.channels.mem-channel-600.capacity = 1080000

master1.channels.mem-channel-600.transactionCapacity = 10000

master1.channels.mem-channel-600.keep-alive = 3

 

master1.channels.mem-channel-700.capacity = 1080000

master1.channels.mem-channel-700.transactionCapacity = 10000

master1.channels.mem-channel-700.keep-alive = 3

 

 

5. Fraud Detector 기동

 

Fraud Detector를 기동하는 startup.sh 쉘 스크립트는 다음과 같다.

 

[root] /home/apache-flume-1.6.0-bin/server > vi startup.sh

#!/bin/sh

 

#export FLUME_HOME=/home/apache-flume-1.6.0-bin;

#export JAVA_HOME=/usr/lib/jvm/jre-1.7.0-openjdk.x86_64;

 

#export CLASSPATH=$CLASSPATH:$FLUME_HOME/lib:$JAVA_HOME/lib

#export PATH=$PATH:$FLUME_HOME/bin:$JAVA_HOME/bin

 

flume-ng agent -n master1 -c $FLUME_HOME/server/ -f flume.conf

 

Fraud Detector 기동은 startup.sh 쉘 스크립트를 백드라운드 프로세스로 다음과 같이 실행하면 된다.

 

[root] /home/apache-flume-1.6.0-bin/server > sh startup.sh &

 

Fraud Detector가 실행되고 있는지 확인하기 위해서는 다음과 같은 명령어를 수행한다.

 

[root] /home/apache-flume-1.6.0-bin/server > ps -ef|grep flume | grep master1 | grep -v grep

 

그러면, 다음과 같이 Fraud Detector 프로세스가 존재하는지 확인할 수 있다.

 

[root] /home/apache-flume-1.6.0-bin/server > ps -ef|grep flume | grep master1 | grep -v grep

root      8144  8140 23 11:45 pts/4    00:00:01 /usr/lib/jvm/jre-1.7.0-openjdk.x86_64/bin/java -XX:MaxDirectMemorySize=128m -cp /home/apache-flume-1.6.0-bin/server/master1:/home/apache-flume-1.6.0-bin/lib/*:/home/apache-flume-1.6.0-bin/lib:/lib/* -Djava.library.path= org.apache.flume.node.Application -n master1 -f flume.conf

 

 

6. Fraud Detector 종료

 

Fraud Detector를 종료하는 shutdown.sh 쉘 스크립트는 다음과 같다.

 

[root] /home/apache-flume-1.6.0-bin/server > vi shutdown.sh

#!/bin/sh

 

#export FLUME_HOME=/home/apache-flume-1.6.0-bin;

#export JAVA_HOME=/usr/lib/jvm/jre-1.7.0-openjdk.x86_64;

 

#export CLASSPATH=$CLASSPATH:$FLUME_HOME/lib:$JAVA_HOME/lib

#export PATH=$PATH:$FLUME_HOME/bin:$JAVA_HOME/bin

 

ps -ef|grep flume | grep master1 | grep -v grep |awk '{print "kill -9 "$2}'|sh -v

 

Fraud Detector 종료는 shutdown.sh 쉘 스크립트를 다음과 같이 실행하면 된다.

 

[root] /home/apache-flume-1.6.0-bin/server > sh shutdown.sh

 

 

7. Fraud Detector 로그

 

Fraud Detector 로그는 Fraud Detector가 실행되면서 발생한 로그(INFO, WARN, ERROR) 및 수집하면서 남긴 로그들이 남아 향후 Fraud Detector 상태 및 장애 발생시 원인 구명 등에 활용하는 중요한 로그다.

 

[root] /home/apache-flume-1.6.0-bin/server/logs > ls -al

합계 20

drwxr-xr-x 2 root root  4096 12  4 11:05 .

drwxr-xr-x 6 root root  4096 12  4 11:04 ..

-rw-r--r-- 1 root root 12188 12  4 11:05 flume.log

 

[root] /home/apache-flume-1.6.0-bin/server/logs > vi flume.log

04 12¿5 11:05:10,391 INFO  [lifecycleSupervisor-1-0] (org.apache.flume.node.PollingPropertiesFileConfigurationProvider.start:61)  - Configuration provider starting

04 12¿5 11:05:10,425 INFO  [conf-file-poller-0] (org.apache.flume.node.PollingPropertiesFileConfigurationProvider$FileWatcherRunnable.run:133)  - Reloading configuration file:flume.conf

04 12¿5 11:05:10,459 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,461 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,463 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-500.sink.sms.message =

04 12¿5 11:05:10,463 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,463 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,463 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,463 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,463 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,463 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,464 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,464 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,464 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,464 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,464 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,472 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,472 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,472 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,472 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,473 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-400.sink.data.charset =

04 12¿5 11:05:10,473 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,473 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,473 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,473 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,474 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,474 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,474 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,474 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:931)  - Added sinks: jdbc-sink-100 jdbc-sink-200 jdbc-sink-300 jdbc-sink-400 jdbc-sink-500 jdbc-sink-600 jdbc-sink-700 Agent: master1

04 12¿5 11:05:10,474 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,475 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,475 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,475 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,475 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,475 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,475 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,475 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,475 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,476 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,476 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-300.sink.data.charset =

04 12¿5 11:05:10,476 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,476 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,476 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,476 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,476 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,476 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,477 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,477 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,477 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,477 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,477 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,477 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,477 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,477 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,478 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-200.sink.fraud.sql.statemet =

04 12¿5 11:05:10,478 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-100.sink.data.charset =

04 12¿5 11:05:10,478 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,478 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,478 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,478 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,478 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,479 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,479 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,479 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,479 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,479 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,479 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,479 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,479 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,480 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,480 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,480 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,480 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,480 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,480 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,480 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,481 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,481 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,481 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,481 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,481 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,481 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,481 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,482 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,482 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,482 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,482 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,482 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-100.sink.sms.message =

04 12¿5 11:05:10,482 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,482 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,482 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,483 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,483 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,483 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,483 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,483 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,483 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-300.sink.cust.sql.statemet =

04 12¿5 11:05:10,483 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,483 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-500.sink.sms.sql.statemet =

04 12¿5 11:05:10,484 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,484 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,484 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,484 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-700.sink.sms.message =

04 12¿5 11:05:10,484 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,484 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,484 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,484 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-600.sink.cust.sql.statemet =

04 12¿5 11:05:10,485 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,485 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,485 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,485 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,485 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,485 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,485 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,485 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,485 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-100.sink.sms.sql.statemet =

04 12¿5 11:05:10,486 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,486 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,486 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,486 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,486 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,486 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,486 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,486 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-500.sink.cust.sql.statemet =

04 12¿5 11:05:10,486 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,487 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,487 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,487 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,487 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-500.sink.fraud.sql.statemet =

04 12¿5 11:05:10,487 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,487 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,487 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,487 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,487 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,488 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,488 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,488 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,488 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,488 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,488 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-100.sink.fraud.sql.statemet =

04 12¿5 11:05:10,488 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-700.sink.cust.sql.statemet =

04 12¿5 11:05:10,488 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,488 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,489 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,489 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,489 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-700.sink.data.charset =

04 12¿5 11:05:10,489 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,489 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-300.sink.fraud.sql.statemet =

04 12¿5 11:05:10,489 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,489 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,489 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,489 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,489 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,490 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,490 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,490 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,490 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,490 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,490 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,490 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,490 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,490 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,491 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,491 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,491 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-300.sink.sms.sql.statemet =

04 12¿5 11:05:10,491 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,491 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,491 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,491 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,491 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,491 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-100.sink.cust.sql.statemet =

04 12¿5 11:05:10,491 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,492 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,492 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,492 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,492 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-600.sink.fraud.sql.statemet =

04 12¿5 11:05:10,492 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,492 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,492 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,492 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,492 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,492 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,493 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,493 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,493 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,493 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,493 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,493 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,493 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-700.sink.fraud.sql.statemet =

04 12¿5 11:05:10,493 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,493 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,494 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,494 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,494 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,494 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,494 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,494 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,494 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,494 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,494 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,495 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,495 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,495 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,495 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,495 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,495 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,495 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,495 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,495 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,495 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,496 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,496 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,496 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,496 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-200.sink.cust.sql.statemet =

04 12¿5 11:05:10,496 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,496 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,496 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,496 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,496 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,497 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,497 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,497 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-600.sink.data.charset =

04 12¿5 11:05:10,497 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,497 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,497 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-400.sink.sms.sql.statemet =

04 12¿5 11:05:10,497 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-200.sink.sms.sql.statemet =

04 12¿5 11:05:10,497 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,497 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-600.sink.sms.sql.statemet =

04 12¿5 11:05:10,498 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,498 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-400.sink.cust.sql.statemet =

04 12¿5 11:05:10,498 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-400.sink.fraud.sql.statemet =

04 12¿5 11:05:10,498 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-700.sink.sms.sql.statemet =

04 12¿5 11:05:10,498 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-200.sink.data.charset =

04 12¿5 11:05:10,498 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,498 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,498 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-600.sink.sms.message =

04 12¿5 11:05:10,498 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,498 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,499 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,499 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-400

04 12¿5 11:05:10,499 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,499 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,499 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,499 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,499 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,499 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,499 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,500 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-300

04 12¿5 11:05:10,500 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-700

04 12¿5 11:05:10,500 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,500 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-300.sink.sms.message =

04 12¿5 11:05:10,500 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,500 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,500 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,500 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-500.sink.data.charset =

04 12¿5 11:05:10,500 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-600

04 12¿5 11:05:10,500 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,501 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-500

04 12¿5 11:05:10,501 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-200

04 12¿5 11:05:10,501 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-400.sink.sms.message =

04 12¿5 11:05:10,501 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration$AgentConfiguration.addProperty:1017)  - Processing:jdbc-sink-100

04 12¿5 11:05:10,501 WARN  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.<init>:102)  - Configuration property ignored: master1.sinks.jdbc-sink-200.sink.sms.message =

04 12¿5 11:05:10,528 INFO  [conf-file-poller-0] (org.apache.flume.conf.FlumeConfiguration.validateConfiguration:141)  - Post-validation flume configuration contains configuration for agents: [master1]

04 12¿5 11:05:10,528 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.loadChannels:145)  - Creating channels

04 12¿5 11:05:10,535 INFO  [conf-file-poller-0] (org.apache.flume.channel.DefaultChannelFactory.create:42)  - Creating instance of channel mem-channel-200 type memory

04 12¿5 11:05:10,539 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.loadChannels:200)  - Created channel mem-channel-200

04 12¿5 11:05:10,539 INFO  [conf-file-poller-0] (org.apache.flume.channel.DefaultChannelFactory.create:42)  - Creating instance of channel mem-channel-600 type memory

04 12¿5 11:05:10,539 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.loadChannels:200)  - Created channel mem-channel-600

04 12¿5 11:05:10,539 INFO  [conf-file-poller-0] (org.apache.flume.channel.DefaultChannelFactory.create:42)  - Creating instance of channel mem-channel-500 type memory

04 12¿5 11:05:10,540 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.loadChannels:200)  - Created channel mem-channel-500

04 12¿5 11:05:10,540 INFO  [conf-file-poller-0] (org.apache.flume.channel.DefaultChannelFactory.create:42)  - Creating instance of channel mem-channel-700 type memory

04 12¿5 11:05:10,540 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.loadChannels:200)  - Created channel mem-channel-700

04 12¿5 11:05:10,540 INFO  [conf-file-poller-0] (org.apache.flume.channel.DefaultChannelFactory.create:42)  - Creating instance of channel mem-channel-400 type memory

04 12¿5 11:05:10,540 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.loadChannels:200)  - Created channel mem-channel-400

04 12¿5 11:05:10,540 INFO  [conf-file-poller-0] (org.apache.flume.channel.DefaultChannelFactory.create:42)  - Creating instance of channel mem-channel-300 type memory

04 12¿5 11:05:10,540 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.loadChannels:200)  - Created channel mem-channel-300

04 12¿5 11:05:10,540 INFO  [conf-file-poller-0] (org.apache.flume.channel.DefaultChannelFactory.create:42)  - Creating instance of channel mem-channel-100 type memory

04 12¿5 11:05:10,541 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.loadChannels:200)  - Created channel mem-channel-100

04 12¿5 11:05:10,541 INFO  [conf-file-poller-0] (org.apache.flume.source.DefaultSourceFactory.create:41)  - Creating instance of source master1, type avro

04 12¿5 11:05:10,568 INFO  [conf-file-poller-0] (org.apache.flume.sink.DefaultSinkFactory.create:42)  - Creating instance of sink: jdbc-sink-400, type: org.apache.flume.sink.JDBCSink

04 12¿5 11:05:10,607 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSink.configure:45)  - Reading and processing configuration values for sink jdbc-sink-400

04 12¿5 11:05:10,610 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:74)  - JDBCSinkUtils.!!!

04 12¿5 11:05:10,610 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:75)  - jdbcDriver         = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,610 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:76)  - connectionURL      = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,610 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:77)  - charset            = [euc-kr]

04 12¿5 11:05:10,611 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:78)  - user               = [BaroFDS]

04 12¿5 11:05:10,611 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:79)  - password           = [BaroFDS]

04 12¿5 11:05:10,611 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:80)  - dataFormat         = [delimiter]

04 12¿5 11:05:10,611 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:81)  - dataDelimiter      = [,]

04 12¿5 11:05:10,611 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:82)  - dataTable          = [NF_COLLECT_LOG_400]

04 12¿5 11:05:10,612 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:83)  - sqlStatement       = [INSERT INTO NF_COLLECT_LOG_400 (LOG_DTTM,FOREIGN_YN,USER_ID) VALUES (?,?,?)]

04 12¿5 11:05:10,612 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:84)  - sqlDataSeq         = [0,1,2]

04 12¿5 11:05:10,612 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:85)  - ruleDataSeq        = [0,2]

04 12¿5 11:05:10,612 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:86)  - dataCharset        = []

04 12¿5 11:05:10,612 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:88)  - unitRule           = [Y]

04 12¿5 11:05:10,613 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:89)  - unitRuleStatement  = []

04 12¿5 11:05:10,613 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:90)  - unitRuleCodeUpdate = [UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')]

04 12¿5 11:05:10,613 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:92)  - ruleSet            = [Y]

04 12¿5 11:05:10,613 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:93)  - ruleSetDetectStmt1 = [SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1']

04 12¿5 11:05:10,614 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:94)  - ruleSetDetectStmt3 = [SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC]

04 12¿5 11:05:10,614 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:95)  - ruleSetFDSStmt     = [INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')]

04 12¿5 11:05:10,614 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:97)  - fraudDetect        = [N]

04 12¿5 11:05:10,614 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:98)  - fraudJDBCDriver    = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,614 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:99)  - fraudConnectionURL = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,615 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:100)  - fraudCharset       = [utf-8]

04 12¿5 11:05:10,615 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:101)  - fraudUser          = [BaroFDS]

04 12¿5 11:05:10,615 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:102)  - fraudSQLStatement  = []

04 12¿5 11:05:10,615 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:103)  - smsMessage         = []

04 12¿5 11:05:10,615 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:104)  - smsSQLStatement    = []

04 12¿5 11:05:10,616 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:106)  - custJDBCDriver     = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,616 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:107)  - custConnectionURL  = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,616 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:108)  - custCharset        = [utf-8]

04 12¿5 11:05:10,616 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:109)  - custUser           = [BaroFDS]

04 12¿5 11:05:10,616 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:110)  - custSQLStatement   = []

04 12¿5 11:05:10,617 INFO  [conf-file-poller-0] (org.apache.flume.sink.DefaultSinkFactory.create:42)  - Creating instance of sink: jdbc-sink-100, type: org.apache.flume.sink.JDBCSink

04 12¿5 11:05:10,617 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSink.configure:45)  - Reading and processing configuration values for sink jdbc-sink-100

04 12¿5 11:05:10,617 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:74)  - JDBCSinkUtils.!!!

04 12¿5 11:05:10,617 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:75)  - jdbcDriver         = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,618 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:76)  - connectionURL      = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,618 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:77)  - charset            = [euc-kr]

04 12¿5 11:05:10,618 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:78)  - user               = [BaroFDS]

04 12¿5 11:05:10,618 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:79)  - password           = [BaroFDS]

04 12¿5 11:05:10,618 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:80)  - dataFormat         = [delimiter]

04 12¿5 11:05:10,619 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:81)  - dataDelimiter      = [,]

04 12¿5 11:05:10,619 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:82)  - dataTable          = [NF_COLLECT_LOG_100]

04 12¿5 11:05:10,619 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:83)  - sqlStatement       = [INSERT INTO NF_COLLECT_LOG_100 (LOG_DTTM,IP_ADDR,MAC_ADDR,MDM_TP,USER_ID) VALUES (?,LPAD(SPLIT_PART(?,'.',1),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',2),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',3),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',4),3,'0'),UPPER(REPLACE(REPLACE(?,':',''),'-','')),?,?)]

04 12¿5 11:05:10,619 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:84)  - sqlDataSeq         = [0,1,1,1,1,2,3,4]

04 12¿5 11:05:10,619 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:85)  - ruleDataSeq        = [0,4]

04 12¿5 11:05:10,620 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:86)  - dataCharset        = []

04 12¿5 11:05:10,620 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:88)  - unitRule           = [Y]

04 12¿5 11:05:10,620 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:89)  - unitRuleStatement  = []

04 12¿5 11:05:10,620 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:90)  - unitRuleCodeUpdate = [UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')]

04 12¿5 11:05:10,620 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:92)  - ruleSet            = [Y]

04 12¿5 11:05:10,621 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:93)  - ruleSetDetectStmt1 = [SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1']

04 12¿5 11:05:10,621 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:94)  - ruleSetDetectStmt3 = [SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC]

04 12¿5 11:05:10,621 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:95)  - ruleSetFDSStmt     = [INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')]

04 12¿5 11:05:10,621 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:97)  - fraudDetect        = [N]

04 12¿5 11:05:10,621 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:98)  - fraudJDBCDriver    = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,622 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:99)  - fraudConnectionURL = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,622 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:100)  - fraudCharset       = [utf-8]

04 12¿5 11:05:10,622 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:101)  - fraudUser          = [BaroFDS]

04 12¿5 11:05:10,622 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:102)  - fraudSQLStatement  = []

04 12¿5 11:05:10,622 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:103)  - smsMessage         = []

04 12¿5 11:05:10,622 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:104)  - smsSQLStatement    = []

04 12¿5 11:05:10,622 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:106)  - custJDBCDriver     = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,622 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:107)  - custConnectionURL  = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,622 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:108)  - custCharset        = [utf-8]

04 12¿5 11:05:10,623 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:109)  - custUser           = [BaroFDS]

04 12¿5 11:05:10,623 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:110)  - custSQLStatement   = []

04 12¿5 11:05:10,623 INFO  [conf-file-poller-0] (org.apache.flume.sink.DefaultSinkFactory.create:42)  - Creating instance of sink: jdbc-sink-500, type: org.apache.flume.sink.JDBCSink

04 12¿5 11:05:10,623 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSink.configure:45)  - Reading and processing configuration values for sink jdbc-sink-500

04 12¿5 11:05:10,623 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:74)  - JDBCSinkUtils.!!!

04 12¿5 11:05:10,623 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:75)  - jdbcDriver         = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,623 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:76)  - connectionURL      = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,623 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:77)  - charset            = [euc-kr]

04 12¿5 11:05:10,623 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:78)  - user               = [BaroFDS]

04 12¿5 11:05:10,623 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:79)  - password           = [BaroFDS]

04 12¿5 11:05:10,623 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:80)  - dataFormat         = [delimiter]

04 12¿5 11:05:10,624 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:81)  - dataDelimiter      = [,]

04 12¿5 11:05:10,624 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:82)  - dataTable          = [NF_COLLECT_LOG_500]

04 12¿5 11:05:10,624 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:83)  - sqlStatement       = [INSERT INTO NF_COLLECT_LOG_500 (LOG_DTTM,USER_ID,IP_ADDR,RCVG_FNS_CD,OUR_ANCO_TP_CD,RCVG_BNK_BRCH_CD,RCVG_ACNT_NO,TRD_AMT,RCVG_ACNT_NM,OTAM_ACNT_NM,OTAM_ACNT_NO,BKNG_TRD_STAT_CD,CHNL_TP_CD,MDM_CLASS_CD,ELEC_FN_MDM_TP_CD,ATM_MACH_NO) VALUES (?,?,LPAD(SPLIT_PART(?,'.',1),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',2),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',3),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',4),3,'0'),?,?,?,?,?,?,?,?,?,?,?,?,?)]

04 12¿5 11:05:10,624 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:84)  - sqlDataSeq         = [0,1,2,2,2,2,3,4,5,6,7,8,9,10,11,12,13,14,15]

04 12¿5 11:05:10,624 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:85)  - ruleDataSeq        = [0,1]

04 12¿5 11:05:10,624 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:86)  - dataCharset        = []

04 12¿5 11:05:10,624 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:88)  - unitRule           = [Y]

04 12¿5 11:05:10,624 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:89)  - unitRuleStatement  = []

04 12¿5 11:05:10,624 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:90)  - unitRuleCodeUpdate = [UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')]

04 12¿5 11:05:10,624 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:92)  - ruleSet            = [Y]

04 12¿5 11:05:10,625 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:93)  - ruleSetDetectStmt1 = [SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1']

04 12¿5 11:05:10,625 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:94)  - ruleSetDetectStmt3 = [SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC]

04 12¿5 11:05:10,625 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:95)  - ruleSetFDSStmt     = [INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')]

04 12¿5 11:05:10,625 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:97)  - fraudDetect        = [N]

04 12¿5 11:05:10,625 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:98)  - fraudJDBCDriver    = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,625 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:99)  - fraudConnectionURL = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,625 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:100)  - fraudCharset       = [utf-8]

04 12¿5 11:05:10,625 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:101)  - fraudUser          = [BaroFDS]

04 12¿5 11:05:10,625 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:102)  - fraudSQLStatement  = []

04 12¿5 11:05:10,625 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:103)  - smsMessage         = []

04 12¿5 11:05:10,625 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:104)  - smsSQLStatement    = []

04 12¿5 11:05:10,625 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:106)  - custJDBCDriver     = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,626 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:107)  - custConnectionURL  = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,626 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:108)  - custCharset        = [utf-8]

04 12¿5 11:05:10,626 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:109)  - custUser           = [BaroFDS]

04 12¿5 11:05:10,626 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:110)  - custSQLStatement   = []

04 12¿5 11:05:10,626 INFO  [conf-file-poller-0] (org.apache.flume.sink.DefaultSinkFactory.create:42)  - Creating instance of sink: jdbc-sink-600, type: org.apache.flume.sink.JDBCSink

04 12¿5 11:05:10,626 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSink.configure:45)  - Reading and processing configuration values for sink jdbc-sink-600

04 12¿5 11:05:10,626 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:74)  - JDBCSinkUtils.!!!

04 12¿5 11:05:10,626 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:75)  - jdbcDriver         = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,626 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:76)  - connectionURL      = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,626 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:77)  - charset            = [euc-kr]

04 12¿5 11:05:10,627 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:78)  - user               = [BaroFDS]

04 12¿5 11:05:10,627 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:79)  - password           = [BaroFDS]

04 12¿5 11:05:10,627 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:80)  - dataFormat         = [delimiter]

04 12¿5 11:05:10,627 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:81)  - dataDelimiter      = [,]

04 12¿5 11:05:10,627 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:82)  - dataTable          = [NF_COLLECT_LOG_600]

04 12¿5 11:05:10,627 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:83)  - sqlStatement       = [INSERT INTO NF_COLLECT_LOG_600 (LOG_DTTM,DLV_DT,OTP_STAT_CD,USER_ID) VALUES (?,?,?,?)]

04 12¿5 11:05:10,627 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:84)  - sqlDataSeq         = [0,1,2,3]

04 12¿5 11:05:10,627 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:85)  - ruleDataSeq        = [0,3]

04 12¿5 11:05:10,627 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:86)  - dataCharset        = []

04 12¿5 11:05:10,627 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:88)  - unitRule           = [Y]

04 12¿5 11:05:10,627 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:89)  - unitRuleStatement  = []

04 12¿5 11:05:10,627 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:90)  - unitRuleCodeUpdate = [UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')]

04 12¿5 11:05:10,628 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:92)  - ruleSet            = [Y]

04 12¿5 11:05:10,628 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:93)  - ruleSetDetectStmt1 = [SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1']

04 12¿5 11:05:10,628 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:94)  - ruleSetDetectStmt3 = [SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC]

04 12¿5 11:05:10,628 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:95)  - ruleSetFDSStmt     = [INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')]

04 12¿5 11:05:10,628 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:97)  - fraudDetect        = [N]

04 12¿5 11:05:10,628 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:98)  - fraudJDBCDriver    = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,628 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:99)  - fraudConnectionURL = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,628 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:100)  - fraudCharset       = [utf-8]

04 12¿5 11:05:10,628 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:101)  - fraudUser          = [BaroFDS]

04 12¿5 11:05:10,628 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:102)  - fraudSQLStatement  = []

04 12¿5 11:05:10,628 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:103)  - smsMessage         = []

04 12¿5 11:05:10,628 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:104)  - smsSQLStatement    = []

04 12¿5 11:05:10,629 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:106)  - custJDBCDriver     = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,629 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:107)  - custConnectionURL  = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,629 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:108)  - custCharset        = [utf-8]

04 12¿5 11:05:10,629 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:109)  - custUser           = [BaroFDS]

04 12¿5 11:05:10,629 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:110)  - custSQLStatement   = []

04 12¿5 11:05:10,629 INFO  [conf-file-poller-0] (org.apache.flume.sink.DefaultSinkFactory.create:42)  - Creating instance of sink: jdbc-sink-300, type: org.apache.flume.sink.JDBCSink

04 12¿5 11:05:10,629 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSink.configure:45)  - Reading and processing configuration values for sink jdbc-sink-300

04 12¿5 11:05:10,629 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:74)  - JDBCSinkUtils.!!!

04 12¿5 11:05:10,629 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:75)  - jdbcDriver         = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,629 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:76)  - connectionURL      = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,629 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:77)  - charset            = [euc-kr]

04 12¿5 11:05:10,630 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:78)  - user               = [BaroFDS]

04 12¿5 11:05:10,630 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:79)  - password           = [BaroFDS]

04 12¿5 11:05:10,630 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:80)  - dataFormat         = [delimiter]

04 12¿5 11:05:10,630 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:81)  - dataDelimiter      = [,]

04 12¿5 11:05:10,630 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:82)  - dataTable          = [NF_COLLECT_LOG_300]

04 12¿5 11:05:10,630 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:83)  - sqlStatement       = [INSERT INTO NF_COLLECT_LOG_300 (LOG_DTTM,IP_ADDR,HDD_SN,MDM_TP,USER_ID) VALUES (?,LPAD(SPLIT_PART(?,'.',1),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',2),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',3),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',4),3,'0'),?,?,?)]

04 12¿5 11:05:10,630 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:84)  - sqlDataSeq         = [0,1,1,1,1,2,3,4]

04 12¿5 11:05:10,630 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:85)  - ruleDataSeq        = [0,4]

04 12¿5 11:05:10,630 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:86)  - dataCharset        = []

04 12¿5 11:05:10,630 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:88)  - unitRule           = [Y]

04 12¿5 11:05:10,630 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:89)  - unitRuleStatement  = []

04 12¿5 11:05:10,630 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:90)  - unitRuleCodeUpdate = [UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')]

04 12¿5 11:05:10,631 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:92)  - ruleSet            = [Y]

04 12¿5 11:05:10,631 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:93)  - ruleSetDetectStmt1 = [SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1']

04 12¿5 11:05:10,631 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:94)  - ruleSetDetectStmt3 = [SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC]

04 12¿5 11:05:10,631 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:95)  - ruleSetFDSStmt     = [INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')]

04 12¿5 11:05:10,631 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:97)  - fraudDetect        = [N]

04 12¿5 11:05:10,631 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:98)  - fraudJDBCDriver    = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,631 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:99)  - fraudConnectionURL = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,631 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:100)  - fraudCharset       = [utf-8]

04 12¿5 11:05:10,631 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:101)  - fraudUser          = [BaroFDS]

04 12¿5 11:05:10,631 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:102)  - fraudSQLStatement  = []

04 12¿5 11:05:10,631 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:103)  - smsMessage         = []

04 12¿5 11:05:10,631 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:104)  - smsSQLStatement    = []

04 12¿5 11:05:10,632 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:106)  - custJDBCDriver     = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,632 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:107)  - custConnectionURL  = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,632 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:108)  - custCharset        = [utf-8]

04 12¿5 11:05:10,632 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:109)  - custUser           = [BaroFDS]

04 12¿5 11:05:10,632 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:110)  - custSQLStatement   = []

04 12¿5 11:05:10,632 INFO  [conf-file-poller-0] (org.apache.flume.sink.DefaultSinkFactory.create:42)  - Creating instance of sink: jdbc-sink-200, type: org.apache.flume.sink.JDBCSink

04 12¿5 11:05:10,632 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSink.configure:45)  - Reading and processing configuration values for sink jdbc-sink-200

04 12¿5 11:05:10,632 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:74)  - JDBCSinkUtils.!!!

04 12¿5 11:05:10,632 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:75)  - jdbcDriver         = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,632 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:76)  - connectionURL      = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,632 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:77)  - charset            = [euc-kr]

04 12¿5 11:05:10,633 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:78)  - user               = [BaroFDS]

04 12¿5 11:05:10,633 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:79)  - password           = [BaroFDS]

04 12¿5 11:05:10,633 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:80)  - dataFormat         = [delimiter]

04 12¿5 11:05:10,633 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:81)  - dataDelimiter      = [,]

04 12¿5 11:05:10,633 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:82)  - dataTable          = [NF_COLLECT_LOG_200]

04 12¿5 11:05:10,633 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:83)  - sqlStatement       = [INSERT INTO NF_COLLECT_LOG_200 (LOG_DTTM,IP_ADDR,CERT_CHG_CD,MDM_TP,USER_ID,CERT_SVC_CD) VALUES (?,LPAD(SPLIT_PART(?,'.',1),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',2),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',3),3,'0') || '.' || LPAD(SPLIT_PART(?,'.',4),3,'0'),?,?,?,?)]

04 12¿5 11:05:10,633 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:84)  - sqlDataSeq         = [0,1,1,1,1,2,3,4,5]

04 12¿5 11:05:10,633 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:85)  - ruleDataSeq        = [0,4]

04 12¿5 11:05:10,633 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:86)  - dataCharset        = []

04 12¿5 11:05:10,633 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:88)  - unitRule           = [Y]

04 12¿5 11:05:10,633 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:89)  - unitRuleStatement  = []

04 12¿5 11:05:10,633 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:90)  - unitRuleCodeUpdate = [UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')]

04 12¿5 11:05:10,634 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:92)  - ruleSet            = [Y]

04 12¿5 11:05:10,634 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:93)  - ruleSetDetectStmt1 = [SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1']

04 12¿5 11:05:10,634 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:94)  - ruleSetDetectStmt3 = [SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC]

04 12¿5 11:05:10,634 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:95)  - ruleSetFDSStmt     = [INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')]

04 12¿5 11:05:10,634 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:97)  - fraudDetect        = [N]

04 12¿5 11:05:10,634 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:98)  - fraudJDBCDriver    = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,634 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:99)  - fraudConnectionURL = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,634 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:100)  - fraudCharset       = [utf-8]

04 12¿5 11:05:10,634 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:101)  - fraudUser          = [BaroFDS]

04 12¿5 11:05:10,634 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:102)  - fraudSQLStatement  = []

04 12¿5 11:05:10,634 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:103)  - smsMessage         = []

04 12¿5 11:05:10,635 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:104)  - smsSQLStatement    = []

04 12¿5 11:05:10,635 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:106)  - custJDBCDriver     = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,635 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:107)  - custConnectionURL  = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,635 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:108)  - custCharset        = [utf-8]

04 12¿5 11:05:10,635 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:109)  - custUser           = [BaroFDS]

04 12¿5 11:05:10,635 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:110)  - custSQLStatement   = []

04 12¿5 11:05:10,635 INFO  [conf-file-poller-0] (org.apache.flume.sink.DefaultSinkFactory.create:42)  - Creating instance of sink: jdbc-sink-700, type: org.apache.flume.sink.JDBCSink

04 12¿5 11:05:10,635 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSink.configure:45)  - Reading and processing configuration values for sink jdbc-sink-700

04 12¿5 11:05:10,635 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:74)  - JDBCSinkUtils.!!!

04 12¿5 11:05:10,635 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:75)  - jdbcDriver         = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,635 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:76)  - connectionURL      = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,636 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:77)  - charset            = [euc-kr]

04 12¿5 11:05:10,636 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:78)  - user               = [BaroFDS]

04 12¿5 11:05:10,636 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:79)  - password           = [BaroFDS]

04 12¿5 11:05:10,636 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:80)  - dataFormat         = [delimiter]

04 12¿5 11:05:10,636 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:81)  - dataDelimiter      = [,]

04 12¿5 11:05:10,636 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:82)  - dataTable          = [NF_COLLECT_LOG_700]

04 12¿5 11:05:10,636 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:83)  - sqlStatement       = [INSERT INTO NF_COLLECT_LOG_700 (LOG_DTTM,REG_DT,USER_ID) VALUES (?,?,?)]

04 12¿5 11:05:10,636 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:84)  - sqlDataSeq         = [0,1,2]

04 12¿5 11:05:10,636 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:85)  - ruleDataSeq        = [0,2]

04 12¿5 11:05:10,636 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:86)  - dataCharset        = []

04 12¿5 11:05:10,636 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:88)  - unitRule           = [Y]

04 12¿5 11:05:10,636 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:89)  - unitRuleStatement  = []

04 12¿5 11:05:10,637 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:90)  - unitRuleCodeUpdate = [UPDATE NF_COLLECT_LOG_{task_type} SET UNITRULE_CODE = DECODE(UNITRULE_CODE, NULL, ?, UNITRULE_CODE || ',' || ?) WHERE LOG_DTTM = ? AND USER_ID = ? AND (UNITRULE_CODE IS NULL OR UNITRULE_CODE NOT LIKE '%' || ? || '%')]

04 12¿5 11:05:10,637 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:92)  - ruleSet            = [Y]

04 12¿5 11:05:10,637 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:93)  - ruleSetDetectStmt1 = [SELECT NVL(B.FINNAL_HANDLING, ' ') AS FINNAL_HANDLING FROM NF_COLLECT_LOG_{task_type} A, NF_FDS B WHERE A.LOG_DTTM = ? AND A.USER_ID = ? AND B.USER_ID(+) = A.USER_ID AND B.TRANS_DTTM(+) >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND B.TRANS_DTTM(+) <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND B.FINNAL_HANDLING(+) <> '1']

04 12¿5 11:05:10,637 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:94)  - ruleSetDetectStmt3 = [SELECT RULESET_CODE, UNITRULE_CODE FROM NF_RULE_SET WHERE UNITRULE_CODE LIKE '%' || ? || '%' AND USE_YN = 'Y' ORDER BY RULESET_CODE ASC]

04 12¿5 11:05:10,637 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:95)  - ruleSetFDSStmt     = [INSERT INTO NF_FDS (TRANS_DTTM,USER_ID,RULESET_CODE,ACCIDENT_YN,MEASURE_YN,RCVG_ACNT_NM_YN,PAST_INFO_YN,FINNAL_HANDLING) SELECT TO_CHAR(SYSTIMESTAMP, 'YYYYMMDDHH24MISSFF6'),?,?,'Y','N','N','N','1' FROM DUAL WHERE NOT EXISTS (SELECT 'Y' FROM NF_FDS Z WHERE Z.USER_ID = ? AND Z.TRANS_DTTM >= TO_CHAR(SYSDATE, 'YYYYMMDD') || '000000000000' AND Z.TRANS_DTTM <= TO_CHAR(SYSDATE, 'YYYYMMDD') || '240000000000' AND Z.FINNAL_HANDLING = '1')]

04 12¿5 11:05:10,637 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:97)  - fraudDetect        = [N]

04 12¿5 11:05:10,637 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:98)  - fraudJDBCDriver    = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,637 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:99)  - fraudConnectionURL = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,637 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:100)  - fraudCharset       = [utf-8]

04 12¿5 11:05:10,637 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:101)  - fraudUser          = [BaroFDS]

04 12¿5 11:05:10,637 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:102)  - fraudSQLStatement  = []

04 12¿5 11:05:10,637 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:103)  - smsMessage         = []

04 12¿5 11:05:10,638 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:104)  - smsSQLStatement    = []

04 12¿5 11:05:10,638 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:106)  - custJDBCDriver     = [oracle.jdbc.OracleDriver]

04 12¿5 11:05:10,638 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:107)  - custConnectionURL  = [jdbc:oracle:thin:@1.234.83.169:1521:ORCL]

04 12¿5 11:05:10,638 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:108)  - custCharset        = [utf-8]

04 12¿5 11:05:10,638 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:109)  - custUser           = [BaroFDS]

04 12¿5 11:05:10,638 INFO  [conf-file-poller-0] (org.apache.flume.sink.JDBCSinkUtils.<init>:110)  - custSQLStatement   = []

04 12¿5 11:05:10,640 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.getConfiguration:114)  - Channel mem-channel-200 connected to [master1, jdbc-sink-200]

04 12¿5 11:05:10,640 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.getConfiguration:114)  - Channel mem-channel-600 connected to [master1, jdbc-sink-600]

04 12¿5 11:05:10,640 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.getConfiguration:114)  - Channel mem-channel-500 connected to [master1, jdbc-sink-500]

04 12¿5 11:05:10,640 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.getConfiguration:114)  - Channel mem-channel-700 connected to [master1, jdbc-sink-700]

04 12¿5 11:05:10,640 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.getConfiguration:114)  - Channel mem-channel-400 connected to [master1, jdbc-sink-400]

04 12¿5 11:05:10,640 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.getConfiguration:114)  - Channel mem-channel-300 connected to [master1, jdbc-sink-300]

04 12¿5 11:05:10,640 INFO  [conf-file-poller-0] (org.apache.flume.node.AbstractConfigurationProvider.getConfiguration:114)  - Channel mem-channel-100 connected to [master1, jdbc-sink-100]

04 12¿5 11:05:10,647 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:138)  - Starting new configuration:{ sourceRunners:{master1=EventDrivenSourceRunner: { source:Avro source master1: { bindAddress: 1.234.83.169, port: 61616 } }} sinkRunners:{jdbc-sink-400=SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@21139f1b counterGroup:{ name:null counters:{} } }, jdbc-sink-100=SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@f32b694 counterGroup:{ name:null counters:{} } }, jdbc-sink-500=SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@4a70b657 counterGroup:{ name:null counters:{} } }, jdbc-sink-300=SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@2dd32fef counterGroup:{ name:null counters:{} } }, jdbc-sink-600=SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@3f00b6a counterGroup:{ name:null counters:{} } }, jdbc-sink-200=SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@47d5e2b counterGroup:{ name:null counters:{} } }, jdbc-sink-700=SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@42b15b5a counterGroup:{ name:null counters:{} } }} channels:{mem-channel-200=org.apache.flume.channel.MemoryChannel{name: mem-channel-200}, mem-channel-500=org.apache.flume.channel.MemoryChannel{name: mem-channel-500}, mem-channel-600=org.apache.flume.channel.MemoryChannel{name: mem-channel-600}, mem-channel-400=org.apache.flume.channel.MemoryChannel{name: mem-channel-400}, mem-channel-700=org.apache.flume.channel.MemoryChannel{name: mem-channel-700}, mem-channel-100=org.apache.flume.channel.MemoryChannel{name: mem-channel-100}, mem-channel-300=org.apache.flume.channel.MemoryChannel{name: mem-channel-300}} }

04 12¿5 11:05:10,647 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:145)  - Starting Channel mem-channel-200

04 12¿5 11:05:10,647 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:145)  - Starting Channel mem-channel-500

04 12¿5 11:05:10,647 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:145)  - Starting Channel mem-channel-600

04 12¿5 11:05:10,648 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:145)  - Starting Channel mem-channel-400

04 12¿5 11:05:10,648 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:145)  - Starting Channel mem-channel-700

04 12¿5 11:05:10,649 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:145)  - Starting Channel mem-channel-100

04 12¿5 11:05:10,649 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:145)  - Starting Channel mem-channel-300

04 12¿5 11:05:10,750 INFO  [lifecycleSupervisor-1-1] (org.apache.flume.instrumentation.MonitoredCounterGroup.register:120)  - Monitored counter group for type: CHANNEL, name: mem-channel-500: Successfully registered new MBean.

04 12¿5 11:05:10,750 INFO  [lifecycleSupervisor-1-2] (org.apache.flume.instrumentation.MonitoredCounterGroup.register:120)  - Monitored counter group for type: CHANNEL, name: mem-channel-600: Successfully registered new MBean.

04 12¿5 11:05:10,750 INFO  [lifecycleSupervisor-1-3] (org.apache.flume.instrumentation.MonitoredCounterGroup.register:120)  - Monitored counter group for type: CHANNEL, name: mem-channel-400: Successfully registered new MBean.

04 12¿5 11:05:10,750 INFO  [lifecycleSupervisor-1-0] (org.apache.flume.instrumentation.MonitoredCounterGroup.register:120)  - Monitored counter group for type: CHANNEL, name: mem-channel-200: Successfully registered new MBean.

04 12¿5 11:05:10,751 INFO  [lifecycleSupervisor-1-3] (org.apache.flume.instrumentation.MonitoredCounterGroup.start:96)  - Component type: CHANNEL, name: mem-channel-400 started

04 12¿5 11:05:10,751 INFO  [lifecycleSupervisor-1-2] (org.apache.flume.instrumentation.MonitoredCounterGroup.start:96)  - Component type: CHANNEL, name: mem-channel-600 started

04 12¿5 11:05:10,751 INFO  [lifecycleSupervisor-1-1] (org.apache.flume.instrumentation.MonitoredCounterGroup.start:96)  - Component type: CHANNEL, name: mem-channel-500 started

04 12¿5 11:05:10,751 INFO  [lifecycleSupervisor-1-6] (org.apache.flume.instrumentation.MonitoredCounterGroup.register:120)  - Monitored counter group for type: CHANNEL, name: mem-channel-300: Successfully registered new MBean.

04 12¿5 11:05:10,751 INFO  [lifecycleSupervisor-1-4] (org.apache.flume.instrumentation.MonitoredCounterGroup.register:120)  - Monitored counter group for type: CHANNEL, name: mem-channel-700: Successfully registered new MBean.

04 12¿5 11:05:10,751 INFO  [lifecycleSupervisor-1-6] (org.apache.flume.instrumentation.MonitoredCounterGroup.start:96)  - Component type: CHANNEL, name: mem-channel-300 started

04 12¿5 11:05:10,751 INFO  [lifecycleSupervisor-1-5] (org.apache.flume.instrumentation.MonitoredCounterGroup.register:120)  - Monitored counter group for type: CHANNEL, name: mem-channel-100: Successfully registered new MBean.

04 12¿5 11:05:10,751 INFO  [lifecycleSupervisor-1-0] (org.apache.flume.instrumentation.MonitoredCounterGroup.start:96)  - Component type: CHANNEL, name: mem-channel-200 started

04 12¿5 11:05:10,752 INFO  [lifecycleSupervisor-1-5] (org.apache.flume.instrumentation.MonitoredCounterGroup.start:96)  - Component type: CHANNEL, name: mem-channel-100 started

04 12¿5 11:05:10,751 INFO  [lifecycleSupervisor-1-4] (org.apache.flume.instrumentation.MonitoredCounterGroup.start:96)  - Component type: CHANNEL, name: mem-channel-700 started

04 12¿5 11:05:10,752 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:173)  - Starting Sink jdbc-sink-400

04 12¿5 11:05:10,752 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:173)  - Starting Sink jdbc-sink-100

04 12¿5 11:05:10,752 INFO  [lifecycleSupervisor-1-7] (org.apache.flume.sink.JDBCSink.start:56)  - Starting JDBCSink jdbc-sink-400 ...

04 12¿5 11:05:10,752 INFO  [lifecycleSupervisor-1-2] (org.apache.flume.sink.JDBCSink.start:56)  - Starting JDBCSink jdbc-sink-100 ...

04 12¿5 11:05:10,752 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:173)  - Starting Sink jdbc-sink-500

04 12¿5 11:05:10,753 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:173)  - Starting Sink jdbc-sink-300

04 12¿5 11:05:10,753 INFO  [lifecycleSupervisor-1-1] (org.apache.flume.sink.JDBCSink.start:56)  - Starting JDBCSink jdbc-sink-500 ...

04 12¿5 11:05:10,754 INFO  [lifecycleSupervisor-1-6] (org.apache.flume.sink.JDBCSink.start:56)  - Starting JDBCSink jdbc-sink-300 ...

04 12¿5 11:05:10,754 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:173)  - Starting Sink jdbc-sink-600

04 12¿5 11:05:10,754 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:173)  - Starting Sink jdbc-sink-200

04 12¿5 11:05:10,754 INFO  [lifecycleSupervisor-1-4] (org.apache.flume.sink.JDBCSink.start:56)  - Starting JDBCSink jdbc-sink-600 ...

04 12¿5 11:05:10,754 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:173)  - Starting Sink jdbc-sink-700

04 12¿5 11:05:10,754 INFO  [lifecycleSupervisor-1-4] (org.apache.flume.sink.JDBCSink.start:56)  - Starting JDBCSink jdbc-sink-200 ...

04 12¿5 11:05:10,755 INFO  [lifecycleSupervisor-1-8] (org.apache.flume.sink.JDBCSink.start:56)  - Starting JDBCSink jdbc-sink-700 ...

04 12¿5 11:05:10,755 INFO  [conf-file-poller-0] (org.apache.flume.node.Application.startAllComponents:184)  - Starting Source master1

 

사업자 정보 표시
주식회사 누리아이티 | 이종일 | 서울시 강서구 공항대로 186 로뎀타워 617호 | 사업자 등록번호 : 258-87-00901 | TEL : 010-2771-4076 | Mail : mc529@nurit.co.kr | 사이버몰의 이용약관 바로가기