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/23 02:45:25 UTC
[flink] branch master updated (de8a385 -> 6c7416a)
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 de8a385 [hotfix] Remove unused SlotPoolImpl.get(SlotRequestId)
add 6c7416a [FLINK-17678][hbase] Add flink-sql-connector-hbase module to provide uber jar for HBase connector
No new revisions were added by this update.
Summary of changes:
flink-connectors/flink-sql-connector-hbase/pom.xml | 153 ++
.../src/main/resources/META-INF/NOTICE | 35 +
.../resources/META-INF/licenses/LICENSE.protobuf | 0
.../src/main/resources/hbase-default.xml | 1558 ++++++++++++++++++++
flink-connectors/pom.xml | 8 +-
.../tests/util/kafka/SQLClientKafkaITCase.java | 10 +-
.../tests/util/kafka/StreamingKafkaITCase.java | 2 +-
.../org/apache/flink/tests/util/TestUtils.java | 29 +-
.../flink-end-to-end-tests-hbase/pom.xml | 212 +++
.../flink/tests/util/hbase/HBaseResource.java | 72 +
.../tests/util/hbase/HBaseResourceFactory.java} | 12 +-
.../util/hbase/LocalStandaloneHBaseResource.java | 190 +++
.../hbase/LocalStandaloneHBaseResourceFactory.java | 10 +-
.../tests/util/hbase/SQLClientHBaseITCase.java | 190 +++
.../src/test/resources/hbase_e2e.sql | 56 +
.../src/test/resources/log4j2-test.properties | 0
flink-end-to-end-tests/pom.xml | 1 +
17 files changed, 2504 insertions(+), 34 deletions(-)
create mode 100644 flink-connectors/flink-sql-connector-hbase/pom.xml
create mode 100644 flink-connectors/flink-sql-connector-hbase/src/main/resources/META-INF/NOTICE
copy {flink-python => flink-connectors/flink-sql-connector-hbase}/src/main/resources/META-INF/licenses/LICENSE.protobuf (100%)
create mode 100644 flink-connectors/flink-sql-connector-hbase/src/main/resources/hbase-default.xml
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-hbase/pom.xml
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-hbase/src/main/java/org/apache/flink/tests/util/hbase/HBaseResource.java
copy flink-end-to-end-tests/{flink-end-to-end-tests-common-kafka/src/main/java/org/apache/flink/tests/util/kafka/KafkaResourceFactory.java => flink-end-to-end-tests-hbase/src/main/java/org/apache/flink/tests/util/hbase/HBaseResourceFactory.java} (78%)
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-hbase/src/main/java/org/apache/flink/tests/util/hbase/LocalStandaloneHBaseResource.java
copy flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/SecureAzureFSFactory.java => flink-end-to-end-tests/flink-end-to-end-tests-hbase/src/main/java/org/apache/flink/tests/util/hbase/LocalStandaloneHBaseResourceFactory.java (74%)
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-hbase/src/test/java/org/apache/flink/tests/util/hbase/SQLClientHBaseITCase.java
create mode 100644 flink-end-to-end-tests/flink-end-to-end-tests-hbase/src/test/resources/hbase_e2e.sql
copy {flink-yarn => flink-end-to-end-tests/flink-end-to-end-tests-hbase}/src/test/resources/log4j2-test.properties (100%)