hlteoh37 opened a new pull request, #25:
URL: https://github.com/apache/flink-connector-aws/pull/25
## What is the purpose of the change
Rename destinationTableName to tableName to remove redundancy.
## Verifying this change
Built locally and ran unit tests.
## Does this
[
https://issues.apache.org/jira/browse/FLINK-30118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30118:
--
Fix Version/s: aws-connector-2.0.0
> Migrate DDB connector Integration Tests/ITCase to E2E
[
https://issues.apache.org/jira/browse/FLINK-30118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30118:
--
Affects Version/s: (was: aws-connector-2.0.0)
> Migrate DDB connector Integration
[
https://issues.apache.org/jira/browse/FLINK-30118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30118:
--
Summary: Migrate DDB connector Integration Tests/ITCase to E2E module
(was: Migrate DDB
[
https://issues.apache.org/jira/browse/FLINK-30118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daren Wong updated FLINK-30118:
---
Summary: Migrate DDB connector Integration Tests/ITCase to E2E test (was:
Move DDB connector
Daren Wong created FLINK-30118:
--
Summary: Move DDB connector Integration Tests/ITCase to E2E test
Key: FLINK-30118
URL: https://issues.apache.org/jira/browse/FLINK-30118
Project: Flink
Issue
echauchot commented on PR #1:
URL:
https://github.com/apache/flink-connector-cassandra/pull/1#issuecomment-1322351036
> > > We'd like to preserve the git history; can you integrate the
`cas_rewrite` branch from this repo into your PR?
> >
> >
> > That makes total sense. I'll
echauchot commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-cassandra/pull/1#discussion_r1028282565
##
src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java:
##
@@ -0,0 +1,912 @@
+/*
+ * Licensed to the Apache
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1028262896
##
pom.xml:
##
@@ -0,0 +1,463 @@
+
+
+http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd;
+
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1028262896
##
pom.xml:
##
@@ -0,0 +1,463 @@
+
+
+http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd;
+
[
https://issues.apache.org/jira/browse/FLINK-29440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29440:
--
Component/s: (was: Connectors / DynamoDB)
> Setup CI Logging
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-29440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer closed FLINK-29440.
-
Resolution: Won't Do
This is not required
> Setup CI Logging
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-29440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-29440:
--
Fix Version/s: (was: aws-connector-2.0.0)
> Setup CI Logging
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-30098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-30098.
---
Resolution: Fixed
> Update DynamoDb Sink unit tests to JUnit 5
>
[
https://issues.apache.org/jira/browse/FLINK-30098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636760#comment-17636760
]
Danny Cranmer commented on FLINK-30098:
---
Merged commit
[
https://issues.apache.org/jira/browse/FLINK-30098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-30098:
-
Assignee: Hong Liang Teoh
> Update DynamoDb Sink unit tests to JUnit 5
>
[
https://issues.apache.org/jira/browse/FLINK-30098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-30098:
--
Fix Version/s: aws-connector-2.0.0
> Update DynamoDb Sink unit tests to JUnit 5
>
dannycranmer merged PR #23:
URL: https://github.com/apache/flink-connector-aws/pull/23
--
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:
reta commented on PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1322306067
> Do you, by chance, have a branch that shows the _actual_ changes made on
the ES connector code? Otherwise I'll just have to continue manually comparing
them one-by-one and
gaborgsomogyi commented on code in PR #446:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/446#discussion_r1028244984
##
e2e-tests/utils.sh:
##
@@ -108,12 +113,37 @@ function retry_times() {
return 1
}
+function check_operator_log_for_errors {
+ echo
Gabor Somogyi created FLINK-30117:
-
Summary: Evaluate error whitelist entries added in FLINK-29475
Key: FLINK-30117
URL: https://issues.apache.org/jira/browse/FLINK-30117
Project: Flink
gaborgsomogyi commented on code in PR #446:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/446#discussion_r1028227493
##
e2e-tests/utils.sh:
##
@@ -108,12 +113,37 @@ function retry_times() {
return 1
}
+function check_operator_log_for_errors {
+ echo
morhidi commented on code in PR #446:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/446#discussion_r1028223409
##
e2e-tests/utils.sh:
##
@@ -108,12 +113,37 @@ function retry_times() {
return 1
}
+function check_operator_log_for_errors {
+ echo
zentol commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1028176163
##
pom.xml:
##
@@ -0,0 +1,463 @@
+
+
+http://maven.apache.org/POM/4.0.0
http://maven.apache.org/xsd/maven-4.0.0.xsd;
+
echauchot commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-cassandra/pull/1#discussion_r1028212357
##
pom.xml:
##
@@ -0,0 +1,432 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
+
morhidi commented on PR #446:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/446#issuecomment-1322269298
Hi @gaborgsomogyi thanks for opening the PR. The main motivator behind this
Jira is to eliminate ERRORS/WARNINGS from the operator logs that are harmless
but generating
gaborgsomogyi commented on PR #446:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/446#issuecomment-1322262374
I've gone through the whitelisted messages and I think there is no issue w/
the actual feature set.
Newly coming error messages will be breaking the build when
gaborgsomogyi commented on PR #446:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/446#issuecomment-1322263029
cc @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
[
https://issues.apache.org/jira/browse/FLINK-30111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Prabhu Joseph updated FLINK-30111:
--
Description:
CacheRead fails with below exception when running multiple parallel jobs in
[
https://issues.apache.org/jira/browse/FLINK-29815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636740#comment-17636740
]
Márton Balassi commented on FLINK-29815:
[~voidking] I reuploaded the 1.16.0 images, please
1996fanrui commented on PR #21360:
URL: https://github.com/apache/flink/pull/21360#issuecomment-1322247519
Hi @pnowojski , please help take a look in your free time, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
1996fanrui commented on PR #21359:
URL: https://github.com/apache/flink/pull/21359#issuecomment-1322246872
Hi @pnowojski , please help take a look in your free time, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-25343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636714#comment-17636714
]
Ferenc Csaky commented on FLINK-25343:
--
Okay, this new run showed the actual difference:
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1028121584
##
pom.xml:
##
@@ -327,6 +327,12 @@ under the License.
+
+
reta commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1028121584
##
pom.xml:
##
@@ -327,6 +327,12 @@ under the License.
+
+
zentol commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1028111806
##
pom.xml:
##
@@ -327,6 +327,12 @@ under the License.
+
+
[
https://issues.apache.org/jira/browse/FLINK-30085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-30085:
-
Issue Type: Technical Debt (was: Bug)
> JVM hanging after executing
>
[
https://issues.apache.org/jira/browse/FLINK-30085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-30085.
Fix Version/s: 1.17.0
Resolution: Fixed
master:
zentol merged PR #21357:
URL: https://github.com/apache/flink/pull/21357
--
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:
echauchot commented on PR #1:
URL:
https://github.com/apache/flink-connector-cassandra/pull/1#issuecomment-1322134409
> > We'd like to preserve the git history; can you integrate the
`cas_rewrite` branch from this repo into your PR?
>
> That makes total sense. I'll rebase on the
zentol commented on PR #1:
URL:
https://github.com/apache/flink-connector-cassandra/pull/1#issuecomment-1322130904
> IMHO it would be interesting to add an item to your migration doc to
inform contributors to keep history
I've already added this as an item to
echauchot commented on PR #1:
URL:
https://github.com/apache/flink-connector-cassandra/pull/1#issuecomment-1322126546
> We'd like to preserve the git history; can you integrate the `cas_rewrite`
branch from this repo into your PR?
That makes total sense. I'll rebase on the branch.
echauchot commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-cassandra/pull/1#discussion_r1028076179
##
src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java:
##
@@ -0,0 +1,912 @@
+/*
+ * Licensed to the Apache
echauchot closed pull request #1: [FLINK-29982] move the existing Cassandra
connector to external repository
URL: https://github.com/apache/flink-connector-cassandra/pull/1
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
Konstantin Knauf created FLINK-30116:
Summary: Don't Show Env Vars in Web UI
Key: FLINK-30116
URL: https://issues.apache.org/jira/browse/FLINK-30116
Project: Flink
Issue Type:
echauchot commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-cassandra/pull/1#discussion_r1028076179
##
src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java:
##
@@ -0,0 +1,912 @@
+/*
+ * Licensed to the Apache
echauchot commented on PR #1:
URL:
https://github.com/apache/flink-connector-cassandra/pull/1#issuecomment-1322108960
Thanks for the very prompt review @zentol !
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-29815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi reassigned FLINK-29815:
--
Assignee: Márton Balassi
> image apache/flink:1.16.0-scala_2.12 does not exist
>
[
https://issues.apache.org/jira/browse/FLINK-29815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636689#comment-17636689
]
Márton Balassi commented on FLINK-29815:
Thanks for reporting [~voidking] , taking a look.
>
zentol commented on code in PR #21349:
URL: https://github.com/apache/flink/pull/21349#discussion_r1028018356
##
tools/ci/flink-ci-tools/src/main/java/org/apache/flink/tools/ci/optional/ShadeOptionalChecker.java:
##
@@ -0,0 +1,164 @@
+/*
+ * Licensed to the Apache Software
zentol commented on code in PR #21349:
URL: https://github.com/apache/flink/pull/21349#discussion_r1028005133
##
tools/ci/flink-ci-tools/src/main/java/org/apache/flink/tools/ci/optional/ShadeOptionalChecker.java:
##
@@ -0,0 +1,164 @@
+/*
+ * Licensed to the Apache Software
zentol commented on code in PR #21349:
URL: https://github.com/apache/flink/pull/21349#discussion_r1028005133
##
tools/ci/flink-ci-tools/src/main/java/org/apache/flink/tools/ci/optional/ShadeOptionalChecker.java:
##
@@ -0,0 +1,164 @@
+/*
+ * Licensed to the Apache Software
Alexis Sarda-Espinosa created FLINK-30115:
-
Summary: Include log4j-layout-template-json jar in the default
operator image
Key: FLINK-30115
URL: https://issues.apache.org/jira/browse/FLINK-30115
[
https://issues.apache.org/jira/browse/FLINK-29437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei resolved FLINK-29437.
--
Resolution: Fixed
merged commit
[
https://issues.apache.org/jira/browse/FLINK-30115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexis Sarda-Espinosa updated FLINK-30115:
--
Issue Type: Improvement (was: Bug)
> Include log4j-layout-template-json jar
eskabetxe commented on PR #20097:
URL: https://github.com/apache/flink/pull/20097#issuecomment-1322026302
Hi @wanglijie95 thanks for reviewing this..
1. The idea for JdbcProducer is to allow that we can generate a new producer
if needed, for example have a clickhouse producer based
[
https://issues.apache.org/jira/browse/FLINK-29437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Mei updated FLINK-29437:
-
Fix Version/s: 1.17.0
> The partition of data before and after the Kafka Shuffle are not aligned
>
curcur merged PR #20942:
URL: https://github.com/apache/flink/pull/20942
--
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:
gaborgsomogyi commented on PR #446:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/446#issuecomment-1322022848
Excluded all the errors for now for testing purposes. Each and every error
needs evaluation one by one.
--
This is an automated message from the Apache Git
curcur commented on PR #20942:
URL: https://github.com/apache/flink/pull/20942#issuecomment-1322022669
LGTM, as discussed offline.
--
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
dannycranmer commented on code in PR #581:
URL: https://github.com/apache/flink-web/pull/581#discussion_r1027992592
##
_posts/2022-11-10-release-1.15.3.md:
##
@@ -0,0 +1,185 @@
+---
+layout: post
+title: "Apache Flink 1.15.3 Release Announcement"
+date:
gaborgsomogyi commented on PR #21357:
URL: https://github.com/apache/flink/pull/21357#issuecomment-1322011679
FYI @MartijnVisser @zentol this is not related to Hadoop version bump but
quite a big gain accidentally.
--
This is an automated message from the Apache Git Service.
To respond
gaborgsomogyi commented on PR #21357:
URL: https://github.com/apache/flink/pull/21357#issuecomment-1321975092
If I check correct numbers then the gain looks good.
Before:
1996fanrui commented on PR #21353:
URL: https://github.com/apache/flink/pull/21353#issuecomment-1321952773
Hi @pnowojski please help take a look, thanks. It's also a cleanup PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-29833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-29833.
Resolution: Fixed
> Improve PyFlink support in Windows
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-29475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29475:
---
Labels: pull-request-available (was: )
> Add WARNING/ERROR checker for the operator in e2e
gaborgsomogyi opened a new pull request, #446:
URL: https://github.com/apache/flink-kubernetes-operator/pull/446
## What is the purpose of the change
At the moment we're not checking that the operator is not having an error in
its log. In this PR I've added an assertion when error
[
https://issues.apache.org/jira/browse/FLINK-30062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636651#comment-17636651
]
Ferenc Csaky commented on FLINK-30062:
--
[~martijnvisser] can you assign this one to me? Thanks!
>
[
https://issues.apache.org/jira/browse/FLINK-30041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-30041.
Resolution: Fixed
> Setup conjars https mirror
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-30041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634836#comment-17634836
]
Chesnay Schepler edited comment on FLINK-30041 at 11/21/22 11:40 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-30041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636649#comment-17636649
]
Chesnay Schepler edited comment on FLINK-30041 at 11/21/22 11:39 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-30041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636649#comment-17636649
]
Chesnay Schepler edited comment on FLINK-30041 at 11/21/22 11:39 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-30041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636649#comment-17636649
]
Chesnay Schepler commented on FLINK-30041:
--
We'll need to setup a {{http://conjars.org/repo/}}
[
https://issues.apache.org/jira/browse/FLINK-30071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-30071.
Assignee: Jane Chan
Resolution: Fixed
master: 4616e775efd567001704fea0734e5e12e72cfffd
>
[
https://issues.apache.org/jira/browse/FLINK-30041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-30041:
--
This only works for private builds, not for those on the alibaba machines.
> Setup
JingsongLi merged PR #386:
URL: https://github.com/apache/flink-table-store/pull/386
--
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:
JingsongLi commented on code in PR #388:
URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027901067
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/source/SnapshotEnumerator.java:
##
@@ -99,11 +103,48 @@ public static class
[
https://issues.apache.org/jira/browse/FLINK-30048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xljtswf closed FLINK-30048.
---
Resolution: Won't Do
> MapState.remove(UK key) is better to return the old value.
>
Jingsong Lee created FLINK-30114:
Summary: Introduce PyFlink example for table store
Key: FLINK-30114
URL: https://issues.apache.org/jira/browse/FLINK-30114
Project: Flink
Issue Type: New
zentol closed pull request #21352: fix(sec): upgrade
org.apache.calcite:calcite-core to 1.32.0
URL: https://github.com/apache/flink/pull/21352
--
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-24679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-24679.
Resolution: Fixed
master: 3d1c43cc1da1f227b409952daca70d5b663e1a5a
> Configuration
zentol commented on code in PR #21300:
URL: https://github.com/apache/flink/pull/21300#discussion_r1027885797
##
flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobDetails.java:
##
@@ -93,6 +92,29 @@ public class JobDetails implements Serializable {
zentol merged PR #21297:
URL: https://github.com/apache/flink/pull/21297
--
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:
zentol commented on code in PR #21300:
URL: https://github.com/apache/flink/pull/21300#discussion_r1027885797
##
flink-runtime/src/main/java/org/apache/flink/runtime/messages/webmonitor/JobDetails.java:
##
@@ -93,6 +92,29 @@ public class JobDetails implements Serializable {
[
https://issues.apache.org/jira/browse/FLINK-21340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-21340.
Fix Version/s: 1.17.0
Resolution: Fixed
master:
violations fixed in
zentol merged PR #21312:
URL: https://github.com/apache/flink/pull/21312
--
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-29993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29993.
Resolution: Fixed
master: c814348d486a2e16644f084c841df4f1bb586fd3
> Provide more
zentol merged PR #21337:
URL: https://github.com/apache/flink/pull/21337
--
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:
flinkbot commented on PR #21360:
URL: https://github.com/apache/flink/pull/21360#issuecomment-1321890732
## CI report:
* 4ba3df460e4fd201e1a722e85ada84dfd90ec113 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
SteNicholas commented on code in PR #388:
URL: https://github.com/apache/flink-table-store/pull/388#discussion_r1027877730
##
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/source/SnapshotEnumerator.java:
##
@@ -99,11 +103,48 @@ public static class
flinkbot commented on PR #21359:
URL: https://github.com/apache/flink/pull/21359#issuecomment-1321883950
## CI report:
* 88c1dd3f37714f11092d4ab1ee39b1cde806f8d7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1996fanrui opened a new pull request, #21360:
URL: https://github.com/apache/flink/pull/21360
Backport FLINK-28695 to 1.16.
--
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.
1996fanrui opened a new pull request, #21359:
URL: https://github.com/apache/flink/pull/21359
Backport FLINK-28695 to 1.15.
--
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.
[
https://issues.apache.org/jira/browse/FLINK-30086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-30086.
Resolution: Fixed
master: 4ad7a955d58db01a502abded0871a4564609cffc
> Include classifier
zentol merged PR #21345:
URL: https://github.com/apache/flink/pull/21345
--
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:
zentol commented on PR #1:
URL:
https://github.com/apache/flink-connector-cassandra/pull/1#issuecomment-1321863407
> We'd like to preserve the git history; can you integrate the cas_rewrite
branch from this repo into your PR?
hold on I may want to update that branch to also contain
zentol commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-cassandra/pull/1#discussion_r1027825022
##
src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java:
##
@@ -0,0 +1,912 @@
+/*
+ * Licensed to the Apache
1996fanrui commented on PR #21351:
URL: https://github.com/apache/flink/pull/21351#issuecomment-1321861598
Thanks @reswqa and @pnowojski review.
--
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
pnowojski merged PR #21351:
URL: https://github.com/apache/flink/pull/21351
--
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:
zentol commented on PR #1:
URL:
https://github.com/apache/flink-connector-cassandra/pull/1#issuecomment-1321849479
We'd like to preserve the git history; can you rebase your PR against the
`cas_rewrite` branch in this repo?
--
This is an automated message from the Apache Git Service.
To
101 - 200 of 256 matches
Mail list logo
