[jira] [Assigned] (FLINK-30814) The parallelism&maxParallelism of sort after a global partitioning is not forced to be 1

[ https://issues.apache.org/jira/browse/FLINK-30814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30814: -- Assignee: Godfrey He > The parallelism&maxParallelism of sort after a global partitioning is

[jira] [Commented] (FLINK-30814) The parallelism&maxParallelism of sort after a global partitioning is not forced to be 1

[ https://issues.apache.org/jira/browse/FLINK-30814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681693#comment-17681693 ] Godfrey He commented on FLINK-30814: [~zhuzh] thanks for reporting this issue. Curr

[GitHub] [flink] luoyuxia commented on a diff in pull request #21698: [FLINK-30665][table] Planner supports row-level update

luoyuxia commented on code in PR #21698: URL: https://github.com/apache/flink/pull/21698#discussion_r1089889731 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/utils/SqlToOperationConverterTestUtils.java: ## @@ -0,0 +1,107 @@ +/* + * Licensed to t

[GitHub] [flink] ifndef-SleePy commented on pull request #21773: [FLINK-30799][runtime] Make SinkFunction support speculative execution for batch jobs

ifndef-SleePy commented on PR #21773: URL: https://github.com/apache/flink/pull/21773#issuecomment-1407586058 @zhuzhurk Thanks for reviewing! I have addressed the comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[jira] [Assigned] (FLINK-30477) Not properly blocking retries when timeout occurs in AsyncWaitOperator

[ https://issues.apache.org/jira/browse/FLINK-30477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-30477: --- Assignee: lincoln lee > Not properly blocking retries when timeout occurs in AsyncWaitOpera

[jira] [Updated] (FLINK-30799) Make SinkFunction support speculative execution for batch jobs

[ https://issues.apache.org/jira/browse/FLINK-30799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30799: --- Labels: pull-request-available (was: ) > Make SinkFunction support speculative execution fo

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21773: [FLINK-30799][runtime] Make SinkFunction support speculative execution for batch jobs

zhuzhurk commented on code in PR #21773: URL: https://github.com/apache/flink/pull/21773#discussion_r1089880149 ## flink-tests/src/test/java/org/apache/flink/test/scheduling/SpeculativeSchedulerITCase.java: ## @@ -184,6 +185,23 @@ public void testSpeculativeSlowSink() throws Exc

[jira] [Closed] (FLINK-30192) Update python-dateutil from 2.8.0 to 2.8.2

[ https://issues.apache.org/jira/browse/FLINK-30192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-30192. --- Fix Version/s: FLINK-25874 Resolution: Duplicate The version of python-dateutil has been bumped to 2.

[jira] [Updated] (FLINK-30192) Update python-dateutil from 2.8.0 to 2.8.2

[ https://issues.apache.org/jira/browse/FLINK-30192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-30192: Fix Version/s: (was: FLINK-25874) > Update python-dateutil from 2.8.0 to 2.8.2 > -

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089876108 ## flink-core/src/test/java/org/apache/flink/api/common/ExecutionConfigTest.java: ## @@ -67,37 +61,37 @@ public void testDoubleTypeRegistration() { int counte

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089876108 ## flink-core/src/test/java/org/apache/flink/api/common/ExecutionConfigTest.java: ## @@ -67,37 +61,37 @@ public void testDoubleTypeRegistration() { int counte

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089877362 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/DynamicFilteringITCase.java: ## @@ -48,9 +48,7 @@ public class Dynami

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089876108 ## flink-core/src/test/java/org/apache/flink/api/common/ExecutionConfigTest.java: ## @@ -67,37 +61,37 @@ public void testDoubleTypeRegistration() { int counte

[GitHub] [flink-table-store] zhangjun0x01 commented on a diff in pull request #471: [FLINK-30608] support rename table

zhangjun0x01 commented on code in PR #471: URL: https://github.com/apache/flink-table-store/pull/471#discussion_r1089874987 ## flink-table-store-hive/flink-table-store-hive-catalog/src/test/java/org/apache/flink/table/store/hive/HiveCatalogITCase.java: ## @@ -276,6 +279,36 @@ pu

[jira] [Closed] (FLINK-30752) Support 'EXPLAIN PLAN_ADVICE' statement in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-30752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-30752. --- Assignee: Jane Chan Resolution: Fixed Merged to master via d2710743eb55e76e0e8d1fe8a5c0d6d791147c56 >

[GitHub] [flink] dianfu closed pull request #21727: [FLINK-30752][python] Support 'EXPLAIN PLAN_ADVICE' statement in PyFlink

dianfu closed pull request #21727: [FLINK-30752][python] Support 'EXPLAIN PLAN_ADVICE' statement in PyFlink URL: https://github.com/apache/flink/pull/21727 -- 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

[jira] [Closed] (FLINK-25874) PyFlink package dependencies conflict

[ https://issues.apache.org/jira/browse/FLINK-25874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-25874. --- Fix Version/s: 1.17.0 1.16.2 Resolution: Fixed Merged to - master via 647f0b29768

[GitHub] [flink] lincoln-lil commented on pull request #21704: [FLINK-29558][table-planner] Fix projection pushdown rule select nothing from source when no column is needed logically

lincoln-lil commented on PR #21704: URL: https://github.com/apache/flink/pull/21704#issuecomment-1407572221 @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 commen

[jira] [Reopened] (FLINK-25874) PyFlink package dependencies conflict

[ https://issues.apache.org/jira/browse/FLINK-25874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reopened FLINK-25874: - > PyFlink package dependencies conflict > - > > Key: FLI

[GitHub] [flink] dianfu commented on pull request #18561: [FLINK-25874] loose PyFlink dependency of 'python-dateutil' to '>=2.8.0,<3'

dianfu commented on PR #18561: URL: https://github.com/apache/flink/pull/18561#issuecomment-1407571369 Very sorry for the late response. 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

[GitHub] [flink] dianfu closed pull request #18561: [FLINK-25874] loose PyFlink dependency of 'python-dateutil' to '>=2.8.0,<3'

dianfu closed pull request #18561: [FLINK-25874] loose PyFlink dependency of 'python-dateutil' to '>=2.8.0,<3' URL: https://github.com/apache/flink/pull/18561 -- 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] [Commented] (FLINK-29558) Use select count(*) from xxx; and get SQL syntax

[ https://issues.apache.org/jira/browse/FLINK-29558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681683#comment-17681683 ] lincoln lee commented on FLINK-29558: - After discussed with [~godfreyhe], the proble

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089864450 ## flink-core/src/test/java/org/apache/flink/api/common/ExecutionConfigTest.java: ## @@ -297,7 +294,7 @@ private void testLoadingSchedulerTypeFromConfiguration(

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089864919 ## flink-core/src/test/java/org/apache/flink/api/common/ExecutionConfigTest.java: ## @@ -44,13 +44,10 @@ import java.util.List; import java.util.Random; -import st

[jira] [Updated] (FLINK-30815) BatchTestBase/BatchAbstractTestBase are using JUnit4 while some child tests are using JUnit5

[ https://issues.apache.org/jira/browse/FLINK-30815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30815: Summary: BatchTestBase/BatchAbstractTestBase are using JUnit4 while some child tests are using JUnit5 (wa

[jira] [Created] (FLINK-30815) BatchTestBase/BatchAbstractTestBase are using Junit4 while some child tests are using JUnit5

Zhu Zhu created FLINK-30815: --- Summary: BatchTestBase/BatchAbstractTestBase are using Junit4 while some child tests are using JUnit5 Key: FLINK-30815 URL: https://issues.apache.org/jira/browse/FLINK-30815 Pr

[jira] [Updated] (FLINK-30752) Support 'EXPLAIN PLAN_ADVICE' statement in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-30752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-30752: -- Priority: Major (was: Not a Priority) > Support 'EXPLAIN PLAN_ADVICE' statement in PyFlink >

[jira] [Resolved] (FLINK-29751) Introduce Client Result to wrap the ResultSet returned by SQL Gateway

[ https://issues.apache.org/jira/browse/FLINK-29751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang resolved FLINK-29751. --- Resolution: Resolved > Introduce Client Result to wrap the ResultSet returned by SQL Gateway

[jira] [Closed] (FLINK-29945) Supports to submit SQL to a embedded SQL Gateway in the SQL Client

[ https://issues.apache.org/jira/browse/FLINK-29945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-29945. - Resolution: Implemented > Supports to submit SQL to a embedded SQL Gateway in the SQL Client > -

[jira] [Commented] (FLINK-29945) Supports to submit SQL to a embedded SQL Gateway in the SQL Client

[ https://issues.apache.org/jira/browse/FLINK-29945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681673#comment-17681673 ] Shengkai Fang commented on FLINK-29945: --- Merged into master: 1534ea751613772d93699

[GitHub] [flink] fsk119 merged pull request #21717: [FLINK-29945][sql-client] Supports to submit SQL to a embedded SQL Ga…

fsk119 merged PR #21717: URL: https://github.com/apache/flink/pull/21717 -- 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] alpinegizmo commented on pull request #20049: [FLINK-28046][connectors] Mark SourceFunction interface as @Deprecated

alpinegizmo commented on PR #20049: URL: https://github.com/apache/flink/pull/20049#issuecomment-1407553971 @afedulov I'm not a fan of the TopSpeedWindowing example -- it's not at all obvious what it's doing. I do like that it's a decent example of how to use the FileSource and FileSink, bu

[GitHub] [flink] fsk119 commented on pull request #21717: [FLINK-29945][sql-client] Supports to submit SQL to a embedded SQL Ga…

fsk119 commented on PR #21717: URL: https://github.com/apache/flink/pull/21717#issuecomment-1407553872 Thanks for your patience and detailed tests! It's nice of you! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] TJX2014 commented on pull request #21761: [FLINK-30795][tests] StreamingWithStateTestBase of win not correct

TJX2014 commented on PR #21761: URL: https://github.com/apache/flink/pull/21761#issuecomment-1407553501 Hi @healchow @zentol , could you please review and merge this pr? the ci has passed. -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089859804 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/DefaultSlotPoolServiceSchedulerFactory.java: ## @@ -223,15 +223,15 @@ public static DefaultSlotPoolSe

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089860256 ## flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/DagOptimizationTest.xml: ## @@ -273,7 +273,7 @@ Calc(select=[a AS a

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089860256 ## flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/DagOptimizationTest.xml: ## @@ -273,7 +273,7 @@ Calc(select=[a AS a

[GitHub] [flink] ruanhang1993 commented on pull request #21589: [FLINK-25509][connector-base] Add RecordEvaluator to dynamically stop source based on de-serialized records

ruanhang1993 commented on PR #21589: URL: https://github.com/apache/flink/pull/21589#issuecomment-1407551827 @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 comme

[jira] [Updated] (FLINK-30684) Use the default parallelism as a flag for vertices that can automatically derive parallelism.

[ https://issues.apache.org/jira/browse/FLINK-30684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30684: --- Labels: pull-request-available (was: ) > Use the default parallelism as a flag for vertices

[GitHub] [flink] JunRuiLee commented on pull request #21772: [FLINK-30684][runtime] Use the default parallelism as a flag for vertices that can automatically derive parallelism.

JunRuiLee commented on PR #21772: URL: https://github.com/apache/flink/pull/21772#issuecomment-1407551721 @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] zjureel commented on a diff in pull request #480: [FLINK-27845] Support column type evolution for file data

zjureel commented on code in PR #480: URL: https://github.com/apache/flink-table-store/pull/480#discussion_r1089857616 ## flink-table-store-common/src/main/java/org/apache/flink/table/store/file/predicate/LeafPredicate.java: ## @@ -84,7 +99,10 @@ public List literals() {

[jira] [Updated] (FLINK-30814) The parallelism&maxParallelism of sort after a global partitioning is not forced to be 1

[ https://issues.apache.org/jira/browse/FLINK-30814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30814: Description: The parallelism&maxParallelism of sort after a global partitioning is not forced to be 1. The

[jira] [Updated] (FLINK-30814) The parallelism&maxParallelism of sort after a global partitioning is not forced to be 1

[ https://issues.apache.org/jira/browse/FLINK-30814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30814: Summary: The parallelism&maxParallelism of sort after a global partitioning is not forced to be 1 (was: T

[jira] [Created] (FLINK-30814) The parallelism&maxParallelism of sort after a global partitioning is forced to be 1

Zhu Zhu created FLINK-30814: --- Summary: The parallelism&maxParallelism of sort after a global partitioning is forced to be 1 Key: FLINK-30814 URL: https://issues.apache.org/jira/browse/FLINK-30814 Project: F

[jira] [Commented] (FLINK-30803) PyFlink mishandles script dependencies

[ https://issues.apache.org/jira/browse/FLINK-30803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681663#comment-17681663 ] Dian Fu commented on FLINK-30803: - [~nuafonso] Could you try if the following command wo

[GitHub] [flink] liming30 closed pull request #20405: [FLINK-28010][state] Use deleteRange to optimize the clear method of RocksDBMapState.

liming30 closed pull request #20405: [FLINK-28010][state] Use deleteRange to optimize the clear method of RocksDBMapState. URL: https://github.com/apache/flink/pull/20405 -- 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] lincoln-lil commented on a diff in pull request #21698: [FLINK-30665][table] Planner supports row-level update

lincoln-lil commented on code in PR #21698: URL: https://github.com/apache/flink/pull/21698#discussion_r1089853488 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/batch/sql/RowLevelUpdateTest.java: ## @@ -0,0 +1,149 @@ +/* + * Licensed to the

[GitHub] [flink-table-store] zjureel commented on a diff in pull request #480: [FLINK-27845] Support column type evolution for file data

zjureel commented on code in PR #480: URL: https://github.com/apache/flink-table-store/pull/480#discussion_r1089853994 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/casting/CastedRowData.java: ## @@ -0,0 +1,170 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [flink] wanglijie95 commented on a diff in pull request #21695: [FLINK-30707][runtime] Let speculative execution take input data amount into account when detecting slow tasks.

wanglijie95 commented on code in PR #21695: URL: https://github.com/apache/flink/pull/21695#discussion_r1089853063 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AllToAllBlockingResultInfo.java: ## @@ -81,6 +82,28 @@ public long getNumBytesProduc

[GitHub] [flink] flinkbot commented on pull request #21775: [FLINK-29878][hive] Include libfb303 to fix fail to use flink-sql-connector-hive-3.1.3

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

[GitHub] [flink] link3280 commented on pull request #21581: [FLINK-30538][SQL gateway/client] Improve error handling of stop job operation

link3280 commented on PR #21581: URL: https://github.com/apache/flink/pull/21581#issuecomment-1407542153 ping @fsk119 -- 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 un

[GitHub] [flink] luoyuxia opened a new pull request, #21775: [FLINK-29878][hive] Include libfb303 to fix fail to use flink-sql-connector-hive-3.1.3

luoyuxia opened a new pull request, #21775: URL: https://github.com/apache/flink/pull/21775 ## What is the purpose of the change To fix the class not found issue for flink hive3 connector ## Brief change log - include `org.apache.thrift:libfb303` in pom.xml ##

[jira] [Resolved] (FLINK-30034) class not found exception when using Hive 3.1.3 connector

[ https://issues.apache.org/jira/browse/FLINK-30034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-30034. -- Resolution: Duplicate > class not found exception when using Hive 3.1.3 connector > --

[GitHub] [flink] ifndef-SleePy commented on pull request #21773: [Flink-30799][runtime] Make SinkFunction support speculative execution for batch jobs

ifndef-SleePy commented on PR #21773: URL: https://github.com/apache/flink/pull/21773#issuecomment-1407540935 @zhuzhurk Please take a look when you have time. By the way, the failed test case seems unstable. I think it's not caused by this PR. -- This is an automated message from the A

[jira] [Commented] (FLINK-30034) class not found exception when using Hive 3.1.3 connector

[ https://issues.apache.org/jira/browse/FLINK-30034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681658#comment-17681658 ] luoyuxia commented on FLINK-30034: -- Miss to include it in FLINK-29878 > class not foun

[GitHub] [flink] dianfu commented on pull request #21727: [FLINK-30752][python] Support 'EXPLAIN PLAN_ADVICE' statement in PyFlink

dianfu commented on PR #21727: URL: https://github.com/apache/flink/pull/21727#issuecomment-1407540260 @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. T

[jira] [Updated] (FLINK-30637) In linux-aarch64 environment, using “is” judgment to match the window type of overwindow have returned incorrect matching results

[ https://issues.apache.org/jira/browse/FLINK-30637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-30637: Fix Version/s: 1.17.0 > In linux-aarch64 environment, using “is” judgment to match the window type of > o

[GitHub] [flink] luoyuxia commented on pull request #21731: [FLINK-30679][hive]Fix IndexOutOfBoundsException for Hive lookup join when column pushdown to Hive lookup table source

luoyuxia commented on PR #21731: URL: https://github.com/apache/flink/pull/21731#issuecomment-1407533209 The initial pr and comments is in #21668 -- 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

[GitHub] [flink] luoyuxia commented on pull request #21731: [FLINK-30679][hive]Fix IndexOutOfBoundsException for Hive lookup join when column pushdown to Hive lookup table source

luoyuxia commented on PR #21731: URL: https://github.com/apache/flink/pull/21731#issuecomment-1407532010 @hehuiyuan For test failure, you can pull the lastest master and rebase the master and try it again. -- This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] fsk119 commented on pull request #21717: [FLINK-29945][sql-client] Supports to submit SQL to a embedded SQL Ga…

fsk119 commented on PR #21717: URL: https://github.com/apache/flink/pull/21717#issuecomment-1407530104 @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-connector-jdbc] eskabetxe closed pull request #17: [FLINK-30790] Better performance on testing

eskabetxe closed pull request #17: [FLINK-30790] Better performance on testing URL: https://github.com/apache/flink-connector-jdbc/pull/17 -- 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

[jira] [Commented] (FLINK-30790) [Connectors/Jdbc] Refactor of testings

[ https://issues.apache.org/jira/browse/FLINK-30790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681643#comment-17681643 ] João Boto commented on FLINK-30790: --- h3. Change log level to off on CI This reduce th

[jira] [Updated] (FLINK-30790) [Connectors/Jdbc] Refactor of testings

[ https://issues.apache.org/jira/browse/FLINK-30790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto updated FLINK-30790: -- Description: This is one attempt to get better results executing tests on jdbc connector.. In current

[jira] [Updated] (FLINK-30790) [Connectors/Jdbc] Refactor of testings

[ https://issues.apache.org/jira/browse/FLINK-30790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] João Boto updated FLINK-30790: -- Description: This is one attempt to get better results executing tests on jdbc connector.. In current

[GitHub] [flink-connector-jdbc] eskabetxe opened a new pull request, #18: [FLINK-30790] Improve performance and extensibility in tests

eskabetxe opened a new pull request, #18: URL: https://github.com/apache/flink-connector-jdbc/pull/18 ## What is the purpose of the change Get better performance executing tests and set a easy way to extend a test to a new database ## Brief change log - Change log level

[GitHub] [flink] afedulov commented on pull request #20049: [FLINK-28046][connectors] Mark SourceFunction interface as @Deprecated

afedulov commented on PR #20049: URL: https://github.com/apache/flink/pull/20049#issuecomment-1407470640 @MartijnVisser https://github.com/apache/flink/pull/21774 @alpinegizmo While reworking the `TopSpeedWindowing` example I found it pretty convoluted. I believe we previously had di

[GitHub] [flink] flinkbot commented on pull request #21774: [FLINK-28227][connectors] Use new DataGeneratorSource instead of SourceFunction in examples

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

[jira] [Updated] (FLINK-28227) Add implementations for classes in o.a.f.streaming.examples based on the new new Source API

[ https://issues.apache.org/jira/browse/FLINK-28227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28227: --- Labels: pull-request-available (was: ) > Add implementations for classes in o.a.f.streaming

[GitHub] [flink] afedulov opened a new pull request, #21774: [FLINK-28227][connectors] Use new DataGeneratorSource instead of SourceFunction in examples

afedulov opened a new pull request, #21774: URL: https://github.com/apache/flink/pull/21774 ## What is the purpose of the change Migrates the existing examples to use the new `DataGeneratorSource` instead of `SourceFunction`. This change is required to unblock https://github.com/

[jira] [Updated] (FLINK-28227) Add implementations for classes in o.a.f.streaming.examples based on the new new Source API

[ https://issues.apache.org/jira/browse/FLINK-28227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28227: -- Component/s: Examples > Add implementations for classes in o.a.f.streaming.examples ba

[jira] [Commented] (FLINK-25874) PyFlink package dependencies conflict

[ https://issues.apache.org/jira/browse/FLINK-25874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681611#comment-17681611 ] Laurent commented on FLINK-25874: - The issue creates a conflict with `jupyter-client`, a

[GitHub] [flink] flinkbot commented on pull request #21773: [Flink-30799][runtime] Make SinkFunction support speculative execution for batch jobs

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

[GitHub] [flink] ifndef-SleePy opened a new pull request, #21773: [Flink-30799][runtime] Make SinkFunction support speculative execution for batch jobs

ifndef-SleePy opened a new pull request, #21773: URL: https://github.com/apache/flink/pull/21773 ## What is the purpose of the change *This pull request introduces a way to enable speculative execution for `SinkFunction`* ## Brief change log - *Speculative execution wo

[jira] (FLINK-30745) Check-pointing with Azure Data Lake Storage

[ https://issues.apache.org/jira/browse/FLINK-30745 ] Dheeraj Panangat deleted comment on FLINK-30745: -- was (Author: JIRAUSER297631): Hi [~surendralilhore] , Post configuring these properties, the check-pointing works, but the hudi-flink

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089772628 ## flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/join/SingleRowJoinTest.xml: ## @@ -237,20 +237,18 @@ LogicalProject

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089756452 ## flink-core/src/test/java/org/apache/flink/api/common/ExecutionConfigTest.java: ## @@ -282,23 +281,22 @@ public void testLoadingDefaultKryoSerializersFromConfigurat

[GitHub] [flink] flinkbot commented on pull request #21772: Flink 30684

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

[GitHub] [flink] JunRuiLee opened a new pull request, #21772: Flink 30684

JunRuiLee opened a new pull request, #21772: URL: https://github.com/apache/flink/pull/21772 ## What is the purpose of the change This change proposes to add a parallelismConfigured property as a flag to identify whether the parallelism of node is used "parallelism.default" or

[jira] [Updated] (FLINK-30807) State Processor API - Overwrite Support for Savepoints

[ https://issues.apache.org/jira/browse/FLINK-30807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rion Williams updated FLINK-30807: -- Description: Currently there is no overwrite support when using the State Processor API to cr

[jira] [Updated] (FLINK-30807) State Processor API - Overwrite Support for Savepoints

[ https://issues.apache.org/jira/browse/FLINK-30807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rion Williams updated FLINK-30807: -- Description: Currently there is no overwrite support when using the State Processor API to cr

[jira] [Commented] (FLINK-30811) Fix sql gateway can not stop job correctly

[ https://issues.apache.org/jira/browse/FLINK-30811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681582#comment-17681582 ] Jane Chan commented on FLINK-30811: --- I'd like to fix this issue, cc [~fsk119]  > Fix

[GitHub] [flink] swuferhong commented on pull request #21724: [FLINK-30727][table-planner] Fix JoinReorderITCaseBase.testBushyTreeJoinReorder failed

swuferhong commented on PR #21724: URL: https://github.com/apache/flink/pull/21724#issuecomment-1407376224 @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] tsreaper commented on a diff in pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

tsreaper commented on code in PR #21393: URL: https://github.com/apache/flink/pull/21393#discussion_r1089692781 ## flink-table/flink-table-code-splitter/src/main/java/org/apache/flink/table/codesplit/BlockStatementSplitter.java: ## @@ -0,0 +1,281 @@ +/* + * Licensed to the Apach

[jira] [Commented] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681561#comment-17681561 ] Jark Wu commented on FLINK-28897: - I reproduced this bug on the master branch. I think t

[GitHub] [flink] tsreaper commented on a diff in pull request #21759: [FLINK-29237][table] Remove RexSimplify from Flink code, SearchOperator code generation for RexUnknown.nullAs

tsreaper commented on code in PR #21759: URL: https://github.com/apache/flink/pull/21759#discussion_r1089701066 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/SearchOperatorGen.scala: ## @@ -97,6 +97,9 @@ object SearchOperatorGen {

[jira] [Comment Edited] (FLINK-22247) can not pass AddressList when connecting to rabbitmq

[ https://issues.apache.org/jira/browse/FLINK-22247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681558#comment-17681558 ] Gaurav Shah edited comment on FLINK-22247 at 1/28/23 10:27 AM: ---

[jira] [Updated] (FLINK-22247) can not pass AddressList when connecting to rabbitmq

[ https://issues.apache.org/jira/browse/FLINK-22247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gaurav Shah updated FLINK-22247: Attachment: added_support_for_multiple_addresses.patch > can not pass AddressList when connecting

[jira] [Commented] (FLINK-22247) can not pass AddressList when connecting to rabbitmq

[ https://issues.apache.org/jira/browse/FLINK-22247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17681558#comment-17681558 ] Gaurav Shah commented on FLINK-22247: - created a patch here [^added_support_for_mult

[jira] [Created] (FLINK-30813) Residual zk data when using the kubernetes session mode

liuzhuo created FLINK-30813: --- Summary: Residual zk data when using the kubernetes session mode Key: FLINK-30813 URL: https://issues.apache.org/jira/browse/FLINK-30813 Project: Flink Issue Type: Bug

[GitHub] [flink] LadyForest commented on a diff in pull request #21717: [FLINK-29945][sql-client] Supports to submit SQL to a embedded SQL Ga…

LadyForest commented on code in PR #21717: URL: https://github.com/apache/flink/pull/21717#discussion_r1089690301 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ExecutorImpl.java: ## @@ -0,0 +1,447 @@ +/* + * Licensed to the Apache Software F

[GitHub] [flink] tsreaper commented on a diff in pull request #21759: [FLINK-29237][table] Remove RexSimplify from Flink code, SearchOperator code generation for RexUnknown.nullAs

tsreaper commented on code in PR #21759: URL: https://github.com/apache/flink/pull/21759#discussion_r1089701341 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/SearchOperatorGen.scala: ## @@ -97,6 +97,9 @@ object SearchOperatorGen {

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089703394 ## flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResourceConfiguration.java: ## @@ -111,6 +112,11 @@ public Builder setNumberSlotsPerTaskMa

[jira] [Created] (FLINK-30812) YARN with S3 resource storage fails for Hadoop 3.3.2

Mate Czagany created FLINK-30812: Summary: YARN with S3 resource storage fails for Hadoop 3.3.2 Key: FLINK-30812 URL: https://issues.apache.org/jira/browse/FLINK-30812 Project: Flink Issue Ty

[GitHub] [flink] swuferhong commented on pull request #21724: [FLINK-30727][table-planner] Fix JoinReorderITCaseBase.testBushyTreeJoinReorder failed

swuferhong commented on PR #21724: URL: https://github.com/apache/flink/pull/21724#issuecomment-1407354297 > @flinkbot run azure The result of this round is: SUCCESS -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [flink] swuferhong commented on pull request #21724: [FLINK-30727][table-planner] Fix JoinReorderITCaseBase.testBushyTreeJoinReorder failed

swuferhong commented on PR #21724: URL: https://github.com/apache/flink/pull/21724#issuecomment-1407354065 @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] luoyuxia commented on pull request #21698: [FLINK-30665][table] Planner supports row-level update

luoyuxia commented on PR #21698: URL: https://github.com/apache/flink/pull/21698#issuecomment-1407353968 @lincoln-lil The pr is ready to review. Could you please help review when you're free? -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21672: [FLINK-30683][runtime] Make adaptive batch scheduler as the default batch scheduler

zhuzhurk commented on code in PR #21672: URL: https://github.com/apache/flink/pull/21672#discussion_r1089682373 ## flink-core/src/test/java/org/apache/flink/api/common/ExecutionConfigTest.java: ## @@ -282,23 +281,22 @@ public void testLoadingDefaultKryoSerializersFromConfigurat

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21743: [FLINK-15325][coordination] Ignores the input locations of a ConsumePartitionGroup if the corresponding ConsumerVertexGroup is too

zhuzhurk commented on code in PR #21743: URL: https://github.com/apache/flink/pull/21743#discussion_r1089678609 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/ExecutionGraphToInputsLocationsRetrieverAdapterTest.java: ## @@ -24,104 +24,113 @@ import org.apache

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21743: [FLINK-15325][coordination] Ignores the input locations of a ConsumePartitionGroup if the corresponding ConsumerVertexGroup is too

zhuzhurk commented on code in PR #21743: URL: https://github.com/apache/flink/pull/21743#discussion_r1089677576 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ConsumedPartitionGroup.java: ## @@ -130,4 +138,12 @@ public boolean areAllPartitionsFinished

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21743: [FLINK-15325][coordination] Ignores the input locations of a ConsumePartitionGroup if the corresponding ConsumerVertexGroup is too

zhuzhurk commented on code in PR #21743: URL: https://github.com/apache/flink/pull/21743#discussion_r1089677545 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ConsumerVertexGroup.java: ## @@ -66,4 +75,12 @@ public boolean isEmpty() { public Execu

  1   2   >