[jira] [Commented] (FLINK-28953) Release Testing: Verify FLIP-91 SQL Gateway

2022-08-22 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17583402#comment-17583402 ] Godfrey He commented on FLINK-28953: [~junhe]  assign to you > Release Testing: Ver

[jira] [Assigned] (FLINK-28953) Release Testing: Verify FLIP-91 SQL Gateway

2022-08-22 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-28953: -- Assignee: Jun He > Release Testing: Verify FLIP-91 SQL Gateway >

[jira] [Assigned] (FLINK-29069) Release Testing: Verify FLIP-218 Create table as select syntax

2022-08-22 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-29069: -- Assignee: Qingsheng Ren > Release Testing: Verify FLIP-218 Create table as select syntax > --

[jira] [Assigned] (FLINK-29068) Release Testing: Verify FLIP-214 Create function using jar syntax

2022-08-22 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-29068: -- Assignee: Qingsheng Ren > Release Testing: Verify FLIP-214 Create function using jar syntax >

[jira] [Assigned] (FLINK-28989) Release Testing: Verify FLIP-221 lookup table cache

2022-08-22 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-28989: -- Assignee: dalongliu (was: Qingsheng Ren) > Release Testing: Verify FLIP-221 lookup table cac

[jira] [Commented] (FLINK-28923) Release Testing: Verify flip-241 completed jobs information enhancement

2022-08-22 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17583399#comment-17583399 ] Weijie Guo commented on FLINK-28923: [~xtsong] Thank you for such a good job, I have

[jira] [Resolved] (FLINK-28943) Add Transformer and Estimator for MaxAbsScaler

2022-08-22 Thread Zhipeng Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang resolved FLINK-28943. --- Fix Version/s: ml-2.2.0 Resolution: Fixed Fixed on master via 3aa21751ddb1b561c44ec00

[GitHub] [flink] LadyForest commented on pull request #20652: [FLINK-22315][table] Support add/modify column/constraint/watermark for ALTER TABLE statement

2022-08-22 Thread GitBox
LadyForest commented on PR #20652: URL: https://github.com/apache/flink/pull/20652#issuecomment-1223612021 @flinkbot run azure -- 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

[jira] [Commented] (FLINK-29074) use 'add jar' in sql client throws "Could not find any jdbc dialect factories that implement"

2022-08-22 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17583388#comment-17583388 ] dalongliu commented on FLINK-29074: --- [~xuyangzhong] Thanks for report, I will take a l

[GitHub] [flink] swuferhong commented on pull request #20596: [FLINK-28993][table-planner] Fix adjusting join cost for dpp query pattern error

2022-08-22 Thread GitBox
swuferhong commented on PR #20596: URL: https://github.com/apache/flink/pull/20596#issuecomment-1223604050 @flinkbot run azure -- 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

[jira] [Updated] (FLINK-28989) Release Testing: Verify FLIP-221 lookup table cache

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-28989: - Labels: release-testing (was: test-stability) > Release Testing: Verify FLIP-221 lookup table c

[jira] [Closed] (FLINK-29071) Fix Table Store Hive CDH support

2022-08-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29071. Fix Version/s: (was: table-store-0.3.0) Resolution: Fixed master: fe57dfa704117ff9f14dc

[GitHub] [flink] lincoln-lil commented on a diff in pull request #20577: [FLINK-28971][table-planner][doc] Adds user documentation for the new LOOKUP hint

2022-08-22 Thread GitBox
lincoln-lil commented on code in PR #20577: URL: https://github.com/apache/flink/pull/20577#discussion_r952185567 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,311 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[jira] [Updated] (FLINK-29069) Release Testing: Verify FLIP-218 Create table as select syntax

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29069: - Labels: release-testing (was: ) > Release Testing: Verify FLIP-218 Create table as select synta

[jira] [Updated] (FLINK-29068) Release Testing: Verify FLIP-214 Create function using jar syntax

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29068: - Labels: release-testing (was: ) > Release Testing: Verify FLIP-214 Create function using jar sy

[GitHub] [flink-table-store] JingsongLi merged pull request #271: [FLINK-29071] Fix Table Store Hive CDH support

2022-08-22 Thread GitBox
JingsongLi merged PR #271: URL: https://github.com/apache/flink-table-store/pull/271 -- 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. To unsubscribe, e-mail: issues-unsubscr...@

[jira] [Created] (FLINK-29074) use 'add jar' in sql client throws "Could not find any jdbc dialect factories that implement"

2022-08-22 Thread xuyang (Jira)
xuyang created FLINK-29074: -- Summary: use 'add jar' in sql client throws "Could not find any jdbc dialect factories that implement" Key: FLINK-29074 URL: https://issues.apache.org/jira/browse/FLINK-29074 Pro

[jira] [Assigned] (FLINK-29046) HiveTableSourceStatisticsReportTest fails with Hadoop 3

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-29046: Assignee: Yunhong Zheng > HiveTableSourceStatisticsReportTest fails with Hadoop 3 > -

[GitHub] [flink-ml] zhipeng93 merged pull request #142: [FLINK-28943] Add Transformer and Estimator for MaxAbsScaler

2022-08-22 Thread GitBox
zhipeng93 merged PR #142: URL: https://github.com/apache/flink-ml/pull/142 -- 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. To unsubscribe, e-mail: issues-unsubscr...@flink.apac

[GitHub] [flink-ml] zhipeng93 commented on pull request #142: [FLINK-28943] Add Transformer and Estimator for MaxAbsScaler

2022-08-22 Thread GitBox
zhipeng93 commented on PR #142: URL: https://github.com/apache/flink-ml/pull/142#issuecomment-1223587486 LGTM. -- 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. To unsubscrib

[jira] [Closed] (FLINK-28139) Add documentation for speculative execution

2022-08-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28139. --- Resolution: Done Done via 70d9f6c31b289b6ea284a02fdb1d8cfc1a1a5414 > Add documentation for speculative exec

[GitHub] [flink] zhuzhurk closed pull request #20507: [FLINK-28139][docs] Add documentation for speculative execution

2022-08-22 Thread GitBox
zhuzhurk closed pull request #20507: [FLINK-28139][docs] Add documentation for speculative execution URL: https://github.com/apache/flink/pull/20507 -- 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 t

[jira] [Updated] (FLINK-28985) support create table like view

2022-08-22 Thread waywtdcc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] waywtdcc updated FLINK-28985: - Description: At present, to create a table based on table like, you can only use the table type table,

[GitHub] [flink] flinkbot commented on pull request #20665: [FLINK-28938][hive] Fix HiveServer2 Endpoint can not set variable correctly

2022-08-22 Thread GitBox
flinkbot commented on PR #20665: URL: https://github.com/apache/flink/pull/20665#issuecomment-1223540011 ## CI report: * 408ae49c21326afab014303624336fe6bf802f8b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29068) Release Testing: Verify FLIP-214 Create function using jar syntax

2022-08-22 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-29068: -- Description: This issue aims to verify FLIP-214: [https://cwiki.apache.org/confluence/display/FLINK/F

[GitHub] [flink] godfreyhe commented on a diff in pull request #20577: [FLINK-28971][table-planner][doc] Adds user documentation for the new LOOKUP hint

2022-08-22 Thread GitBox
godfreyhe commented on code in PR #20577: URL: https://github.com/apache/flink/pull/20577#discussion_r952126257 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,323 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[jira] [Updated] (FLINK-28938) Fix HiveServer2 Endpoint can not set variable correctly

2022-08-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28938: --- Labels: pull-request-available (was: ) > Fix HiveServer2 Endpoint can not set variable corr

[GitHub] [flink] luoyuxia opened a new pull request, #20665: [FLINK-28938][hive] Fix HiveServer2 Endpoint can not set variable correctly

2022-08-22 Thread GitBox
luoyuxia opened a new pull request, #20665: URL: https://github.com/apache/flink/pull/20665 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

[GitHub] [flink] zhuzhurk commented on pull request #20507: [FLINK-28139][docs] Add documentation for speculative execution

2022-08-22 Thread GitBox
zhuzhurk commented on PR #20507: URL: https://github.com/apache/flink/pull/20507#issuecomment-1223513193 @flinkbot run azure -- 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.

[jira] [Closed] (FLINK-29010) flink planner test is not correct

2022-08-22 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau closed FLINK-29010. Resolution: Fixed > flink planner test is not correct > - > >

[GitHub] [flink] liuyongvs closed pull request #20610: [FLINK-29010][planner] fix wrong result check of unit test.

2022-08-22 Thread GitBox
liuyongvs closed pull request #20610: [FLINK-29010][planner] fix wrong result check of unit test. URL: https://github.com/apache/flink/pull/20610 -- 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

[GitHub] [flink] lincoln-lil commented on a diff in pull request #20513: [FLINK-28858][docs] Add document to describe join hints for batch sql

2022-08-22 Thread GitBox
lincoln-lil commented on code in PR #20513: URL: https://github.com/apache/flink/pull/20513#discussion_r952126195 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,210 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[GitHub] [flink-kubernetes-operator] haoxins opened a new pull request, #353: [docs] Add an example about how to enable Prometheus for FlinkDeployment

2022-08-22 Thread GitBox
haoxins opened a new pull request, #353: URL: https://github.com/apache/flink-kubernetes-operator/pull/353 ## What is the purpose of the change *(For example: This pull request adds a new feature to periodically create and maintain savepoints through the `FlinkDeployment` cust

[GitHub] [flink] godfreyhe commented on a diff in pull request #20577: [FLINK-28971][table-planner][doc] Adds user documentation for the new LOOKUP hint

2022-08-22 Thread GitBox
godfreyhe commented on code in PR #20577: URL: https://github.com/apache/flink/pull/20577#discussion_r952122673 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,323 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[jira] [Updated] (FLINK-29000) Support python UDF in the SQL Gateway

2022-08-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-29000: -- Parent: FLINK-29073 Issue Type: Sub-task (was: New Feature) > Support python UDF in t

[jira] [Updated] (FLINK-29000) Support python UDF in the SQL Gateway

2022-08-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-29000: -- Parent: (was: FLINK-15472) Issue Type: New Feature (was: Sub-task) > Support pyth

[jira] [Updated] (FLINK-27837) Support statement set in the SQL Gateway

2022-08-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-27837: -- Parent: FLINK-29073 Issue Type: Sub-task (was: New Feature) > Support statement set i

[jira] [Updated] (FLINK-27837) Support statement set in the SQL Gateway

2022-08-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-27837: -- Parent: (was: FLINK-15472) Issue Type: New Feature (was: Sub-task) > Support stat

[jira] [Updated] (FLINK-27838) Support timeout mechansim for executeStatement API

2022-08-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-27838: -- Parent: (was: FLINK-15472) Issue Type: New Feature (was: Sub-task) > Support time

[jira] [Updated] (FLINK-27838) Support timeout mechansim for executeStatement API

2022-08-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-27838: -- Parent: FLINK-29073 Issue Type: Sub-task (was: New Feature) > Support timeout mechans

[jira] [Updated] (FLINK-27772) Expose Operation-level logs in the SqlGatewayService

2022-08-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-27772: -- Parent: FLINK-29073 Issue Type: Sub-task (was: New Feature) > Expose Operation-level

[jira] [Updated] (FLINK-27772) Expose Operation-level logs in the SqlGatewayService

2022-08-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-27772: -- Parent: (was: FLINK-15472) Issue Type: New Feature (was: Sub-task) > Expose Opera

[jira] [Assigned] (FLINK-24852) Cleanup of Orphaned Incremental State Artifacts

2022-08-22 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reassigned FLINK-24852: Assignee: Yuan Mei > Cleanup of Orphaned Incremental State Artifacts > --

[jira] [Assigned] (FLINK-29071) Fix Table Store Hive CDH support

2022-08-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29071: Assignee: Caizhi Weng > Fix Table Store Hive CDH support > --

[GitHub] [flink] xuyangzhong commented on a diff in pull request #20577: [FLINK-28971][table-planner][doc] Adds user documentation for the new LOOKUP hint

2022-08-22 Thread GitBox
xuyangzhong commented on code in PR #20577: URL: https://github.com/apache/flink/pull/20577#discussion_r952111310 ## docs/content/docs/dev/table/sql/queries/hints.md: ## @@ -84,4 +84,323 @@ insert into kafka_table1 /*+ OPTIONS('sink.partitioner'='round-robin') */ select ```

[jira] [Updated] (FLINK-26942) Support SELECT clause in CREATE TABLE(CTAS)

2022-08-22 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-26942: -- Fix Version/s: 1.17.0 (was: 1.16.0) > Support SELECT clause in CREATE TABLE(CTA

[jira] [Created] (FLINK-29073) [FLIP-91] Support SQL Gateway(Part 2)

2022-08-22 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-29073: - Summary: [FLIP-91] Support SQL Gateway(Part 2) Key: FLINK-29073 URL: https://issues.apache.org/jira/browse/FLINK-29073 Project: Flink Issue Type: New Featu

[jira] [Created] (FLINK-29072) Migrate DDL-related schema handling to the new Schema framework

2022-08-22 Thread Jane Chan (Jira)
Jane Chan created FLINK-29072: - Summary: Migrate DDL-related schema handling to the new Schema framework Key: FLINK-29072 URL: https://issues.apache.org/jira/browse/FLINK-29072 Project: Flink Is

[GitHub] [flink] swuferhong commented on pull request #20646: [hotfix][docs] Fix ./build_docs.sh error caused by elasticsearch page not exists

2022-08-22 Thread GitBox
swuferhong commented on PR #20646: URL: https://github.com/apache/flink/pull/20646#issuecomment-1223485799 > If you follow the build instructions for the docs it will work: https://github.com/apache/flink/blob/master/docs/README.md Hi, @zentol , thanks for the tip. I followed the ste

[jira] [Resolved] (FLINK-27771) Introduce the listAPIs in the SqlGatewayService

2022-08-22 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang resolved FLINK-27771. --- Resolution: Implemented > Introduce the listAPIs in the SqlGatewayService >

[GitHub] [flink] flinkbot commented on pull request #20664: [FLINK-29046][Connectors/Hive] Fix HiveTableSourceStatisticsReportTest fails with Hive 3.x

2022-08-22 Thread GitBox
flinkbot commented on PR #20664: URL: https://github.com/apache/flink/pull/20664#issuecomment-1223484875 ## CI report: * a6b37957c8100a937d08b1660fb6e1804e99a54b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29071) Fix Table Store Hive CDH support

2022-08-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29071: --- Labels: pull-request-available (was: ) > Fix Table Store Hive CDH support > ---

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #271: [FLINK-29071] Fix Table Store Hive CDH support

2022-08-22 Thread GitBox
JingsongLi commented on code in PR #271: URL: https://github.com/apache/flink-table-store/pull/271#discussion_r952113723 ## .github/workflows/build-different-versions.yml: ## @@ -16,10 +16,13 @@ jobs: - name: Build Flink 1.15 run: | mvn clean install -

[jira] [Assigned] (FLINK-29063) FileFormatTest has some wrong assertion

2022-08-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29063: Assignee: Kirill Listopad > FileFormatTest has some wrong assertion > ---

[jira] [Updated] (FLINK-27583) Improve the plan for TPC-DS queries

2022-08-22 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-27583: --- Fix Version/s: 1.17.0 (was: 1.16.0) > Improve the plan for TPC-DS queries > -

[jira] [Updated] (FLINK-29046) HiveTableSourceStatisticsReportTest fails with Hadoop 3

2022-08-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29046: --- Labels: pull-request-available (was: ) > HiveTableSourceStatisticsReportTest fails with Had

[GitHub] [flink] swuferhong opened a new pull request, #20664: [FLINK-29046][Connectors/Hive] Fix HiveTableSourceStatisticsReportTest fails with Hive 3.x

2022-08-22 Thread GitBox
swuferhong opened a new pull request, #20664: URL: https://github.com/apache/flink/pull/20664 ## What is the purpose of the change For `Hive 3.x` version, `HiveTableSourceStatisticsReportTest` will fail because of `Orc` format encounter decimal type columns (like deci

[jira] [Closed] (FLINK-29070) Provide a option to force the removal of the normalize node when streaming read

2022-08-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29070. Resolution: Fixed master: b4f187f370d3e47c436bc9c0aafa5f6e381e6387 release-0.2: fa11e8748c763fcc89

[GitHub] [flink-table-store] JingsongLi merged pull request #273: [FLINK-29070] Provide a option to force the removal of the normalize node when streaming read

2022-08-22 Thread GitBox
JingsongLi merged PR #273: URL: https://github.com/apache/flink-table-store/pull/273 -- 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. To unsubscribe, e-mail: issues-unsubscr...@

[jira] [Created] (FLINK-29071) Fix Table Store Hive CDH support

2022-08-22 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-29071: --- Summary: Fix Table Store Hive CDH support Key: FLINK-29071 URL: https://issues.apache.org/jira/browse/FLINK-29071 Project: Flink Issue Type: Bug Comp

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #273: [FLINK-29070] Provide a option to force the removal of the normalize node when streaming read

2022-08-22 Thread GitBox
LadyForest commented on code in PR #273: URL: https://github.com/apache/flink-table-store/pull/273#discussion_r952105130 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/TableStoreSource.java: ## @@ -120,6 +121,10 @@ public ChangelogMode

[jira] [Updated] (FLINK-29069) Release Testing: Verify FLIP-218 Create table as select syntax

2022-08-22 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-29069: -- Description: This issue aims to verify FLIP-218: https://cwiki.apache.org/confluence/pages/viewpage.a

[jira] [Updated] (FLINK-25244) Deprecate Java 8 support

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-25244: - Fix Version/s: 1.17.0 (was: 1.16.0) > Deprecate Java 8 support >

[jira] [Updated] (FLINK-28985) support create table like view

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-28985: - Fix Version/s: 1.17.0 (was: 1.16.0) > support create table like view > --

[jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-21634: - Fix Version/s: 1.17.0 (was: 1.16.0) > ALTER TABLE statement enhancement >

[jira] [Updated] (FLINK-28937) Add doc for SqlGateway

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-28937: - Component/s: Documentation > Add doc for SqlGateway > -- > >

[jira] [Updated] (FLINK-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-20834: - Fix Version/s: 1.17.0 (was: 1.16.0) > Add metrics for reporting the memor

[jira] [Updated] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-14032: - Fix Version/s: 1.17.0 (was: 1.16.0) > Make the cache size of RocksDBPrior

[jira] [Updated] (FLINK-14684) Add Pinterest to Chinese Powered By page

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-14684: - Fix Version/s: 1.17.0 (was: 1.16.0) > Add Pinterest to Chinese Powered By

[jira] [Closed] (FLINK-21559) Python DataStreamTests::test_process_function failed on AZP

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-21559. Resolution: Cannot Reproduce > Python DataStreamTests::test_process_function failed on AZP > -

[jira] [Updated] (FLINK-24536) flink sql where condition is not supported != writing

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-24536: - Fix Version/s: 1.17.0 (was: 1.16.0) > flink sql where condition is not su

[jira] [Updated] (FLINK-24536) flink sql where condition is not supported != writing

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-24536: - Issue Type: Improvement (was: New Feature) > flink sql where condition is not supported != wri

[jira] [Updated] (FLINK-17337) Send UPDATE messages instead of INSERT and DELETE in streaming join operator

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-17337: - Fix Version/s: 1.17.0 (was: 1.16.0) > Send UPDATE messages instead of INS

[jira] [Updated] (FLINK-24536) flink sql where condition is not supported != writing

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-24536: - Issue Type: New Feature (was: Improvement) > flink sql where condition is not supported != wri

[jira] [Updated] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-21711: - Fix Version/s: 1.17.0 (was: 1.16.0) > DataStreamSink doesn't allow settin

[jira] [Commented] (FLINK-26051) one sql has row_number =1 and the subsequent SQL has "case when" and "where" statement result Exception : The window can only be ordered in ASCENDING mode

2022-08-22 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17583305#comment-17583305 ] Jane Chan commented on FLINK-26051: --- Hi [~maver1ck], sorry for keeping you waiting. Ch

[jira] [Updated] (FLINK-27327) Add description about changing max parallelism explicitly leads to state incompatibility

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-27327: - Fix Version/s: 1.17.0 (was: 1.16.0) > Add description about changing max

[jira] [Updated] (FLINK-26840) [minor refactor] Add a general TopNBufferCacheRemovalListener for topN function

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-26840: - Fix Version/s: 1.17.0 (was: 1.16.0) > [minor refactor] Add a general TopN

[jira] [Updated] (FLINK-22235) Document stability concerns of flamegraphs for heavier jobs

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-22235: - Fix Version/s: 1.17.0 (was: 1.16.0) > Document stability concerns of flam

[jira] [Updated] (FLINK-25900) Create view example does not assign alias to functions resulting in generated names like EXPR$5

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-25900: - Fix Version/s: 1.17.0 (was: 1.16.0) > Create view example does not assign

[jira] [Updated] (FLINK-28909) Add ribbon filter policy option in RocksDBConfiguredOptions

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-28909: - Fix Version/s: 1.17.0 (was: 1.16.0) > Add ribbon filter policy option in

[jira] [Updated] (FLINK-29040) When using the JDBC Catalog, the custom cannot be applied because it is fixed in the code

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29040: - Fix Version/s: 1.17.0 (was: 1.16.0) > When using the JDBC Catalog, the cu

[GitHub] [flink] lsyldliu commented on pull request #20633: [FLINK-29014][streaming-java][table] Improve end-to-end story about PipelinesOptions.JARS

2022-08-22 Thread GitBox
lsyldliu commented on PR #20633: URL: https://github.com/apache/flink/pull/20633#issuecomment-1223458198 > @lsyldliu could you help me with a review? Thanks :) Ok, I will review it as soon as possible. -- This is an automated message from the Apache Git Service. To respond to the me

[jira] [Updated] (FLINK-22828) Allow using a custom AWS credentials provider for the Kinesis Connector

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-22828: - Fix Version/s: 1.17.0 (was: 1.16.0) > Allow using a custom AWS credential

[jira] [Updated] (FLINK-29070) Provide a option to force the removal of the normalize node when streaming read

2022-08-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29070: --- Labels: pull-request-available (was: ) > Provide a option to force the removal of the norma

[jira] [Updated] (FLINK-25887) FLIP-193: Snapshots ownership follow ups

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-25887: - Fix Version/s: 1.17.0 (was: 1.16.0) > FLIP-193: Snapshots ownership follo

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #273: [FLINK-29070] Provide a option to force the removal of the normalize node when streaming read

2022-08-22 Thread GitBox
JingsongLi opened a new pull request, #273: URL: https://github.com/apache/flink-table-store/pull/273 There are many jobs that do not require a downstream normalize node, and the key is that the node has a very large cost. Introduce a option: Whether to force the removal of the nor

[jira] [Created] (FLINK-29070) Provide a option to force the removal of the normalize node when streaming read

2022-08-22 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29070: Summary: Provide a option to force the removal of the normalize node when streaming read Key: FLINK-29070 URL: https://issues.apache.org/jira/browse/FLINK-29070 Proje

[jira] [Updated] (FLINK-26683) Commit side effects if stop-with-savepoint failed while finishing

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-26683: - Fix Version/s: 1.17.0 (was: 1.16.0) > Commit side effects if stop-with-sa

[jira] [Updated] (FLINK-26664) Improve Python exception messages to be more Pythonic in PyFlink

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-26664: - Fix Version/s: 1.17.0 (was: 1.16.0) > Improve Python exception messages t

[jira] [Updated] (FLINK-26326) FLIP-203: Support native and incremental savepoints 1.1

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-26326: - Fix Version/s: 1.17.0 (was: 1.16.0) > FLIP-203: Support native and increm

[jira] [Updated] (FLINK-23737) Ensure publish-to-dockerhub.sh only publish specific flink versions

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-23737: - Fix Version/s: 1.17.0 (was: 1.16.0) > Ensure publish-to-dockerhub.sh only

[jira] [Updated] (FLINK-24258) Connection timed out or very slowly when visiting Flink website

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-24258: - Fix Version/s: 1.17.0 (was: 1.16.0) > Connection timed out or very slowly

[jira] [Updated] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-21648: - Fix Version/s: 1.17.0 (was: 1.16.0) > FLIP-151: Incremental snapshots for

[jira] [Updated] (FLINK-22909) Supports change log inputs for event time operators

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-22909: - Fix Version/s: 1.17.0 (was: 1.16.0) > Supports change log inputs for even

[jira] [Updated] (FLINK-24273) Relocate io.fabric8 dependency

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-24273: - Fix Version/s: 1.17.0 (was: 1.16.0) > Relocate io.fabric8 dependency > --

[jira] [Updated] (FLINK-23350) Write doc for change log disorder by special operators

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-23350: - Fix Version/s: 1.17.0 (was: 1.16.0) > Write doc for change log disorder b

[jira] [Updated] (FLINK-16137) Translate all DataStream API related pages into Chinese

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-16137: - Fix Version/s: 1.17.0 (was: 1.16.0) > Translate all DataStream API relate

[jira] [Updated] (FLINK-23216) RM keeps allocating and freeing slots after a TM lost until its heartbeat timeout

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-23216: - Fix Version/s: 1.17.0 (was: 1.16.0) > RM keeps allocating and freeing slo

[jira] [Updated] (FLINK-23849) Support react to the node decommissioning change state on yarn and do graceful restart

2022-08-22 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-23849: - Fix Version/s: 1.17.0 (was: 1.16.0) > Support react to the node decommiss

  1   2   3   4   5   6   >