You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ja...@apache.org on 2020/06/17 06:02:39 UTC

[flink] branch master updated (204aa6d -> 03a8ef6)

This is an automated email from the ASF dual-hosted git repository.

jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 204aa6d  [FLINK-18332][state] Add error message to precondition in KeyGroupPartitionedPriorityQueue
     add 03a8ef6  [FLINK-18072][hbase] Fix HBaseLookupFunction can not work with new internal data structure RowData

No new revisions were added by this update.

Summary of changes:
 .../hbase/source/HBaseDynamicTableSource.java      |   2 +-
 .../hbase/source/HBaseLookupFunction.java          |   2 +-
 ...nction.java => HBaseRowDataLookupFunction.java} |  48 +--
 .../flink/connector/hbase/util/HBaseSerde.java     |  26 ++
 .../connector/hbase/HBaseConnectorITCase.java      | 423 ++++++++-------------
 .../hbase/HBaseDynamicTableFactoryTest.java        |   6 +-
 .../flink/connector/hbase/util/HBaseTestBase.java  |  68 +++-
 7 files changed, 279 insertions(+), 296 deletions(-)
 copy flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/{HBaseLookupFunction.java => HBaseRowDataLookupFunction.java} (79%)