Skip to content

Commit e8d0178

Browse files
committed
[fix-30263] fix oceanbase sink error
1 parent 2b71680 commit e8d0178

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

oceanbase/oceanbase-sink/src/main/java/com/dtstack/flink/sql/sink/oceanbase/OceanbaseDialect.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* See the License for the specific language governing permissions and
1616
* limitations under the License.
1717
*/
18-
package com.dtstack.flink.sql.sink.ocean;
18+
package com.dtstack.flink.sql.sink.oceanbase;
1919

2020
import com.dtstack.flink.sql.sink.rdb.dialect.JDBCDialect;
2121

oceanbase/oceanbase-sink/src/main/java/com/dtstack/flink/sql/sink/oceanbase/OceanbaseSink.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* See the License for the specific language governing permissions and
1616
* limitations under the License.
1717
*/
18-
package com.dtstack.flink.sql.sink.ocean;
18+
package com.dtstack.flink.sql.sink.oceanbase;
1919

2020
import com.dtstack.flink.sql.sink.IStreamSinkGener;
2121
import com.dtstack.flink.sql.sink.rdb.AbstractRdbSink;

oceanbase/oceanbase-sink/src/main/java/com/dtstack/flink/sql/sink/oceanbase/table/OceanbaseSinkParser.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* See the License for the specific language governing permissions and
1616
* limitations under the License.
1717
*/
18-
package com.dtstack.flink.sql.sink.ocean.table;
18+
package com.dtstack.flink.sql.sink.oceanbase.table;
1919

2020
import com.dtstack.flink.sql.sink.rdb.table.RdbSinkParser;
2121
import com.dtstack.flink.sql.table.AbstractTableInfo;

0 commit comments

Comments
 (0)