Re: [PR] [FLINK-33632] Adding custom flink mutator [flink-kubernetes-operator]

2024-01-14 Thread via GitHub
gyfora commented on code in PR #733: URL: https://github.com/apache/flink-kubernetes-operator/pull/733#discussion_r1452023246 ## flink-kubernetes-webhook/src/main/java/org/apache/flink/kubernetes/operator/admission/mutator/FlinkMutator.java: ## @@ -17,55 +17,82 @@ package or

[jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Khanh Vu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Khanh Vu updated FLINK-34076: - Description: The following issue encounters with flink-kinesis-connector v4.2.0, Flink 1.17, it's worki

[jira] [Commented] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Khanh Vu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806669#comment-17806669 ] Khanh Vu commented on FLINK-34076: -- Hi [~jiabao.sun], Yes, if I have `flink-connector-b

Re: [PR] [FLINK-33268][rest] Skip unknown fields in REST response deserialization [flink]

2024-01-14 Thread via GitHub
gyfora commented on PR #23930: URL: https://github.com/apache/flink/pull/23930#issuecomment-1891493012 Looks good @gaborgsomogyi 🚢 -- 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 co

[jira] [Commented] (FLINK-33998) Flink Job Manager restarted after kube-apiserver connection intermittent

2024-01-14 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806664#comment-17806664 ] Matthias Pohl commented on FLINK-33998: --- I couldn't find anything that sounds rela

Re: [PR] [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel [flink]

2024-01-14 Thread via GitHub
yunfengzhou-hub commented on code in PR #23927: URL: https://github.com/apache/flink/pull/23927#discussion_r1452012771 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java: ## @@ -69,10 +69,10 @@ default void notifyPriorityEven

Re: [PR] [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel [flink]

2024-01-14 Thread via GitHub
yunfengzhou-hub commented on code in PR #23927: URL: https://github.com/apache/flink/pull/23927#discussion_r1452009484 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionIndexSet.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache

[jira] [Assigned] (FLINK-34078) Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package

2024-01-14 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-34078: Assignee: Jinzhong Li > Move InternalKeyContext classes from o.a.f.runtime.state.heap to

[jira] [Updated] (FLINK-34081) Refactor all callers that using the public Xxx getXxx(ConfigOption configOption) and public void setXxx(ConfigOption key, Xxx value)

2024-01-14 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34081: Description: FLINK-34080 deprecate some methods of Configuration, we should refactor all callers of depre

[jira] [Commented] (FLINK-34078) Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package

2024-01-14 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806660#comment-17806660 ] Hangxiang Yu commented on FLINK-34078: -- Thanks for reporting this. It makes sense

[jira] [Assigned] (FLINK-34083) Deprecate string configuration keys and unused constants in ConfigConstants

2024-01-14 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34083: --- Assignee: Xuannan Su > Deprecate string configuration keys and unused constants in ConfigConstants

[jira] [Assigned] (FLINK-34084) Deprecate unused configuration in BinaryInput/OutputFormat and FileInput/OutputFormat

2024-01-14 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34084: --- Assignee: Xuannan Su > Deprecate unused configuration in BinaryInput/OutputFormat and > FileInput/

[jira] [Assigned] (FLINK-34050) Rocksdb state has space amplification after rescaling with DeleteRange

2024-01-14 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-34050: Assignee: Jinzhong Li > Rocksdb state has space amplification after rescaling with Delete

[jira] [Assigned] (FLINK-34085) Remove deprecated string configuration keys in Flink 2.0

2024-01-14 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34085: --- Assignee: Xuannan Su > Remove deprecated string configuration keys in Flink 2.0 > -

[jira] [Commented] (FLINK-34050) Rocksdb state has space amplification after rescaling with DeleteRange

2024-01-14 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806659#comment-17806659 ] Hangxiang Yu commented on FLINK-34050: -- [~lijinzhong] Yeah, I think this benchmark

Re: [PR] [FLINK-24024][table-planner] support session window tvf in plan [flink]

2024-01-14 Thread via GitHub
LadyForest commented on code in PR #23505: URL: https://github.com/apache/flink/pull/23505#discussion_r1448461452 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowUtil.scala: ## @@ -234,11 +238,71 @@ object WindowUtil { v

[jira] [Created] (FLINK-34085) Remove deprecated string configuration keys in Flink 2.0

2024-01-14 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-34085: -- Summary: Remove deprecated string configuration keys in Flink 2.0 Key: FLINK-34085 URL: https://issues.apache.org/jira/browse/FLINK-34085 Project: Flink Issue Ty

[jira] [Created] (FLINK-34084) Deprecate unused configuration in BinaryInput/OutputFormat and FileInput/OutputFormat

2024-01-14 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-34084: -- Summary: Deprecate unused configuration in BinaryInput/OutputFormat and FileInput/OutputFormat Key: FLINK-34084 URL: https://issues.apache.org/jira/browse/FLINK-34084 Pro

Re: [PR] [FLINK-33689][table-runtime] Fix JsonObjectAggFunction can't retract records when enabling LocalGlobal. [flink]

2024-01-14 Thread via GitHub
xishuaidelin commented on code in PR #23827: URL: https://github.com/apache/flink/pull/23827#discussion_r1451985731 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/JsonObjectAggFunction.java: ## @@ -128,6 +137,15 @@ public void

[jira] [Created] (FLINK-34083) Deprecate string configuration keys and unused constants in ConfigConstants

2024-01-14 Thread Xuannan Su (Jira)
Xuannan Su created FLINK-34083: -- Summary: Deprecate string configuration keys and unused constants in ConfigConstants Key: FLINK-34083 URL: https://issues.apache.org/jira/browse/FLINK-34083 Project: Flin

Re: [PR] [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel [flink]

2024-01-14 Thread via GitHub
reswqa commented on code in PR #23927: URL: https://github.com/apache/flink/pull/23927#discussion_r1450161095 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedSequenceNumberingViewReader.java: ## @@ -291,13 +291,18 @@ public void releaseAllReso

Re: [PR] [FLINK-34080][configuration] Simplify the Configuration [flink]

2024-01-14 Thread via GitHub
flinkbot commented on PR #24088: URL: https://github.com/apache/flink/pull/24088#issuecomment-1891392365 ## CI report: * 39fc4c7369deceabffb7bc2496300e8a8061faba UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-34080][configuration] Simplify the Configuration [flink]

2024-01-14 Thread via GitHub
1996fanrui opened a new pull request, #24088: URL: https://github.com/apache/flink/pull/24088 ## What is the purpose of the change See the part 2.2 of [FLIP-405](https://cwiki.apache.org/confluence/x/6Yr5E) ## Brief change log - [FLINK-34080][configuration] Add the `T

[jira] [Updated] (FLINK-34080) Simplify the Configuration

2024-01-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34080: --- Labels: pull-request-available (was: ) > Simplify the Configuration > -

[jira] [Updated] (FLINK-34077) Python Sphinx version error

2024-01-14 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-34077: - Issue Type: Technical Debt (was: Bug) > Python Sphinx version error > -

[jira] [Updated] (FLINK-34077) Python Sphinx version error

2024-01-14 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-34077: - Summary: Python Sphinx version error (was: Sphinx version needs upgrade) > Python Sphinx versio

[jira] [Resolved] (FLINK-34077) Sphinx version needs upgrade

2024-01-14 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang resolved FLINK-34077. -- Resolution: Fixed Merged into master via d2fbe464b1a353a7eb35926299d5c048647a3073 > Sphinx ve

Re: [PR] [FLINK-34077][python] Limits some sphinxcontrib packages upper bounds [flink]

2024-01-14 Thread via GitHub
HuangXingBo merged PR #24086: URL: https://github.com/apache/flink/pull/24086 -- 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] [Commented] (FLINK-33728) do not rewatch when KubernetesResourceManagerDriver watch fail

2024-01-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806641#comment-17806641 ] Xintong Song commented on FLINK-33728: -- Sure, thanks for volunteering working on th

[jira] [Assigned] (FLINK-33728) do not rewatch when KubernetesResourceManagerDriver watch fail

2024-01-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-33728: Assignee: xiaogang zhou > do not rewatch when KubernetesResourceManagerDriver watch fail

Re: [PR] [FLINK-34077][python] Limits some sphinxcontrib packages upper bounds [flink]

2024-01-14 Thread via GitHub
HuangXingBo commented on PR #24086: URL: https://github.com/apache/flink/pull/24086#issuecomment-1891366044 https://dev.azure.com/hxbks2ks/FLINK-TEST/_build/results?buildId=2214&view=logs&j=fba17979-6d2e-591d-72f1-97cf42797c11 -- This is an automated message from the Apache Git Service.

[jira] [Updated] (FLINK-34080) Simplify the Configuration

2024-01-14 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34080: Priority: Blocker (was: Major) > Simplify the Configuration > -- > >

[jira] [Created] (FLINK-34082) Remove deprecated methods of Configuration in 2.0

2024-01-14 Thread Rui Fan (Jira)
Rui Fan created FLINK-34082: --- Summary: Remove deprecated methods of Configuration in 2.0 Key: FLINK-34082 URL: https://issues.apache.org/jira/browse/FLINK-34082 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34081) Refactor all callers that using the public Xxx getXxx(ConfigOption configOption) and public void setXxx(ConfigOption key, Xxx value)

2024-01-14 Thread Rui Fan (Jira)
Rui Fan created FLINK-34081: --- Summary: Refactor all callers that using the public Xxx getXxx(ConfigOption configOption) and public void setXxx(ConfigOption key, Xxx value) Key: FLINK-34081 URL: https://issues.apache.

[jira] [Created] (FLINK-34080) Simplify the Configuration

2024-01-14 Thread Rui Fan (Jira)
Rui Fan created FLINK-34080: --- Summary: Simplify the Configuration Key: FLINK-34080 URL: https://issues.apache.org/jira/browse/FLINK-34080 Project: Flink Issue Type: Sub-task Components: R

[jira] [Commented] (FLINK-33728) do not rewatch when KubernetesResourceManagerDriver watch fail

2024-01-14 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806640#comment-17806640 ] xiaogang zhou commented on FLINK-33728: --- [~xtsong] [~wangyang0918] Ok, glad to hea

[jira] [Created] (FLINK-34079) FLIP-405: Migrate string configuration key to ConfigOption

2024-01-14 Thread Rui Fan (Jira)
Rui Fan created FLINK-34079: --- Summary: FLIP-405: Migrate string configuration key to ConfigOption Key: FLINK-34079 URL: https://issues.apache.org/jira/browse/FLINK-34079 Project: Flink Issue Type:

[jira] [Created] (FLINK-34078) Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package

2024-01-14 Thread Jinzhong Li (Jira)
Jinzhong Li created FLINK-34078: --- Summary: Move InternalKeyContext classes from o.a.f.runtime.state.heap to o.a.f.runtime.state package Key: FLINK-34078 URL: https://issues.apache.org/jira/browse/FLINK-34078

Re: [PR] [FLINK-33576][core] Introduce new Flink conf file 'config.yaml' supporting standard YAML syntax. [flink]

2024-01-14 Thread via GitHub
JunRuiLee commented on PR #23852: URL: https://github.com/apache/flink/pull/23852#issuecomment-1891254763 @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-32978) Deprecate RichFunction#open(Configuration parameters)

2024-01-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-32978. Resolution: Fixed Breaking changes reverted. master (1.19): 1d6150f386d9c9ec61f4ab30853b915de77120

Re: [PR] [hotfix] Revert the breaking change to the public implementations of RichFunction [flink]

2024-01-14 Thread via GitHub
xintongsong closed pull request #24067: [hotfix] Revert the breaking change to the public implementations of RichFunction URL: https://github.com/apache/flink/pull/24067 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-27756) Fix intermittently failing test in AsyncSinkWriterTest.checkLoggedSendTimesAreWithinBounds

2024-01-14 Thread Junrui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806608#comment-17806608 ] Junrui Li commented on FLINK-27756: --- https://dev.azure.com/apache-flink/apache-flink/_

Re: [PR] [FLINK-33980][core] Reorganize job configuration [flink]

2024-01-14 Thread via GitHub
JunRuiLee commented on code in PR #24025: URL: https://github.com/apache/flink/pull/24025#discussion_r1451894290 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -792,7 +792,11 @@ public CompletableFuture disposeSavepoint(String savepoin

Re: [PR] [FLINK-33980][core] Reorganize job configuration [flink]

2024-01-14 Thread via GitHub
JunRuiLee commented on code in PR #24025: URL: https://github.com/apache/flink/pull/24025#discussion_r1451892446 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointAfterAllTasksFinishedITCase.java: ## @@ -82,7 +83,8 @@ public void setUp() { @Test

[jira] [Commented] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806605#comment-17806605 ] Jiabao Sun commented on FLINK-34076: Hi [~khanhvu], do you add dependencies with "pr

[jira] [Resolved] (FLINK-33792) Generate the same code for the same logic

2024-01-14 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li resolved FLINK-33792. Fix Version/s: 1.19.0 Resolution: Fixed Implemented via d26c1b668b7febc60aab1e4174f568958cd

Re: [PR] [FLINK-33768] Support dynamic source parallelism inference for batch jobs [flink]

2024-01-14 Thread via GitHub
flinkbot commented on PR #24087: URL: https://github.com/apache/flink/pull/24087#issuecomment-1891229367 ## CI report: * e81e5b792e05f208b281274fde872a8ca0035253 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-33792] Generate the same code for the same logic [flink]

2024-01-14 Thread via GitHub
libenchao closed pull request #23984: [FLINK-33792] Generate the same code for the same logic URL: https://github.com/apache/flink/pull/23984 -- 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 spec

[jira] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076 ] Jiabao Sun deleted comment on FLINK-34076: was (Author: jiabao.sun): Hi [~khanhvu], do you add dependencies with "provided" scope to classpath? !screenshot-1.png! > flink-connector-base m

[jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiabao Sun updated FLINK-34076: --- Attachment: screenshot-1.png > flink-connector-base missing fails kinesis table sink to create > ---

[jira] [Commented] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Jiabao Sun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806603#comment-17806603 ] Jiabao Sun commented on FLINK-34076: Hi [~khanhvu], do you add dependencies with "pr

[PR] [FLINK-33768] Support dynamic source parallelism inference for batch jobs [flink]

2024-01-14 Thread via GitHub
SinBex opened a new pull request, #24087: URL: https://github.com/apache/flink/pull/24087 ## What is the purpose of the change Currently, for JobVertices without parallelism configured, the AdaptiveBatchScheduler dynamically infers the vertex parallelism based on the volume of input

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

2024-01-14 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806600#comment-17806600 ] Yang Wang commented on FLINK-34007: --- Maybe I did not make myself clear. I mean the old

[jira] [Commented] (FLINK-34050) Rocksdb state has space amplification after rescaling with DeleteRange

2024-01-14 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806599#comment-17806599 ] Jinzhong Li commented on FLINK-34050: - Thanks for your reply. [~mayuehappy]   [~mast

Re: [PR] [FLINK-33768] Support dynamic source parallelism inference for batch jobs [flink]

2024-01-14 Thread via GitHub
SinBex closed pull request #24078: [FLINK-33768] Support dynamic source parallelism inference for batch jobs URL: https://github.com/apache/flink/pull/24078 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[jira] [Updated] (FLINK-34035) when flinksql with group by partition field, some errors occured in jobmanager.log

2024-01-14 Thread hansonhe (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hansonhe updated FLINK-34035: - Summary: when flinksql with group by partition field, some errors occured in jobmanager.log (was: when

Re: [PR] [FLINK-34077][python] Limits some sphinxcontrib packages upper bounds [flink]

2024-01-14 Thread via GitHub
flinkbot commented on PR #24086: URL: https://github.com/apache/flink/pull/24086#issuecomment-1891216727 ## CI report: * 0e96556bd28f20a0e60008df3c9ceabd00598a3d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34077) Sphinx version needs upgrade

2024-01-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34077: --- Labels: pull-request-available (was: ) > Sphinx version needs upgrade > ---

[PR] [FLINK-34077][python] Limits some sphinxcontrib packages upper bounds [flink]

2024-01-14 Thread via GitHub
HuangXingBo opened a new pull request, #24086: URL: https://github.com/apache/flink/pull/24086 ## What is the purpose of the change *This pull request will limit some sphinxcontrib packages upper bounds* ## Brief change log - *Limits some sphinxcontrib packages uppe

Re: [PR] [FLINK-34049][table]Refactor classes related to window TVF aggregation to prepare for non-aligned windows [flink]

2024-01-14 Thread via GitHub
xuyangzhong commented on PR #24068: URL: https://github.com/apache/flink/pull/24068#issuecomment-1891209495 The CI failure is caused by https://issues.apache.org/jira/browse/FLINK-34077 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-33998) Flink Job Manager restarted after kube-apiserver connection intermittent

2024-01-14 Thread Xiangyan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806596#comment-17806596 ] Xiangyan commented on FLINK-33998: -- I can't reproduce it in 1.14.6. May I know where ca

[jira] [Commented] (FLINK-34077) Sphinx version needs upgrade

2024-01-14 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806595#comment-17806595 ] Xingbo Huang commented on FLINK-34077: -- Some sphinxcontrib(sphinxcontrib-applehelp,

[jira] [Assigned] (FLINK-34077) Sphinx version needs upgrade

2024-01-14 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-34077: Assignee: Xingbo Huang > Sphinx version needs upgrade > > >

[jira] [Resolved] (FLINK-33057) Add options to disable creating job-id subdirectories under the checkpoint directory

2024-01-14 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-33057. -- Fix Version/s: 1.19.0 Resolution: Fixed merged 73b036c3 into master > Add options to d

[jira] [Commented] (FLINK-33728) do not rewatch when KubernetesResourceManagerDriver watch fail

2024-01-14 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806592#comment-17806592 ] Yang Wang commented on FLINK-33728: --- Not only the {{KubernetesResourceManagerDriver}}

Re: [PR] [FLINK-33057][Checkpointing] Add options to disable creating job-id subdirectories under the checkpoint directory [flink]

2024-01-14 Thread via GitHub
masteryhx closed pull request #23509: [FLINK-33057][Checkpointing] Add options to disable creating job-id subdirectories under the checkpoint directory URL: https://github.com/apache/flink/pull/23509 -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[jira] [Closed] (FLINK-33879) Hybrid Shuffle may stop working for a while during redistribution

2024-01-14 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33879. -- Resolution: Fixed master(1.19) via 879509d7ca886f8f0ed4dd966e859d3c2a5aa231. > Hybrid Shuffle may sto

Re: [PR] [FLINK-33879] Avoids the potential hang of Hybrid Shuffle during redistribution [flink]

2024-01-14 Thread via GitHub
reswqa merged PR #23957: URL: https://github.com/apache/flink/pull/23957 -- 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.apache

[jira] [Resolved] (FLINK-30613) Improve resolving schema compatibility -- Milestone one

2024-01-14 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-30613. -- Resolution: Fixed merged 13921a08...0e5de813 into master > Improve resolving schema compatibi

Re: [PR] [FLINK-30613] Improve resolving schema compatibility -- Milestone one [flink]

2024-01-14 Thread via GitHub
masteryhx closed pull request #21635: [FLINK-30613] Improve resolving schema compatibility -- Milestone one URL: https://github.com/apache/flink/pull/21635 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[jira] [Commented] (FLINK-33728) do not rewatch when KubernetesResourceManagerDriver watch fail

2024-01-14 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806586#comment-17806586 ] Xintong Song commented on FLINK-33728: -- Sorry for the late reply, I was distracted

[jira] [Commented] (FLINK-34077) Sphinx version needs upgrade

2024-01-14 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806581#comment-17806581 ] xuyang commented on FLINK-34077: https://dev.azure.com/apache-flink/apache-flink/_build/

[jira] [Updated] (FLINK-34077) Sphinx version needs upgrade

2024-01-14 Thread Yunfeng Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunfeng Zhou updated FLINK-34077: - Description: [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=56357&view=

[jira] [Created] (FLINK-34077) Sphinx version needs upgrade

2024-01-14 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-34077: Summary: Sphinx version needs upgrade Key: FLINK-34077 URL: https://issues.apache.org/jira/browse/FLINK-34077 Project: Flink Issue Type: Bug Compon

[jira] [Commented] (FLINK-34063) When snapshot compression is enabled, rescaling of a source operator leads to some splits getting lost

2024-01-14 Thread Yang LI (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806520#comment-17806520 ] Yang LI commented on FLINK-34063: - Ok [~dmvk] , I'll do it > When snapshot compression

Re: [PR] [FLINK-33980][core] Reorganize job configuration [flink]

2024-01-14 Thread via GitHub
zhuzhurk commented on code in PR #24025: URL: https://github.com/apache/flink/pull/24025#discussion_r1451774802 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java: ## @@ -140,7 +140,7 @@ public StreamGraph( ExecutionConfig ex

Re: [PR] [FLINK-33980][core] Reorganize job configuration [flink]

2024-01-14 Thread via GitHub
zhuzhurk commented on code in PR #24025: URL: https://github.com/apache/flink/pull/24025#discussion_r1451772433 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointAfterAllTasksFinishedITCase.java: ## @@ -82,7 +83,8 @@ public void setUp() { @Test

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-14 Thread via GitHub
jeyhunkarimov commented on PR #23470: URL: https://github.com/apache/flink/pull/23470#issuecomment-189017 Hi @JingGe @xuyangzhong thanks for your reviews. I updated the PR addressing your comments. I think the CI failure is not related to this PR -- This is an automated message from t

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-14 Thread via GitHub
jeyhunkarimov commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1451764950 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -50,14 +51,23 @@ cl

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-14 Thread via GitHub
jeyhunkarimov commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1451763272 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -50,14 +51,23 @@ cl

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-14 Thread via GitHub
jeyhunkarimov commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1451763251 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -50,14 +51,23 @@ cl

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-14 Thread via GitHub
jeyhunkarimov commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1451763129 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -50,14 +51,23 @@ cl

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-14 Thread via GitHub
jeyhunkarimov commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1451762837 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/analyze/MiniBatchOptimizationTest.java: ## @@ -0,0 +1,169 @@ +/* + * Licensed to t

[jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Khanh Vu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Khanh Vu updated FLINK-34076: - Description: The [commit|https://github.com/apache/flink-connector-aws/commit/01f112bd5a69f95cd5d2a4bc7

[jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Khanh Vu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Khanh Vu updated FLINK-34076: - Description: The [commit|https://github.com/apache/flink-connector-aws/commit/01f112bd5a69f95cd5d2a4bc7

Re: [PR] [FLINK-33741]Expose Rocksdb Histogram statistics in Flink metrics [flink]

2024-01-14 Thread via GitHub
flinkbot commented on PR #24050: URL: https://github.com/apache/flink/pull/24050#issuecomment-1890987057 ## CI report: * 64ca2d0a5711ffa6a5121db073fbeceaba9178b6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Khanh Vu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Khanh Vu updated FLINK-34076: - Description: The [commit|https://github.com/apache/flink-connector-aws/commit/01f112bd5a69f95cd5d2a4bc7

[jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Khanh Vu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Khanh Vu updated FLINK-34076: - Description: The [commit|https://github.com/apache/flink-connector-aws/commit/01f112bd5a69f95cd5d2a4bc7

[jira] [Updated] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Khanh Vu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Khanh Vu updated FLINK-34076: - Description: The [commit|https://github.com/apache/flink-connector-aws/commit/01f112bd5a69f95cd5d2a4bc7

[jira] [Created] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-14 Thread Khanh Vu (Jira)
Khanh Vu created FLINK-34076: Summary: flink-connector-base missing fails kinesis table sink to create Key: FLINK-34076 URL: https://issues.apache.org/jira/browse/FLINK-34076 Project: Flink Issu

Re: [PR] [FLINK-33741]Expose Rocksdb Histogram statistics in Flink metrics [flink]

2024-01-14 Thread via GitHub
Myasuka commented on code in PR #24050: URL: https://github.com/apache/flink/pull/24050#discussion_r1451751194 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBNativeMetricOptions.java: ## @@ -302,6 +303,20 @@ publi

Re: [PR] [FLINK-34072][scripts] Replace java command to JAVA_RUN in config.sh [flink]

2024-01-14 Thread via GitHub
flinkbot commented on PR #24085: URL: https://github.com/apache/flink/pull/24085#issuecomment-1890975682 ## CI report: * 6b6151ac82aa466850d93eefd7951e1fd65ca01b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34072) Use JAVA_RUN in shell scripts

2024-01-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34072: --- Labels: pull-request-available (was: ) > Use JAVA_RUN in shell scripts > --

[PR] [FLINK-34072][scripts] Replace java command to JAVA_RUN in config.sh [flink]

2024-01-14 Thread via GitHub
yuchen-ecnu opened a new pull request, #24085: URL: https://github.com/apache/flink/pull/24085 ## What is the purpose of the change Replace the `java` command with `JAVA_RUN` in scripts. ## Brief change log - Replace `java` with `JAVA_RUN` in config.sh ## V

Re: [PR] [FLINK-33057][Checkpointing] Add options to disable creating job-id subdirectories under the checkpoint directory [flink]

2024-01-14 Thread via GitHub
Zakelly commented on PR #23509: URL: https://github.com/apache/flink/pull/23509#issuecomment-1890974314 > Thanks for the update. Current PR LGTM % the conflict. Could you rebase all commits into master to resolve the conflict ? BTW, please remember to rename the title with component tag.

Re: [PR] [FLINK-33057] Add options to disable creating job-id subdirectories under the checkpoint directory [flink]

2024-01-14 Thread via GitHub
Myasuka commented on code in PR #23509: URL: https://github.com/apache/flink/pull/23509#discussion_r1451744345 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/MemoryBackendCheckpointStorageAccess.java: ## @@ -72,6 +73,7 @@ public MemoryBackendCheckpointStora

[jira] [Commented] (FLINK-34072) Use JAVA_RUN in shell scripts

2024-01-14 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34072?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806474#comment-17806474 ] Yun Tang commented on FLINK-34072: -- [~Yu Chen] Already assigned, please go ahead. > Us

[jira] [Assigned] (FLINK-34072) Use JAVA_RUN in shell scripts

2024-01-14 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-34072: Assignee: Yu Chen > Use JAVA_RUN in shell scripts > - > >

[jira] [Assigned] (FLINK-33839) Deploy Python artifacts to PyPI (need PMC role)

2024-01-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-33839: --- Assignee: (was: Jing Ge) > Deploy Python artifacts to PyPI (need PMC role) > --

[jira] [Assigned] (FLINK-33840) Deploy artifacts to Maven Central Repository (need PMC role)

2024-01-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-33840: --- Assignee: (was: Jing Ge) > Deploy artifacts to Maven Central Repository (need PMC role) > -

  1   2   >