0

テキストファイルやログファイルをmapreduceで処理したい場合はデフォルトでマッパーの入力値が改行文字まで改行するがログファイルを処理したい

A (18:18:43,703 [ERROR] AccStmtGeneratorImpl - Statement not generated for::304005)

B (11:40:04,202 [ERROR] JobStoreTX - Failed to close Connection
 java.sql.SQLException: Already closed.
    at org.apache.commons.dbcp.PoolableConnection.close(PoolableConnection.java:114)
    at `enter code here`org.apache.commons.dbcp.PoolingDataSource$PoolGuardConnectionWrapper.close(PoolingDataSource.java:191)
    at org.quartz.impl.jdbcjobstore.JobStoreSupport.closeConnection(JobStoreSupport.java:3579)
    at org.quartz.impl.jdbcjobstore.JobStoreSupport.cleanupConnection(JobStoreSupport.java:3555)
    at org.quartz.impl.jdbcjobstore.JobStoreSupport.executeInNonManagedTXLock(JobStoreSupport.java:3783)
    at org.quartz.impl.jdbcjobstore.JobStoreSupport.acquireNextTrigger(JobStoreSupport.java:2728)
    at org.quartz.core.QuartzSchedulerThread.run(QuartzSchedulerThread.java:264)
)

ここで、私のマッパーは 11:40:04,202 から新しいタイムスタンプへの値を取得する必要があります。これは、A が値になり、B 全体が別の値になることを意味します。前もって感謝します助けてください...

4

0 に答える 0