[jira] [Created] (FLINK-29558) Use select count(*) from xxx; and get SQL syntax
Hang HOU created FLINK-29558: Summary: Use select count(*) from xxx; and get SQL syntax Key: FLINK-29558 URL: https://issues.apache.org/jira/browse/FLINK-29558 Project: Flink Issue Type: Bug Components: Connectors / JDBC Affects Versions: 1.15.2 Environment: flink 1.15.2 CentOS Linux release 7.9.2009 (Core) 5.7.32-log MySQL Community Server (GPL) Reporter: Hang HOU Attachments: image-2022-10-10-15-31-34-341.png Hi, I use flink sql to make kafka records to mysql. so I create these 2 tables in flink sql,here is the mysql ,and I created the table in mysql before I did the insert action in flink sql. CREATE TABLE mysql_MyUserTable ( id STRING, name STRING, age STRING, status STRING, PRIMARY KEY (id) NOT ENFORCED ) WITH ( 'connector' = 'jdbc', 'url' = 'jdbc:mysql://10.19.29.170:3306/fromflink152', 'table-name' = 'users', 'username' = 'root', 'password' = '29sj&170_r' ); In mysql, I created database "fromflink152" then created the table like this way CREATE TABLE `users` ( `id` varchar(64) NOT NULL DEFAULT '', `name` varchar(255) DEFAULT NULL, `age` varchar(255) DEFAULT NULL, `status` varchar(255) DEFAULT NULL, PRIMARY KEY (`id`) ) After executed insert sql,I found select * from mysql_MyUserTable can get correct result,but select count(*) from mysql_MyUserTable or select count(id) from mysql_MyUserTable ,zhe collect job in flink app keep restarting again and again.The exception is: !image-2022-10-10-15-31-34-341.png! So I wonder which config that I missed about the table in flink or mysql side :( -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-29917) In standalone mode can't view flink dashboard page in default
Hang HOU created FLINK-29917: Summary: In standalone mode can't view flink dashboard page in default Key: FLINK-29917 URL: https://issues.apache.org/jira/browse/FLINK-29917 Project: Flink Issue Type: Improvement Components: Runtime / Network Affects Versions: 1.16.0 Environment: FLINK 0.16.0 CentOS Linux release 7.9.2009 Reporter: Hang HOU If "rest.bind-address" in conf/flink-conf.yaml default value is "localhost",user can't get the correct flink dashboard page in browser when use the standalone mode.In other situation like yarn-session,no difference between "rest.bind-address: 0.0.0.0" and "rest.bind-address: localhost",user could get the page in both env. In some official documents,no more detail about "Why 8081 port is keep listening but the error shows ERR_CONNECTION_REFUSED?" So I guess maybe turn the default value to "0.0.0.0" can lead to beginners no more confused with error dashboard page:) -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-29924) Update official document
Hang HOU created FLINK-29924: Summary: Update official document Key: FLINK-29924 URL: https://issues.apache.org/jira/browse/FLINK-29924 Project: Flink Issue Type: Improvement Components: Table Store Affects Versions: table-store-0.2.1 Environment: Flink Table Store v0.2.1 Reporter: Hang HOU Common missing of a period. [链接标题|https://nightlies.apache.org/flink/flink-table-store-docs-release-0.2/docs/development/configuration/#kafkalogoptions] -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-29952) Using DROP TABLE XXX to drop a temporary table （or view） in sql-client can get an exception with incomplete explaination.
Hang HOU created FLINK-29952: Summary: Using DROP TABLE XXX to drop a temporary table （or view） in sql-client can get an exception with incomplete explaination. Key: FLINK-29952 URL: https://issues.apache.org/jira/browse/FLINK-29952 Project: Flink Issue Type: Improvement Components: Table SQL / API Affects Versions: 1.16.0 Environment: Flink 1.16.0 Red Hat Enterprise Linux Server release 7.4 Reporter: Hang HOU Attachments: image-2022-11-09-15-06-33-188.png Drop temporary table by using DROP TABLE XXX...always get "Drop it first before removing the permanent table" but I just create a temporary table and have no relation with any permanent table. Like the official example : -- create a word data generator table CREATE TEMPORARY TABLE word_table ( word STRING ) WITH ( 'connector' = 'datagen', 'fields.word.length' = '1' ); current exception: !image-2022-11-09-15-06-33-188.png! So I guess the exception should append some notice like "please check whether miss a TEMPORARY before TABLE". -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-29994) Update official document about Lookup Join.
Hang HOU created FLINK-29994: Summary: Update official document about Lookup Join. Key: FLINK-29994 URL: https://issues.apache.org/jira/browse/FLINK-29994 Project: Flink Issue Type: Improvement Components: Table Store Affects Versions: 1.16.0 Reporter: Hang HOU Missed a period in Description of "lookup.cache-rows". [About rocksdb'configuration|https://nightlies.apache.org/flink/flink-table-store-docs-release-0.2/docs/development/lookup-join/#rocksdboptions] -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-30012) A typo in official Table Store document.
Hang HOU created FLINK-30012: Summary: A typo in official Table Store document. Key: FLINK-30012 URL: https://issues.apache.org/jira/browse/FLINK-30012 Project: Flink Issue Type: Improvement Components: Table Store Affects Versions: 1.16.0 Environment: Flink 1.16.0 Reporter: Hang HOU Found a typo in Rescale Bucket document which is "exiting". [Rescale Bucket|https://nightlies.apache.org/flink/flink-table-store-docs-release-0.2/docs/development/rescale-bucket/#rescale-bucket] -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-30028) A little fix with document about period in log.changelog-mode description.
Hang HOU created FLINK-30028: Summary: A little fix with document about period in log.changelog-mode description. Key: FLINK-30028 URL: https://issues.apache.org/jira/browse/FLINK-30028 Project: Flink Issue Type: Improvement Components: Table Store Affects Versions: 1.16.0 Environment: Flink 0.16.0 Reporter: Hang HOU One more period in the end of ”log.changelog-mode“description. [log.changelog-mode|https://nightlies.apache.org/flink/flink-table-store-docs-release-0.2/docs/development/configuration/#coreoptions] -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-30039) Insert overwrite show excetion that query and insert schema do not match
Hang HOU created FLINK-30039: Summary: Insert overwrite show excetion that query and insert schema do not match Key: FLINK-30039 URL: https://issues.apache.org/jira/browse/FLINK-30039 Project: Flink Issue Type: Bug Components: Table Store Affects Versions: 1.16.0 Environment: Flink 1.16.0 Reporter: Hang HOU After change a table's bucket num in table store,I used a insert overwrite sql to reorganize records to new files (I guess form old orc file to the new). Everytime if select column contains the partition column,then get the next exception: !image-2022-11-16-17-43-01-552.png! When exclude the partition field,it do perform the overwrite. I wonder the “EXPR$3: STRING NOT NULL” means what , -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-30043) Some example sqls in flink table store rescale-bucket doucument are incorrect.
Hang HOU created FLINK-30043: Summary: Some example sqls in flink table store rescale-bucket doucument are incorrect. Key: FLINK-30043 URL: https://issues.apache.org/jira/browse/FLINK-30043 Project: Flink Issue Type: Improvement Components: Table Store Affects Versions: 1.16.0 Reporter: Hang HOU Attachments: image-2022-11-16-18-30-24-261.png [rescale-bucket|https://nightlies.apache.org/flink/flink-table-store-docs-release-0.2/docs/development/rescale-bucket/#use-case] For example, in this table (in table store catalog),it's columns were defined as the 4 : "trade_order_id BIGINT, item_id BIGINT, item_price DOUBLE, dt STRING," So when get start “insert overwrite” , probably have no relation with the column “order_status ” in the table "raw_orders". !image-2022-11-16-18-30-24-261.png! What's more, I guess it's better append a DDL example to create the temporary table "raw_orders" in this character. And not all the sqls have a “;” in the end. Maybe could do some little adjustment. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-30094) Flink Table Sotre's Lookup Join document may needs left table DDL example.
Hang HOU created FLINK-30094: Summary: Flink Table Sotre's Lookup Join document may needs left table DDL example. Key: FLINK-30094 URL: https://issues.apache.org/jira/browse/FLINK-30094 Project: Flink Issue Type: Improvement Components: Table Store Affects Versions: 1.16.0 Reporter: Hang HOU In this “Lookup Join” character, official document don't give a DDL example about the left table. Maybe some first time users who using lookup join with right table which in table store will get some confusions about "Processing Time Temporal Join". -- This message was sent by Atlassian Jira (v8.20.10#820010)
