[
https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647898#comment-17647898
]
Zhu Zhu edited comment on FLINK-30246 at 12/15/22 7:57 AM:
---
Yo
[
https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-30246:
Fix Version/s: 2.0.0
> Registering the same metric object with different name and group will
> conflict i
[
https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647898#comment-17647898
]
Zhu Zhu commented on FLINK-30246:
-
You are right. Unfortunately, we cannot change the pr
[
https://issues.apache.org/jira/browse/FLINK-30424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647874#comment-17647874
]
Ran Tao commented on FLINK-30424:
-
[~becket_qin] can u help me to review this pr?
> Ad
[
https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647870#comment-17647870
]
xingbe commented on FLINK-30246:
I found that the access level of maps in AbstractReport
xintongsong commented on PR #21508:
URL: https://github.com/apache/flink/pull/21508#issuecomment-1352602522
Sure. I'll try to take a look asap.
--
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
carp84 commented on PR #21508:
URL: https://github.com/apache/flink/pull/21508#issuecomment-1352600177
Thanks for the contribution @ramkrish86 .
@xintongsong could you help review this one since you have experience
reviewing similar support for Google storage FS (PR#15599)? Many thank
[
https://issues.apache.org/jira/browse/FLINK-28185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647864#comment-17647864
]
Mason Chen commented on FLINK-28185:
Yup this is easily backported since we decided
EchoLee5 commented on PR #5:
URL:
https://github.com/apache/flink-connector-jdbc/pull/5#issuecomment-1352588573
> @EchoLee5 Thanks for the PR, is it possible to add a test for this?
I have added test cases, please help me review the code again, thank you.
--
This is an automated me
[
https://issues.apache.org/jira/browse/FLINK-30424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-30424:
Description:
When a job start firstly, we can find 'assignPartitions' from log。but if source
recover from
flinkbot commented on PR #21513:
URL: https://github.com/apache/flink/pull/21513#issuecomment-1352576672
## CI report:
* c8d4b98e6581e9c41a7aec3673a6073e40330285 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liming30 commented on PR #21503:
URL: https://github.com/apache/flink/pull/21503#issuecomment-1352576482
@gaoyunhaii If you have time, please take a look at this merge request.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/FLINK-30424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ran Tao updated FLINK-30424:
Description:
When a job start firstly, we can find 'assignPartitions' from log。but if source
recover from
[
https://issues.apache.org/jira/browse/FLINK-30424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30424:
---
Labels: pull-request-available (was: )
> Add source operator restore readerState log to dis
chucheng92 opened a new pull request, #21513:
URL: https://github.com/apache/flink/pull/21513
## What is the purpose of the change
If source recover from state, we can not distinguish the newPartitions is
from timed discover thread or from reader task state. So add recover log to
he
[
https://issues.apache.org/jira/browse/FLINK-30410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30410:
---
Labels: pull-request-available (was: )
> Rename 'full' to 'latest-full' and 'compacted' to
tsreaper opened a new pull request, #439:
URL: https://github.com/apache/flink-table-store/pull/439
As discussed in the [dev mailing
list](https://lists.apache.org/thread/t76f0ofl6k7mlvqotp57ot10x8o1x90p), we're
going to rename some values for `scan.mode` in Table Store.
Specifically
Ran Tao created FLINK-30424:
---
Summary: Add source operator restore readerState log to
distinguish split is from newPartitions or split state
Key: FLINK-30424
URL: https://issues.apache.org/jira/browse/FLINK-30424
Myracle commented on PR #21347:
URL: https://github.com/apache/flink/pull/21347#issuecomment-1352472772
@xintongsong Have a look? Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the speci
[
https://issues.apache.org/jira/browse/FLINK-29767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-29767.
Fix Version/s: 1.17.0
Resolution: Done
master (1.17): a6a321777a53b8d7807078cb8d98c7b3de242
xintongsong closed pull request #21199: [FLINK-29767] Adaptive batch scheduler
supports hybrid shuffle
URL: https://github.com/apache/flink/pull/21199
--
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
xintongsong commented on PR #21199:
URL: https://github.com/apache/flink/pull/21199#issuecomment-1352467803
@zhuzhurk, thanks for reviewing. Merging 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 t
[
https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627632#comment-17627632
]
Benchao Li edited comment on FLINK-16024 at 12/15/22 1:56 AM:
[
https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li updated FLINK-16024:
---
Fix Version/s: (was: 1.16.1)
> support filter pushdown in jdbc connector
> -
[
https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647789#comment-17647789
]
Matheus Felisberto edited comment on FLINK-26088 at 12/15/22 1:39 AM:
[
https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647789#comment-17647789
]
Matheus Felisberto commented on FLINK-26088:
Hi guys,
I have been working o
[ https://issues.apache.org/jira/browse/FLINK-26088 ]
Matheus Felisberto deleted comment on FLINK-26088:
was (Author: JIRAUSER298391):
Hi guys,
I have been working on an implementation that supports Elasticsearch v8 because
of a proje
[
https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647787#comment-17647787
]
Matheus Felisberto commented on FLINK-26088:
Hi guys,
I have been working
zjureel commented on code in PR #423:
URL: https://github.com/apache/flink-table-store/pull/423#discussion_r1049126191
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/DataValueConverter.java:
##
@@ -0,0 +1,327 @@
+/*
+ * Licensed to the Apache So
Shammon created FLINK-30423:
---
Summary: Introduce cast executor codegen for column type evolution
Key: FLINK-30423
URL: https://issues.apache.org/jira/browse/FLINK-30423
Project: Flink
Issue Type: S
[
https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647772#comment-17647772
]
Benchao Li commented on FLINK-16024:
[~martijnvisser] According to the Jira comment
LadyForest commented on PR #21507:
URL: https://github.com/apache/flink/pull/21507#issuecomment-1352387719
@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
liuml07 commented on PR #4:
URL:
https://github.com/apache/flink-connector-jdbc/pull/4#issuecomment-1352374675
I found the `git fetch origin main && git rebase origin/main` has no
conflicts. I just rebased and it still builds locally.
--
This is an automated message from the Apache Git S
dependabot[bot] opened a new pull request, #6:
URL: https://github.com/apache/flink-connector-pulsar/pull/6
[
> SqlClient leaks flink-table-planner jar under /tmp
Samrat002 opened a new pull request, #21512:
URL: https://github.com/apache/flink/pull/21512
## What is the purpose of the change
sql-client leaks flink-table-planner jar in /tmp. Fix the leak by removing
on exists
## Brief change log
## Verifying th
gyfora opened a new pull request, #484:
URL: https://github.com/apache/flink-kubernetes-operator/pull/484
## What is the purpose of the change
This is the initial implementation of the autoscaler module as described in
https://cwiki.apache.org/confluence/display/FLINK/FLIP-271%3A+Auto
flinkbot commented on PR #21511:
URL: https://github.com/apache/flink/pull/21511#issuecomment-1351819679
## CI report:
* 77ed253a77605fe791ff91b1d53970d4048db018 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gaborgsomogyi opened a new pull request, #21511:
URL: https://github.com/apache/flink/pull/21511
## What is the purpose of the change
These are multiple commits to reach generalized delegation token framework
described
[here](https://cwiki.apache.org/confluence/display/FLINK/FLIP-272
[
https://issues.apache.org/jira/browse/FLINK-30375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647626#comment-17647626
]
Samrat Deb commented on FLINK-30375:
I will like to work on this issue
> SqlClient
[
https://issues.apache.org/jira/browse/FLINK-30418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daren Wong updated FLINK-30418:
---
Description:
h2. What?
Use synchronous KinesisClient for consumer
registration/de-registration/de
[
https://issues.apache.org/jira/browse/FLINK-30420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647614#comment-17647614
]
Sergey Nuyanzin commented on FLINK-30420:
-
Looks like an old issue
I was able to
pnowojski commented on code in PR #20151:
URL: https://github.com/apache/flink/pull/20151#discussion_r1048286114
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java:
##
@@ -18,280 +18,265 @@
package org.apache.flink.runti
flinkbot commented on PR #21510:
URL: https://github.com/apache/flink/pull/21510#issuecomment-1351746357
## CI report:
* cfa1b6a4e03781412a3185a42f8dfb4886775711 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30383:
---
Labels: pull-request-available (was: )
> UseLogicalIdentifier makes datadog consider metric
zentol opened a new pull request, #21510:
URL: https://github.com/apache/flink/pull/21510
DataDog only considers metrics as coming from Flink if the metric name has
"flink" prefix. Otherwise they are considered as custom metrics, governed by
different billing rules.
This was so far a
[
https://issues.apache.org/jira/browse/FLINK-30422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-30422:
-
Assignee: Gabor Somogyi
> Generalize token framework provider API
> ---
Gabor Somogyi created FLINK-30422:
-
Summary: Generalize token framework provider API
Key: FLINK-30422
URL: https://issues.apache.org/jira/browse/FLINK-30422
Project: Flink
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/FLINK-30421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-30421:
-
Assignee: Gabor Somogyi
> Move TGT renewal to hadoop module
> -
Gabor Somogyi created FLINK-30421:
-
Summary: Move TGT renewal to hadoop module
Key: FLINK-30421
URL: https://issues.apache.org/jira/browse/FLINK-30421
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-30413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yufan Sheng updated FLINK-30413:
Summary: Drop Shared and Key_Shared subscription support in Pulsar
connector (was: Drop Share and
gyfora commented on PR #481:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/481#issuecomment-1351679950
Thank you for the work @swathic95 :) Looks great!
--
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-30420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiang Xin updated FLINK-30420:
--
Description:
Run the following unit test.
{code:java}
import org.apache.flink.api.common.eventtime.Wat
[
https://issues.apache.org/jira/browse/FLINK-30420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiang Xin updated FLINK-30420:
--
Description:
Run the following unit test.
{code:java}
import org.apache.flink.api.common.eventtime.Wat
Jiang Xin created FLINK-30420:
-
Summary: NPE thrown when using window time in Table API
Key: FLINK-30420
URL: https://issues.apache.org/jira/browse/FLINK-30420
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-30402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-30402.
--
Fix Version/s: 1.17.0
Resolution: Fixed
4ba3366 in main
> Separate token framework gen
mbalassi merged PR #21505:
URL: https://github.com/apache/flink/pull/21505
--
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
[
https://issues.apache.org/jira/browse/FLINK-24999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647536#comment-17647536
]
Martijn Visser commented on FLINK-24999:
[~dianfu] [~hxbks2ks] Is the Java 17 su
[
https://issues.apache.org/jira/browse/FLINK-24999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647527#comment-17647527
]
Yufan Sheng commented on FLINK-24999:
-
What's the state here?
> flink-python doesn'
gyfora merged PR #457:
URL: https://github.com/apache/flink-kubernetes-operator/pull/457
--
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
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-30361:
---
Affects Version/s: kubernetes-operator-1.3.0
> Cluster deleted and created back while updating repli
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-30361.
--
Fix Version/s: kubernetes-operator-1.4.0
Resolution: Fixed
merged to main efefd31b5155436b36e53
gyfora merged PR #481:
URL: https://github.com/apache/flink-kubernetes-operator/pull/481
--
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
Vicky Papavasileiou created FLINK-30419:
---
Summary: Allow tuning of transaction timeout
Key: FLINK-30419
URL: https://issues.apache.org/jira/browse/FLINK-30419
Project: Flink
Issue Type:
1996fanrui commented on code in PR #20151:
URL: https://github.com/apache/flink/pull/20151#discussion_r1048554412
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/ExecutionCheckpointingOptions.java:
##
@@ -252,4 +252,13 @@ public class ExecutionCh
MartijnVisser commented on PR #20343:
URL: https://github.com/apache/flink/pull/20343#issuecomment-1351540640
@jaumebecks Yes, but let's not create that right now. We're in the process
of externalizing Kafka (see
https://github.com/apache/flink-connector-kafka/pull/1) and when that's done,
jaumebecks commented on PR #20343:
URL: https://github.com/apache/flink/pull/20343#issuecomment-1351525105
@MartijnVisser it seems @paul8263 is not responding to the requested
changes, we may create a similar PR in the following days for fixing this, does
that sound good to you?
--
This
MartijnVisser commented on code in PR #21501:
URL: https://github.com/apache/flink/pull/21501#discussion_r1048545657
##
flink-docs/src/main/java/org/apache/flink/docs/util/ConfigurationOptionLocator.java:
##
@@ -73,15 +73,6 @@ public class ConfigurationOptionLocator {
MartijnVisser commented on code in PR #21501:
URL: https://github.com/apache/flink/pull/21501#discussion_r1047808521
##
flink-docs/src/main/java/org/apache/flink/docs/util/ConfigurationOptionLocator.java:
##
@@ -73,15 +73,6 @@ public class ConfigurationOptionLocator {
[
https://issues.apache.org/jira/browse/FLINK-30315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-30315.
--
Fix Version/s: kubernetes-operator-1.4.0
Resolution: Fixed
merged to main 40357168fba199320c742
gyfora merged PR #476:
URL: https://github.com/apache/flink-kubernetes-operator/pull/476
--
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
eskabetxe commented on PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#issuecomment-1351401591
@MartijnVisser rebased, but this is blocked @wanglijie95 could give more
feedback, but basically we are waiting for a new FLIP to expose ExecutionConfig
or isObjectReuseEnabled
eskabetxe commented on PR #3:
URL:
https://github.com/apache/flink-connector-jdbc/pull/3#issuecomment-1351396885
@MartijnVisser done.. would be great that someone could check this..
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
1996fanrui commented on code in PR #21498:
URL: https://github.com/apache/flink/pull/21498#discussion_r1048482228
##
docs/layouts/shortcodes/generated/cluster_configuration.html:
##
@@ -70,7 +70,7 @@
cluster.thread-dump.stacktrace-max-depth
-
[
https://issues.apache.org/jira/browse/FLINK-30418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647106#comment-17647106
]
Danny Cranmer commented on FLINK-30418:
---
Thanks Daren, have assigned to you
> Imp
[
https://issues.apache.org/jira/browse/FLINK-30418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-30418:
-
Assignee: Daren Wong
> Implement synchronous KinesisClient in EFO
> ---
[
https://issues.apache.org/jira/browse/FLINK-30418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30418:
--
Affects Version/s: (was: aws-connector-4.1.0)
> Implement synchronous KinesisClient in EFO
[
https://issues.apache.org/jira/browse/FLINK-30418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30418:
---
Labels: pull-request-available (was: )
> Implement synchronous KinesisClient in EFO
> -
darenwkt opened a new pull request, #39:
URL: https://github.com/apache/flink-connector-aws/pull/39
Implemented synchronous KinesisClient as described in
https://issues.apache.org/jira/browse/FLINK-30418.
--
This is an automated message from the Apache Git Service.
To respond to the messa
[
https://issues.apache.org/jira/browse/FLINK-28185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647105#comment-17647105
]
Martijn Visser commented on FLINK-28185:
[~Erbureth] Let's see. Especially given
Daren Wong created FLINK-30418:
--
Summary: Implement synchronous KinesisClient in EFO
Key: FLINK-30418
URL: https://issues.apache.org/jira/browse/FLINK-30418
Project: Flink
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-28185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647100#comment-17647100
]
Jan Kriho commented on FLINK-28185:
---
Hi,
could you please backport the fix to 1.15 &
smulikHakipod commented on PR #21509:
URL: https://github.com/apache/flink/pull/21509#issuecomment-1351345317
https://github.com/apache/flink-connector-rabbitmq/pull/4
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
smulikHakipod closed pull request #4: [FLINK-30417] [Connectors/ RabbitMQ] add
"RabbitMQ" to rabbit error while creating the channel
URL: https://github.com/apache/flink-connector-rabbitmq/pull/4
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
pvary commented on code in PR #476:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/476#discussion_r1048461390
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentControllerTest.java:
##
@@ -297,88 +297,10 @@ p
boring-cyborg[bot] commented on PR #4:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/4#issuecomment-1351342984
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
smulikHakipod opened a new pull request, #4:
URL: https://github.com/apache/flink-connector-rabbitmq/pull/4
Related to https://github.com/apache/flink/pull/21509
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-30417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30417:
--
Assignee: Yaron Shani
> RabbitMQ error is not clear
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-30417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-30417:
---
Summary: RabbitMQ error is not clear (was: Rabbit error is not clear)
> RabbitMQ error is n
MartijnVisser commented on PR #21509:
URL: https://github.com/apache/flink/pull/21509#issuecomment-1351335361
@smulikHakipod Please redirect this PR to
https://github.com/apache/flink-connector-rabbitmq as connectors are being
externalized
--
This is an automated message from the Apache
MartijnVisser closed pull request #21509: [FLINK-30417] [Connectors/ RabbitMQ]
add "RabbitMQ" to rabbit error while creating the channel
URL: https://github.com/apache/flink/pull/21509
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
flinkbot commented on PR #21509:
URL: https://github.com/apache/flink/pull/21509#issuecomment-1351334793
## CI report:
* c3c666f2575ae9912614978d12dd6205a5c4bee6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30417:
---
Labels: pull-request-available (was: )
> Rabbit error is not clear
> --
[
https://issues.apache.org/jira/browse/FLINK-30417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17647096#comment-17647096
]
Yaron Shani commented on FLINK-30417:
-
https://github.com/apache/flink/pull/21509
>
smulikHakipod opened a new pull request, #21509:
URL: https://github.com/apache/flink/pull/21509
Jira:
https://issues.apache.org/jira/browse/FLINK-30417
## What is the purpose of the change
To better describe the error of RabbitMQ connection failures.
## Brief
1 - 100 of 185 matches
Mail list logo
