[jira] [Reopened] (FLINK-30025) Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

2023-09-07 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reopened FLINK-30025: - > Unified the max display column width for SqlClient and Table APi in both > Streaming and Batch execMode >

[GitHub] [flink] masteryhx commented on a diff in pull request #23376: [FLINK-14032][state]Make the cache size of RocksDBPriorityQueueSetFactory configurable

2023-09-07 Thread via GitHub
masteryhx commented on code in PR #23376: URL: https://github.com/apache/flink/pull/23376#discussion_r1319396962 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackendBuilder.java: ## @@ -126,6 +129,7 @@

[GitHub] [flink] JunRuiLee commented on pull request #23181: W.I.P only used to run ci.

2023-09-07 Thread via GitHub
JunRuiLee commented on PR #23181: URL: https://github.com/apache/flink/pull/23181#issuecomment-1711124974 @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-33053) Watcher leak in Zookeeper HA mode

2023-09-07 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762965#comment-17762965 ] Zili Chen commented on FLINK-33053: --- The log seems trimed. I saw: 2023-09-08 11:09:03

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762962#comment-17762962 ] Matthias Pohl commented on FLINK-33053: --- Thanks for sharing this. I guess, the thr

[jira] [Comment Edited] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762962#comment-17762962 ] Matthias Pohl edited comment on FLINK-33053 at 9/8/23 5:51 AM: ---

[GitHub] [flink] JunRuiLee commented on pull request #23181: W.I.P only used to run ci.

2023-09-07 Thread via GitHub
JunRuiLee commented on PR #23181: URL: https://github.com/apache/flink/pull/23181#issuecomment-1711096171 @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] [Closed] (FLINK-32620) Migrate DiscardingSink to sinkv2

2023-09-07 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-32620. -- Resolution: Fixed master(1.19) via c4a76e2f006d834771092a8fac96bfc63361e20b. > Migrate DiscardingSink

[jira] [Updated] (FLINK-32620) Migrate DiscardingSink to sinkv2

2023-09-07 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32620: --- Fix Version/s: 1.19.0 > Migrate DiscardingSink to sinkv2 > > >

[GitHub] [flink] flinkbot commented on pull request #23378: [FLINK-33055][doc]Correct the error value about 'state.backend.type' in the document

2023-09-07 Thread via GitHub
flinkbot commented on PR #23378: URL: https://github.com/apache/flink/pull/23378#issuecomment-1711059626 ## CI report: * 144ab76379d0058918c30cc5e0830f65f7f53d09 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] ljz2051 opened a new pull request, #23378: [FLINK-33055][doc]Correct the error value about 'state.backend.type' in the document

2023-09-07 Thread via GitHub
ljz2051 opened a new pull request, #23378: URL: https://github.com/apache/flink/pull/23378 ## What is the purpose of the change This pull request correct the error value about 'state.backend.type' in the document(config.md). ## Brief change log - Update the description about

[GitHub] [flink] flinkbot commented on pull request #23377: [FLINK-33064][table-planner] Improve the error message when the lookup source is used as the scan source

2023-09-07 Thread via GitHub
flinkbot commented on PR #23377: URL: https://github.com/apache/flink/pull/23377#issuecomment-1711053515 ## CI report: * acfd24c22b8b16fd8d2f3d12b89ec3759efac90f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Resolved] (FLINK-30217) Use ListState#update() to replace clear + add mode.

2023-09-07 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-30217. -- Fix Version/s: 1.19.0 Resolution: Fixed merged 20c0acf60d137cd613914503f1b40e7b2adb86c1

[GitHub] [flink] JunRuiLee commented on pull request #23181: W.I.P only used to run ci.

2023-09-07 Thread via GitHub
JunRuiLee commented on PR #23181: URL: https://github.com/apache/flink/pull/23181#issuecomment-1711052496 @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-33055) Correct the error value about 'state.backend.type' in the document

2023-09-07 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762950#comment-17762950 ] Hangxiang Yu commented on FLINK-33055: -- [~lijinzhong] Thanks for volunteering, alre

[jira] [Assigned] (FLINK-33055) Correct the error value about 'state.backend.type' in the document

2023-09-07 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-33055: Assignee: Jinzhong Li > Correct the error value about 'state.backend.type' in the documen

[GitHub] [flink] masteryhx closed pull request #23344: [FLINK-30217] Replace ListState#clear along with following #add/addAll with a ListState#update

2023-09-07 Thread via GitHub
masteryhx closed pull request #23344: [FLINK-30217] Replace ListState#clear along with following #add/addAll with a ListState#update URL: https://github.com/apache/flink/pull/23344 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] swuferhong opened a new pull request, #23377: [FLINK-33064][table-planner] Improve the error message when the lookup source is used as the scan source

2023-09-07 Thread via GitHub
swuferhong opened a new pull request, #23377: URL: https://github.com/apache/flink/pull/23377 ## What is the purpose of the change Improve the error message when the lookup source is used as the scan source. Currently, if we use a source which only implement `LookupTab

[jira] [Commented] (FLINK-33055) Correct the error value about 'state.backend.type' in the document

2023-09-07 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762948#comment-17762948 ] Jinzhong Li commented on FLINK-33055: - hi,[~masteryhx] , I would like to take this t

[GitHub] [flink] JunRuiLee commented on pull request #23181: W.I.P only used to run ci.

2023-09-07 Thread via GitHub
JunRuiLee commented on PR #23181: URL: https://github.com/apache/flink/pull/23181#issuecomment-1711047440 @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] [Created] (FLINK-33064) Improve the error message when the lookup source is used as the scan source

2023-09-07 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-33064: - Summary: Improve the error message when the lookup source is used as the scan source Key: FLINK-33064 URL: https://issues.apache.org/jira/browse/FLINK-33064 Project

[jira] [Resolved] (FLINK-15922) Show "Warn - received late message for checkpoint" only when checkpoint actually expired

2023-09-07 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-15922. -- Fix Version/s: 1.19.0 Resolution: Fixed merged 80a8250176fb2b1d9809fcd47df6097fd53999f6

[GitHub] [flink] masteryhx closed pull request #23364: [FLINK-15922] Only remember expired checkpoints and log received late messages of those in CheckpointCoordinator

2023-09-07 Thread via GitHub
masteryhx closed pull request #23364: [FLINK-15922] Only remember expired checkpoints and log received late messages of those in CheckpointCoordinator URL: https://github.com/apache/flink/pull/23364 -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] xintongsong commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

2023-09-07 Thread via GitHub
xintongsong commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1319297747 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/PartitionFileReader.java: ## @@ -78,4 +87,79 @@ long getPriority(

[GitHub] [flink] flinkbot commented on pull request #23376: [FLINK-14032][state]Make the cache size of RocksDBPriorityQueueSetFactory configurable

2023-09-07 Thread via GitHub
flinkbot commented on PR #23376: URL: https://github.com/apache/flink/pull/23376#issuecomment-1711040369 ## CI report: * df6392d251e75003327ada3ba5d728ec98674ac6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

2023-09-07 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-33063: --- Assignee: Yunhong Zheng > udaf with user defined pojo object throw error while generate rec

[jira] [Commented] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

2023-09-07 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762946#comment-17762946 ] lincoln lee commented on FLINK-33063: - [~337361...@qq.com] assigned to you :) > uda

[GitHub] [flink] ljz2051 opened a new pull request, #23376: [FLINK-14032]Make the cache size of RocksDBPriorityQueueSetFactory configurable

2023-09-07 Thread via GitHub
ljz2051 opened a new pull request, #23376: URL: https://github.com/apache/flink/pull/23376 ## What is the purpose of the change This pull request make the cache size of RocksDBPriorityQueueSetFactory configurable. ## Brief change log - Pass the configurableOptions of Embedde

[GitHub] [flink] JunRuiLee commented on pull request #23181: W.I.P only used to run ci.

2023-09-07 Thread via GitHub
JunRuiLee commented on PR #23181: URL: https://github.com/apache/flink/pull/23181#issuecomment-1711032791 @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] JunRuiLee commented on pull request #23181: W.I.P only used to run ci.

2023-09-07 Thread via GitHub
JunRuiLee commented on PR #23181: URL: https://github.com/apache/flink/pull/23181#issuecomment-1711029547 @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] JunRuiLee commented on pull request #23181: W.I.P only used to run ci.

2023-09-07 Thread via GitHub
JunRuiLee commented on PR #23181: URL: https://github.com/apache/flink/pull/23181#issuecomment-1711027731 @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-33053) Watcher leak in Zookeeper HA mode

2023-09-07 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762936#comment-17762936 ] Yangze Guo commented on FLINK-33053: I reproduce the issue and filter out some logs.

[jira] [Updated] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-07 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33053: --- Attachment: 26.dump.zip > Watcher leak in Zookeeper HA mode > - > >

[jira] [Updated] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-07 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-33053: --- Attachment: 26.log > Watcher leak in Zookeeper HA mode > - > >

[GitHub] [flink] flinkbot commented on pull request #23375: Dev 0908 1101

2023-09-07 Thread via GitHub
flinkbot commented on PR #23375: URL: https://github.com/apache/flink/pull/23375#issuecomment-1711016903 ## CI report: * ac37fad2d9e939bd2dd3397de07f677b0931eaad UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] WencongLiu opened a new pull request, #23375: Dev 0908 1101

2023-09-07 Thread via GitHub
WencongLiu opened a new pull request, #23375: URL: https://github.com/apache/flink/pull/23375 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] mayuehappy commented on pull request #23169: [FLINK-31238] [WIP] Use IngestDB to speed up Rocksdb rescaling recovery

2023-09-07 Thread via GitHub
mayuehappy commented on PR #23169: URL: https://github.com/apache/flink/pull/23169#issuecomment-1711009736 > @mayuehappy I noticed that one required PR against RocksDB ([facebook/rocksdb#11646](https://github.com/facebook/rocksdb/pull/11646)) is still not merged and the conversation is stal

[GitHub] [flink] mayuehappy commented on pull request #23169: [FLINK-31238] [WIP] Use IngestDB to speed up Rocksdb rescaling recovery

2023-09-07 Thread via GitHub
mayuehappy commented on PR #23169: URL: https://github.com/apache/flink/pull/23169#issuecomment-1711007885 > It looks like we will need to bump RocksDB from 6.20.x to 8.5.x > > > 8.5.0-ververica-1.0-db-SNASHOT > > @curcur or @Myasuka , do you know if there are any known hurdles

[jira] [Commented] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

2023-09-07 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762932#comment-17762932 ] Yunhong Zheng commented on FLINK-33063: --- Hi, [~lincoln.86xy] . Can you assign this

[GitHub] [flink] flinkbot commented on pull request #23374: [FLINK-33063][table-runtime] Fix udaf with complex user defined pojo object throw error while generate record equaliser

2023-09-07 Thread via GitHub
flinkbot commented on PR #23374: URL: https://github.com/apache/flink/pull/23374#issuecomment-1711004891 ## CI report: * 52afe17fa1e4ac66fa3eb72bb9fc0d0159e2a631 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Zakelly commented on pull request #23364: [FLINK-15922] Only remember expired checkpoints and log received late messages of those in CheckpointCoordinator

2023-09-07 Thread via GitHub
Zakelly commented on PR #23364: URL: https://github.com/apache/flink/pull/23364#issuecomment-1711002566 @masteryhx Thanks for your comments. I changed my PR accordingly. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] swuferhong opened a new pull request, #23374: [FLINK-33063][table-planner] Fix udaf with complex user defined pojo object throw error while generate record equaliser

2023-09-07 Thread via GitHub
swuferhong opened a new pull request, #23374: URL: https://github.com/apache/flink/pull/23374 ## What is the purpose of the change When user create an udaf while recore contains user define complex pojo object (like List or Map). The codegen will throw error while gen

[jira] [Created] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

2023-09-07 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-33063: - Summary: udaf with user defined pojo object throw error while generate record equaliser Key: FLINK-33063 URL: https://issues.apache.org/jira/browse/FLINK-33063 Proj

[GitHub] [flink] WencongLiu commented on pull request #23362: [FLINK-33041][docs] Add an article to guide users to migrate their DataSet jobs to DataStream

2023-09-07 Thread via GitHub
WencongLiu commented on PR #23362: URL: https://github.com/apache/flink/pull/23362#issuecomment-1710989624 @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-32962) Failure to install python dependencies from requirements file

2023-09-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762927#comment-17762927 ] Dian Fu commented on FLINK-32962: - +1 to backport to Flink 1.17 and 1.18, especially Fli

[jira] [Assigned] (FLINK-32962) Failure to install python dependencies from requirements file

2023-09-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-32962: --- Assignee: Aleksandr Pilipenko > Failure to install python dependencies from requirements file > ---

[GitHub] [flink] 1996fanrui commented on pull request #23372: [FLINK-33042][flamegraph] Allow trigger flamegraph when task is initializing

2023-09-07 Thread via GitHub
1996fanrui commented on PR #23372: URL: https://github.com/apache/flink/pull/23372#issuecomment-1710983769 cc @RocMarshal -- 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] [Assigned] (FLINK-33061) Translate failure-enricher documentation to Chinese

2023-09-07 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33061: - Assignee: Matt Wang > Translate failure-enricher documentation to Chinese > ---

[jira] [Assigned] (FLINK-31895) End-to-end integration tests for failure labels

2023-09-07 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-31895: - Assignee: Matt Wang > End-to-end integration tests for failure labels > ---

[jira] [Created] (FLINK-33062) Deserialization creates multiple instances of case objects in Scala 2.13

2023-09-07 Thread SmedbergM (Jira)
SmedbergM created FLINK-33062: - Summary: Deserialization creates multiple instances of case objects in Scala 2.13 Key: FLINK-33062 URL: https://issues.apache.org/jira/browse/FLINK-33062 Project: Flink

[jira] [Updated] (FLINK-20628) Port RabbitMQ Sources to FLIP-27 API

2023-09-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20628: --- Labels: auto-deprioritized-major pull-request-available stale-assigned (was: auto-depriorit

[jira] [Updated] (FLINK-32509) avoid using skip in InputStreamFSInputWrapper.seek

2023-09-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32509: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available stal

[jira] [Updated] (FLINK-12869) Add yarn acls capability to flink containers

2023-09-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12869: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-31238) Use IngestDB to speed up Rocksdb rescaling recovery

2023-09-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31238: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-27402) Unexpected boolean expression simplification for AND expression

2023-09-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27402: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[GitHub] [flink] flinkbot commented on pull request #23373: [FLINK-30025][doc] improve the option description with more precise content

2023-09-07 Thread via GitHub
flinkbot commented on PR #23373: URL: https://github.com/apache/flink/pull/23373#issuecomment-1710829165 ## CI report: * 6251199a537a74a4f122b1d6139380b7da89de3c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] JingGe opened a new pull request, #23373: [FLINK-30025][doc] improve the option description with more precise content

2023-09-07 Thread via GitHub
JingGe opened a new pull request, #23373: URL: https://github.com/apache/flink/pull/23373 ## What is the purpose of the change improve the option description with more precise content ## Brief change log - SqlClientOptions - TableConfigOptions

[jira] [Commented] (FLINK-32906) Release Testing: Verify FLIP-279 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

2023-09-07 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762879#comment-17762879 ] Jing Ge commented on FLINK-32906: - [~liyubin117] e.g. means "for example", it does not n

[GitHub] [flink] pgaref commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
pgaref commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1318975346 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,106 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: advanc

[GitHub] [flink] pgaref commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
pgaref commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1318968366 ## docs/content.zh/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,106 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: adv

[GitHub] [flink] pgaref commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
pgaref commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1318966093 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,106 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: advanc

[GitHub] [flink] pgaref commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
pgaref commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1318964767 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,112 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: advanc

[GitHub] [flink] pgaref commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
pgaref commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1318963910 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,112 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: advanc

[GitHub] [flink] venkata91 commented on pull request #23313: [FLINK-20767][table planner] Support filter push down on nested fields

2023-09-07 Thread via GitHub
venkata91 commented on PR #23313: URL: https://github.com/apache/flink/pull/23313#issuecomment-171041 Also tagging @slinkydeveloper -- 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 specifi

[GitHub] [flink] venkata91 commented on pull request #23313: [FLINK-20767][table planner] Support filter push down on nested fields

2023-09-07 Thread via GitHub
venkata91 commented on PR #23313: URL: https://github.com/apache/flink/pull/23313#issuecomment-1710555055 @wuchong @swuferhong @JingsongLi @becketqin please review -- 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] zentol commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
zentol commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1318921748 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,112 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: advanc

[GitHub] [flink] zentol commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
zentol commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1318921748 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,112 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: advanc

[GitHub] [flink] zentol commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
zentol commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1318909983 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,106 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: advanc

[GitHub] [flink] zentol commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
zentol commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1318907314 ## docs/content.zh/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,106 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: adv

[GitHub] [flink] zentol commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
zentol commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1318902851 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,106 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: advanc

[GitHub] [flink] zentol commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
zentol commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1318898982 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,112 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: advanc

[GitHub] [flink] zentol commented on a diff in pull request #22468: [FLINK-31889] Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
zentol commented on code in PR #22468: URL: https://github.com/apache/flink/pull/22468#discussion_r1318898608 ## docs/content/docs/deployment/advanced/failure_enrichers.md: ## @@ -0,0 +1,112 @@ +--- +title: "Failure Enrichers" +nav-title: failure-enrichers +nav-parent_id: advanc

[jira] [Commented] (FLINK-32962) Failure to install python dependencies from requirements file

2023-09-07 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762807#comment-17762807 ] Hong Liang Teoh commented on FLINK-32962: - [~a.pilipenko]  should we also backpo

[jira] [Commented] (FLINK-32962) Failure to install python dependencies from requirements file

2023-09-07 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762805#comment-17762805 ] Hong Liang Teoh commented on FLINK-32962: - merged commit [{{1193e17}}|https://g

[GitHub] [flink] hlteoh37 merged pull request #23297: [FLINK-32962][python] Remove pip version check on installing dependencies.

2023-09-07 Thread via GitHub
hlteoh37 merged PR #23297: URL: https://github.com/apache/flink/pull/23297 -- 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.apac

[GitHub] [flink] pgaref commented on pull request #22468: FLINK-31889: Add documentation for implementing/loading enrichers

2023-09-07 Thread via GitHub
pgaref commented on PR #22468: URL: https://github.com/apache/flink/pull/22468#issuecomment-1710421376 > This needs a copy in the chinese version of the docs. (that may be in english; translation is a follow-up) Thanks for the review @zentol ! Addressed your comments, also created

[GitHub] [flink] flinkbot commented on pull request #23372: [FLINK-33042][flamegraph] Allow trigger flamegraph when task is initializing

2023-09-07 Thread via GitHub
flinkbot commented on PR #23372: URL: https://github.com/apache/flink/pull/23372#issuecomment-1710406803 ## CI report: * 5a37a649a983c2f23d4de33ccac525bd9ead16bb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] hlteoh37 commented on pull request #23297: [FLINK-32962][python] Remove pip version check on installing dependencies.

2023-09-07 Thread via GitHub
hlteoh37 commented on PR #23297: URL: https://github.com/apache/flink/pull/23297#issuecomment-1710397554 @JingGe @HuangXingBo Any thoughts on this? -- 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 t

[GitHub] [flink] 1996fanrui opened a new pull request, #23372: [FLINK-33042][flamegraph] Allow trigger flamegraph when task is initializing

2023-09-07 Thread via GitHub
1996fanrui opened a new pull request, #23372: URL: https://github.com/apache/flink/pull/23372 ## What is the purpose of the change Currently, the flamegraph can be triggered when task is running. After [FLINK-17012](https://issues.apache.org/jira/browse/FLINK-17012) and [FLINK-

[jira] [Commented] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-09-07 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762793#comment-17762793 ] Ryan Skraba commented on FLINK-33018: - I think I have a fix -- it looks like occasio

[jira] [Updated] (FLINK-15736) Support Java 17 (LTS)

2023-09-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-15736: -- Release Note: Apache Flink was made ready to compile and run with Java 17 (LTS). This feature

[jira] [Commented] (FLINK-33061) Translate failure-enricher documentation to Chinese

2023-09-07 Thread Panagiotis Garefalakis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762782#comment-17762782 ] Panagiotis Garefalakis commented on FLINK-33061: [~wangm92]  feel free t

[jira] [Updated] (FLINK-33061) Translate failure-enricher documentation to Chinese

2023-09-07 Thread Panagiotis Garefalakis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Panagiotis Garefalakis updated FLINK-33061: --- Summary: Translate failure-enricher documentation to Chinese (was: Translat

[jira] [Created] (FLINK-33061) Translate failure-enricher documentation

2023-09-07 Thread Panagiotis Garefalakis (Jira)
Panagiotis Garefalakis created FLINK-33061: -- Summary: Translate failure-enricher documentation Key: FLINK-33061 URL: https://issues.apache.org/jira/browse/FLINK-33061 Project: Flink

[jira] [Commented] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-09-07 Thread Jayadeep Jayaraman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762765#comment-17762765 ] Jayadeep Jayaraman commented on FLINK-33018: I ran it 23K times yesterday an

[jira] [Assigned] (FLINK-30649) Shutting down MiniCluster times out

2023-09-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-30649: - Assignee: (was: Matthias Pohl) > Shutting down MiniCluster times out >

[jira] [Commented] (FLINK-31889) Add documentation for implementing/loading enrichers

2023-09-07 Thread Matt Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762746#comment-17762746 ] Matt Wang commented on FLINK-31889: --- [~pgaref] if you create a ticket for chinese docu

[jira] [Updated] (FLINK-24943) SequenceNumber class is not POJO type

2023-09-07 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-24943: -- Fix Version/s: (was: 1.15.5) (was: 1.16.3) > SequenceNumber class i

[jira] [Commented] (FLINK-24943) SequenceNumber class is not POJO type

2023-09-07 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762736#comment-17762736 ] Danny Cranmer commented on FLINK-24943: --- [~Cyberness] can you please recreate this

[jira] [Commented] (FLINK-24943) SequenceNumber class is not POJO type

2023-09-07 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762731#comment-17762731 ] Danny Cranmer commented on FLINK-24943: --- [~martijnvisser] we will pick this up. Th

[jira] [Commented] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-09-07 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762728#comment-17762728 ] Ryan Skraba commented on FLINK-33018: - Hey, I can reproduce this -- all you need to

[jira] [Commented] (FLINK-31895) End-to-end integration tests for failure labels

2023-09-07 Thread Panagiotis Garefalakis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762718#comment-17762718 ] Panagiotis Garefalakis commented on FLINK-31895: Fine by me [~wangm92]  

[jira] [Commented] (FLINK-31895) End-to-end integration tests for failure labels

2023-09-07 Thread Matt Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762715#comment-17762715 ] Matt Wang commented on FLINK-31895: --- [~pgaref] I would like to take this ticket if pos

[GitHub] [flink] wangyang0918 commented on a diff in pull request #23164: [FLINK- 32775]Add parent dir of files to classpath using yarn.provided.lib.dirs

2023-09-07 Thread via GitHub
wangyang0918 commented on code in PR #23164: URL: https://github.com/apache/flink/pull/23164#discussion_r1318475489 ## flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java: ## @@ -360,11 +362,27 @@ List registerProvidedLocalResources() {

[jira] [Commented] (FLINK-33000) SqlGatewayServiceITCase should utilize TestExecutorExtension instead of using a ThreadFactory

2023-09-07 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762707#comment-17762707 ] Matthias Pohl commented on FLINK-33000: --- Hi [~ade_hddu], thanks for offering your

[jira] [Created] (FLINK-33060) Fix the javadoc of ListState.update/addAll about not allowing null value

2023-09-07 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-33060: --- Summary: Fix the javadoc of ListState.update/addAll about not allowing null value Key: FLINK-33060 URL: https://issues.apache.org/jira/browse/FLINK-33060 Project: Flink

[jira] [Assigned] (FLINK-33060) Fix the javadoc of ListState.update/addAll about not allowing null value

2023-09-07 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-33060: --- Assignee: Zakelly Lan > Fix the javadoc of ListState.update/addAll about not allowing null

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

2023-09-07 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762700#comment-17762700 ] Yangze Guo commented on FLINK-33053: Thanks for the pointer [~mapohl]. I'll try to g

[GitHub] [flink] flinkbot commented on pull request #23371: [FLINK-5865][state] Unwrapping exceptions and throw the original ones in state interfaces

2023-09-07 Thread via GitHub
flinkbot commented on PR #23371: URL: https://github.com/apache/flink/pull/23371#issuecomment-1709932341 ## CI report: * 4198ccb50d2dc4f18ed2ce1b3d57b2b04e96de32 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Zakelly opened a new pull request, #23371: [FLINK-5865][state] Unwrapping exceptions and throw the original ones in state interfaces

2023-09-07 Thread via GitHub
Zakelly opened a new pull request, #23371: URL: https://github.com/apache/flink/pull/23371 ## What is the purpose of the change Some implementations of state interfaces wrap the original exception and throw as FlinkRuntimeException. Since all the interfaces claim to throw Exception,

  1   2   >