Skip to content

Commit 3a7fae9

Browse files
committed
Merge branch '1.5_v3.6.0_oralce_write_get_index_bug' into '1.5_v3.6.0'
修改oracle 获取索引问题 修改oracle 获取索引问题 See merge request !6
2 parents f60b5b7 + 3c1d7b9 commit 3a7fae9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/format/ExtendOutputFormat.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public boolean isReplaceInsertQuery() throws SQLException {
6262
*/
6363
public void fillRealIndexes() throws SQLException {
6464
Map<String, List<String>> map = Maps.newHashMap();
65-
ResultSet rs = getDbConn().getMetaData().getIndexInfo(null, null, getTableName(), true, false);
65+
ResultSet rs = getDbConn().getMetaData().getIndexInfo(null, null, getTableName(), true, true);
6666

6767
while (rs.next()) {
6868
String indexName = rs.getString("INDEX_NAME");

0 commit comments

Comments
 (0)