質問編集履歴
5
質問内容の更新
title
CHANGED
File without changes
|
body
CHANGED
@@ -3,47 +3,7 @@
|
|
3
3
|
|
4
4
|
環境:windows7 , oracle 12c , embulk 0.9.8
|
5
5
|
|
6
|
-
※出力されたjavaエラー
|
7
|
-
```ここに言語を入力
|
8
|
-
org.embulk.exec.PartialExecutionException: org.embulk.spi.DataException: Invalid record at line 185:
|
9
|
-
at org.embulk.exec.BulkLoader$LoaderState.buildPartialExecuteException(BulkLoader.java:339)
|
10
|
-
at org.embulk.exec.BulkLoader.doRun(BulkLoader.java:565)
|
11
|
-
at org.embulk.exec.BulkLoader.access$000(BulkLoader.java:34)
|
12
|
-
at org.embulk.exec.BulkLoader$1.run(BulkLoader.java:352)
|
13
|
-
at org.embulk.exec.BulkLoader$1.run(BulkLoader.java:349)
|
14
|
-
at org.embulk.spi.Exec.doWith(Exec.java:22)
|
15
|
-
at org.embulk.exec.BulkLoader.run(BulkLoader.java:349)
|
16
|
-
at org.embulk.EmbulkEmbed.run(EmbulkEmbed.java:161)
|
17
|
-
at org.embulk.EmbulkRunner.runInternal(EmbulkRunner.java:292)
|
18
|
-
at org.embulk.EmbulkRunner.run(EmbulkRunner.java:156)
|
19
|
-
at org.embulk.cli.EmbulkRun.runSubcommand(EmbulkRun.java:436)
|
20
|
-
at org.embulk.cli.EmbulkRun.run(EmbulkRun.java:91)
|
21
6
|
|
22
|
-
Caused by: org.embulk.spi.DataException: Invalid record at line 185:
|
23
|
-
at org.embulk.standards.CsvParserPlugin.run(CsvParserPlugin.java:363)
|
24
|
-
at org.embulk.spi.FileInputRunner.run(FileInputRunner.java:140)
|
25
|
-
at org.embulk.exec.LocalExecutorPlugin$ScatterExecutor.runInputTask(LocalExecutorPlugin.java:271)
|
26
|
-
at org.embulk.exec.LocalExecutorPlugin$ScatterExecutor.access$000(LocalExecutorPlugin.java:196)
|
27
|
-
at org.embulk.exec.LocalExecutorPlugin$ScatterExecutor$1.call(LocalExecutorPlugin.java:235)
|
28
|
-
at org.embulk.exec.LocalExecutorPlugin$ScatterExecutor$1.call(LocalExecutorPlugin.java:232)
|
29
|
-
at java.util.concurrent.FutureTask.run(Unknown Source)
|
30
|
-
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
|
31
|
-
|
32
|
-
Caused by: org.embulk.standards.CsvParserPlugin$CsvRecordValidateException: java.lang.NumberFormatException: For input string:
|
33
|
-
at org.embulk.standards.CsvParserPlugin$1.longColumn(CsvParserPlugin.java:280)
|
34
|
-
at org.embulk.spi.Column.visit(Column.java:48)
|
35
|
-
at org.embulk.spi.Schema.visitColumns(Schema.java:68)
|
36
|
-
at org.embulk.standards.CsvParserPlugin.run(CsvParserPlugin.java:261)
|
37
|
-
... 9 more
|
38
|
-
Caused by: java.lang.NumberFormatException: For input string:
|
39
|
-
at java.lang.NumberFormatException.forInputString(Unknown Source)
|
40
|
-
at java.lang.Long.parseLong(Unknown Source)
|
41
|
-
at java.lang.Long.parseLong(Unknown Source)
|
42
|
-
at org.embulk.standards.CsvParserPlugin$1.longColumn(CsvParserPlugin.java:277)
|
43
|
-
... 12 more
|
44
|
-
Error: org.embulk.spi.DataException: Invalid record at line 185:
|
45
|
-
```
|
46
|
-
|
47
7
|
※検証用の業務データのため、エラー内容から出力されたデータ項目は除いています。
|
48
8
|
|
49
9
|
embulk定義ファイル
|
@@ -171,4 +131,32 @@
|
|
171
131
|
out: {type: oracle, host: xxxx, port: xxx, database: xxx, user: xxx, password: xxx,
|
172
132
|
table: xxxx, mode: insert, insert_method: normal, driver_path: 'C:\Users\xxx\Desktop\embulkDB\product\12.2.0\dbhome_1\jdbc\lib\ojdbc8.jar'}
|
173
133
|
|
134
|
+
```
|
135
|
+
|
136
|
+
|
137
|
+
※2018/11/26 現在のエラー
|
138
|
+
```ここに言語を入力
|
139
|
+
org.embulk.exec.PartialExecutionException: org.jruby.exceptions.RaiseException: (Error) failed during waiting a Copy job, get_job(fluid-emissary-216806, embulk_copy_job_f19fafe0-795f-4b9d-a49d-35269a460a2f), errors:[{:reason=>"invalid", :message=>"Provided Schema does not match Table fluid-emissary-216806:embulk_test.T_RS_TRAN. Field ORDER_NO has changed type from FLOAT to INTEGER."}]
|
140
|
+
at org.embulk.exec.BulkLoader$LoaderState.buildPartialExecuteException(BulkLoader.java:339)
|
141
|
+
at org.embulk.exec.BulkLoader.doRun(BulkLoader.java:565)
|
142
|
+
at org.embulk.exec.BulkLoader.access$000(BulkLoader.java:34)
|
143
|
+
at org.embulk.exec.BulkLoader$1.run(BulkLoader.java:352)
|
144
|
+
at org.embulk.exec.BulkLoader$1.run(BulkLoader.java:349)
|
145
|
+
at org.embulk.spi.Exec.doWith(Exec.java:22)
|
146
|
+
at org.embulk.exec.BulkLoader.run(BulkLoader.java:349)
|
147
|
+
at org.embulk.EmbulkEmbed.run(EmbulkEmbed.java:161)
|
148
|
+
at org.embulk.EmbulkRunner.runInternal(EmbulkRunner.java:292)
|
149
|
+
at org.embulk.EmbulkRunner.run(EmbulkRunner.java:156)
|
150
|
+
at org.embulk.cli.EmbulkRun.runSubcommand(EmbulkRun.java:436)
|
151
|
+
at org.embulk.cli.EmbulkRun.run(EmbulkRun.java:91)
|
152
|
+
at org.embulk.cli.Main.main(Main.java:26)
|
153
|
+
Caused by: org.jruby.exceptions.RaiseException: (Error) failed during waiting a Copy job, get_job(fluid-emissary-216806, embulk_copy_job_f19fafe0-795f-4b9d-a49d-35269a460a2f), errors:[{:reason=>"invalid", :message=>"Provided Schema does not match Table fluid-emissary-216806:embulk_test.T_RS_TRAN. Field ORDER_NO has changed type from FLOAT to INTEGER."}]
|
154
|
+
at RUBY.wait_load(C:/Users/yazaki/.embulk/lib/gems/gems/embulk-output-bigquery-0.4.9/lib/embulk/output/bigquery/bigquery_client.rb:346)
|
155
|
+
at RUBY.block in copy(C:/Users/yazaki/.embulk/lib/gems/gems/embulk-output-bigquery-0.4.9/lib/embulk/output/bigquery/bigquery_client.rb:289)
|
156
|
+
at RUBY.with_job_retry(C:/Users/yazaki/.embulk/lib/gems/gems/embulk-output-bigquery-0.4.9/lib/embulk/output/bigquery/bigquery_client.rb:58)
|
157
|
+
at RUBY.copy(C:/Users/yazaki/.embulk/lib/gems/gems/embulk-output-bigquery-0.4.9/lib/embulk/output/bigquery/bigquery_client.rb:249)
|
158
|
+
at RUBY.transaction(C:/Users/yazaki/.embulk/lib/gems/gems/embulk-output-bigquery-0.4.9/lib/embulk/output/bigquery.rb:407)
|
159
|
+
at RUBY.transaction(uri:classloader:/gems/embulk-0.9.8-java/lib/embulk/output_plugin.rb:64)
|
160
|
+
|
161
|
+
Error: org.jruby.exceptions.RaiseException: (Error) failed during waiting a Copy job, get_job(fluid-emissary-216806, embulk_copy_job_f19fafe0-795f-4b9d-a49d-35269a460a2f), errors:[{:reason=>"invalid", :message=>"Provided Schema does not match Table fluid-emissary-216806:embulk_test.T_RS_TRAN. FieldORDER_NO has changed type from FLOAT to INTEGER."}]
|
174
162
|
```
|
4
質問内容の更新
title
CHANGED
File without changes
|
body
CHANGED
File without changes
|
3
状況更新
title
CHANGED
File without changes
|
body
CHANGED
@@ -44,4 +44,131 @@
|
|
44
44
|
Error: org.embulk.spi.DataException: Invalid record at line 185:
|
45
45
|
```
|
46
46
|
|
47
|
-
※検証用の業務データのため、エラー内容から出力されたデータ項目は除いています。
|
47
|
+
※検証用の業務データのため、エラー内容から出力されたデータ項目は除いています。
|
48
|
+
|
49
|
+
embulk定義ファイル
|
50
|
+
```ここに言語を入力
|
51
|
+
インプット
|
52
|
+
in:
|
53
|
+
type: file
|
54
|
+
path_prefix: 'C:\Users\xxx\Desktop\embulk\xxxx.csv'
|
55
|
+
parser:
|
56
|
+
type: csv
|
57
|
+
delimiter: ','
|
58
|
+
skip_header_line: false
|
59
|
+
stop_on_invalid_record: true
|
60
|
+
out:
|
61
|
+
type: oracle
|
62
|
+
host: xxxx
|
63
|
+
port: xxx
|
64
|
+
database: xxx
|
65
|
+
user: xxx
|
66
|
+
password: xxx
|
67
|
+
table: xxx
|
68
|
+
mode: insert
|
69
|
+
insert_method: normal
|
70
|
+
driver_path: 'C:\Users\xxx\Desktop\embulkDB\product\12.2.0\dbhome_1\jdbc\lib\ojdbc8.jar'
|
71
|
+
|
72
|
+
アウトプット
|
73
|
+
in:
|
74
|
+
type: file
|
75
|
+
path_prefix: C:\Users\xxx\Desktop\embulk\xxxx.csv
|
76
|
+
parser:
|
77
|
+
type: csv
|
78
|
+
delimiter: ','
|
79
|
+
skip_header_line: false
|
80
|
+
stop_on_invalid_record: true
|
81
|
+
charset: UTF-8
|
82
|
+
newline: CRLF
|
83
|
+
quote: '"'
|
84
|
+
escape: '"'
|
85
|
+
trim_if_not_quoted: false
|
86
|
+
skip_header_lines: 1
|
87
|
+
allow_extra_columns: false
|
88
|
+
allow_optional_columns: false
|
89
|
+
columns:
|
90
|
+
- {name: ORDER_NO, type: long}
|
91
|
+
- {name: RS_TYPE, type: long}
|
92
|
+
- {name: FACTORY_CODE, type: long}
|
93
|
+
- {name: ORG_CODE, type: string}
|
94
|
+
- {name: TRAN_DATE, type: timestamp, format: '%Y/%m/%d'}
|
95
|
+
- {name: HINBAN, type: string}
|
96
|
+
- {name: QTY, type: long}
|
97
|
+
- {name: SLIP_NO, type: string}
|
98
|
+
- {name: ITEM_NO, type: string}
|
99
|
+
- {name: DIVISION_NO, type: long}
|
100
|
+
- {name: FROM_FACTORY_CODE, type: long}
|
101
|
+
- {name: FROM_ORG_CODE, type: string}
|
102
|
+
- {name: FROM_SUBINV_CODE, type: string}
|
103
|
+
- {name: FROM_VALUE_CODE, type: string}
|
104
|
+
- {name: FROM_OPERATOR_NAME, type: string}
|
105
|
+
- {name: TO_FACTORY_CODE, type: string}
|
106
|
+
- {name: TO_ORG_CODE, type: string}
|
107
|
+
- {name: TO_SUBINV_CODE, type: long}
|
108
|
+
- {name: TO_VALUE_CODE, type: long}
|
109
|
+
- {name: TO_OPERATOR_NAME, type: string}
|
110
|
+
- {name: SUB_SYSTEM_TYPE1, type: string}
|
111
|
+
- {name: CANCEL_FLAG, type: long}
|
112
|
+
- {name: ACT_CREATION_DATE, type: timestamp, format: '%Y/%m/%d %H:%M:%S'}
|
113
|
+
- {name: WH_ACT_CREATION_DATE, type: timestamp, format: '%Y/%m/%d %H:%M:%S'}
|
114
|
+
- {name: JOB_CODE, type: string}
|
115
|
+
- {name: UNIT_PRICE, type: string}
|
116
|
+
- {name: ERROR_STATUS, type: long}
|
117
|
+
- {name: DESCRIPTION, type: string}
|
118
|
+
- {name: LOCATION, type: string}
|
119
|
+
- {name: REVISION_NO, type: string}
|
120
|
+
- {name: OPE_CODE, type: string}
|
121
|
+
- {name: BOX_KIND, type: string}
|
122
|
+
- {name: DEMAND_NO, type: string}
|
123
|
+
- {name: SUB_NO, type: string}
|
124
|
+
- {name: TRAFFIC_NO, type: string}
|
125
|
+
- {name: IF_FLAG, type: long}
|
126
|
+
- {name: SELL_BUY_DATA_FLAG, type: long}
|
127
|
+
- {name: SOURCE_ORDER_NO, type: long}
|
128
|
+
- {name: FT_DEFINE_ID, type: long}
|
129
|
+
- {name: FROM_SELL_BUY_ID, type: string}
|
130
|
+
- {name: TO_SELL_BUY_ID, type: string}
|
131
|
+
- {name: CREATION_DATE, type: timestamp, format: '%Y/%m/%d %H:%M:%S'}
|
132
|
+
- {name: CREATED_BY, type: string}
|
133
|
+
- {name: LAST_UPDATE_DATE, type: timestamp, format: '%Y/%m/%d %H:%M:%S'}
|
134
|
+
- {name: LAST_UPDATED_BY, type: string}
|
135
|
+
- {name: UPDATE_REQUEST_ID, type: long}
|
136
|
+
- {name: TIME_STAMP, type: timestamp, format: '%Y/%m/%d %H:%M:%S'}
|
137
|
+
- {name: INV_UPDATE_FLAG, type: long}
|
138
|
+
- {name: ISSUE_SEQ, type: string}
|
139
|
+
- {name: SOUMEI_ID, type: long}
|
140
|
+
- {name: GCPCS_IF_FLAG, type: string}
|
141
|
+
- {name: GCPCS_IF_CREATION_DATE, type: string}
|
142
|
+
- {name: RECIEPT_CODE, type: string}
|
143
|
+
- {name: DELIV_BIN_NO, type: string}
|
144
|
+
- {name: DELIV_NO, type: string}
|
145
|
+
- {name: RECV_BIN_NO, type: string}
|
146
|
+
- {name: SUB_SYSTEM_TYPE2, type: string}
|
147
|
+
- {name: SHIP_DATE, type: timestamp, format: '%Y/%m/%d'}
|
148
|
+
- {name: C_NO, type: long}
|
149
|
+
- {name: T_NO, type: long}
|
150
|
+
- {name: RECV_OFFICE_CODE, type: long}
|
151
|
+
- {name: SR_IF_FLAG, type: long}
|
152
|
+
- {name: SR_IF_CREATION_DATE, type: timestamp, format: '%Y/%m/%d %H:%M:%S'}
|
153
|
+
- {name: PS_IF_FLAG, type: long}
|
154
|
+
- {name: PS_IF_CREATION_DATE, type: timestamp, format: '%Y/%m/%d %H:%M:%S'}
|
155
|
+
- {name: CUSTOMER_CODE, type: long}
|
156
|
+
- {name: KS_TYPE, type: string}
|
157
|
+
- {name: SUPPLY_SECTION, type: string}
|
158
|
+
- {name: MANAGE_NO, type: string}
|
159
|
+
- {name: SEND_OFFICE_CODE, type: long}
|
160
|
+
- {name: SOUMEI_SLIP_NO, type: long}
|
161
|
+
- {name: SOUMEI_ITEM_NO, type: string}
|
162
|
+
- {name: PS_YAZAKI_HINBAN, type: long}
|
163
|
+
- {name: INVOICE_CASE_INFO_NO, type: string}
|
164
|
+
- {name: GYK_SITE_CODE, type: string}
|
165
|
+
- {name: CASE_NO, type: string}
|
166
|
+
- {name: CASE_SUB_NO, type: string}
|
167
|
+
- {name: FROM_LOCATION, type: string}
|
168
|
+
- {name: TO_LOCATION, type: string}
|
169
|
+
- {name: GYK_TRAN_TYPE, type: string}
|
170
|
+
- {name: INV_INFO_UPDATE_FLAG, type: string}
|
171
|
+
out: {type: oracle, host: xxxx, port: xxx, database: xxx, user: xxx, password: xxx,
|
172
|
+
table: xxxx, mode: insert, insert_method: normal, driver_path: 'C:\Users\xxx\Desktop\embulkDB\product\12.2.0\dbhome_1\jdbc\lib\ojdbc8.jar'}
|
173
|
+
|
174
|
+
```
|
2
質問内容の更新
title
CHANGED
File without changes
|
body
CHANGED
@@ -29,7 +29,7 @@
|
|
29
29
|
at java.util.concurrent.FutureTask.run(Unknown Source)
|
30
30
|
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
|
31
31
|
|
32
|
-
Caused by: org.embulk.standards.CsvParserPlugin$CsvRecordValidateException: java.lang.NumberFormatException: For input string:
|
32
|
+
Caused by: org.embulk.standards.CsvParserPlugin$CsvRecordValidateException: java.lang.NumberFormatException: For input string:
|
33
33
|
at org.embulk.standards.CsvParserPlugin$1.longColumn(CsvParserPlugin.java:280)
|
34
34
|
at org.embulk.spi.Column.visit(Column.java:48)
|
35
35
|
at org.embulk.spi.Schema.visitColumns(Schema.java:68)
|
1
質問更新
title
CHANGED
File without changes
|
body
CHANGED
@@ -1,6 +1,8 @@
|
|
1
1
|
csvファイルのデータをOracleDBへバルクインサートを試みると失敗します。
|
2
2
|
csvファイルは16万行、81列のファイルになります。
|
3
3
|
|
4
|
+
環境:windows7 , oracle 12c , embulk 0.9.8
|
5
|
+
|
4
6
|
※出力されたjavaエラー
|
5
7
|
```ここに言語を入力
|
6
8
|
org.embulk.exec.PartialExecutionException: org.embulk.spi.DataException: Invalid record at line 185:
|