Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -0,0 +1,7 @@
create table icebergtable (id int, name string) stored by iceberg stored as parquet;

insert into icebergtable values (1, 'Joe'), (2, 'Jack');

select * from icebergtable limit 1;

create table icebergtable (id int, name string) stored by iceberg stored as parquet;
Original file line number Diff line number Diff line change
@@ -0,0 +1,5 @@
create table icebergtable (id int, name string) stored by iceberg stored as parquet;

insert into icebergtable values (1, 'Joe'), (2, 'Jack');

select * from icebergtable limit 1;
Original file line number Diff line number Diff line change
@@ -0,0 +1,30 @@
PREHOOK: query: create table icebergtable (id int, name string) stored by iceberg stored as parquet
PREHOOK: type: CREATETABLE
PREHOOK: Output: database:default
PREHOOK: Output: default@icebergtable
POSTHOOK: query: create table icebergtable (id int, name string) stored by iceberg stored as parquet
POSTHOOK: type: CREATETABLE
POSTHOOK: Output: database:default
POSTHOOK: Output: default@icebergtable
PREHOOK: query: insert into icebergtable values (1, 'Joe'), (2, 'Jack')
PREHOOK: type: QUERY
PREHOOK: Input: _dummy_database@_dummy_table
PREHOOK: Output: default@icebergtable
POSTHOOK: query: insert into icebergtable values (1, 'Joe'), (2, 'Jack')
POSTHOOK: type: QUERY
POSTHOOK: Input: _dummy_database@_dummy_table
POSTHOOK: Output: default@icebergtable
PREHOOK: query: select * from icebergtable limit 1
PREHOOK: type: QUERY
PREHOOK: Input: default@icebergtable
PREHOOK: Output: hdfs://### HDFS PATH ###
POSTHOOK: query: select * from icebergtable limit 1
POSTHOOK: type: QUERY
POSTHOOK: Input: default@icebergtable
POSTHOOK: Output: hdfs://### HDFS PATH ###
1 Joe
PREHOOK: query: create table icebergtable (id int, name string) stored by iceberg stored as parquet
PREHOOK: type: CREATETABLE
PREHOOK: Output: database:default
PREHOOK: Output: default@icebergtable
FAILED: Execution Error, return code 40000 from org.apache.hadoop.hive.ql.ddl.DDLTask. AlreadyExistsException(message:Table hive.default.icebergtable already exists)
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
PREHOOK: query: create table icebergtable (id int, name string) stored by iceberg stored as parquet
PREHOOK: type: CREATETABLE
PREHOOK: Output: database:default
PREHOOK: Output: default@icebergtable
POSTHOOK: query: create table icebergtable (id int, name string) stored by iceberg stored as parquet
POSTHOOK: type: CREATETABLE
POSTHOOK: Output: database:default
POSTHOOK: Output: default@icebergtable
PREHOOK: query: insert into icebergtable values (1, 'Joe'), (2, 'Jack')
PREHOOK: type: QUERY
PREHOOK: Input: _dummy_database@_dummy_table
PREHOOK: Output: default@icebergtable
POSTHOOK: query: insert into icebergtable values (1, 'Joe'), (2, 'Jack')
POSTHOOK: type: QUERY
POSTHOOK: Input: _dummy_database@_dummy_table
POSTHOOK: Output: default@icebergtable
PREHOOK: query: select * from icebergtable limit 1
PREHOOK: type: QUERY
PREHOOK: Input: default@icebergtable
PREHOOK: Output: hdfs://### HDFS PATH ###
POSTHOOK: query: select * from icebergtable limit 1
POSTHOOK: type: QUERY
POSTHOOK: Input: default@icebergtable
POSTHOOK: Output: hdfs://### HDFS PATH ###
1 Joe
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,8 @@
import java.util.List;
import org.apache.hadoop.hive.cli.control.CliAdapter;
import org.apache.hadoop.hive.cli.control.CliConfigs;
import org.apache.hadoop.hive.ql.exec.tez.ObjectCache;
import org.apache.tez.runtime.common.objectregistry.ObjectRegistryImpl;
import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.Test;
Expand Down Expand Up @@ -55,6 +57,7 @@ public TestIcebergCliDriver(String name, File qfile) {

@Test
public void testCliDriver() throws Exception {
ObjectCache.setupObjectRegistry(new ObjectRegistryImpl());
adapter.runTest(name, qfile);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,8 @@
import java.util.List;
import org.apache.hadoop.hive.cli.control.CliAdapter;
import org.apache.hadoop.hive.cli.control.CliConfigs;
import org.apache.hadoop.hive.ql.exec.tez.ObjectCache;
import org.apache.tez.runtime.common.objectregistry.ObjectRegistryImpl;
import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.Test;
Expand Down Expand Up @@ -55,6 +57,7 @@ public TestIcebergNegativeCliDriver(String name, File qfile) {

@Test
public void testCliDriver() throws Exception {
ObjectCache.setupObjectRegistry(new ObjectRegistryImpl());
adapter.runTest(name, qfile);
}
}