[GitHub] [flink] JingGe commented on a diff in pull request #21322: [FLINK-30025][table] the max column width should be resizable while printing the query result to the client console.

JingGe commented on code in PR #21322: URL: https://github.com/apache/flink/pull/21322#discussion_r1027671723 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -926,7 +926,7 @@ private TableResultInternal

[GitHub] [flink] JingGe commented on a diff in pull request #21322: [FLINK-30025][table] the max column width should be resizable while printing the query result to the client console.

JingGe commented on code in PR #21322: URL: https://github.com/apache/flink/pull/21322#discussion_r102766 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/TableConfigOptions.java: ## @@ -102,6 +102,16 @@ private TableConfigOptions() {}

[GitHub] [flink] JingGe commented on a diff in pull request #21322: [FLINK-30025][table] the max column width should be resizable while printing the query result to the client console.

JingGe commented on code in PR #21322: URL: https://github.com/apache/flink/pull/21322#discussion_r102766 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/TableConfigOptions.java: ## @@ -102,6 +102,16 @@ private TableConfigOptions() {}

[jira] [Updated] (FLINK-30025) table.execute().print() can only use the default max column width

[ https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-30025: Description: when running table API program "table.execute().print();", the columns with long string

[jira] [Updated] (FLINK-30025) table.execute().print() can only use the default max column width

[ https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-30025: Description: "sql-client.display.max-column-width" seems only work in cli: SET

[GitHub] [flink-table-store] JingsongLi merged pull request #392: [SECURITY] Fix Temporary File Information Disclosure Vulnerability

JingsongLi merged PR #392: URL: https://github.com/apache/flink-table-store/pull/392 -- 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] [Closed] (FLINK-30091) mvn package verify fails with "Error creating shaded jar: duplicate entry"

[ https://issues.apache.org/jira/browse/FLINK-30091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30091. Fix Version/s: table-store-0.3.0 Assignee: Alex Sorokoumov Resolution: Fixed

[GitHub] [flink-table-store] JingsongLi merged pull request #391: [FLINK-30091] Update maven-shade-plugin version to 3.4.1

JingsongLi merged PR #391: URL: https://github.com/apache/flink-table-store/pull/391 -- 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] [Updated] (FLINK-29985) TaskManager might not close SlotTable on SIGTERM

[ https://issues.apache.org/jira/browse/FLINK-29985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29985: -- Component/s: Runtime / Coordination > TaskManager might not close SlotTable on SIGTERM >

[jira] [Updated] (FLINK-29985) TaskManager might not close SlotTable on SIGTERM

[ https://issues.apache.org/jira/browse/FLINK-29985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29985: -- Affects Version/s: 1.17.0 > TaskManager might not close SlotTable on SIGTERM >

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

JingsongLi commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027654165 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSource.java: ## @@ -130,4 +119,42 @@ public

[jira] [Created] (FLINK-30110) Enable from-timestamp log scan when timestamp-millis is configured

Jingsong Lee created FLINK-30110: Summary: Enable from-timestamp log scan when timestamp-millis is configured Key: FLINK-30110 URL: https://issues.apache.org/jira/browse/FLINK-30110 Project: Flink

[GitHub] [flink-ml] lindong28 merged pull request #175: [FLINK-29602] Add Transformer for SQLTransformer

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

[GitHub] [flink] flinkbot commented on pull request #21356: [BP-1.15][FLINK-16582][runtime][test] Fix the buffer leaks in NettyBufferPoolTest

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

[jira] [Resolved] (FLINK-29602) Add Transformer for SQLTransformer

[ https://issues.apache.org/jira/browse/FLINK-29602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved FLINK-29602. -- Resolution: Fixed > Add Transformer for SQLTransformer > -- > >

[GitHub] [flink] flinkbot commented on pull request #21355: [BP-1.16][FLINK-16582][runtime][test] Fix the buffer leaks in NettyBufferPoolTest

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

[jira] [Assigned] (FLINK-29602) Add Transformer for SQLTransformer

[ https://issues.apache.org/jira/browse/FLINK-29602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-29602: Assignee: Yunfeng Zhou > Add Transformer for SQLTransformer > --

[jira] [Updated] (FLINK-29602) Add Transformer for SQLTransformer

[ https://issues.apache.org/jira/browse/FLINK-29602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-29602: - Affects Version/s: (was: ml-2.2.0) > Add Transformer for SQLTransformer >

[GitHub] [flink-ml] lindong28 commented on pull request #175: [FLINK-29602] Add Transformer for SQLTransformer

lindong28 commented on PR #175: URL: https://github.com/apache/flink-ml/pull/175#issuecomment-1321558329 Thanks for the update! LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] gaoyunhaii commented on pull request #14319: [FLINK-16582][runtime][test] Fix the buffer leaks in NettyBufferPoolTest

gaoyunhaii commented on PR #14319: URL: https://github.com/apache/flink/pull/14319#issuecomment-1321558015 Ah, very thanks for that! I'll finalize the issue today. -- 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] XComp commented on pull request #14319: [FLINK-16582][runtime][test] Fix the buffer leaks in NettyBufferPoolTest

XComp commented on PR #14319: URL: https://github.com/apache/flink/pull/14319#issuecomment-1321557610 The backports are created. Feel free to have a look, merge all PRs after the CI is green and finalize the Jira issue. Thanks :-) -- This is an automated message from the Apache Git

[GitHub] [flink] XComp opened a new pull request, #21356: [FLINK-16582][runtime][test] Fix the buffer leaks in NettyBufferPoolTest

XComp opened a new pull request, #21356: URL: https://github.com/apache/flink/pull/21356 1.15 backport for PR https://github.com/apache/flink/pull/14319 -- 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

[GitHub] [flink] gaoyunhaii commented on pull request #14319: [FLINK-16582][runtime][test] Fix the buffer leaks in NettyBufferPoolTest

gaoyunhaii commented on PR #14319: URL: https://github.com/apache/flink/pull/14319#issuecomment-1321555445 Hi @XComp very thanks for reviewing and very sorry for missing the previous message, I'll create the backports and merge it after the ci passed. -- This is an automated message

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

JingsongLi commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027645758 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSource.java: ## @@ -130,4 +119,42 @@ public

[GitHub] [flink] XComp opened a new pull request, #21355: [FLINK-16582][runtime][test] Fix the buffer leaks in NettyBufferPoolTest

XComp opened a new pull request, #21355: URL: https://github.com/apache/flink/pull/21355 1.16 backport for PR #14319 -- 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

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

JingsongLi commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027645758 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSource.java: ## @@ -130,4 +119,42 @@ public

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

JingsongLi commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027644999 ## flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/ContinuousFileStoreITCase.java: ## @@ -114,6 +121,55 @@ public void

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

JingsongLi commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027644463 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSource.java: ## @@ -130,4 +119,42 @@ public

[GitHub] [flink] XComp commented on pull request #14319: [FLINK-16582][runtime][test] Fix the buffer leaks in NettyBufferPoolTest

XComp commented on PR #14319: URL: https://github.com/apache/flink/pull/14319#issuecomment-1321551142 I force-pushed the rebase myself. -- 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-table-store] JingsongLi commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

JingsongLi commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027639409 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSource.java: ## @@ -130,4 +119,42 @@ public

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

JingsongLi commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027638918 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSource.java: ## @@ -130,4 +119,42 @@ public

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636464#comment-17636464 ] yuemeng commented on FLINK-29801: - Hi [~ruanhang1993], [~zhuzh]  A further consideration is good, very

[GitHub] [flink] XComp commented on a diff in pull request #21300: [FLINK-29423][rest] Remove custom JobDetails serializer

XComp commented on code in PR #21300: URL: https://github.com/apache/flink/pull/21300#discussion_r1027615498 ## flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobDetails.java: ## @@ -93,6 +92,29 @@ public class JobDetails implements Serializable {

[GitHub] [flink] flinkbot commented on pull request #21354: [FLINK-30084][Runtime] Remove unused method notifyAllocationFailure.

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

[jira] [Updated] (FLINK-30084) Remove unused ResourceActions.notifyAllocationFailure

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

[GitHub] [flink] huwh opened a new pull request, #21354: [FLINK-30084][Runtime] Remove unused method notifyAllocationFailure.

huwh opened a new pull request, #21354: URL: https://github.com/apache/flink/pull/21354 ## What is the purpose of the change The methods ResourceActions#notifyAllocationFailure and JobMasterGateway#notifyAllocationFailure are not used and should be removed. ## Brief

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #438: [FLINK-29974] Not allowing the cancelling the which are already in the completed state.

gyfora commented on code in PR #438: URL: https://github.com/apache/flink-kubernetes-operator/pull/438#discussion_r1027609040 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java: ## @@ -362,11 +362,22 @@ public void

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #438: [FLINK-29974] Not allowing the cancelling the which are already in the completed state.

gyfora commented on code in PR #438: URL: https://github.com/apache/flink-kubernetes-operator/pull/438#discussion_r1027607734 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java: ## @@ -362,11 +362,21 @@ public void

[GitHub] [flink] XComp commented on pull request #21252: [FLINK-29830][Connector/Pulsar] Create the topic with schema before consuming messages in PulsarSinkITCase

XComp commented on PR #21252: URL: https://github.com/apache/flink/pull/21252#issuecomment-1321488646 Thanks for taking over @tisonkun. I was offline for a week anyway. So, good that you unblocked PR #21249 by merging this PR. > Style concern, if it's not enforced by the spotless

[GitHub] [flink] XComp commented on a diff in pull request #21252: [FLINK-29830][Connector/Pulsar] Create the topic with schema before consuming messages in PulsarSinkITCase

XComp commented on code in PR #21252: URL: https://github.com/apache/flink/pull/21252#discussion_r1027592579 ## flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/runtime/PulsarRuntimeOperator.java: ## @@ -180,6 +180,10 @@ public

[GitHub] [flink-kubernetes-operator] rgsriram commented on a diff in pull request #438: [FLINK-29974] Not allowing the cancelling the which are already in the completed state.

rgsriram commented on code in PR #438: URL: https://github.com/apache/flink-kubernetes-operator/pull/438#discussion_r1027591433 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java: ## @@ -362,11 +362,21 @@ public

[jira] [Created] (FLINK-30109) Checked exceptions are sneakingly transformed into unchecked exceptions in the Pulsar

Matthias Pohl created FLINK-30109: - Summary: Checked exceptions are sneakingly transformed into unchecked exceptions in the Pulsar Key: FLINK-30109 URL: https://issues.apache.org/jira/browse/FLINK-30109

[jira] [Commented] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636431#comment-17636431 ] Leonard Xu commented on FLINK-29461:

[jira] [Commented] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636430#comment-17636430 ] Leonard Xu commented on FLINK-26037:

[jira] [Created] (FLINK-30108) flink-core module tests exited with code 143

Leonard Xu created FLINK-30108: -- Summary: flink-core module tests exited with code 143 Key: FLINK-30108 URL: https://issues.apache.org/jira/browse/FLINK-30108 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636429#comment-17636429 ] Leonard Xu commented on FLINK-26037:

[jira] [Commented] (FLINK-29836) PulsarUnorderedSourceITCase failed due to an expected job restart not happening

[ https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636428#comment-17636428 ] Leonard Xu commented on FLINK-29836:

[jira] [Updated] (FLINK-30107) Unstable test ChangelogRecoveryITCase#testMaterialization failed on azure

[ https://issues.apache.org/jira/browse/FLINK-30107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-30107: --- Summary: Unstable test ChangelogRecoveryITCase#testMaterialization failed on azure (was:

[jira] [Created] (FLINK-30107) ChangelogRecoveryITCase#testMaterialization

Leonard Xu created FLINK-30107: -- Summary: ChangelogRecoveryITCase#testMaterialization Key: FLINK-30107 URL: https://issues.apache.org/jira/browse/FLINK-30107 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30106) Build python wheels on macs failed due to install for crcmod error

Leonard Xu created FLINK-30106: -- Summary: Build python wheels on macs failed due to install for crcmod error Key: FLINK-30106 URL: https://issues.apache.org/jira/browse/FLINK-30106 Project: Flink

[jira] [Commented] (FLINK-30103) Test InputFormatCacheLoaderTest.checkCounter failed due to unexpected value on azure

[ https://issues.apache.org/jira/browse/FLINK-30103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636425#comment-17636425 ] Leonard Xu commented on FLINK-30103:

[jira] [Commented] (FLINK-29755) PulsarSourceUnorderedE2ECase.testSavepoint failed because of missing TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636424#comment-17636424 ] Leonard Xu commented on FLINK-29755: [~syhily] I also found some shade error log and pulsar

[jira] [Comment Edited] (FLINK-28326) ResultPartitionTest.testIdleAndBackPressuredTime failed with AssertError

[ https://issues.apache.org/jira/browse/FLINK-28326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636423#comment-17636423 ] Qingsheng Ren edited comment on FLINK-28326 at 11/21/22 4:16 AM: -

[jira] [Reopened] (FLINK-28326) ResultPartitionTest.testIdleAndBackPressuredTime failed with AssertError

[ https://issues.apache.org/jira/browse/FLINK-28326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reopened FLINK-28326: --- > ResultPartitionTest.testIdleAndBackPressuredTime failed with AssertError >

[jira] [Commented] (FLINK-28326) ResultPartitionTest.testIdleAndBackPressuredTime failed with AssertError

[ https://issues.apache.org/jira/browse/FLINK-28326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636423#comment-17636423 ] Qingsheng Ren commented on FLINK-28326: ---

[jira] [Commented] (FLINK-29755) PulsarSourceUnorderedE2ECase.testSavepoint failed because of missing TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636422#comment-17636422 ] Leonard Xu commented on FLINK-29755: PulsarSourceUnorderedE2ECase.testSourceSingleSplit failed on

[GitHub] [flink] fsk119 commented on a diff in pull request #21322: [FLINK-30025][table] the max column width should be resizable while printing the query result to the client console.

fsk119 commented on code in PR #21322: URL: https://github.com/apache/flink/pull/21322#discussion_r1027549706 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/TableConfigOptions.java: ## @@ -102,6 +102,16 @@ private TableConfigOptions() {}

[GitHub] [flink] fsk119 commented on a diff in pull request #21322: [FLINK-30025][table] the max column width should be resizable while printing the query result to the client console.

fsk119 commented on code in PR #21322: URL: https://github.com/apache/flink/pull/21322#discussion_r1027555804 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -926,7 +926,7 @@ private TableResultInternal

[GitHub] [flink] ruanhang1993 commented on pull request #21197: [FLINK-29801] OperatorCoordinator need open the way to operate metric…

ruanhang1993 commented on PR #21197: URL: https://github.com/apache/flink/pull/21197#issuecomment-1321431135 > @ruanhang1993 would you work with @JerryYue-M on the FLIP? > > cc @PatrickRen > FLIP for the change and a discuss it in the community. I would love to

[jira] [Comment Edited] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636421#comment-17636421 ] Hang Ruan edited comment on FLINK-29801 at 11/21/22 3:52 AM: - Hi, [~MengYue]

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636421#comment-17636421 ] Hang Ruan commented on FLINK-29801: --- Hi, [~MengYue] , For the question 1, what I means is better to

[jira] [Created] (FLINK-30105) SubtaskExecutionAttemptAccumulatorsInfoTest failed with JVM exit code 239

Qingsheng Ren created FLINK-30105: - Summary: SubtaskExecutionAttemptAccumulatorsInfoTest failed with JVM exit code 239 Key: FLINK-30105 URL: https://issues.apache.org/jira/browse/FLINK-30105

[jira] [Commented] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636418#comment-17636418 ] Qingsheng Ren commented on FLINK-26974: ---

[jira] [Assigned] (FLINK-30097) CachedDataStream java example in the document is not correct

[ https://issues.apache.org/jira/browse/FLINK-30097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-30097: Assignee: Xuannan Su > CachedDataStream java example in the document is not correct >

[jira] [Commented] (FLINK-29462) LookupJoinITCase failed on azure due to classloader leaking

[ https://issues.apache.org/jira/browse/FLINK-29462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636417#comment-17636417 ] Qingsheng Ren commented on FLINK-29462: ---

[jira] [Commented] (FLINK-29836) PulsarUnorderedSourceITCase failed due to an expected job restart not happening

[ https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636415#comment-17636415 ] Leonard Xu commented on FLINK-29836:

[jira] [Commented] (FLINK-26624) Running HA (hashmap, async) end-to-end test failed on azure due to unable to find master logs

[ https://issues.apache.org/jira/browse/FLINK-26624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636414#comment-17636414 ] Leonard Xu commented on FLINK-26624:

[jira] [Updated] (FLINK-30104) Snapshot deployment failed due to could not transfer artifact org.apache.flink:flink-runtime-web:jar:1.15-20221119.010836-325 from/to apache.snapshots

[ https://issues.apache.org/jira/browse/FLINK-30104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-30104: --- Summary: Snapshot deployment failed due to could not transfer artifact

[jira] [Created] (FLINK-30104) Snapshot deployment failed due to Could not transfer artifact org.apache.flink:flink-runtime-web:jar:1.15-20221119.010836-325 from/to apache.snapshots

Leonard Xu created FLINK-30104: -- Summary: Snapshot deployment failed due to Could not transfer artifact org.apache.flink:flink-runtime-web:jar:1.15-20221119.010836-325 from/to apache.snapshots Key: FLINK-30104 URL:

[jira] [Updated] (FLINK-30101) Always use StandaloneClientHAServices to create RestClusterClient when retriving a Flink on YARN cluster client

[ https://issues.apache.org/jira/browse/FLINK-30101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-30101: -- Description: *Problem* Currently, the procedure of retrieving a Flink on YARN cluster client

[jira] [Commented] (FLINK-29427) LookupJoinITCase failed with classloader problem

[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636412#comment-17636412 ] Leonard Xu commented on FLINK-29427:

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

[ https://issues.apache.org/jira/browse/FLINK-29072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636404#comment-17636404 ] Yubin Li edited comment on FLINK-29072 at 11/21/22 3:21 AM: Hi, [~qingyue]

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

[ https://issues.apache.org/jira/browse/FLINK-29072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636404#comment-17636404 ] Yubin Li edited comment on FLINK-29072 at 11/21/22 3:20 AM: Hi, [~qingyue]

[jira] [Created] (FLINK-30103) Test InputFormatCacheLoaderTest.checkCounter failed due to unexpected value on azure

Leonard Xu created FLINK-30103: -- Summary: Test InputFormatCacheLoaderTest.checkCounter failed due to unexpected value on azure Key: FLINK-30103 URL: https://issues.apache.org/jira/browse/FLINK-30103

[GitHub] [flink-table-store] JingsongLi closed pull request #390: [WIP] Extract BucketComputer

JingsongLi closed pull request #390: [WIP] Extract BucketComputer URL: https://github.com/apache/flink-table-store/pull/390 -- 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

[jira] [Created] (FLINK-30102) Unstable test EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow failed runs on azure

Leonard Xu created FLINK-30102: -- Summary: Unstable test EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow failed runs on azure Key: FLINK-30102 URL:

[jira] [Updated] (FLINK-29614) Introduce Spark writer for table store

[ https://issues.apache.org/jira/browse/FLINK-29614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29614: - Fix Version/s: table-store-0.3.0 > Introduce Spark writer for table store >

[jira] [Updated] (FLINK-29614) Introduce Spark writer for table store

[ https://issues.apache.org/jira/browse/FLINK-29614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29614: --- Labels: pull-request-available (was: ) > Introduce Spark writer for table store >

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #394: [FLINK-29614] Introduce Spark writer for table store

JingsongLi opened a new pull request, #394: URL: https://github.com/apache/flink-table-store/pull/394 - Supports spark batch write by v1 write. - Supports spark delete. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #388: [FLINK-29232] File store continuous reading support from_timestamp scan mode

JingsongLi commented on code in PR #388: URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027507379 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/SnapshotManager.java: ## @@ -90,6 +90,22 @@ public boolean

[jira] [Commented] (FLINK-30101) Always use StandaloneClientHAServices to create RestClusterClient when retriving a Flink on YARN cluster client

[ https://issues.apache.org/jira/browse/FLINK-30101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636408#comment-17636408 ] Zhanghao Chen commented on FLINK-30101: --- [~xtsong] Looking forwarding to your opinions on the

[jira] [Updated] (FLINK-30101) Always use StandaloneClientHAServices to create RestClusterClient when retriving a Flink on YARN cluster client

[ https://issues.apache.org/jira/browse/FLINK-30101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-30101: -- Summary: Always use StandaloneClientHAServices to create RestClusterClient when retriving a

[jira] [Created] (FLINK-30101) YARN client should

Zhanghao Chen created FLINK-30101: - Summary: YARN client should Key: FLINK-30101 URL: https://issues.apache.org/jira/browse/FLINK-30101 Project: Flink Issue Type: Improvement

[GitHub] [flink] XComp commented on a diff in pull request #20755: [FLINK-29092][tests] Use base path bucket assigner

XComp commented on code in PR #20755: URL: https://github.com/apache/flink/pull/20755#discussion_r1027503224 ## flink-formats/flink-hadoop-bulk/src/test/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPartFileWriterTest.java: ## @@ -82,13 +84,23 @@ public void

[GitHub] [flink] XComp commented on a diff in pull request #20755: [FLINK-29092][tests] Use base path bucket assigner

XComp commented on code in PR #20755: URL: https://github.com/apache/flink/pull/20755#discussion_r1027502971 ## flink-formats/flink-hadoop-bulk/src/test/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPartFileWriterTest.java: ## @@ -82,13 +82,14 @@ public void

[jira] [Updated] (FLINK-29092) HadoopPathBasedPartFileWriterTest.testWriteFile failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29092: -- Affects Version/s: 1.15.2 > HadoopPathBasedPartFileWriterTest.testWriteFile failed with

[jira] [Updated] (FLINK-29679) Migrate to new schema framework & show column comment

[ https://issues.apache.org/jira/browse/FLINK-29679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-29679: - Parent: FLINK-29072 Issue Type: Sub-task (was: New Feature) > Migrate to new schema framework

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

[ https://issues.apache.org/jira/browse/FLINK-29072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636404#comment-17636404 ] Yubin Li commented on FLINK-29072: -- Hi, [~qingyue] [~luoyuxia], I have implemented the feature in

[jira] [Updated] (FLINK-29679) Migrate to new schema framework & show column comment

[ https://issues.apache.org/jira/browse/FLINK-29679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-29679: - Summary: Migrate to new schema framework & show column comment (was: DESCRIBE statement shows column

[jira] [Commented] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636400#comment-17636400 ] Suhan Mao commented on FLINK-30093: --- [~rmetzger] Thanks for your findings! I did not consider that

[jira] [Commented] (FLINK-23035) Add explicit method to StateChangelogWriter to write metadata

[ https://issues.apache.org/jira/browse/FLINK-23035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636399#comment-17636399 ] Yanfei Lei commented on FLINK-23035: [~binh] How is it going? we intend to finish it in 1.17,  the

[GitHub] [flink] wanglijie95 commented on pull request #20097: [FLINK-28284][Connectors/Jdbc] Add JdbcSink with new format

wanglijie95 commented on PR #20097: URL: https://github.com/apache/flink/pull/20097#issuecomment-1321372510 Thanks @eskabetxe for creating this PR. I have 3 questions about the changes: 1. Do we need to introduce `JdbcProducer/NonXaJdbcProducer`? I think the existing `JdbcOutputFormat`

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #175: [FLINK-29602] Add Transformer for SQLTransformer

yunfengzhou-hub commented on code in PR #175: URL: https://github.com/apache/flink-ml/pull/175#discussion_r1027464467 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/sqltransformer/SQLTransformer.java: ## @@ -0,0 +1,194 @@ +/* + * Licensed to the Apache Software

[jira] [Closed] (FLINK-27874) KeyedStateCheckpointingITCase Timeout

[ https://issues.apache.org/jira/browse/FLINK-27874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-27874. -- Resolution: Cannot Reproduce > KeyedStateCheckpointingITCase Timeout >

[jira] [Commented] (FLINK-27874) KeyedStateCheckpointingITCase Timeout

[ https://issues.apache.org/jira/browse/FLINK-27874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636392#comment-17636392 ] Yanfei Lei commented on FLINK-27874: Since this hasn't been reproduced in 5 months, I'm going to

[jira] [Closed] (FLINK-28010) Use deleteRange to optimize the clear operation of RocksDBMapState.

[ https://issues.apache.org/jira/browse/FLINK-28010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei closed FLINK-28010. -- Resolution: Won't Fix > Use deleteRange to optimize the clear operation of RocksDBMapState. >

[jira] [Commented] (FLINK-28010) Use deleteRange to optimize the clear operation of RocksDBMapState.

[ https://issues.apache.org/jira/browse/FLINK-28010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636391#comment-17636391 ] Yanfei Lei commented on FLINK-28010: Because the experimental results of

[jira] [Commented] (FLINK-28695) Fail to send partition request to restarted taskmanager

[ https://issues.apache.org/jira/browse/FLINK-28695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636390#comment-17636390 ] nobleyd commented on FLINK-28695: - [~pnowojski] Hi, we have the same problem, and adjusting

[jira] [Assigned] (FLINK-29614) Introduce Spark writer for table store

[ https://issues.apache.org/jira/browse/FLINK-29614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29614: Assignee: Jingsong Lee > Introduce Spark writer for table store >

[jira] [Closed] (FLINK-30094) Flink Table Sotre's Lookup Join document may needs left table DDL example.

[ https://issues.apache.org/jira/browse/FLINK-30094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30094. Fix Version/s: table-store-0.3.0 Assignee: Hang HOU Resolution: Fixed master:

  1   2   >