[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764514#comment-17764514
]
Martijn Visser commented on FLINK-31788:
Thanks for driving this [~qingyue]
> A
[
https://issues.apache.org/jira/browse/FLINK-33013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun closed FLINK-33013.
--
Resolution: Won't Do
> Shade flink-connector-base info flink-sql-connector-connector
> ---
[
https://issues.apache.org/jira/browse/FLINK-33013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764511#comment-17764511
]
Hang Ruan commented on FLINK-33013:
---
Hi,all. I think we should reject this issue and k
[
https://issues.apache.org/jira/browse/FLINK-33013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764512#comment-17764512
]
Jiabao Sun commented on FLINK-33013:
Thanks [~ruanhang1993], it make sense to me.
A
Jiabao-Sun closed pull request #15: [FLINK-33013][connectors/mongodb] Shade
flink-connector-base into flink-sql-connector-mongodb
URL: https://github.com/apache/flink-connector-mongodb/pull/15
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
[
https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764510#comment-17764510
]
Hang Ruan commented on FLINK-30400:
---
Hi, all. I would like to help to check. Thanks.
[
https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764503#comment-17764503
]
Kwangin (Dennis) Jung edited comment on FLINK-28758 at 9/13/23 6:33 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-28758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764503#comment-17764503
]
Kwangin (Dennis) Jung commented on FLINK-28758:
---
[~dwysakowicz] [~markcho]
[
https://issues.apache.org/jira/browse/FLINK-33079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fangliang Liu updated FLINK-33079:
--
Description:
The gap between the checkpoint timeout and the interval settings is too large
in
[
https://issues.apache.org/jira/browse/FLINK-33079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fangliang Liu updated FLINK-33079:
--
Summary: The gap between the checkpoint timeout and the interval settings
is too large in the
gyfora commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1324028361
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java:
##
@@ -420,13 +421,24 @@ private void se
[
https://issues.apache.org/jira/browse/FLINK-33079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fangliang Liu updated FLINK-33079:
--
Description:
The gap between the checkpoint timeout and the interval settings is too large
So
[
https://issues.apache.org/jira/browse/FLINK-33079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fangliang Liu updated FLINK-33079:
--
Description:
The gap between the checkpoint timeout and the interval settings is too large
ht
[
https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-14032.
--
Fix Version/s: 1.19.0
(was: 1.18.0)
Resolution: Fixed
merged 367
masteryhx closed pull request #23376: [FLINK-14032][state]Make the cache size
of RocksDBPriorityQueueSetFactory configurable
URL: https://github.com/apache/flink/pull/23376
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-33079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fangliang Liu updated FLINK-33079:
--
Attachment: image-2023-09-13-14-19-05-493.png
> The gap between the checkpoint timeout and the
[
https://issues.apache.org/jira/browse/FLINK-33079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fangliang Liu updated FLINK-33079:
--
Attachment: image-2023-09-13-14-17-12-718.png
> The gap between the checkpoint timeout and the
Fangliang Liu created FLINK-33079:
-
Summary: The gap between the checkpoint timeout and the interval
settings is too large
Key: FLINK-33079
URL: https://issues.apache.org/jira/browse/FLINK-33079
Proje
venkata91 commented on code in PR #23313:
URL: https://github.com/apache/flink/pull/23313#discussion_r1324012808
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRuleTest.java:
##
@@ -86,6 +86,39 @@ p
zhongqishang closed pull request #20570: [hotfix][docs] Fix typos in java doc
URL: https://github.com/apache/flink/pull/20570
--
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
[
https://issues.apache.org/jira/browse/FLINK-33064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-33064:
-
Assignee: Yunhong Zheng
> Improve the error message when the lookup source is used as t
[
https://issues.apache.org/jira/browse/FLINK-33064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764498#comment-17764498
]
Shengkai Fang commented on FLINK-33064:
---
Merged into master: be509e6d67471d886e58d
[
https://issues.apache.org/jira/browse/FLINK-33064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-33064.
-
Resolution: Fixed
> Improve the error message when the lookup source is used as the scan source
reswqa commented on code in PR #23404:
URL: https://github.com/apache/flink/pull/23404#discussion_r1324007518
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/writer/BroadcastRecordWriterTest.java:
##
@@ -132,35 +132,34 @@ public void testRandomEmitAndBuffe
[
https://issues.apache.org/jira/browse/FLINK-33051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764496#comment-17764496
]
Panagiotis Garefalakis commented on FLINK-33051:
Hey [~wangm92] – I alr
huwh commented on code in PR #23399:
URL: https://github.com/apache/flink/pull/23399#discussion_r1323974700
##
docs/content/docs/deployment/advanced/failure_enrichers.md:
##
@@ -42,7 +42,7 @@ To implement a custom FailureEnricher plugin, you need to:
Then, create a jar which
flinkbot commented on PR #23406:
URL: https://github.com/apache/flink/pull/23406#issuecomment-1716944631
## CI report:
* 291433141e0c930c751c3e990a159b1f1ab9823c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32884:
---
Labels: pull-request-available (was: )
> PyFlink remote execution should support URLs with
elkhand opened a new pull request, #23406:
URL: https://github.com/apache/flink/pull/23406
[FLINK-32884](https://issues.apache.org/jira/browse/FLINK-32884) PyFlink
remote execution should support URLs with paths and https scheme
## What is the purpose of the change
Currently, t
Jiabao-Sun commented on code in PR #15:
URL:
https://github.com/apache/flink-connector-mongodb/pull/15#discussion_r1323965537
##
flink-sql-connector-mongodb/pom.xml:
##
@@ -60,6 +60,10 @@ under the License.
Jiabao-Sun commented on code in PR #15:
URL:
https://github.com/apache/flink-connector-mongodb/pull/15#discussion_r1323965389
##
flink-sql-connector-mongodb/pom.xml:
##
@@ -60,6 +60,10 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764484#comment-17764484
]
Yuan Mei edited comment on FLINK-33052 at 9/13/23 4:44 AM:
---
Le
[
https://issues.apache.org/jira/browse/FLINK-32884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elkhan Dadashov updated FLINK-32884:
Description:
Currently, the `SUBMIT_ARGS=remote -m http://:` format. For
local execution
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764485#comment-17764485
]
lincoln lee commented on FLINK-31788:
-
[~qingyue] assigned to you.
> Add back Suppo
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-31788:
---
Assignee: Jane Chan
> Add back Support emitValueWithRetract for TableAggregateFunction
> --
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764484#comment-17764484
]
Yuan Mei commented on FLINK-33052:
--
Let me see whether i can get a new machine for this
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei reassigned FLINK-33052:
Assignee: Yuan Mei (was: Yanfei Lei)
> codespeed server is down
>
>
>
swuferhong commented on code in PR #23313:
URL: https://github.com/apache/flink/pull/23313#discussion_r1323892173
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/RexNodeExtractor.scala:
##
@@ -395,9 +397,19 @@ class RexNodeToExpression
[
https://issues.apache.org/jira/browse/FLINK-33034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-33034.
--
Fix Version/s: 1.19.0
Resolution: Fixed
merged 36b9da50da9405b5b79f0d4da9393921982ab040
huwh commented on code in PR #23386:
URL: https://github.com/apache/flink/pull/23386#discussion_r1323944084
##
flink-runtime/src/test/java/org/apache/flink/runtime/failure/FailureEnricherUtilsTest.java:
##
@@ -109,6 +109,15 @@ public void testGetFailureEnrichers() {
ass
masteryhx closed pull request #23355: [FLINK-33034][runtime] Correct ValueState
creating for StateBackendTestBase#testGetKeysAndNamespaces
URL: https://github.com/apache/flink/pull/23355
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
morhidi commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1323925122
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilderTest.java:
##
@@ -478,6 +478,50 @@ public void
morhidi commented on PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#issuecomment-1716915082
What happens when users overwrite the configuration with standard memory
parameters? Could you please handle these cases and cover with tests?
--
This is an automated m
[
https://issues.apache.org/jira/browse/FLINK-23411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu updated FLINK-23411:
-
Component/s: Runtime / Checkpointing
> Expose Flink checkpoint details metrics
> ---
morhidi commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1323925122
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilderTest.java:
##
@@ -478,6 +478,50 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-23411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764477#comment-17764477
]
Hangxiang Yu commented on FLINK-23411:
--
Thanks for the quick reply.
{quote}Anyway,
morhidi commented on PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#issuecomment-1716912377
The last column looks good to me, we're not failing on any previous values
which is important for backward compatibility reasons. I'm leaning towards
accepting the correc
[
https://issues.apache.org/jira/browse/FLINK-33013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33013:
---
Labels: pull-request-available (was: )
> Shade flink-connector-base info flink-sql-connecto
ruanhang1993 commented on code in PR #15:
URL:
https://github.com/apache/flink-connector-mongodb/pull/15#discussion_r1323913992
##
flink-sql-connector-mongodb/pom.xml:
##
@@ -60,6 +60,10 @@ under the License.
TanYuxin-tyx commented on code in PR #23404:
URL: https://github.com/apache/flink/pull/23404#discussion_r1323910378
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/writer/BroadcastRecordWriterTest.java:
##
@@ -132,35 +132,34 @@ public void testRandomEmitAn
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764475#comment-17764475
]
Jane Chan edited comment on FLINK-31788 at 9/13/23 3:49 AM:
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764475#comment-17764475
]
Jane Chan commented on FLINK-31788:
---
Hi, according to the discussion, we're one the co
[
https://issues.apache.org/jira/browse/FLINK-33065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764472#comment-17764472
]
Rui Fan commented on FLINK-33065:
-
Merged via d5b2cdb618cd7a50818d7eaa575c0fac6aaeac9a
[
https://issues.apache.org/jira/browse/FLINK-33065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-33065.
-
Fix Version/s: 1.19.0
Resolution: Fixed
> Optimize the exception message when the program plan co
[
https://issues.apache.org/jira/browse/FLINK-33051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764473#comment-17764473
]
Matt Wang commented on FLINK-33051:
---
[~pgaref] Have you started this tricket? If you a
flinkbot commented on PR #23405:
URL: https://github.com/apache/flink/pull/23405#issuecomment-1716894944
## CI report:
* 6ec84c4729ced192747cff0778d42fa69dc68a39 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
wangzzu commented on PR #23405:
URL: https://github.com/apache/flink/pull/23405#issuecomment-1716892702
@huwh @pgaref when you have time, help me review 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 abov
[
https://issues.apache.org/jira/browse/FLINK-31895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31895:
---
Labels: pull-request-available (was: )
> End-to-end integration tests for failure labels
>
wangzzu opened a new pull request, #23405:
URL: https://github.com/apache/flink/pull/23405
## 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 on
[
https://issues.apache.org/jira/browse/FLINK-32863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764464#comment-17764464
]
Jufang He commented on FLINK-32863:
---
Hi [~guoyangze], I have created a
PR([https://gi
masteryhx commented on code in PR #14611:
URL: https://github.com/apache/flink/pull/14611#discussion_r1323873654
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java:
##
@@ -30,6 +30,11 @@
/**
* A keyed state backend provides methods for managi
flinkbot commented on PR #23404:
URL: https://github.com/apache/flink/pull/23404#issuecomment-1716849649
## CI report:
* ae67b21f40ba17fb643acd1e5a410e37562e7119 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33076:
---
Labels: pull-request-available (was: )
> broadcastEmit of ChannelSelectorRecordWriter shoul
reswqa opened a new pull request, #23404:
URL: https://github.com/apache/flink/pull/23404
## What is the purpose of the change
*ChannelSelectorRecordWriter#broadcastEmit serialize the record to
ByteBuffer but didn't use it. It will re-serialize this record per-channel. We
should allo
[
https://issues.apache.org/jira/browse/FLINK-33066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764455#comment-17764455
]
dongwoo.kim commented on FLINK-33066:
-
Thanks [~gyfora], I have opened the pr :)
>
[
https://issues.apache.org/jira/browse/FLINK-33066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33066:
---
Labels: pull-request-available (was: )
> Enable to inject environment variable from secret/
dongwoo6kim opened a new pull request, #671:
URL: https://github.com/apache/flink-kubernetes-operator/pull/671
## What is the purpose of the change
To enhance Helm chart by adding full support for setting environment
variables in values.yaml, including valueFrom and envFrom option
dalelane commented on PR #23395:
URL: https://github.com/apache/flink/pull/23395#issuecomment-1716773854
Apologies for the flurry of follow-on commits - this is my first
contribution to Flink so I'd missed the checkstyle and spotless rules when
testing locally.
I think it's ready to
architgyl commented on code in PR #23164:
URL: https://github.com/apache/flink/pull/23164#discussion_r1323745882
##
flink-yarn/src/test/java/org/apache/flink/yarn/YarnApplicationFileUploaderTest.java:
##
@@ -143,6 +165,22 @@ private static Map getLibJars() {
return libJ
venkata91 commented on code in PR #23164:
URL: https://github.com/apache/flink/pull/23164#discussion_r1323679045
##
flink-yarn/src/test/java/org/apache/flink/yarn/YarnApplicationFileUploaderTest.java:
##
@@ -143,6 +165,22 @@ private static Map getLibJars() {
return libJ
srpraneeth commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1323676402
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java:
##
@@ -420,13 +421,24 @@ private voi
[
https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-33018:
---
Labels: pull-request-available stale-blocker (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-30774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-30774:
---
Labels: auto-deprioritized-major starter (was: stale-major starter)
Priority: Minor (
[
https://issues.apache.org/jira/browse/FLINK-32564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32564:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-31689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-31689:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
srpraneeth commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1323659448
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilderTest.java:
##
@@ -478,6 +478,50 @@ public v
architgyl commented on code in PR #23164:
URL: https://github.com/apache/flink/pull/23164#discussion_r1323653567
##
flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java:
##
@@ -360,11 +362,27 @@ List registerProvidedLocalResources() {
[
https://issues.apache.org/jira/browse/FLINK-32884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elkhan Dadashov updated FLINK-32884:
Fix Version/s: 1.19.0
> PyFlink remote execution should support URLs with paths and https
[
https://issues.apache.org/jira/browse/FLINK-32884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elkhan Dadashov updated FLINK-32884:
Description:
Currently, the `SUBMIT_ARGS=remote -m http://:` format. For
local execution
[
https://issues.apache.org/jira/browse/FLINK-32885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elkhan Dadashov closed FLINK-32885.
---
> Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used
> by RestClusterC
[
https://issues.apache.org/jira/browse/FLINK-32885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elkhan Dadashov resolved FLINK-32885.
-
Resolution: Fixed
> Refactoring: Moving UrlPrefixDecorator into flink-clients so it can
tweise merged PR #23383:
URL: https://github.com/apache/flink/pull/23383
--
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
Oscar Perez created FLINK-33078:
---
Summary: Enhance ParameterTool to support múltiple environments
Key: FLINK-33078
URL: https://issues.apache.org/jira/browse/FLINK-33078
Project: Flink
Issue Ty
morhidi commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1323483540
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java:
##
@@ -420,13 +421,24 @@ private void s
morhidi commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1323483540
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java:
##
@@ -420,13 +421,24 @@ private void s
morhidi commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1323483540
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java:
##
@@ -420,13 +421,24 @@ private void s
gyfora commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1323424948
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java:
##
@@ -420,13 +421,24 @@ private void se
[
https://issues.apache.org/jira/browse/FLINK-32885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Elkhan Dadashov updated FLINK-32885:
Fix Version/s: 1.19.0
Description:
UrlPrefixDecorator is introduced in `flink-sql-ga
morhidi commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1323381133
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java:
##
@@ -420,13 +421,24 @@ private void s
morhidi commented on PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#issuecomment-1716182195
Thanks for contributing @srpraneeth. Could you please update the PR and help
understand the goal here with specific examples CR examples?
--
This is an automated messag
morhidi commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1323382871
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilderTest.java:
##
@@ -478,6 +478,50 @@ public void
venkata91 commented on code in PR #23164:
URL: https://github.com/apache/flink/pull/23164#discussion_r1323383321
##
flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java:
##
@@ -360,11 +362,27 @@ List registerProvidedLocalResources() {
[
https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764321#comment-17764321
]
Tzu-Li (Gordon) Tai edited comment on FLINK-33017 at 9/12/23 5:55 PM:
[
https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764321#comment-17764321
]
Tzu-Li (Gordon) Tai edited comment on FLINK-33017 at 9/12/23 5:55 PM:
[
https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764321#comment-17764321
]
Tzu-Li (Gordon) Tai commented on FLINK-33017:
-
Lets only resolve this ticket
morhidi commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1323381133
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java:
##
@@ -420,13 +421,24 @@ private void s
[
https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764320#comment-17764320
]
Tzu-Li (Gordon) Tai commented on FLINK-33017:
-
Fixed via:
apache/flink-conne
[
https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-33017:
Fix Version/s: kafka-3.0.1
kafka-3.1.0
> Nightly run for Flink
morhidi commented on code in PR #670:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/670#discussion_r1323380347
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java:
##
@@ -420,13 +421,24 @@ private void s
[
https://issues.apache.org/jira/browse/FLINK-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-33017:
---
Assignee: Alex Sorokoumov
> Nightly run for Flink Kafka connector fails
> -
1 - 100 of 192 matches
Mail list logo
