diff --git a/hbase-shell/src/main/ruby/hbase/table.rb b/hbase-shell/src/main/ruby/hbase/table.rb index 2535a68b4d4..b5769ca38f4 100644 --- a/hbase-shell/src/main/ruby/hbase/table.rb +++ b/hbase-shell/src/main/ruby/hbase/table.rb @@ -359,7 +359,8 @@ EOF unless filter.class == String get.setFilter(filter) else - get.setFilter(org.apache.hadoop.hbase.filter.ParseFilter.new.parseFilterString(filter)) + get.setFilter( + org.apache.hadoop.hbase.filter.ParseFilter.new.parseFilterString(filter.to_java_bytes)) end get.setConsistency(org.apache.hadoop.hbase.client.Consistency.valueOf(consistency)) if consistency @@ -458,7 +459,8 @@ EOF unless filter.class == String scan.setFilter(filter) else - scan.setFilter(org.apache.hadoop.hbase.filter.ParseFilter.new.parseFilterString(filter)) + scan.setFilter( + org.apache.hadoop.hbase.filter.ParseFilter.new.parseFilterString(filter.to_java_bytes)) end scan.setScanMetricsEnabled(enablemetrics) if enablemetrics diff --git a/hbase-shell/src/test/ruby/hbase/table_test.rb b/hbase-shell/src/test/ruby/hbase/table_test.rb index 70ed04b640a..d4547b742ae 100644 --- a/hbase-shell/src/test/ruby/hbase/table_test.rb +++ b/hbase-shell/src/test/ruby/hbase/table_test.rb @@ -598,6 +598,22 @@ module Hbase end end + define_test "scan should support FILTER with non-ASCII bytes" do + @test_table.put(4, "x:a", "\x82") + begin + res = @test_table._scan_internal FILTER => "SingleColumnValueFilter('x', 'a', >=, 'binary:\x82', true, true)" + assert_not_equal(res, {}, "Result is empty") + assert_kind_of(Hash, res) + assert_not_nil(res['4']) + assert_not_nil(res['4']['x:a']) + assert_nil(res['1']) + assert_nil(res['2']) + ensure + # clean up newly added columns for this test only. + @test_table.delete(4, "x:a") + end + end + define_test "scan hbase meta table" do res = table("hbase:meta")._scan_internal assert_not_nil(res)