[GitHub] [flink] fsk119 merged pull request #19193: [FLINK-26813[SQL-API] Supports ADD/MODIFY column/watermark/constraint syntax parse for ALTER TABLE

fsk119 merged PR #19193: URL: https://github.com/apache/flink/pull/19193 -- 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.apache

[GitHub] [flink] reswqa commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

reswqa commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r915527214 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsResultPartitionReadSchedulerTest.java: ## @@ -0,0 +1,403 @@ +/* + * Licensed to the

[jira] [Closed] (FLINK-26813) Supports ADD/MODIFY column/watermark/constraint syntax parse for ALTER TABLE

[ https://issues.apache.org/jira/browse/FLINK-26813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-26813. - Resolution: Implemented Merged into master: 4f57d02ddf1788f2a16d4855aefceab7b3316c06 > Supports

[jira] [Assigned] (FLINK-26813) Supports ADD/MODIFY column/watermark/constraint syntax parse for ALTER TABLE

[ https://issues.apache.org/jira/browse/FLINK-26813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-26813: - Assignee: dalongliu > Supports ADD/MODIFY column/watermark/constraint syntax parse for

[jira] [Commented] (FLINK-28434) Extend "NestedProjectionUtil" to unify support for projection pushdown for physical fields or metadata only

[ https://issues.apache.org/jira/browse/FLINK-28434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563601#comment-17563601 ] Shengkai Fang commented on FLINK-28434: --- Sure. I will take a look when I am free.

[jira] [Assigned] (FLINK-28434) Extend "NestedProjectionUtil" to unify support for projection pushdown for physical fields or metadata only

[ https://issues.apache.org/jira/browse/FLINK-28434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-28434: - Assignee: Shengkai Fang > Extend "NestedProjectionUtil" to unify support for projection

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #182: [FLINK-27708] Add background compaction task for append-only table when ingesting

LadyForest commented on code in PR #182: URL: https://github.com/apache/flink-table-store/pull/182#discussion_r915536943 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/data/AppendOnlyWriter.java: ## @@ -88,6 +81,9 @@ public void write(RowData rowData)

[GitHub] [flink] bzhaoopenstack opened a new pull request, #20193: [FLINK-28433][connector/jdbc]Add mariadb jdbc connection validation

bzhaoopenstack opened a new pull request, #20193: URL: https://github.com/apache/flink/pull/20193 Flink Connector support the jdbc connection with Mysql series DB, such as MySQL, MariaDB, Percona and etc. But we see the doc reference[1] shows the Mariadb Connector/J 3.0 will accepts j

[jira] [Updated] (FLINK-28433) Allow connection to mysql through mariadb driver

[ https://issues.apache.org/jira/browse/FLINK-28433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28433: --- Labels: pull-request-available (was: ) > Allow connection to mysql through mariadb driver >

[GitHub] [flink] pengmide opened a new pull request, #20194: [FLINK-28140][python][docs] Improve the documentation by adding Python examples

pengmide opened a new pull request, #20194: URL: https://github.com/apache/flink/pull/20194 ## What is the purpose of the change Improve the documentation by adding Python examples. ## Brief change log - Improve the Time Attributes of Table api documentation by adding P

[GitHub] [flink] Devinaille opened a new pull request, #20195: Table API 查询，select字段修改

Devinaille opened a new pull request, #20195: URL: https://github.com/apache/flink/pull/20195 sum对象只能对数字使用，原文中对country使用sum，这会产生错误，并且按照结果的意思是对revenue进行sum聚合 更改为revenue ## What is the purpose of the change *(For example: This pull request makes task deployment go throu

[GitHub] [flink] pengmide commented on pull request #20194: [FLINK-28140][python][docs] Improve the documentation by adding Python examples

pengmide commented on PR #20194: URL: https://github.com/apache/flink/pull/20194#issuecomment-1177186921 @dianfu Time Attributes of Table api Chinese documentation is out of date, could i fix this in next PR? -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot commented on pull request #20193: [FLINK-28433][connector/jdbc]Add mariadb jdbc connection validation

flinkbot commented on PR #20193: URL: https://github.com/apache/flink/pull/20193#issuecomment-1177188510 ## CI report: * deb8d27f47c263fae38e578e254a432b3d94d343 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] pengmide commented on a diff in pull request #20120: [FLINK-27964][python] Support Cassandra connector in Python DataStream API

pengmide commented on code in PR #20120: URL: https://github.com/apache/flink/pull/20120#discussion_r915548401 ## flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/SimpleClusterBuilder.java: ## @@ -0,0 +1,338 @@ +/* + * Lice

[GitHub] [flink] PatrickRen opened a new pull request, #20196: [FLINK-28417][table] Add interfaces for LookupCache and default implementation

PatrickRen opened a new pull request, #20196: URL: https://github.com/apache/flink/pull/20196 ## What is the purpose of the change This pull request introduces interfaces for LookupCache and CacheMetricGroup, also a default implementation of LookupCache. ## Brief change log

[jira] [Updated] (FLINK-28417) Add interface and default implementation for cache in lookup table

[ https://issues.apache.org/jira/browse/FLINK-28417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28417: --- Labels: pull-request-available (was: ) > Add interface and default implementation for cache

[GitHub] [flink] pengmide commented on a diff in pull request #20120: [FLINK-27964][python] Support Cassandra connector in Python DataStream API

pengmide commented on code in PR #20120: URL: https://github.com/apache/flink/pull/20120#discussion_r915551455 ## flink-python/pyflink/datastream/connectors/cassandra.py: ## @@ -126,14 +132,340 @@ def if_not_exists(self, enabled: bool) -> 'MapperOptions': return self

[GitHub] [flink] flinkbot commented on pull request #20194: [FLINK-28140][python][docs] Improve the documentation by adding Python examples

flinkbot commented on PR #20194: URL: https://github.com/apache/flink/pull/20194#issuecomment-1177195978 ## CI report: * 3c330f2b72b5bc15a251a8676ec97d00f6f913d2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #20195: Table API 查询，select字段修改

flinkbot commented on PR #20195: URL: https://github.com/apache/flink/pull/20195#issuecomment-1177196682 ## CI report: * 09302c7775d974a266fbf60b8dcb7589217fe8c9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] suxinglee commented on pull request #20134: [FLINK-28353][k8s] Exclude unschedulable nodes using IP addresses of kubernetes nodes

suxinglee commented on PR #20134: URL: https://github.com/apache/flink/pull/20134#issuecomment-1177198751 Please help to take a review when you are free @wangyang0918 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [flink] Peng-Lei commented on pull request #20193: [FLINK-28433][connector/jdbc]Add mariadb jdbc connection validation

Peng-Lei commented on PR #20193: URL: https://github.com/apache/flink/pull/20193#issuecomment-1177205191 +1， After the change. We can use mariadb driver to connect the mysql through by setting the jdbcOptions of `driver` parameter without change the url prefix. -- This is an automated mes

[GitHub] [flink] rkhachatryan commented on a diff in pull request #20091: [FLINK-27570][runtime] Fix initialize base locations for checkpoint

rkhachatryan commented on code in PR #20091: URL: https://github.com/apache/flink/pull/20091#discussion_r915560439 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStorageAccess.java: ## @@ -113,8 +113,14 @@ public boolean supportsHighlyAvaila

[GitHub] [flink] flinkbot commented on pull request #20196: [FLINK-28417][table] Add interfaces for LookupCache and default implementation

flinkbot commented on PR #20196: URL: https://github.com/apache/flink/pull/20196#issuecomment-1177205928 ## CI report: * dd5d10df1abeba770807ea291f5c96901ac7fe55 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] reswqa commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

reswqa commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r915563903 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsResultPartitionReadSchedulerTest.java: ## @@ -0,0 +1,403 @@ +/* + * Licensed to the

[GitHub] [flink] xintongsong commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

xintongsong commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r915516805 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderTest.java: ## @@ -0,0 +1,418 @@ +/* + * Licensed to the A

[jira] [Assigned] (FLINK-28297) Incorrect metric group order for namespaced operator metrics

[ https://issues.apache.org/jira/browse/FLINK-28297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-28297: -- Assignee: Gyula Fora (was: Matyas Orhidi) > Incorrect metric group order for namespaced oper

[jira] [Created] (FLINK-28437) Document Engine Matrix and Build page

Jingsong Lee created FLINK-28437: Summary: Document Engine Matrix and Build page Key: FLINK-28437 URL: https://issues.apache.org/jira/browse/FLINK-28437 Project: Flink Issue Type: Improvement

[GitHub] [flink-table-store] JingsongLi merged pull request #201: [FLINK-28384][hive] Add CatalogLock support for HiveCatalog in table store

JingsongLi merged PR #201: URL: https://github.com/apache/flink-table-store/pull/201 -- 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] [Closed] (FLINK-28384) Add CatalogLock support for HiveCatalog in table store

[ https://issues.apache.org/jira/browse/FLINK-28384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28384. Resolution: Fixed master: 7c6ddd6ec19a1a232450a2f604fd6df8d1144f82 > Add CatalogLock support for

[jira] [Commented] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563616#comment-17563616 ] Yordan Pavlov commented on FLINK-16419: --- [~martijnvisser]  I am still seeing the i

[jira] [Created] (FLINK-28438) We should clear the error message after the session job is running/finished

Xin Hao created FLINK-28438: --- Summary: We should clear the error message after the session job is running/finished Key: FLINK-28438 URL: https://issues.apache.org/jira/browse/FLINK-28438 Project: Flink

[jira] [Commented] (FLINK-28398) CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest( gets stuck

[ https://issues.apache.org/jira/browse/FLINK-28398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563625#comment-17563625 ] Chesnay Schepler commented on FLINK-28398: -- [~gaoyunhaii] Do you have some thou

[GitHub] [flink] pnowojski merged pull request #20158: [FLINK-28357][datastream] Disallow null elements in StreamNode#typeSerializersIn

pnowojski merged PR #20158: URL: https://github.com/apache/flink/pull/20158 -- 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.apa

[GitHub] [flink] pnowojski opened a new pull request, #20197: [FLINK-28357][datastream] Disallow null elements in StreamNode#typeSerializersIn (1.14)

pnowojski opened a new pull request, #20197: URL: https://github.com/apache/flink/pull/20197 This is 1.14 backport of https://github.com/apache/flink/pull/20158 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #300: [FLINK-28438] Clear error if session job is running or finished

gyfora commented on PR #300: URL: https://github.com/apache/flink-kubernetes-operator/pull/300#issuecomment-1177237016 Please provide a clear description of the problem in the JIRA ticket and an overview of your solution in the PR description. We cannot review it until then -- Thi

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #299: [FLINK-28356] Move operator metric recording logic into statusrecorder

gyfora merged PR #299: URL: https://github.com/apache/flink-kubernetes-operator/pull/299 -- 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] [Updated] (FLINK-28438) We should clear the error message after the session job is running/finished

[ https://issues.apache.org/jira/browse/FLINK-28438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28438: --- Labels: pull-request-available (was: ) > We should clear the error message after the sessio

[jira] [Assigned] (FLINK-28200) Add Table Store Hive reader documentation

[ https://issues.apache.org/jira/browse/FLINK-28200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28200: Assignee: Caizhi Weng > Add Table Store Hive reader documentation > -

[jira] [Closed] (FLINK-28356) Move operator metric recording logic into statusrecorder

[ https://issues.apache.org/jira/browse/FLINK-28356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-28356. -- Resolution: Fixed merged to main 2adf8f6188c86759caa27d1c10ed9d74ed3a1006 > Move operator metric reco

[jira] [Updated] (FLINK-27739) Add benchmark module for table store

[ https://issues.apache.org/jira/browse/FLINK-27739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-27739: - Fix Version/s: table-store-0.2.0 > Add benchmark module for table store > --

[GitHub] [flink] reswqa commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

reswqa commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r915597495 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderTest.java: ## @@ -0,0 +1,418 @@ +/* + * Licensed to the Apache

[GitHub] [flink] swuferhong commented on pull request #20007: [FLINK-27989][table-planner] Csv format supports reporting statistics

swuferhong commented on PR #20007: URL: https://github.com/apache/flink/pull/20007#issuecomment-1177244677 @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

[GitHub] [flink] swuferhong commented on pull request #20008: [FLINK-27990][table-planner] Parquet format supports reporting statis…

swuferhong commented on PR #20008: URL: https://github.com/apache/flink/pull/20008#issuecomment-1177244990 @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

[GitHub] [flink] reswqa commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

reswqa commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r915601498 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderTest.java: ## @@ -0,0 +1,418 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot commented on pull request #20197: [FLINK-28357][datastream] Disallow null elements in StreamNode#typeSerializersIn (1.14)

flinkbot commented on PR #20197: URL: https://github.com/apache/flink/pull/20197#issuecomment-1177247586 ## CI report: * 25de16478dab0373a210e76e8facd9567e9ff1c2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] reswqa commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

reswqa commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r915606824 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderTest.java: ## @@ -0,0 +1,418 @@ +/* + * Licensed to the Apache

[GitHub] [flink] Vancior opened a new pull request, #20198: [FLINK-28413][python][format] Support ParquetColumnarRowInputFormat

Vancior opened a new pull request, #20198: URL: https://github.com/apache/flink/pull/20198 ## What is the purpose of the change This PR supports reading parquet columnar format in PyFlink. ## Brief change log - introduce ParquetColumnarRowInputFormat class in Pyth

[jira] [Updated] (FLINK-28413) Support ParquetColumnarRowInputFormat in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-28413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28413: --- Labels: pull-request-available (was: ) > Support ParquetColumnarRowInputFormat in PyFlink >

[jira] [Commented] (FLINK-28338) org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParseException: Invalid numeric value: Leading zeroes not allowed

[ https://issues.apache.org/jira/browse/FLINK-28338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563640#comment-17563640 ] wangkang commented on FLINK-28338: -- filnkSql.I'm really sorry for my slow reply~ > org

[jira] [Updated] (FLINK-28438) We should clear the error message after the session job is running/finished

[ https://issues.apache.org/jira/browse/FLINK-28438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Hao updated FLINK-28438: Description: Once there is an error occurs, the error filed will contain the message even if the job are

[GitHub] [flink] flinkbot commented on pull request #20198: [FLINK-28413][python][format] Support ParquetColumnarRowInputFormat

flinkbot commented on PR #20198: URL: https://github.com/apache/flink/pull/20198#issuecomment-1177269224 ## CI report: * 6b14b962035141fc75fa90686d1f29c3204a9898 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28438) We should clear the error message after the session job is running/finished

[ https://issues.apache.org/jira/browse/FLINK-28438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Hao updated FLINK-28438: Description: Once an error occurs, the error filed will contain the message even if the job is running su

[GitHub] [flink] pnowojski commented on a diff in pull request #20197: [FLINK-28357][datastream] Disallow null elements in StreamNode#typeSerializersIn (1.14)

pnowojski commented on code in PR #20197: URL: https://github.com/apache/flink/pull/20197#discussion_r915626510 ## flink-tests/src/test/java/org/apache/flink/test/streaming/api/datastream/FinishedSourcesWatermarkITCase.java: ## @@ -0,0 +1,143 @@ +/* + * Licensed to the Apache So

[GitHub] [flink-table-store] tsreaper opened a new pull request, #204: [hotfix] CommitterOperator#endInput should also commit snapshots for batch jobs even if checkpoint interval is set

tsreaper opened a new pull request, #204: URL: https://github.com/apache/flink-table-store/pull/204 Current implementation of `CommitterOperator#endInput` only checks for checkpoint interval but forgets to check if this job is also a batch job. This PR fixes this issue. -- This is an aut

[GitHub] [flink] swuferhong commented on a diff in pull request #20009: [FLINK-27991][table-planner] ORC format supports reporting statistics

swuferhong commented on code in PR #20009: URL: https://github.com/apache/flink/pull/20009#discussion_r915632151 ## flink-formats/flink-orc/src/test/java/org/apache/flink/orc/OrcFileSystemStatisticsReportTest.java: ## @@ -0,0 +1,238 @@ +/* + * Licensed to the Apache Software Fou

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #204: [hotfix] CommitterOperator#endInput should also commit snapshots for batch jobs even if checkpoint interval is set

JingsongLi commented on code in PR #204: URL: https://github.com/apache/flink-table-store/pull/204#discussion_r915632540 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreSink.java: ## @@ -124,7 +124,7 @@ public DataStreamSink sinkTo(D

[jira] [Created] (FLINK-28439) Support SUBSTR and REGEXP built-in function in Table API

LuNing Wang created FLINK-28439: --- Summary: Support SUBSTR and REGEXP built-in function in Table API Key: FLINK-28439 URL: https://issues.apache.org/jira/browse/FLINK-28439 Project: Flink Issue

[jira] [Commented] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563647#comment-17563647 ] Huang Xingbo commented on FLINK-25813: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Updated] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-25813: - Affects Version/s: 1.16.0 > TableITCase.testCollectWithClose failed on azure > -

[GitHub] [flink-kubernetes-operator] haoxins commented on pull request #300: [FLINK-28438] Clear the previous error if session job is running or finished

haoxins commented on PR #300: URL: https://github.com/apache/flink-kubernetes-operator/pull/300#issuecomment-1177292637 > Please provide a clear description of the problem in the JIRA ticket and an overview of your solution in the PR description. > > We cannot review it until then

[GitHub] [flink] akalash commented on a diff in pull request #19864: [FLINK-27162][runtime] Trigger non-periodic checkpoint in 'timer' thread

akalash commented on code in PR #19864: URL: https://github.com/apache/flink/pull/19864#discussion_r915648538 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java: ## @@ -286,7 +286,7 @@ CompletableFuture triggerCheckpoint() {

[jira] [Commented] (FLINK-26912) EventTimeWindowCheckpointingITCase.testTumblingTimeWindow failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563648#comment-17563648 ] Huang Xingbo commented on FLINK-26912: -- https://dev.azure.com/apache-flink/apache-f

[jira] (FLINK-26912) EventTimeWindowCheckpointingITCase.testTumblingTimeWindow failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26912 ] Huang Xingbo deleted comment on FLINK-26912: -- was (Author: hxbks2ks): https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=37772&view=logs&j=4d4a0d10-fca2-5507-8eed-c07f0bd

[GitHub] [flink] akalash commented on a diff in pull request #19864: [FLINK-27162][runtime] Trigger non-periodic checkpoint in 'timer' thread

akalash commented on code in PR #19864: URL: https://github.com/apache/flink/pull/19864#discussion_r915654734 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java: ## @@ -493,6 +498,15 @@ private CompletableFuture triggerSavepointInterna

[GitHub] [flink-table-store] tsreaper opened a new pull request, #205: [FLINK-28200] Add table store Hive reader documentation

tsreaper opened a new pull request, #205: URL: https://github.com/apache/flink-table-store/pull/205 This PR adds documentation for table store Hive reader. -- 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

[jira] [Updated] (FLINK-28200) Add Table Store Hive reader documentation

[ https://issues.apache.org/jira/browse/FLINK-28200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28200: --- Labels: pull-request-available (was: ) > Add Table Store Hive reader documentation > --

[jira] [Created] (FLINK-28440) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed with restore

Huang Xingbo created FLINK-28440: Summary: EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed with restore Key: FLINK-28440 URL: https://issues.apache.org/jira/browse/FLINK-28440 Project:

[jira] [Updated] (FLINK-28440) EventTimeWindowCheckpointingITCase.testSlidingTimeWindow failed with restore

[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28440: - Labels: test-stability (was: ) > EventTimeWindowCheckpointingITCase.testSlidingTimeWindow faile

[jira] [Created] (FLINK-28441) The parsing result of configuration `pipeline.cached-files` is incorrect

xiaozilong created FLINK-28441: -- Summary: The parsing result of configuration `pipeline.cached-files` is incorrect Key: FLINK-28441 URL: https://issues.apache.org/jira/browse/FLINK-28441 Project: Flink

[jira] [Commented] (FLINK-26456) StreamExecutionEnvironmentTests::test_add_python_file failed with ModuleNotFoundError

[ https://issues.apache.org/jira/browse/FLINK-26456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563657#comment-17563657 ] Huang Xingbo commented on FLINK-26456: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Created] (FLINK-28442) SplitGenerator should use Ordered Packing

Jingsong Lee created FLINK-28442: Summary: SplitGenerator should use Ordered Packing Key: FLINK-28442 URL: https://issues.apache.org/jira/browse/FLINK-28442 Project: Flink Issue Type: Improve

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #206: [FLINK-28442] SplitGenerator should use Ordered Packing

JingsongLi opened a new pull request, #206: URL: https://github.com/apache/flink-table-store/pull/206 SplitGenerator should use Ordered Packing - The full part data in the stream is consumed in an orderly way - Ordered batch reads can make subsequent calculations more efficient, suc

[GitHub] [flink] rkhachatryan commented on a diff in pull request #19864: [FLINK-27162][runtime] Trigger non-periodic checkpoint in 'timer' thread

rkhachatryan commented on code in PR #19864: URL: https://github.com/apache/flink/pull/19864#discussion_r915666243 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java: ## @@ -493,6 +498,15 @@ private CompletableFuture triggerSavepointIn

[jira] [Updated] (FLINK-28442) SplitGenerator should use Ordered Packing

[ https://issues.apache.org/jira/browse/FLINK-28442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28442: --- Labels: pull-request-available (was: ) > SplitGenerator should use Ordered Packing > --

[GitHub] [flink-table-store] JingsongLi merged pull request #202: [FLINK-28110] Support projection pushdown for Hive readers

JingsongLi merged PR #202: URL: https://github.com/apache/flink-table-store/pull/202 -- 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] [Closed] (FLINK-28110) Table Store Hive Reader supports projection pushdown

[ https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28110. Resolution: Fixed master: 952b62a794928391f00f98218f5fab86b6bf5ee2 > Table Store Hive Reader supp

[GitHub] [flink-table-store] JingsongLi merged pull request #204: [hotfix] CommitterOperator#endInput should also commit snapshots for batch jobs even if checkpoint interval is set

JingsongLi merged PR #204: URL: https://github.com/apache/flink-table-store/pull/204 -- 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...@

[GitHub] [flink] swuferhong commented on pull request #20008: [FLINK-27990][table-planner] Parquet format supports reporting statis…

swuferhong commented on PR #20008: URL: https://github.com/apache/flink/pull/20008#issuecomment-1177315980 @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] [Created] (FLINK-28443) Provide official Flink image for PyFlink

Xuannan Su created FLINK-28443: -- Summary: Provide official Flink image for PyFlink Key: FLINK-28443 URL: https://issues.apache.org/jira/browse/FLINK-28443 Project: Flink Issue Type: Improvement

[GitHub] [flink] reswqa commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

reswqa commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r915677727 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderTest.java: ## @@ -0,0 +1,418 @@ +/* + * Licensed to the Apache

[GitHub] [flink] reswqa commented on a diff in pull request #19960: [FLINK-27907][runtime] implement disk read and write logic for hybrid shuffle

reswqa commented on code in PR #19960: URL: https://github.com/apache/flink/pull/19960#discussion_r915677727 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderTest.java: ## @@ -0,0 +1,418 @@ +/* + * Licensed to the Apache

[jira] [Created] (FLINK-28444) Support SUBSTR without parameter in SQL and Table API

LuNing Wang created FLINK-28444: --- Summary: Support SUBSTR without parameter in SQL and Table API Key: FLINK-28444 URL: https://issues.apache.org/jira/browse/FLINK-28444 Project: Flink Issue Typ

[jira] [Commented] (FLINK-28444) Support SUBSTR without parameter in SQL and Table API

[ https://issues.apache.org/jira/browse/FLINK-28444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563662#comment-17563662 ] LuNing Wang commented on FLINK-28444: - I would like to take this. > Support SUBSTR

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #205: [FLINK-28200] Add table store Hive reader documentation

JingsongLi commented on code in PR #205: URL: https://github.com/apache/flink-table-store/pull/205#discussion_r915680437 ## docs/content/docs/engines/hive.md: ## @@ -0,0 +1,155 @@ +--- +title: "Hive" +weight: 2 +type: docs +aliases: +- /engines/hive.html +--- + + +# Hive + +Tabl

[jira] [Updated] (FLINK-28444) Support SUBSTR without parameter in SQL and Table API

[ https://issues.apache.org/jira/browse/FLINK-28444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] LuNing Wang updated FLINK-28444: Description: SUBSTR() has no parameter functionality in the doc, but the code only supports SUBST

[jira] [Created] (FLINK-28445) Support dynamic configurations

Matyas Orhidi created FLINK-28445: - Summary: Support dynamic configurations Key: FLINK-28445 URL: https://issues.apache.org/jira/browse/FLINK-28445 Project: Flink Issue Type: New Feature

[GitHub] [flink-table-store] tsreaper commented on a diff in pull request #203: [FLINK-28437] Document Engine Matrix and Build page

tsreaper commented on code in PR #203: URL: https://github.com/apache/flink-table-store/pull/203#discussion_r915685924 ## docs/content/docs/development/write-table.md: ## @@ -186,9 +186,8 @@ The following parameters determine when to stop writing: ## Memory There are three m

[jira] [Updated] (FLINK-28437) Document Engine Matrix and Build page

[ https://issues.apache.org/jira/browse/FLINK-28437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28437: --- Labels: pull-request-available (was: ) > Document Engine Matrix and Build page > --

[jira] [Created] (FLINK-28446) Expose more information in PartitionDescriptor to support more optimized Shuffle Service

Yuxin Tan created FLINK-28446: - Summary: Expose more information in PartitionDescriptor to support more optimized Shuffle Service Key: FLINK-28446 URL: https://issues.apache.org/jira/browse/FLINK-28446 Pr

[GitHub] [flink] wingwuyao opened a new pull request, #20199: Update and rename docs/content/docs/dev/datastream/event-time/generat…

wingwuyao opened a new pull request, #20199: URL: https://github.com/apache/flink/pull/20199 …ing_watermarks.md to docs /content /docs /dev /datastream /event-time /generating_watermarks.md There seems to be a problem with the spelling of 'punctuated', fix that ## What

[GitHub] [flink] swuferhong commented on pull request #20007: [FLINK-27989][table-planner] Csv format supports reporting statistics

swuferhong commented on PR #20007: URL: https://github.com/apache/flink/pull/20007#issuecomment-1177355620 @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] [Assigned] (FLINK-28445) Support operator configuration from multiple configmaps

[ https://issues.apache.org/jira/browse/FLINK-28445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-28445: -- Assignee: Matyas Orhidi > Support operator configuration from multiple configmaps > -

[GitHub] [flink] flinkbot commented on pull request #20199: Update and rename docs/content/docs/dev/datastream/event-time/generat…

flinkbot commented on PR #20199: URL: https://github.com/apache/flink/pull/20199#issuecomment-1177357458 ## CI report: * 3a42d872ec5fb5ac6d9f74b2962bf69953fa337f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28445) Support operator configuration from multiple configmaps

[ https://issues.apache.org/jira/browse/FLINK-28445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-28445: --- Summary: Support operator configuration from multiple configmaps (was: Support dynamic configuratio

[jira] [Updated] (FLINK-28435) Flink version 1.15.0 consumption Kafka has backpressure.

[ https://issues.apache.org/jira/browse/FLINK-28435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28435: --- Component/s: Connectors / Kafka > Flink version 1.15.0 consumption Kafka has backpressure.

[GitHub] [flink] snuyanzin commented on pull request #19623: [FLINK-27471][table] Add ARRAY_DISTINCT function

snuyanzin commented on PR #19623: URL: https://github.com/apache/flink/pull/19623#issuecomment-1177360455 @dianfu since you merged recently several functions, could you please have a look here? -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-28435) Flink version 1.15.0 consumption Kafka has backpressure.

[ https://issues.apache.org/jira/browse/FLINK-28435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563667#comment-17563667 ] Martijn Visser commented on FLINK-28435: [~HunterHunter] There have been more ch

[jira] [Assigned] (FLINK-28433) Allow connection to mysql through mariadb driver

[ https://issues.apache.org/jira/browse/FLINK-28433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-28433: -- Assignee: bo zhao > Allow connection to mysql through mariadb driver > --

[GitHub] [flink] luoyuxia commented on pull request #19283: [FLINK-27016][hive] Improve supporting for complex data type for Hive dialect

luoyuxia commented on PR #19283: URL: https://github.com/apache/flink/pull/19283#issuecomment-1177364588 @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.

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #203: [FLINK-28437] Document Engine Matrix and Build page

JingsongLi commented on code in PR #203: URL: https://github.com/apache/flink-table-store/pull/203#discussion_r915714640 ## docs/content/docs/engines/build.md: ## @@ -0,0 +1,63 @@ +--- +title: "Build" +weight: 2 +type: docs +aliases: +- /engines/build.html +--- + + +# Build + +I

  1   2   3   4   5   >