[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #396: [FLINK-27846] Schema evolution for reading data file

JingsongLi commented on code in PR #396: URL: https://github.com/apache/flink-table-store/pull/396#discussion_r1031148421 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/SchemaEvolutionUtil.java: ## @@ -62,4 +72,193 @@ public static int[] createI

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031151059 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriterTest.java: ## @@ -218,12 +221,14 @@ public void testRecordingOf

[GitHub] [flink-kubernetes-operator] yangjf2019 closed pull request #442: [hotfix][doc][test] correct the incorrect flink release version

yangjf2019 closed pull request #442: [hotfix][doc][test] correct the incorrect flink release version URL: https://github.com/apache/flink-kubernetes-operator/pull/442 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #180: [FLINK-30159] Add Transformer for ANOVATest

jiangxin369 commented on code in PR #180: URL: https://github.com/apache/flink-ml/pull/180#discussion_r1031142739 ## flink-ml-python/pyflink/ml/lib/tests/test_ml_lib_completeness.py: ## @@ -140,6 +145,11 @@ def module(self): from pyflink.ml.lib import stats ret

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031140868 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriterTest.java: ## @@ -121,13 +122,15 @@ public void testSmallFilesN

[GitHub] [flink] snuyanzin commented on a diff in pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

snuyanzin commented on code in PR #21368: URL: https://github.com/apache/flink/pull/21368#discussion_r1031140868 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriterTest.java: ## @@ -121,13 +122,15 @@ public void testSmallFilesN

[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&focusedCommentId=17638140#comment-17638140 ] Matthias Pohl commented on FLINK-29461: --- https://dev.azure.com/apache-flink/apache

[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&focusedCommentId=17638139#comment-17638139 ] Matthias Pohl commented on FLINK-26037: --- https://dev.azure.com/apache-flink/apache

[jira] [Commented] (FLINK-26632) JobManagerHAProcessFailureRecoveryITCase failed due to JVM exits with code 239

[ https://issues.apache.org/jira/browse/FLINK-26632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638138#comment-17638138 ] Matthias Pohl commented on FLINK-26632: --- https://dev.azure.com/apache-flink/apache

[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=17638134#comment-17638134 ] Matthias Pohl commented on FLINK-25813: --- https://dev.azure.com/apache-flink/apache

[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&focusedCommentId=17638132#comment-17638132 ] Matthias Pohl commented on FLINK-26037: --- https://dev.azure.com/apache-flink/apache

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

[ https://issues.apache.org/jira/browse/FLINK-29073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638133#comment-17638133 ] yuzelin commented on FLINK-29073: - Hi, [~eric.xiao] , I estimate that I will finish the

[jira] [Updated] (FLINK-30160) Add Transformer for FValueTest

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

[GitHub] [flink-ml] jiangxin369 opened a new pull request, #182: [FLINK-30160] Add Transformer for FValueTest

jiangxin369 opened a new pull request, #182: URL: https://github.com/apache/flink-ml/pull/182 ## What is the purpose of the change Add Transformer for FValueTest. ## Brief change log - Adds Transformer implementation and tests of ANOVATest in Java. ## Doe

[GitHub] [flink] 1996fanrui commented on pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

1996fanrui commented on PR #21368: URL: https://github.com/apache/flink/pull/21368#issuecomment-1326037817 Hi @RocMarshal , please help take a look in your free time, thanks~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #180: [FLINK-30159] Add Transformer for ANOVATest

yunfengzhou-hub commented on code in PR #180: URL: https://github.com/apache/flink-ml/pull/180#discussion_r1031101109 ## flink-ml-python/pyflink/ml/lib/tests/test_ml_lib_completeness.py: ## @@ -140,6 +145,11 @@ def module(self): from pyflink.ml.lib import stats

[jira] [Commented] (FLINK-30185) Provide the flame graph to the subtask level

[ https://issues.apache.org/jira/browse/FLINK-30185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638129#comment-17638129 ] Rui Fan commented on FLINK-30185: - Hi [~xtsong]  , please help take a look in your free

[jira] [Comment Edited] (FLINK-28812) Add read.compacted to read compacted snapshot only

[ https://issues.apache.org/jira/browse/FLINK-28812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638073#comment-17638073 ] Jingsong Lee edited comment on FLINK-28812 at 11/24/22 6:55 AM: --

[jira] [Closed] (FLINK-28812) Add read.compacted to read compacted snapshot only

[ https://issues.apache.org/jira/browse/FLINK-28812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28812. Fix Version/s: table-store-0.3.0 Resolution: Fixed > Add read.compacted to read compacted s

[jira] [Commented] (FLINK-30184) Save TM/JM thread stack periodically

[ https://issues.apache.org/jira/browse/FLINK-30184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638128#comment-17638128 ] Rui Fan commented on FLINK-30184: - Hi [~xtsong] , please help take a look in your free t

[GitHub] [flink] snuyanzin commented on a diff in pull request #21377: [FLINK-30175][Build] Bump snakeyaml from 1.31 to 1.33

snuyanzin commented on code in PR #21377: URL: https://github.com/apache/flink/pull/21377#discussion_r1031112947 ## pom.xml: ## @@ -1707,12 +1707,12 @@ under the License.

[GitHub] [flink-table-store] JingsongLi merged pull request #401: [FLINK-28812] Read read-compacted from options

JingsongLi merged PR #401: URL: https://github.com/apache/flink-table-store/pull/401 -- 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] flinkbot commented on pull request #21385: [hotfix] Fix class name typo

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

[jira] [Created] (FLINK-30185) Provide the flame graph to the subtask level

Rui Fan created FLINK-30185: --- Summary: Provide the flame graph to the subtask level Key: FLINK-30185 URL: https://issues.apache.org/jira/browse/FLINK-30185 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-29711) Topic notification not present in metadata after 60000 ms.

[ https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Durgesh Mishra resolved FLINK-29711. Fix Version/s: 1.16.0 Resolution: Fixed > Topic notification not present in metadat

[jira] [Comment Edited] (FLINK-29711) Topic notification not present in metadata after 60000 ms.

[ https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638123#comment-17638123 ] Durgesh Mishra edited comment on FLINK-29711 at 11/24/22 6:50 AM:

[jira] [Commented] (FLINK-29711) Topic notification not present in metadata after 60000 ms.

[ https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638123#comment-17638123 ] Durgesh Mishra commented on FLINK-29711: [~martijnvisser]  Yes you are correct w

[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&focusedCommentId=17638122#comment-17638122 ] yuemeng commented on FLINK-29801: - [~ruanhang1993]   I will review this FLIP later and l

[GitHub] [flink] szgeqin opened a new pull request, #21385: [hotfix] Fix class name typo

szgeqin opened a new pull request, #21385: URL: https://github.com/apache/flink/pull/21385 Fix class name typo. -- 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 unsubscri

[jira] [Commented] (FLINK-28863) Snapshot result of RocksDB native savepoint should have empty shared-state

[ https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638121#comment-17638121 ] Yun Tang commented on FLINK-28863: -- [~lijinzhong] Thanks for the analysis, do you mean

[jira] [Created] (FLINK-30184) Save TM/JM thread stack periodically

Rui Fan created FLINK-30184: --- Summary: Save TM/JM thread stack periodically Key: FLINK-30184 URL: https://issues.apache.org/jira/browse/FLINK-30184 Project: Flink Issue Type: Improvement

[GitHub] [flink] mas-chen commented on pull request #20370: [FLINK-28185][Connector/Kafka] handle missing timestamps when there are empty partitions for the TimestampOffsetsInitializer

mas-chen commented on PR #20370: URL: https://github.com/apache/flink/pull/20370#issuecomment-1326012167 @PatrickRen have a chance to take another look? -- 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] XComp commented on pull request #21368: [FLINK-30165][runtime][JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

XComp commented on PR #21368: URL: https://github.com/apache/flink/pull/21368#issuecomment-1326009814 @snuyanzin may you have time to take a look at it? -- 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] [Updated] (FLINK-30165) [JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

[ https://issues.apache.org/jira/browse/FLINK-30165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30165: -- Parent: FLINK-25325 Issue Type: Sub-task (was: Improvement) > [JUnit5 Migration] Migr

[GitHub] [flink] flinkbot commented on pull request #21384: [BP-1.15][FLINK-30133][hadoop] Changes log level and make log message more descriptive.

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

[jira] [Commented] (FLINK-30133) HadoopModuleFactory creates error if the security module cannot be loaded

[ https://issues.apache.org/jira/browse/FLINK-30133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638117#comment-17638117 ] Matthias Pohl commented on FLINK-30133: --- Thanks for your thorough analysis, Gabor.

[GitHub] [flink] flinkbot commented on pull request #21383: [BP-1.16][FLINK-30133][hadoop] Changes log level and make log message more descriptive.

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

[GitHub] [flink] flinkbot commented on pull request #21382: [FLINK-30133][hadoop] Changes log level and make log message more descriptive.

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

[GitHub] [flink] XComp opened a new pull request, #21384: [FLINK-30133][hadoop] Changes log level and make log message more descriptive.

XComp opened a new pull request, #21384: URL: https://github.com/apache/flink/pull/21384 1.15 backport PR for PR https://github.com/apache/flink/pull/21382 -- 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-30133) HadoopModuleFactory creates error if the security module cannot be loaded

[ https://issues.apache.org/jira/browse/FLINK-30133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30133: --- Labels: pull-request-available starter (was: starter) > HadoopModuleFactory creates error i

[GitHub] [flink] XComp opened a new pull request, #21383: [FLINK-30133][hadoop] Changes log level and make log message more descriptive.

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

[GitHub] [flink] XComp opened a new pull request, #21382: [FLINK-30133][hadoop] Changes log level and make log message more descriptive.

XComp opened a new pull request, #21382: URL: https://github.com/apache/flink/pull/21382 ## What is the purpose of the change Lowers the log level to warning since Flink continues to work properly. ## Does this pull request potentially affect one of the following parts:

[jira] [Resolved] (FLINK-30152) Failure in setting up the CI agent

[ https://issues.apache.org/jira/browse/FLINK-30152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-30152. --- Resolution: Won't Fix Could be. Thanks for looking into it. I'm going to close the issue aga

[jira] [Resolved] (FLINK-30182) Create template for release announcement

[ https://issues.apache.org/jira/browse/FLINK-30182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-30182. --- Resolution: Fixed I linked the [1.15.3 blog post PR|https://github.com/apache/flink-web/pull

[GitHub] [flink-table-store] zjureel commented on pull request #401: [FLINK-28812] Read read-compacted from options

zjureel commented on PR #401: URL: https://github.com/apache/flink-table-store/pull/401#issuecomment-1325979794 LGTM 👍 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To u

[jira] [Updated] (FLINK-30183) We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered

[ https://issues.apache.org/jira/browse/FLINK-30183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30183: -- Description: A [user reported an issue|https://lists.apache.org/thread/yjv0hof5qqnzq22xcjf3y2

[jira] [Updated] (FLINK-30183) We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered

[ https://issues.apache.org/jira/browse/FLINK-30183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-30183: -- Labels: starter (was: ) > We should add a proper error message in case the deprecated reflect

[jira] [Created] (FLINK-30183) We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered

Matthias Pohl created FLINK-30183: - Summary: We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered Key: FLINK-30183 URL: https://issues.apache.org/ji

[GitHub] [flink] yuzelin commented on a diff in pull request #20958: [FLINK-29486][sql-client] Add a new RemoteExecutor to send and retrieve messages form remote SQL gateway through rest endpoint

yuzelin commented on code in PR #20958: URL: https://github.com/apache/flink/pull/20958#discussion_r1031041223 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/remote/RemoteExecutor.java: ## @@ -0,0 +1,423 @@ +/* + * Licensed to the Apache Soft

[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&focusedCommentId=17638076#comment-17638076 ] Hang Ruan edited comment on FLINK-29801 at 11/24/22 3:53 AM: -

[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&focusedCommentId=17638076#comment-17638076 ] Hang Ruan edited comment on FLINK-29801 at 11/24/22 3:48 AM: -

[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&focusedCommentId=17638076#comment-17638076 ] Hang Ruan edited comment on FLINK-29801 at 11/24/22 3:48 AM: -

[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&focusedCommentId=17638076#comment-17638076 ] Hang Ruan edited comment on FLINK-29801 at 11/24/22 3:42 AM: -

[GitHub] [flink-web] XComp commented on a diff in pull request #581: Add 1.15.3 release

XComp commented on code in PR #581: URL: https://github.com/apache/flink-web/pull/581#discussion_r1031029650 ## _posts/2022-11-10-release-1.15.3.md: ## @@ -0,0 +1,185 @@ +--- +layout: post +title: "Apache Flink 1.15.3 Release Announcement" +date: 2022-11-10T22:00:00.000Z +categ

[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&focusedCommentId=17638076#comment-17638076 ] Hang Ruan commented on FLINK-29801: --- Hi, [~MengYue] , I have created a FLIP about thi

[jira] [Created] (FLINK-30182) Create template for release announcement

Matthias Pohl created FLINK-30182: - Summary: Create template for release announcement Key: FLINK-30182 URL: https://issues.apache.org/jira/browse/FLINK-30182 Project: Flink Issue Type: Improv

[jira] [Assigned] (FLINK-30182) Create template for release announcement

[ https://issues.apache.org/jira/browse/FLINK-30182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-30182: - Assignee: Matthias Pohl > Create template for release announcement > --

[GitHub] [flink-table-store] JingsongLi commented on pull request #398: [FLINK-30110] Enable from-timestamp log scan when timestamp-millis is configured

JingsongLi commented on PR #398: URL: https://github.com/apache/flink-table-store/pull/398#issuecomment-1325910438 Hi @SteNicholas Can you rebase the latest master? I think we can just set `log.scan` now, there is a safe `validate` method now. -- This is an automated message from the Apa

[jira] [Commented] (FLINK-29830) PulsarSinkITCase$DeliveryGuaranteeTest.writeRecordsToPulsar failed

[ https://issues.apache.org/jira/browse/FLINK-29830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638075#comment-17638075 ] Matthias Pohl commented on FLINK-29830: --- [~syhily] may you create a backport PR fo

[GitHub] [flink] fsk119 commented on a diff in pull request #20958: [FLINK-29486][sql-client] Add a new RemoteExecutor to send and retrieve messages form remote SQL gateway through rest endpoint

fsk119 commented on code in PR #20958: URL: https://github.com/apache/flink/pull/20958#discussion_r1031026497 ## flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/remote/RemoteExecutor.java: ## @@ -0,0 +1,423 @@ +/* + * Licensed to the Apache Softw

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #401: [FLINK-28812] Read read-compacted from options

JingsongLi opened a new pull request, #401: URL: https://github.com/apache/flink-table-store/pull/401 At present, `read-compacted` does not affect the work of scan in various situations. We can read it directly from options. -- This is an automated message from the Apache Git Service. To

[jira] [Assigned] (FLINK-28812) Add read.compacted to read compacted snapshot only

[ https://issues.apache.org/jira/browse/FLINK-28812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28812: Assignee: Shammon > Add read.compacted to read compacted snapshot only >

[jira] [Commented] (FLINK-28812) Add read.compacted to read compacted snapshot only

[ https://issues.apache.org/jira/browse/FLINK-28812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638073#comment-17638073 ] Jingsong Lee commented on FLINK-28812: -- master: 638c34b39ab0b57b14cef9b050c749de7b1

[GitHub] [flink-table-store] JingsongLi merged pull request #351: [FLINK-28812] Support to read compacted snapshot only

JingsongLi merged PR #351: URL: https://github.com/apache/flink-table-store/pull/351 -- 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-30161) Add TableSchema validation before it is commited

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

[GitHub] [flink-table-store] JingsongLi merged pull request #399: [FLINK-30161] Add table schema validation for full compaction

JingsongLi merged PR #399: URL: https://github.com/apache/flink-table-store/pull/399 -- 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-30181) MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed

[ https://issues.apache.org/jira/browse/FLINK-30181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-30181: --- Attachment: java11-300.txt > MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark fai

[jira] [Updated] (FLINK-30181) MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed

[ https://issues.apache.org/jira/browse/FLINK-30181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-30181: --- Attachment: java8.txt > MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed >

[jira] [Commented] (FLINK-30181) MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed

[ https://issues.apache.org/jira/browse/FLINK-30181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638062#comment-17638062 ] Leonard Xu commented on FLINK-30181: Thanks [~Yanfei Lei]for reporting this issue, b

[jira] [Updated] (FLINK-30181) MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed

[ https://issues.apache.org/jira/browse/FLINK-30181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-30181: --- Component/s: Runtime / Checkpointing > MultiInputCheckpointingTimeBenchmark.checkpointMultiInput ben

[jira] [Comment Edited] (FLINK-30181) MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed

[ https://issues.apache.org/jira/browse/FLINK-30181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638062#comment-17638062 ] Leonard Xu edited comment on FLINK-30181 at 11/24/22 3:04 AM:

[jira] [Commented] (FLINK-27320) When using KafkaSink EXACTLY_ONCE semantics, frequent OutOfOrderSequenceException anomalies

[ https://issues.apache.org/jira/browse/FLINK-27320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638059#comment-17638059 ] Zhengqi Zhang commented on FLINK-27320: --- After many repeated tests, Flink1.16.0 se

[jira] [Commented] (FLINK-30073) Managed memory can be wasted if RocksDB memory is fixed-per-slot

[ https://issues.apache.org/jira/browse/FLINK-30073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638058#comment-17638058 ] Yun Tang commented on FLINK-30073: -- [~roman], the state.backend.rocksdb.memory.fixed-pe

[jira] [Commented] (FLINK-29337) Fix fail to query non-hive table in Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-29337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638056#comment-17638056 ] Jing Zhang commented on FLINK-29337: Shall we open a pr for 1.15 as well? [~jark] [~

[GitHub] [flink] flinkbot commented on pull request #21381: [FLINK-30180][docs] Remove the description of Filesystem supporting for the lookup in the Supported Connectors section

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

[jira] [Closed] (FLINK-30178) Kubernetes test failed with "crictl: command not found"

[ https://issues.apache.org/jira/browse/FLINK-30178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-30178. - Resolution: Duplicate I'm closing this issue in favor of FLINK-29671. We see the same cause in l

[jira] [Comment Edited] (FLINK-30178) Kubernetes test failed with "crictl: command not found"

[ https://issues.apache.org/jira/browse/FLINK-30178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638054#comment-17638054 ] Matthias Pohl edited comment on FLINK-30178 at 11/24/22 2:43 AM: -

[jira] [Updated] (FLINK-30180) Remove the description of Filesystem supporting for the lookup in the Supported Connectors section

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

[GitHub] [flink] YesOrNo828 opened a new pull request, #21381: [FLINK-30180][docs] Remove the description of Filesystem supporting for the lookup in the Supported Connectors section

YesOrNo828 opened a new pull request, #21381: URL: https://github.com/apache/flink/pull/21381 ## What is the purpose of the change In the Supported Connectors [section](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/overview/#supported-connector

[jira] [Commented] (FLINK-23687) Introduce partitioned lookup join to enforce input of LookupJoin to hash shuffle by lookup keys

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638049#comment-17638049 ] Jianhui Dong commented on FLINK-23687: -- Hello, I found one issue https://issues.apa

[GitHub] [flink] fsk119 commented on a diff in pull request #21141: [FLINK-29742][sql-gateway] Support completing statement in SqlGatewayService.

fsk119 commented on code in PR #21141: URL: https://github.com/apache/flink/pull/21141#discussion_r1030264916 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -311,6 +312,13 @@ public GatewayInfo getGatewayIn

[jira] [Comment Edited] (FLINK-30122) Flink ML KMeans getting model data throws TypeError

[ https://issues.apache.org/jira/browse/FLINK-30122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637718#comment-17637718 ] Yunfeng Zhou edited comment on FLINK-30122 at 11/24/22 2:25 AM: --

[GitHub] [flink] flinkbot commented on pull request #21380: [FLINK-30169][python][doc] Adds switcher.json file

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

[jira] [Created] (FLINK-30181) MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed

Yanfei Lei created FLINK-30181: -- Summary: MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed Key: FLINK-30181 URL: https://issues.apache.org/jira/browse/FLINK-30181 Project: Flink

[jira] [Updated] (FLINK-30180) Remove the description of Filesystem supporting for the lookup in the Supported Connectors section

[ https://issues.apache.org/jira/browse/FLINK-30180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xianxun Ye updated FLINK-30180: --- Attachment: Supported connectors.jpg > Remove the description of Filesystem supporting for the looku

[jira] [Updated] (FLINK-30169) Adds version switcher in PyFlink API doc

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

[GitHub] [flink] HuangXingBo opened a new pull request, #21380: [FLINK-30169][python][doc] Adds switcher.json file

HuangXingBo opened a new pull request, #21380: URL: https://github.com/apache/flink/pull/21380 ## What is the purpose of the change *This pull request will add the switcher.json file and we will have a following PR to take use of this file to implement version switcher* ##

[GitHub] [flink] dianfu commented on a diff in pull request #21363: [FLINK-29155][python] Change some configs to make grpc server stable in PyFlink Process Mode

dianfu commented on code in PR #21363: URL: https://github.com/apache/flink/pull/21363#discussion_r1030997572 ## flink-python/src/main/java/org/apache/beam/sdk/fn/server/ServerFactory.java: ## @@ -0,0 +1,298 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one +

[jira] [Closed] (FLINK-28394) Python py36-cython: InvocationError for command install_command.sh fails with exit code 1

[ https://issues.apache.org/jira/browse/FLINK-28394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-28394. - Resolution: Cannot Reproduce [~hxbks2ks] is right. I verified the reported build failures most o

[GitHub] [flink] dianfu commented on a diff in pull request #21332: [FLINK-21223][python] Support to specify the output types of Python UDFs via string

dianfu commented on code in PR #21332: URL: https://github.com/apache/flink/pull/21332#discussion_r1030214339 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/python/PythonAggregateFunction.java: ## @@ -120,6 +163,15 @@ public TypeInference getTyp

[jira] [Created] (FLINK-30180) Remove the description of Filesystem supporting for the lookup in the Supported Connectors section

Xianxun Ye created FLINK-30180: -- Summary: Remove the description of Filesystem supporting for the lookup in the Supported Connectors section Key: FLINK-30180 URL: https://issues.apache.org/jira/browse/FLINK-30180

[jira] [Comment Edited] (FLINK-30075) Failed to load data to the cache after the hive lookup join task is restarted

[ https://issues.apache.org/jira/browse/FLINK-30075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638033#comment-17638033 ] zhanglu153 edited comment on FLINK-30075 at 11/24/22 2:09 AM:

[jira] [Updated] (FLINK-27079) Setup cron jobs

[ https://issues.apache.org/jira/browse/FLINK-27079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27079: - Fix Version/s: 1.15.4 (was: 1.15.3) > Setup cron jobs > --- >

[jira] [Updated] (FLINK-27080) Enable builds for pull requests

[ https://issues.apache.org/jira/browse/FLINK-27080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27080: - Fix Version/s: 1.15.4 (was: 1.15.3) > Enable builds for pull requests > -

[jira] [Updated] (FLINK-27415) Read empty csv file throws exception in FileSystem table connector

[ https://issues.apache.org/jira/browse/FLINK-27415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27415: - Fix Version/s: 1.15.4 (was: 1.15.3) > Read empty csv file throws exceptio

[jira] [Updated] (FLINK-27077) Setup per-commit builds

[ https://issues.apache.org/jira/browse/FLINK-27077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27077: - Fix Version/s: 1.15.4 (was: 1.15.3) > Setup per-commit builds > -

[jira] [Updated] (FLINK-27492) Flink table scala example does not including the scala-api jars

[ https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27492: - Fix Version/s: 1.15.4 (was: 1.15.3) > Flink table scala example does not

[jira] [Updated] (FLINK-28959) 504 gateway timeout when consume large number of topics using TopicPatten

[ https://issues.apache.org/jira/browse/FLINK-28959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28959: - Fix Version/s: 1.15.4 (was: 1.15.3) > 504 gateway timeout when consume la

[jira] [Updated] (FLINK-27075) Migrate CI from Azure to Github Actions

[ https://issues.apache.org/jira/browse/FLINK-27075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27075: - Fix Version/s: 1.15.4 (was: 1.15.3) > Migrate CI from Azure to Github Act

[jira] [Updated] (FLINK-27954) JobVertexFlameGraphHandler does not work on standby Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-27954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-27954: - Fix Version/s: 1.15.4 (was: 1.15.3) > JobVertexFlameGraphHandler does not

  1   2   3   4   >