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

2022-10-27 Thread Xintong Song (Jira)
[ 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

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

2022-10-27 Thread GitBox
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 messa

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

2022-10-27 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624896#comment-17624896 ] Yun Gao commented on FLINK-29610: - Thanks [~Jiale] for tracking the issue! I assigned th

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

2022-10-27 Thread Yun Gao (Jira)
[ 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-table-store] tsreaper opened a new pull request, #338: [FLINK-29075] Fix table store unstable test RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite

2022-10-27 Thread GitBox
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 beca

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

2022-10-27 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624897#comment-17624897 ] Weijie Guo commented on FLINK-24119: https://dev.azure.com/apache-flink/apache-flink

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

2022-10-27 Thread GitBox
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. T

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

2022-10-27 Thread GitBox
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

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

2022-10-27 Thread GitBox
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 feedback,

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

2022-10-27 Thread Xintong Song (Jira)
[ 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 f

[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

2022-10-27 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624900#comment-17624900 ] Yun Gao commented on FLINK-29565: - Also cc [~junhan]  > In Flink per job mode, the logs

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

2022-10-27 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624908#comment-17624908 ] Yun Gao commented on FLINK-29339: -  The PR is already under review previously, let's con

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

2022-10-27 Thread GitBox
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 URL

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #337: [FLINK-29774] Introduce options metadata table

2022-10-27 Thread GitBox
LadyForest commented on code in PR #337: URL: https://github.com/apache/flink-table-store/pull/337#discussion_r1006495256 ## docs/content/docs/development/query-table.md: ## @@ -109,3 +109,19 @@ SELECT * FROM MyTable$snapshots; By querying one table's snapshots table, you can

[GitHub] [flink] xintongsong merged pull request #20838: [FLINK-29306][shell] Fix the error detection of multiple flink-dist-*.jar for config.sh

2022-10-27 Thread GitBox
xintongsong merged PR #20838: URL: https://github.com/apache/flink/pull/20838 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.a

[jira] [Updated] (FLINK-29774) Introduce options metadata table

2022-10-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29774: --- Labels: pull-request-available (was: ) > Introduce options metadata table > ---

[jira] [Closed] (FLINK-29306) fail to check multiple flink-dist*.jar for config.sh

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29306. Fix Version/s: 1.17.0 Resolution: Fixed master (1.17): c0e3500722a6b8491748f57daf35ef9d79a4

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #337: [FLINK-29774] Introduce options metadata table

2022-10-27 Thread GitBox
LadyForest commented on code in PR #337: URL: https://github.com/apache/flink-table-store/pull/337#discussion_r1006498869 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/metadata/OptionsTable.java: ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache So

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #337: [FLINK-29774] Introduce options metadata table

2022-10-27 Thread GitBox
LadyForest commented on code in PR #337: URL: https://github.com/apache/flink-table-store/pull/337#discussion_r1006500419 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/metadata/OptionsTable.java: ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache So

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #337: [FLINK-29774] Introduce options metadata table

2022-10-27 Thread GitBox
JingsongLi commented on code in PR #337: URL: https://github.com/apache/flink-table-store/pull/337#discussion_r1006502339 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/metadata/OptionsTable.java: ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-29125) Placeholder in Apache Flink Web Frontend to display some "tags" to distinguish between frontends of different clusters

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624917#comment-17624917 ] Xintong Song commented on FLINK-29125: -- [~junhan], would you have time to take a lo

[GitHub] [flink-table-store] tsreaper merged pull request #338: [FLINK-29075] Fix table store unstable test RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite

2022-10-27 Thread GitBox
tsreaper merged PR #338: URL: https://github.com/apache/flink-table-store/pull/338 -- 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...@fl

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #337: [FLINK-29774] Introduce options metadata table

2022-10-27 Thread GitBox
LadyForest commented on code in PR #337: URL: https://github.com/apache/flink-table-store/pull/337#discussion_r1006503338 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/metadata/OptionsTable.java: ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-29075) RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite is not stable

2022-10-27 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624922#comment-17624922 ] Caizhi Weng commented on FLINK-29075: - release-0.2: 8377a51c76509dcdfbaa3bf28e806b50

[jira] [Closed] (FLINK-29124) Redundant checkNotNull in cli Package

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-29124. Resolution: Not A Problem I don't think this is a valid issue. Not relying on the callers correctn

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #337: [FLINK-29774] Introduce options metadata table

2022-10-27 Thread GitBox
LadyForest commented on code in PR #337: URL: https://github.com/apache/flink-table-store/pull/337#discussion_r1006512218 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/metadata/OptionsTable.java: ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache So

[jira] [Commented] (FLINK-29167) Time out-of-order optimization for merging multiple data streams into one data stream

2022-10-27 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624927#comment-17624927 ] Lijie Wang commented on FLINK-29167: Is your job bounded stream? Or unbounded stream

[jira] [Closed] (FLINK-28879) New File Sink s3 end-to-end test failed with Output hash mismatch

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28879. Resolution: Cannot Reproduce This has never been reproduced since reported 2.5 months ago. Closing

[jira] [Comment Edited] (FLINK-29167) Time out-of-order optimization for merging multiple data streams into one data stream

2022-10-27 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624927#comment-17624927 ] Lijie Wang edited comment on FLINK-29167 at 10/27/22 7:44 AM:

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #337: [FLINK-29774] Introduce options metadata table

2022-10-27 Thread GitBox
JingsongLi commented on code in PR #337: URL: https://github.com/apache/flink-table-store/pull/337#discussion_r1006513992 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/metadata/OptionsTable.java: ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache So

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

2022-10-27 Thread GitBox
tsreaper merged PR #336: URL: https://github.com/apache/flink-table-store/pull/336 -- 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...@fl

[jira] [Closed] (FLINK-29773) PreAggregationITCase.LastValueAggregation and PreAggregationITCase.LastNonNullValueAggregation are unstable

2022-10-27 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-29773. --- Resolution: Fixed master: 147ea7528edfade6025e76fc66252765dc6f8fe4 > PreAggregationITCase.LastValue

[GitHub] [flink] gaborgsomogyi commented on pull request #21160: [FLINK-29761][runtime][security] Simplify HadoopModule

2022-10-27 Thread GitBox
gaborgsomogyi commented on PR #21160: URL: https://github.com/apache/flink/pull/21160#issuecomment-1293126354 Based on the fact that the UGI APIs are not doing the same things I've refactored the original PR and using the exact same API calls. Re-tested it manually and works fine. -- Thi

[GitHub] [flink] gaborgsomogyi commented on pull request #21160: [FLINK-29761][runtime][security] Simplify HadoopModule

2022-10-27 Thread GitBox
gaborgsomogyi commented on PR #21160: URL: https://github.com/apache/flink/pull/21160#issuecomment-1293126592 cc @mbalassi -- 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] [Closed] (FLINK-28784) ParameterTool support read and parse program arguments from yml file

2022-10-27 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-28784. --- Fix Version/s: (was: 1.15.3) Resolution: Won't Do Close this ticket because it is inactive. > Pa

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

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-28863: - Component/s: (was: Runtime / Checkpointing) > Snapshot result of RocksDB native savepoint sh

[jira] [Closed] (FLINK-28769) Flink History Server show wrong name of batch jobs

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28769. Resolution: Won't Fix Closing as we are no longer actively maintaining the deprecated DataSet API.

[jira] [Updated] (FLINK-28819) The natural time of day TTL

2022-10-27 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang updated FLINK-28819: --- Component/s: Runtime / State Backends > The natural time of day TTL > --- >

[jira] [Created] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb

2022-10-27 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-29775: Summary: [JUnit5 Migration] Module: flink-statebackend-rocksdb Key: FLINK-29775 URL: https://issues.apache.org/jira/browse/FLINK-29775 Project: Flink Issue T

[jira] [Created] (FLINK-29776) [JUnit5 Migration] Module: flink-statebackend-changelog

2022-10-27 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-29776: Summary: [JUnit5 Migration] Module: flink-statebackend-changelog Key: FLINK-29776 URL: https://issues.apache.org/jira/browse/FLINK-29776 Project: Flink Issue

[jira] [Commented] (FLINK-29008) SortMergeResultPartitionTest.testRelease failed with TestTimedOutException

2022-10-27 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624937#comment-17624937 ] Yingjie Cao commented on FLINK-29008: - I ran this test for more than 1000 times loca

[jira] [Closed] (FLINK-29008) SortMergeResultPartitionTest.testRelease failed with TestTimedOutException

2022-10-27 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-29008. --- Resolution: Cannot Reproduce > SortMergeResultPartitionTest.testRelease failed with TestTimedOutExce

[jira] [Created] (FLINK-29777) [JUnit5 Migration] Module: flink-dstl

2022-10-27 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-29777: Summary: [JUnit5 Migration] Module: flink-dstl Key: FLINK-29777 URL: https://issues.apache.org/jira/browse/FLINK-29777 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-28973) Extending /jars/:jarid/plan API to support setting Flink configs

2022-10-27 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624941#comment-17624941 ] Yun Gao commented on FLINK-28973: - Hi [~Zhanghao Chen] may I have a double confirmation

[jira] [Updated] (FLINK-29777) [JUnit5 Migration] Module: flink-dstl

2022-10-27 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-29777: - Priority: Minor (was: Major) > [JUnit5 Migration] Module: flink-dstl >

[jira] [Updated] (FLINK-29776) [JUnit5 Migration] Module: flink-statebackend-changelog

2022-10-27 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-29776: - Priority: Minor (was: Major) > [JUnit5 Migration] Module: flink-statebackend-changelog > --

[jira] [Updated] (FLINK-29775) [JUnit5 Migration] Module: flink-statebackend-rocksdb

2022-10-27 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-29775: - Priority: Minor (was: Major) > [JUnit5 Migration] Module: flink-statebackend-rocksdb >

[GitHub] [flink] SmirAlex opened a new pull request, #21170: Flink 19822

2022-10-27 Thread GitBox
SmirAlex opened a new pull request, #21170: URL: https://github.com/apache/flink/pull/21170 ## What is the purpose of the change Shuffle is one of the most heavy operation, and many shuffle operations is redundant, because the input operators have provide the required shuffle.

[GitHub] [flink] flinkbot commented on pull request #21170: [FLINK-19822][table-planner] Remove redundant shuffle for streaming

2022-10-27 Thread GitBox
flinkbot commented on PR #21170: URL: https://github.com/apache/flink/pull/21170#issuecomment-1293164919 ## CI report: * 7bdfb8b2fe30e853f819591b1110f7df0653f6d3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

2022-10-27 Thread GitBox
czy006 commented on code in PR #21012: URL: https://github.com/apache/flink/pull/21012#discussion_r1006552316 ## flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java: ## @@ -211,6 +218,37 @@ void testProvideJobId() throws Exce

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

2022-10-27 Thread GitBox
czy006 commented on code in PR #21012: URL: https://github.com/apache/flink/pull/21012#discussion_r1006552851 ## flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java: ## @@ -211,6 +218,37 @@ void testProvideJobId() throws Exce

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

2022-10-27 Thread GitBox
czy006 commented on code in PR #21012: URL: https://github.com/apache/flink/pull/21012#discussion_r1006553366 ## flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java: ## @@ -211,6 +218,37 @@ void testProvideJobId() throws Exce

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

2022-10-27 Thread GitBox
czy006 commented on code in PR #21012: URL: https://github.com/apache/flink/pull/21012#discussion_r1006554349 ## flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlerParameterTest.java: ## @@ -211,6 +218,37 @@ void testProvideJobId() throws Exce

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

2022-10-27 Thread GitBox
czy006 commented on PR #21012: URL: https://github.com/apache/flink/pull/21012#issuecomment-1293172070 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. T

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

2022-10-27 Thread hcj (Jira)
hcj created FLINK-29778: --- Summary: fix error in flink-1.13.md Key: FLINK-29778 URL: https://issues.apache.org/jira/browse/FLINK-29778 Project: Flink Issue Type: Bug Components: Documentation

[jira] [Commented] (FLINK-19822) Remove redundant shuffle for streaming

2022-10-27 Thread Alexander Smirnov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624953#comment-17624953 ] Alexander Smirnov commented on FLINK-19822: --- Hi [~godfreyhe]! I was wondering

[jira] [Comment Edited] (FLINK-19822) Remove redundant shuffle for streaming

2022-10-27 Thread Alexander Smirnov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624953#comment-17624953 ] Alexander Smirnov edited comment on FLINK-19822 at 10/27/22 8:37 AM: -

[jira] [Comment Edited] (FLINK-19822) Remove redundant shuffle for streaming

2022-10-27 Thread Alexander Smirnov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624953#comment-17624953 ] Alexander Smirnov edited comment on FLINK-19822 at 10/27/22 8:38 AM: -

[GitHub] [flink-table-store] JingsongLi merged pull request #337: [FLINK-29774] Introduce options metadata table

2022-10-27 Thread GitBox
JingsongLi merged PR #337: URL: https://github.com/apache/flink-table-store/pull/337 -- 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-29774) Introduce options metadata table

2022-10-27 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29774. Resolution: Fixed master: 3959440576f6d8e8e3dc88eb4130a04cdce4c3b1 > Introduce options metadata t

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

2022-10-27 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624967#comment-17624967 ] Yang Wang commented on FLINK-29315: --- I have upgrade the kernel version of Alibaba001 t

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

2022-10-27 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624970#comment-17624970 ] Zhu Zhu commented on FLINK-28697: - Thanks for reporting this problem and opening a PR to

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

2022-10-27 Thread hcj (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624971#comment-17624971 ] hcj commented on FLINK-29778: - could someone help assign this ticket to me? Thanks~ > fix e

[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

2022-10-27 Thread GitBox
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 l

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

2022-10-27 Thread GitBox
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 message,

[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

2022-10-27 Thread GitBox
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 g

[GitHub] [flink] wangyang0918 merged pull request #21168: [FLINK-27579][client] Make the client.timeout and parallelism.default…

2022-10-27 Thread GitBox
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: issues-unsubscr...@flink.

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

2022-10-27 Thread Yang Wang (Jira)
[ 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 wh

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

2022-10-27 Thread Yang Wang (Jira)
[ 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

2022-10-27 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624987#comment-17624987 ] Aitozi commented on FLINK-29557: Yes, I will open a PR to fix this. Please help assign t

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

2022-10-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-29557: -- Assignee: Aitozi > The SinkOperator's OutputFormat function is not recognized > -

[GitHub] [flink] snuyanzin commented on a diff in pull request #19897: [FLINK-27885][tests][JUnit5 migration] flink-csv

2022-10-27 Thread GitBox
snuyanzin commented on code in PR #19897: URL: https://github.com/apache/flink/pull/19897#discussion_r1006642754 ## flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFilesystemStatisticsReportTest.java: ## @@ -34,16 +34,16 @@ /** * Test for statistic

[GitHub] [flink] snuyanzin commented on a diff in pull request #19897: [FLINK-27885][tests][JUnit5 migration] flink-csv

2022-10-27 Thread GitBox
snuyanzin commented on code in PR #19897: URL: https://github.com/apache/flink/pull/19897#discussion_r1006642754 ## flink-formats/flink-csv/src/test/java/org/apache/flink/formats/csv/CsvFormatFilesystemStatisticsReportTest.java: ## @@ -34,16 +34,16 @@ /** * Test for statistic

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

2022-10-27 Thread GitBox
yuzelin commented on PR #21141: URL: https://github.com/apache/flink/pull/21141#issuecomment-1293294800 @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] [Commented] (FLINK-29778) fix error in flink-1.13.md

2022-10-27 Thread zhangjilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625007#comment-17625007 ] zhangjilong commented on FLINK-29778: - I‘m interesting in fixing doc,can you assign

[GitHub] [flink-ml] jiangxin369 opened a new pull request, #166: [FLINK-29598] Add Estimator and Transformer for Imputer

2022-10-27 Thread GitBox
jiangxin369 opened a new pull request, #166: URL: https://github.com/apache/flink-ml/pull/166 ## What is the purpose of the change Add Estimator and Transformer for Imputer ## Brief change log *(for example:)* - Adds Transformer and Estimator implementation o

[jira] [Updated] (FLINK-29598) Add Estimator and Transformer for Imputer

2022-10-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29598: --- Labels: pull-request-available (was: ) > Add Estimator and Transformer for Imputer > --

[GitHub] [flink] ferenc-csaky commented on pull request #21140: [FLINK-25909][runtime][security] Add HBaseDelegationTokenProvider

2022-10-27 Thread GitBox
ferenc-csaky commented on PR #21140: URL: https://github.com/apache/flink/pull/21140#issuecomment-1293309043 Thanks for the explanation @gaborgsomogyi, I plan to verify based on the linked instructions. -- This is an automated message from the Apache Git Service. To respond to the message

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

2022-10-27 Thread GitBox
XComp commented on code in PR #21137: URL: https://github.com/apache/flink/pull/21137#discussion_r1006684103 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunnerTest.java: ## @@ -683,21 +665,66 @@ public void testJobAlreadyDone() thr

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

2022-10-27 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-28863: - Component/s: Runtime / Checkpointing > Snapshot result of RocksDB native savepoint should have empty sha

[jira] [Commented] (FLINK-25444) ClosureCleaner rejects ExecutionConfig as not be Serializable due to TextElement

2022-10-27 Thread Noel O'Connor (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625018#comment-17625018 ] Noel O'Connor commented on FLINK-25444: --- I'm hitting this issue when using a {colo

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

2022-10-27 Thread Robert Metzger (Jira)
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: Fl

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

2022-10-27 Thread Josh Mahonin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625038#comment-17625038 ] Josh Mahonin commented on FLINK-28697: -- Agreed, the use of mismatched JVM versions

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

2022-10-27 Thread GitBox
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: issues-unsubscr...@

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

2022-10-27 Thread Jingsong Lee (Jira)
[ 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] JingGe opened a new pull request, #21171: [hotfix][doc] `FlinkKafkaConsumer` is deprecated and will be removed with Flink 1.17 instead of 1.15

2022-10-27 Thread GitBox
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 re

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

2022-10-27 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625052#comment-17625052 ] Matyas Orhidi commented on FLINK-29779: --- +1 I just realized the other day, it's mi

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

2022-10-27 Thread GitBox
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 UR

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

2022-10-27 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625054#comment-17625054 ] Yun Tang commented on FLINK-24119: -- https://dev.azure.com/apache-flink/apache-flink/_bu

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

2022-10-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625056#comment-17625056 ] Martijn Visser commented on FLINK-29778: It doesn't make much sense to fix this

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

2022-10-27 Thread Martijn Visser (Jira)
[ 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 > -- > >

[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

2022-10-27 Thread GitBox
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`

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

2022-10-27 Thread GitBox
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 releas

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

2022-10-27 Thread GitBox
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`

[GitHub] [flink] MartijnVisser commented on a diff in pull request #20935: [hotfix][doc] Make referencing custom image clearer for Docker

2022-10-27 Thread GitBox
MartijnVisser commented on code in PR #20935: URL: https://github.com/apache/flink/pull/20935#discussion_r1006769024 ## docs/content.zh/docs/deployment/resource-providers/standalone/docker.md: ## @@ -406,15 +406,15 @@ services: You can then start creating tables and queries t

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

2022-10-27 Thread GitBox
morhidi commented on PR #409: URL: https://github.com/apache/flink-kubernetes-operator/pull/409#issuecomment-1293448447 Agree @darenwkt, great job! @gyfora not following the CI stability, but when you feel it's safe we can merge this. -- This is an automated message from the Apache Git S

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

2022-10-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625078#comment-17625078 ] Matthias Pohl commented on FLINK-29315: --- thanks [~wangyang0918] . Did you compare

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

2022-10-27 Thread GitBox
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 comment

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

2022-10-27 Thread Matthias Pohl (Jira)
[ 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] [Commented] (FLINK-27940) [JUnit5 Migration] Module: flink-connector-jdbc

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

  1   2   3   >