openinx commented on issue #9898: [FLINK-14359][hbase] Create a module called
flink-sql-connector-hbase…
URL: https://github.com/apache/flink/pull/9898#issuecomment-542665074
The test logs are here:
{code}
==
Running 'test-scripts/test_sql_client_hbase.sh'
==
TEST_DATA_DIR:
/Users/openinx/software/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-47N
Flink dist directory:
/Users/openinx/software/flink/flink-dist/target/flink-1.10-SNAPSHOT-bin/flink-1.10-SNAPSHOT
Prepare the HBase-1.4.10 standalone cluster...
Downloading hbase dist package from
https://mirrors.tuna.tsinghua.edu.cn/apache/hbase/1.4.10/hbase-1.4.10-bin.tar.gz
running master, logging to
/Users/openinx/software/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-47N/hbase-1.4.10/bin/../logs/hbase-openinx-master-IT-C02ZC51VLVDL.local.out
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m;
support was removed in 8.0
Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m;
support was removed in 8.0
Initialize the source and sink hbase table
Start to load some rows into hbase source table
HBase Shell
Use "help" to get list of supported commands.
Use "exit" to quit this interactive shell.
Version 1.4.10, r76ab087819fe82ccf6f531096e18ad1bed079651, Wed Jun 5
16:48:11 PDT 2019
put 'source_table', 'row1', 'a:c1', 'value1'
0 row(s) in 10.3630 seconds
put 'source_table', 'row1', 'b:c1', 'value2'
0 row(s) in 0.0290 seconds
put 'source_table', 'row2', 'a:c1', 'value3'
0 row(s) in 0.0030 seconds
put 'source_table', 'row2', 'b:c1', 'value4'
0 row(s) in 0.0030 seconds
Preparing Flink cluster...
Starting cluster.
Starting standalonesession daemon on host IT-C02ZC51VLVDL.local.
Starting taskexecutor daemon on host IT-C02ZC51VLVDL.local.
Waiting for dispatcher REST endpoint to come up...
Waiting for dispatcher REST endpoint to come up...
Dispatcher REST endpoint is up.
Start 2 more task managers
[INFO] 1 instance(s) of taskexecutor are already running on
IT-C02ZC51VLVDL.local.
Starting taskexecutor daemon on host IT-C02ZC51VLVDL.local.
[INFO] 2 instance(s) of taskexecutor are already running on
IT-C02ZC51VLVDL.local.
Starting taskexecutor daemon on host IT-C02ZC51VLVDL.local.
INSERT INTO MyHBaseSink
SELECT rowkey, a, b from MyHBaseSource
No default environment specified.
Searching for
'/Users/openinx/software/flink/flink-dist/target/flink-1.10-SNAPSHOT-bin/flink-1.10-SNAPSHOT/conf/sql-client-defaults.yaml'...found.
Reading default environment from:
file:/Users/openinx/software/flink/flink-dist/target/flink-1.10-SNAPSHOT-bin/flink-1.10-SNAPSHOT/conf/sql-client-defaults.yaml
Reading session environment from:
file:/Users/openinx/software/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-47N/sql-client-session.conf
Validating current environment...done.
[INFO] Executing the following statement:
INSERT INTO MyHBaseSink
SELECT rowkey, a, b from MyHBaseSource
[INFO] Submitting SQL update statement to the cluster...
[INFO] Table update statement has been successfully submitted to the cluster:
Cluster ID: StandaloneClusterId
Job ID: caa7f7257ac5fe6647be67170c578e7d
Web interface: http://localhost:8085
Shutting down executor...done.
Got the expected 4 cells, finished the HBase end-to-end test successfully.
stopping hbase..
Checking of logs skipped.
[PASS] 'test-scripts/test_sql_client_hbase.sh' passed after 4 minutes and 47
seconds! Test exited with exit code 0.
Stopping taskexecutor daemon (pid: 9848) on host IT-C02ZC51VLVDL.local.
Stopping standalonesession daemon (pid: 8584) on host IT-C02ZC51VLVDL.local.
Deleted all files under
/Users/openinx/software/flink/flink-dist/target/flink-1.10-SNAPSHOT-bin/flink-1.10-SNAPSHOT/log/
Deleted
/Users/openinx/software/flink/flink-end-to-end-tests/test-scripts/temp-test-directory-47N
No taskexecutor daemon (pid: 9438) is running anymore on
IT-C02ZC51VLVDL.local.
No standalonesession daemon to stop on host IT-C02ZC51VLVDL.local.
{code}
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
