[GitHub] [flink] ashmeet-kandhari commented on a diff in pull request #20991: [FLINK-25538][flink-connector-kafka] JUnit5 Migration

ashmeet-kandhari commented on code in PR #20991: URL: https://github.com/apache/flink/pull/20991#discussion_r1006431695 ## flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java: ## @@ -79,7 +79,8 @@ */

[GitHub] [flink] ashmeet-kandhari commented on a diff in pull request #20991: [FLINK-25538][flink-connector-kafka] JUnit5 Migration

ashmeet-kandhari commented on code in PR #20991: URL: https://github.com/apache/flink/pull/20991#discussion_r1006434961 ## flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java: ## @@ -38,16 +39,16

[GitHub] [flink] HuangXingBo commented on pull request #20859: [release] release notes for the 1.16 release

HuangXingBo commented on PR #20859: URL: https://github.com/apache/flink/pull/20859#issuecomment-1293037990 @zentol Do you have any other comments? -- 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

[GitHub] [flink] saLeox commented on pull request #21149: [FLINK-29527][format] Make unknownFieldsIndices work for single ParquetReader

saLeox commented on PR #21149: URL: https://github.com/apache/flink/pull/21149#issuecomment-1293043228 @lirui-apache please help take a look, thanks -- 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

[GitHub] [flink] snuyanzin commented on pull request #21153: [hotfix][runtime] Remove private methods

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

[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=17624881#comment-17624881 ] Durgesh Mishra edited comment on FLINK-29711 at 10/27/22 6:34 AM: --

[jira] [Updated] (FLINK-29758) Serialization issue with enum

[ https://issues.apache.org/jira/browse/FLINK-29758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29758: - Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) Table SQL / API

[jira] [Closed] (FLINK-29647) report stackoverflow when using kryo

[ https://issues.apache.org/jira/browse/FLINK-29647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29647. Resolution: Workaround Closing this for now as we are not upgrading kryo version right now. Feel

[jira] [Commented] (FLINK-29565) In Flink per job mode, the logs printed by taskManager on the web UI will not be highlighted, because the log contents are annotated due to special symbols, which will

[ https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624900#comment-17624900 ] Yun Gao commented on FLINK-29565: - Also cc [~junhan]  > In Flink per job mode, the logs printed by

[GitHub] [flink] ashmeet-kandhari commented on a diff in pull request #20991: [FLINK-25538][flink-connector-kafka] JUnit5 Migration

ashmeet-kandhari commented on code in PR #20991: URL: https://github.com/apache/flink/pull/20991#discussion_r1006434223 ## flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/shuffle/KafkaShuffleExactlyOnceITCase.java: ## @@ -39,7

[GitHub] [flink] AlexRiedler commented on pull request #21167: [hotfix] [flink-parquet] avro parquet logical type fix

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

[GitHub] [flink] wangyang0918 commented on pull request #21166: [FLINK-29749][client] Make 'flink info' command could support dynamic…

wangyang0918 commented on PR #21166: URL: https://github.com/apache/flink/pull/21166#issuecomment-1293052693 We need a new PR to backport FLINK-27579 to release-1.15 first. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[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=17624881#comment-17624881 ] Durgesh Mishra commented on FLINK-29711: [~mason6345]  I added logs in TripSerializer class

[jira] [Commented] (FLINK-29610) Infinite timeout is used in SavepointHandlers calls to RestfulGateway

[ https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624896#comment-17624896 ] Yun Gao commented on FLINK-29610: - Thanks [~Jiale] for tracking the issue! I assigned the issue to you. 

[GitHub] [flink-table-store] tsreaper commented on pull request #336: [FLINK-29773] Fix table store unstable tests PreAggregationITCase

tsreaper commented on PR #336: URL: https://github.com/apache/flink-table-store/pull/336#issuecomment-1293086994 > How many times have you run without fail? For the latest commit, about 1000 times. -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624897#comment-17624897 ] Weijie Guo commented on FLINK-24119:

[GitHub] [flink] reswqa commented on pull request #21137: [FLINK-29234][runtime] JobMasterServiceLeadershipRunner handle leader event in a separate executor to avoid dead lock

reswqa commented on PR #21137: URL: https://github.com/apache/flink/pull/21137#issuecomment-1293090172 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[GitHub] [flink] reswqa commented on pull request #21125: [FLINK-28102] Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

reswqa commented on PR #21125: URL: https://github.com/apache/flink/pull/21125#issuecomment-1293090715 @zentol , I have update this PR, please take a look again, thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-29339) JobMasterPartitionTrackerImpl#requestShuffleDescriptorsFromResourceManager blocks main thread

[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624908#comment-17624908 ] Yun Gao commented on FLINK-29339: -  The PR is already under review previously, let's continue the review

[GitHub] [flink] gaoyunhaii commented on pull request #20862: [FLINK-29339][runtime] JobMasterPartitionTracker returns future to avoid blocking main thread

gaoyunhaii commented on PR #20862: URL: https://github.com/apache/flink/pull/20862#issuecomment-1293100299 @Sxnan Could you have a look at the above issue first ? -- 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-table-store] tsreaper opened a new pull request, #338: [FLINK-29075] Fix table store unstable test RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite

tsreaper opened a new pull request, #338: URL: https://github.com/apache/flink-table-store/pull/338 (cherry picked from #335.) `RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite` fails due to some expected records in table `T4` does not appear in table `T3`. This is

[jira] [Assigned] (FLINK-29610) Infinite timeout is used in SavepointHandlers calls to RestfulGateway

[ https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-29610: --- Assignee: Jiale Tan > Infinite timeout is used in SavepointHandlers calls to RestfulGateway >

[GitHub] [flink-kubernetes-operator] darenwkt commented on pull request #414: [FLINK-29771] Fix flaky rollback test

darenwkt commented on PR #414: URL: https://github.com/apache/flink-kubernetes-operator/pull/414#issuecomment-1293091814 > Thanks @darenwkt, makes sense. Could you please extract the sleep times to a single `ROLLBACK_DELAY` or similarly named constant please? Thanks for the

[jira] [Commented] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624967#comment-17624967 ] Yang Wang commented on FLINK-29315: --- I have upgrade the kernel version of Alibaba001 to

[jira] [Commented] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624970#comment-17624970 ] Zhu Zhu commented on FLINK-28697: - Thanks for reporting this problem and opening a PR to fix it.

[jira] [Commented] (FLINK-29778) fix error in flink-1.13.md

[ https://issues.apache.org/jira/browse/FLINK-29778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624971#comment-17624971 ] hcj commented on FLINK-29778: - could someone help assign this ticket to me? Thanks~ > fix error in

[GitHub] [flink] yuzelin closed pull request #21040: [FLINK-29486][sql-client] Implement a new ClientResult for sql client to wrap the result returned by sql gateway

yuzelin closed pull request #21040: [FLINK-29486][sql-client] Implement a new ClientResult for sql client to wrap the result returned by sql gateway URL: https://github.com/apache/flink/pull/21040 -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] wangyang0918 commented on pull request #20982: [FLINK-29539] [Deployment/Kubernetes] dnsPolicy in FlinkPod is not overridable

wangyang0918 commented on PR #20982: URL: https://github.com/apache/flink/pull/20982#issuecomment-1293251988 @carloscastrojumo Could you please create the backport PR for release-1.15 and release-1.16? -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] yuzelin commented on pull request #21040: [FLINK-29486][sql-client] Implement a new ClientResult for sql client to wrap the result returned by sql gateway

yuzelin commented on PR #21040: URL: https://github.com/apache/flink/pull/21040#issuecomment-1293252838 Found that renaming branch will close the PR... -- 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] wangyang0918 merged pull request #21168: [FLINK-27579][client] Make the client.timeout and parallelism.default…

wangyang0918 merged PR #21168: URL: https://github.com/apache/flink/pull/21168 -- 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-27579) The param client.timeout can not be set by dynamic properties when stopping the job

[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-27579: -- Issue Type: Bug (was: Improvement) > The param client.timeout can not be set by dynamic properties

[jira] [Updated] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-27579: -- Fix Version/s: 1.15.3 > The param client.timeout can not be set by dynamic properties when stopping

[jira] [Commented] (FLINK-29557) The SinkOperator's OutputFormat function is not recognized

[ https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624987#comment-17624987 ] Aitozi commented on FLINK-29557: Yes, I will open a PR to fix this. Please help assign the ticket > The

[jira] [Created] (FLINK-29779) Allow using MiniCluster with a PluginManager to use metrics reporters

Robert Metzger created FLINK-29779: -- Summary: Allow using MiniCluster with a PluginManager to use metrics reporters Key: FLINK-29779 URL: https://issues.apache.org/jira/browse/FLINK-29779 Project:

[jira] [Resolved] (FLINK-28542) [JUnit5 Migration] FileSystemBehaviorTestSuite

[ https://issues.apache.org/jira/browse/FLINK-28542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-28542. --- Fix Version/s: 1.17.0 Resolution: Fixed master:

[GitHub] [flink] XComp merged pull request #20267: [FLINK-28542][tests][JUnit5 Migration] FileSystemBehaviorTestSuite

XComp merged PR #20267: URL: https://github.com/apache/flink/pull/20267 -- 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] MartijnVisser commented on pull request #21167: [hotfix] [flink-parquet] avro parquet logical type fix

MartijnVisser commented on PR #21167: URL: https://github.com/apache/flink/pull/21167#issuecomment-1293497386 @AlexRiedler Thanks for the PR, but this shouldn't be a hotfix but requires a proper Jira -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-29780) how to persist a flink table like spark persist a dataset

[ https://issues.apache.org/jira/browse/FLINK-29780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] qingwei zhong updated FLINK-29780: -- Summary: how to persist a flink table like spark persist a dataset (was: how to persist a

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #414: [FLINK-29771] Fix flaky rollback test

gyfora merged PR #414: URL: https://github.com/apache/flink-kubernetes-operator/pull/414 -- 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] [Commented] (FLINK-29771) Fix flaky RollbackTest

[ https://issues.apache.org/jira/browse/FLINK-29771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625140#comment-17625140 ] Gyula Fora commented on FLINK-29771: merged to main 3b59de9129c0677dd41a454fe5178103ce29f815 > Fix

[jira] [Commented] (FLINK-29779) Allow using MiniCluster with a PluginManager to use metrics reporters

[ https://issues.apache.org/jira/browse/FLINK-29779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625052#comment-17625052 ] Matyas Orhidi commented on FLINK-29779: --- +1 I just realized the other day, it's missing. > Allow

[GitHub] [flink] Myasuka commented on pull request #20917: [hotfix][doc] Refine code examples in data_stream_api

Myasuka commented on PR #20917: URL: https://github.com/apache/flink/pull/20917#issuecomment-1293387289 The CI failed due to FLINK-24119 @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

[GitHub] [flink] liyubin117 commented on pull request #21116: [FLINK-29679][table] DESCRIBE statement shows column comment

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

[jira] [Updated] (FLINK-29780) how to persist flink table like spark persist dataset

[ https://issues.apache.org/jira/browse/FLINK-29780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] qingwei zhong updated FLINK-29780: -- Attachment: 1027.jpg > how to persist flink table like spark persist dataset >

[jira] [Updated] (FLINK-29781) ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

[ https://issues.apache.org/jira/browse/FLINK-29781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29781: Description: currently WatermarkAssignerChangelogNormalizeTransposeRule didn't remap the

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

yuzelin commented on PR #21141: URL: https://github.com/apache/flink/pull/21141#issuecomment-1293521722 @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] z3d1k commented on a diff in pull request #21129: [FLINK-29496] [Connector/Kinesis] Add configuration option for setting STS endpoint for AWS connectors

z3d1k commented on code in PR #21129: URL: https://github.com/apache/flink/pull/21129#discussion_r1006963662 ## flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java: ## @@ -209,6 +200,28 @@ public void refresh()

[GitHub] [flink] flinkbot commented on pull request #21175: [hotfix] [flink-json] Add support for historical data synchronized by maxwell-bootstrap

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

[GitHub] [flink] flinkbot commented on pull request #21176: [FLINK-29740][Scala] Mark all Scala APIs as `@Deprecated`

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

[jira] [Commented] (FLINK-29480) Skip invalid messages when writing

[ https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625182#comment-17625182 ] Leonard Xu commented on FLINK-29480: [~Alcántara] I've assigned this ticket to you, hope to see you

[jira] [Comment Edited] (FLINK-29480) Skip invalid messages when writing

[ https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625182#comment-17625182 ] Leonard Xu edited comment on FLINK-29480 at 10/27/22 3:43 PM: -- [~Alcántara]

[jira] [Closed] (FLINK-29778) fix error in flink-1.13.md

[ https://issues.apache.org/jira/browse/FLINK-29778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-29778. -- Resolution: Won't Fix > fix error in flink-1.13.md > -- > >

[jira] [Commented] (FLINK-29778) fix error in flink-1.13.md

[ https://issues.apache.org/jira/browse/FLINK-29778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625056#comment-17625056 ] Martijn Visser commented on FLINK-29778: It doesn't make much sense to fix this issue if it only

[jira] [Updated] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29315: -- Component/s: Test Infrastructure > HDFSTest#testBlobServerRecovery fails on CI >

[jira] [Updated] (FLINK-29781) ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

[ https://issues.apache.org/jira/browse/FLINK-29781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29781: --- Labels: pull-request-available (was: ) > ChangelogNormalize uses wrong keys after

[GitHub] [flink] Aitozi opened a new pull request, #21174: [FLINK-29557] Fix the SinkOperator with OutputFormatFunction is ignor…

Aitozi opened a new pull request, #21174: URL: https://github.com/apache/flink/pull/21174 …ed as InputFormatOperator ## What is the purpose of the change This pr is meant to fix the `SinkOperator` with `OutputFormatFunction` is not recognized as `InputFormatOperator` ##

[jira] [Updated] (FLINK-29557) The SinkOperator's OutputFormat function is not recognized

[ https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29557: --- Labels: pull-request-available (was: ) > The SinkOperator's OutputFormat function is not

[GitHub] [flink] XComp commented on pull request #18927: [FLINK-26390] Use try resourses for CliClient#executeFile

XComp commented on PR #18927: URL: https://github.com/apache/flink/pull/18927#issuecomment-1293633295 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Assigned] (FLINK-29480) Skip invalid messages when writing

[ https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-29480: -- Assignee: Salva (was: Leonard Xu) > Skip invalid messages when writing >

[GitHub] [flink] lincoln-lil opened a new pull request, #21177: [FLINK-29781][table-planner] Fix ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTranspose

lincoln-lil opened a new pull request, #21177: URL: https://github.com/apache/flink/pull/21177 ## What is the purpose of the change Fix ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule, the remap logic is necessary here.

[GitHub] [flink] flinkbot commented on pull request #21177: [FLINK-29781][table-planner] Fix ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

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

[jira] [Commented] (FLINK-27940) [JUnit5 Migration] Module: flink-connector-jdbc

[ https://issues.apache.org/jira/browse/FLINK-27940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625096#comment-17625096 ] Ryan Skraba commented on FLINK-27940: - I've run into this situation in other modules. My

[jira] [Commented] (FLINK-29541) [JUnit5 Migration] Module: flink-table-planner

[ https://issues.apache.org/jira/browse/FLINK-29541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625098#comment-17625098 ] Ryan Skraba commented on FLINK-29541: - I can start attacking these tests! I think my proposed

[jira] [Commented] (FLINK-29782) Bash-Java-utils.jar still uses Log4j 2.16.0

[ https://issues.apache.org/jira/browse/FLINK-29782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625152#comment-17625152 ] K Bharath commented on FLINK-29782: --- [~martijnvisser] Thank you. Which version do you suggest? >

[GitHub] [flink] zentol commented on pull request #20859: [release] release notes for the 1.16 release

zentol commented on PR #20859: URL: https://github.com/apache/flink/pull/20859#issuecomment-1293714778 @HuangXingBo Apart from https://github.com/apache/flink/pull/20859#discussion_r983601055 I think we're good :) -- This is an automated message from the Apache Git Service. To respond

[jira] [Closed] (FLINK-29294) Introduce a CompactRewriter for full compaction

[ https://issues.apache.org/jira/browse/FLINK-29294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29294. Resolution: Fixed master: 08211f0e190ca8dcce288d93b72350a2b1185ff6 > Introduce a CompactRewriter

[GitHub] [flink-table-store] JingsongLi merged pull request #332: [FLINK-29294] Introduce a CompactRewriter for full compaction

JingsongLi merged PR #332: URL: https://github.com/apache/flink-table-store/pull/332 -- 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 #21171: [hotfix][doc] `FlinkKafkaConsumer` is deprecated and will be removed with Flink 1.17 instead of 1.15

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

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625121#comment-17625121 ] Leonard Xu commented on FLINK-24119: I upgrade the ticket priority to blocker as to many failure

[jira] [Closed] (FLINK-29780) how to persist a flink table like spark persist a dataset

[ https://issues.apache.org/jira/browse/FLINK-29780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-29780. -- Resolution: Invalid [~zqw99] This question is better suited for the Flink User mailing list

[jira] [Closed] (FLINK-29782) Bash-Java-utils.jar still uses Log4j 2.16.0

[ https://issues.apache.org/jira/browse/FLINK-29782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-29782. -- Resolution: Won't Fix [~bharathkopparapu] You should upgrade to a later version of Flink,

[GitHub] [flink] gaoyunhaii commented on pull request #21077: [FLINK-29498] Add Scala Async Retry Strategies and ResultPredicates Helper Classes

gaoyunhaii commented on PR #21077: URL: https://github.com/apache/flink/pull/21077#issuecomment-1293700381 Hi @ericxiao251 very thanks for the PR and very sorry for the delay between reviewing. But may I have a double confirmation that do you think it would be better if we could wrap the

[jira] [Commented] (FLINK-28697) MapDataSerializer doesn't declare a serialVersionUID

[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625038#comment-17625038 ] Josh Mahonin commented on FLINK-28697: -- Agreed, the use of mismatched JVM versions is not ideal. In

[GitHub] [flink] JingGe opened a new pull request, #21172: [hotfix][doc] `FlinkKafkaConsumer` will be removed with Flink 1.17 instead of 1.15

JingGe opened a new pull request, #21172: URL: https://github.com/apache/flink/pull/21172 ## What is the purpose of the change Change the docs: FlinkKafkaConsumer is deprecated and will be removed with Flink 1.17 instead of 1.15 since Flink 1.16 has code freeze and will be

[GitHub] [flink] flinkbot commented on pull request #21172: [hotfix][doc] `FlinkKafkaConsumer` will be removed with Flink 1.17 instead of 1.15

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

[jira] [Commented] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625078#comment-17625078 ] Matthias Pohl commented on FLINK-29315: --- thanks [~wangyang0918] . Did you compare the kernel

[GitHub] [flink] MartijnVisser merged pull request #21154: [hotfix] Add icon for Flink in IntellijIdea and Toolbox

MartijnVisser merged PR #21154: URL: https://github.com/apache/flink/pull/21154 -- 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-29780) how to persist a flink table like spark persist dataset

[ https://issues.apache.org/jira/browse/FLINK-29780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] qingwei zhong updated FLINK-29780: -- Summary: how to persist a flink table like spark persist dataset (was: how to persist flink

[jira] [Updated] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-24119: --- Priority: Blocker (was: Critical) > KafkaITCase.testTimestamps fails due to "Topic xxx already

[GitHub] [flink] flinkbot commented on pull request #21173: [FLINK-29781][table-planner] Fix ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

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

[GitHub] [flink] czy006 commented on pull request #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

czy006 commented on PR #21012: URL: https://github.com/apache/flink/pull/21012#issuecomment-1293560621 @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] JingGe opened a new pull request, #21171: [hotfix][doc] `FlinkKafkaConsumer` is deprecated and will be removed with Flink 1.17 instead of 1.15

JingGe opened a new pull request, #21171: URL: https://github.com/apache/flink/pull/21171 ## What is the purpose of the change Doc should be updated: `FlinkKafkaConsumer` is deprecated and will be removed with Flink 1.17 instead of 1.15 since Flink 1.16 has code freeze and will be

[GitHub] [flink] MartijnVisser merged pull request #21172: [hotfix][doc] `FlinkKafkaConsumer` will be removed with Flink 1.17 instead of 1.15

MartijnVisser merged PR #21172: URL: https://github.com/apache/flink/pull/21172 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Created] (FLINK-29780) how to persist flink table like spark persist dataset

qingwei zhong created FLINK-29780: - Summary: how to persist flink table like spark persist dataset Key: FLINK-29780 URL: https://issues.apache.org/jira/browse/FLINK-29780 Project: Flink

[GitHub] [flink] MartijnVisser merged pull request #21171: [hotfix][doc] `FlinkKafkaConsumer` is deprecated and will be removed with Flink 1.17 instead of 1.15

MartijnVisser merged PR #21171: URL: https://github.com/apache/flink/pull/21171 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Created] (FLINK-29781) ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

lincoln lee created FLINK-29781: --- Summary: ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule Key: FLINK-29781 URL:

[jira] [Updated] (FLINK-29781) ChangelogNormalize uses wrong keys after transformation by WatermarkAssignerChangelogNormalizeTransposeRule

[ https://issues.apache.org/jira/browse/FLINK-29781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29781: Description: currently WatermarkAssignerChangelogNormalizeTransposeRule didn't remap the

[jira] [Commented] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625129#comment-17625129 ] Yang Wang commented on FLINK-29315: --- Yes. All the CI machines have the same kernel version after last

[GitHub] [flink] RenYang1024 opened a new pull request, #21175: [hotfix] [flink-json] Add support for historical data synchronized by maxwell-bootstrap

RenYang1024 opened a new pull request, #21175: URL: https://github.com/apache/flink/pull/21175 ## What is the purpose of the change The historical data type synchronized by the ”maxwell-bootstrap” command is “bootstrap-insert”. As a result, FlinkSQL cannot be recognized normally when

[jira] [Commented] (FLINK-29782) Bash-Java-utils.jar still uses Log4j 2.16.0

[ https://issues.apache.org/jira/browse/FLINK-29782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625169#comment-17625169 ] Martijn Visser commented on FLINK-29782: [~bharathkopparapu] I would currently recommend Flink

[GitHub] [flink] MartijnVisser opened a new pull request, #21176: [FLINK-29740][Scala] Mark all Scala APIs as `@Deprecated`

MartijnVisser opened a new pull request, #21176: URL: https://github.com/apache/flink/pull/21176 ## What is the purpose of the change * Mark all Scala APIs as deprecated as the outcome of FLIP-265 ## Brief change log * Mark all Scala APIs as `@Deprecated` * Remove

[jira] [Updated] (FLINK-29740) Deprecate all customer-facing Scala APIs

[ https://issues.apache.org/jira/browse/FLINK-29740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29740: --- Labels: pull-request-available (was: ) > Deprecate all customer-facing Scala APIs >

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625054#comment-17625054 ] Yun Tang commented on FLINK-24119: --

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #409: [FLINK-29708] Convert CR Error field to JSON with enriched exception …

gyfora merged PR #409: URL: https://github.com/apache/flink-kubernetes-operator/pull/409 -- 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-29498) Flink Async I/O Retry Strategies Do Not Work for Scala AsyncDataStream API

[ https://issues.apache.org/jira/browse/FLINK-29498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29498: --- Labels: pull-request-available (was: ) > Flink Async I/O Retry Strategies Do Not Work for

[jira] [Commented] (FLINK-29480) Skip invalid messages when writing

[ https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625178#comment-17625178 ] Salva commented on FLINK-29480: --- Please [~martijnvisser] [~leonard] [~renqs] can you please assign the

[jira] [Comment Edited] (FLINK-29480) Skip invalid messages when writing

[ https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17625178#comment-17625178 ] Salva edited comment on FLINK-29480 at 10/27/22 3:32 PM: - Please

[jira] [Assigned] (FLINK-29480) Skip invalid messages when writing

[ https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu reassigned FLINK-29480: -- Assignee: Leonard Xu > Skip invalid messages when writing >

[jira] [Closed] (FLINK-29713) Kubernetes operator should restart failed jobs

[ https://issues.apache.org/jira/browse/FLINK-29713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-29713. -- Resolution: Fixed merged to main 5c2f5bfe4108dad57ecfe5db5dc5de092529d5ac > Kubernetes operator

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #407: [FLINK-29713] Kubernetes operator should restart failed jobs

gyfora merged PR #407: URL: https://github.com/apache/flink-kubernetes-operator/pull/407 -- 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:

  1   2   3   >