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

[ 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

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

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

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

[ 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

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

[ 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:

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

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

[ 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

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

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

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

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

[ 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.

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

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

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`

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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

[ 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

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

[ 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

[ 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

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)

[ 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

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

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

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

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

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

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

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

[ 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

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

[ 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

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

[ 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

[ 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

[ 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

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

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

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

[ 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:

[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

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:

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

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

[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

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

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

[ 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:

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

[ 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

[ 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

[ 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

[ 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

[ 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

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

[ 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

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

[ 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

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

[ 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

[ 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

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

[ 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 !=

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

[ 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

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

[ 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 !=

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

[ 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

[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

[ https://issues.apache.org/jira/browse/FLINK-26051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17583305#comment-17583305 ] Jane Chan commented on FLINK-26051: --- Hi [~maver1ck], sorry for keeping you waiting. Change the cost

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

[ 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

[ 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

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

[ 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

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

[ 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

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

[ 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

[ 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

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

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

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

[ 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

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

[ 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

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

[ 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

[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

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

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

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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

[ 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

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

[ 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

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

[ 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

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

[ 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

[jira] [Updated] (FLINK-24122) Add support to do clean in history server

[ https://issues.apache.org/jira/browse/FLINK-24122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-24122: - Fix Version/s: 1.17.0 (was: 1.16.0) > Add support to do clean in history

[jira] [Updated] (FLINK-22805) Dynamic configuration of Flink checkpoint interval

[ https://issues.apache.org/jira/browse/FLINK-22805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-22805: - Fix Version/s: 1.17.0 (was: 1.16.0) > Dynamic configuration of Flink

[jira] [Updated] (FLINK-24849) Only return stacktrace if RestHandlerException has a cause

[ https://issues.apache.org/jira/browse/FLINK-24849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-24849: - Fix Version/s: 1.17.0 (was: 1.16.0) > Only return stacktrace if

[jira] [Updated] (FLINK-24048) Move changeLog inference out of optimizing phase

[ https://issues.apache.org/jira/browse/FLINK-24048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-24048: - Fix Version/s: 1.17.0 (was: 1.16.0) > Move changeLog inference out of

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

[ 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:

[jira] [Updated] (FLINK-23254) Upgrade Test Framework to JUnit 5

[ https://issues.apache.org/jira/browse/FLINK-23254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-23254: - Fix Version/s: 1.17.0 (was: 1.16.0) > Upgrade Test Framework to JUnit 5

[jira] [Updated] (FLINK-25224) Upgrade the minimal supported hadoop version to 2.8.5

[ https://issues.apache.org/jira/browse/FLINK-25224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-25224: - Fix Version/s: 1.17.0 (was: 1.16.0) > Upgrade the minimal supported

[jira] [Updated] (FLINK-25291) Add failure cases in DataStream source and sink suite of connector testing framework

[ https://issues.apache.org/jira/browse/FLINK-25291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-25291: - Fix Version/s: 1.17.0 (was: 1.16.0) > Add failure cases in DataStream

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

[ 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:

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

[ 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:

[jira] [Updated] (FLINK-27144) Provide timeout details when calling FutureUtils.orTimeout

[ https://issues.apache.org/jira/browse/FLINK-27144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-27144: - Fix Version/s: 1.17.0 (was: 1.16.0) > Provide timeout details when

[jira] [Updated] (FLINK-23564) Make taskmanager.out and taskmanager.err rollable

[ https://issues.apache.org/jira/browse/FLINK-23564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-23564: - Fix Version/s: 1.17.0 (was: 1.16.0) > Make taskmanager.out and

[jira] [Updated] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-23031: - Fix Version/s: 1.17.0 (was: 1.16.0) > Support to emit window result with

[jira] [Updated] (FLINK-24237) Consider disabling or lowering DNS caching timeout in docker image

[ https://issues.apache.org/jira/browse/FLINK-24237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-24237: - Fix Version/s: 1.17.0 (was: 1.16.0) > Consider disabling or lowering DNS

[jira] [Updated] (FLINK-20726) Introduce Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-20726: - Fix Version/s: 1.17.0 (was: 1.16.0) > Introduce Pulsar connector >

[jira] [Updated] (FLINK-24094) Support DROP PARTITION by partial partition specification

[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-24094: - Fix Version/s: 1.17.0 (was: 1.16.0) > Support DROP PARTITION by partial

[jira] [Updated] (FLINK-23141) Support KafkaSerializationSchema in Kafka connector for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-23141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-23141: - Fix Version/s: 1.17.0 (was: 1.16.0) > Support KafkaSerializationSchema

[GitHub] [flink] yuchuanchen commented on a diff in pull request #20616: [FLINK-29005][Connectors/Parquet] Parquet row type reader should not return null value when some child fields is null

yuchuanchen commented on code in PR #20616: URL: https://github.com/apache/flink/pull/20616#discussion_r952094055 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceITCase.java: ## @@ -963,6 +971,121 @@ public void

[GitHub] [flink] yuchuanchen commented on a diff in pull request #20616: [FLINK-29005][Connectors/Parquet] Parquet row type reader should not return null value when some child fields is null

yuchuanchen commented on code in PR #20616: URL: https://github.com/apache/flink/pull/20616#discussion_r952093882 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceITCase.java: ## @@ -963,6 +971,121 @@ public void

[GitHub] [flink] yuchuanchen commented on a diff in pull request #20616: [FLINK-29005][Connectors/Parquet] Parquet row type reader should not return null value when some child fields is null

yuchuanchen commented on code in PR #20616: URL: https://github.com/apache/flink/pull/20616#discussion_r952093643 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveTableSourceITCase.java: ## @@ -963,6 +971,121 @@ public void

  1   2   3   4   5   6   >