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,
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
[
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
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`
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
flinkbot commented on PR #21512:
URL: https://github.com/apache/flink/pull/21512#issuecomment-1351853606
## CI report:
* 9e620de8466ef61d8cec8224615a15cca2f7bd5c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-24999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647527#comment-17647527
]
Yufan Sheng commented on FLINK-24999:
-
What's the state here?
> flink-python doesn't work on Java
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:
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:
[
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
[
https://issues.apache.org/jira/browse/FLINK-30420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647614#comment-17647614
]
Sergey Nuyanzin commented on FLINK-30420:
-
Looks like an old issue
I was able to reproduce it
gaborgsomogyi commented on PR #21511:
URL: https://github.com/apache/flink/pull/21511#issuecomment-1351977066
cc @mbalassi @gyfora @morhidi
--
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
[
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
>
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:
[
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
[
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
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:
[
https://issues.apache.org/jira/browse/FLINK-24999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647536#comment-17647536
]
Martijn Visser commented on FLINK-24999:
[~dianfu] [~hxbks2ks] Is the Java 17 support something
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-30375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30375:
---
Labels: pull-request-available (was: )
> SqlClient leaks flink-table-planner jar under
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:
[
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
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-30422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-30422:
-
Assignee: Gabor Somogyi
> Generalize token framework provider API
>
[
https://issues.apache.org/jira/browse/FLINK-30375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647626#comment-17647626
]
Samrat Deb commented on FLINK-30375:
I will like to work on this issue
> SqlClient leaks
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:
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
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 {
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
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
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
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
[
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
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
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://issues.apache.org/jira/browse/FLINK-28185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647105#comment-17647105
]
Martijn Visser commented on FLINK-28185:
[~Erbureth] Let's see. Especially given that Flink 1.15
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
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 {
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
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`
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
[
https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647659#comment-17647659
]
Etienne Chauchot commented on FLINK-30314:
--
[~dyaraev] I tried to reproduce the behavior you
[
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
[
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:comment-tabpanel=17647106#comment-17647106
]
Danny Cranmer commented on FLINK-30418:
---
Thanks Daren, have assigned to you
> Implement
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
-
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
[
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
[
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
>
Yaron Shani created FLINK-30417:
---
Summary: Rabbit error is not clear
Key: FLINK-30417
URL: https://issues.apache.org/jira/browse/FLINK-30417
Project: Flink
Issue Type: Improvement
MartijnVisser commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-kafka/pull/1#discussion_r1048443842
##
.github/workflows/ci.yml:
##
@@ -80,7 +80,7 @@ jobs:
run: wget -q -c ${{ inputs.flink_url }} -O - | tar -xz
- name: Compile and
MartijnVisser commented on PR #4:
URL:
https://github.com/apache/flink-connector-jdbc/pull/4#issuecomment-1351324792
@liuml07 Could you please rebase?
--
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
MartijnVisser commented on PR #3:
URL:
https://github.com/apache/flink-connector-jdbc/pull/3#issuecomment-1351324229
@eskabetxe It's probably also smart to rebase this one :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
MartijnVisser commented on PR #2:
URL:
https://github.com/apache/flink-connector-jdbc/pull/2#issuecomment-1351323750
@eskabetxe Could you rebase? The architecture tests have now been added and
it would be good to check that the new sink properly implements these
--
This is an automated
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.
##
[
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=17647096#comment-17647096
]
Yaron Shani commented on FLINK-30417:
-
https://github.com/apache/flink/pull/21509
> Rabbit error is
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`
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
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
[
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
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
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 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
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 @@
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
[
https://issues.apache.org/jira/browse/FLINK-28185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647100#comment-17647100
]
Jan Kriho commented on FLINK-28185:
---
Hi,
could you please backport the fix to 1.15 & 1.16 series? As
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
[
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):
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
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
[
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
>
gyfora commented on PR #21511:
URL: https://github.com/apache/flink/pull/21511#issuecomment-1352038862
Thanks Gabor, will look at this tomorrow!
--
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-28185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647679#comment-17647679
]
Jan Kriho commented on FLINK-28185:
---
[~martijnvisser] For what it's worth, I have checked the code,
[
https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647787#comment-17647787
]
Matheus Felisberto commented on FLINK-26088:
Hi guys,
I have been working on an
[ 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
[
https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17627632#comment-17627632
]
Benchao Li edited comment on FLINK-16024 at 12/15/22 1:56 AM:
--
Fixed via
dependabot[bot] opened a new pull request, #6:
URL: https://github.com/apache/flink-connector-pulsar/pull/6
[![Dependabot compatibility
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
[
https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647772#comment-17647772
]
Benchao Li commented on FLINK-16024:
[~martijnvisser] According to the Jira comment email, 1.16.1
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:
[
https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647789#comment-17647789
]
Matheus Felisberto commented on FLINK-26088:
Hi guys,
I have been working on an
[
https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647789#comment-17647789
]
Matheus Felisberto edited comment on FLINK-26088 at 12/15/22 1:39 AM:
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
[
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.
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-30246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647870#comment-17647870
]
xingbe commented on FLINK-30246:
I found that the access level of maps in AbstractReporter is protected,
[
https://issues.apache.org/jira/browse/FLINK-30424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647874#comment-17647874
]
Ran Tao commented on FLINK-30424:
-
[~becket_qin] can u help me to review this pr?
> Add source
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
[
https://issues.apache.org/jira/browse/FLINK-28185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647864#comment-17647864
]
Mason Chen commented on FLINK-28185:
Yup this is easily backported since we decided to defer the
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
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
[
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
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`
1 - 100 of 185 matches
Mail list logo
