flinkbot commented on PR #25346:
URL: https://github.com/apache/flink/pull/25346#issuecomment-2357462017
## CI report:
* 20936762eed6bea3c11a90780ca2f0fd0350fa20 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly commented on PR #95:
URL: https://github.com/apache/flink-benchmarks/pull/95#issuecomment-2357458487
@XComp would you please take a look?
--
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 t
Zakelly opened a new pull request, #25346:
URL: https://github.com/apache/flink/pull/25346
## What is the purpose of the change
Removes the deprecated State&Checkpointing&Recovery related options
## Brief change log
Still in progress, several commits:
- Remove for
xintongsong commented on code in PR #25226:
URL: https://github.com/apache/flink/pull/25226#discussion_r1764328992
##
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableWriter.java:
##
@@ -46,13 +46,22 @@ public class HadoopRecovera
xintongsong commented on code in PR #25226:
URL: https://github.com/apache/flink/pull/25226#discussion_r1764322519
##
flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java:
##
@@ -665,6 +666,16 @@ public RecoverableWriter createRecoverableWriter() throws
IOException
zoltar9264 commented on PR #24879:
URL: https://github.com/apache/flink/pull/24879#issuecomment-2357426433
@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
xintongsong commented on code in PR #25226:
URL: https://github.com/apache/flink/pull/25226#discussion_r1764322519
##
flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java:
##
@@ -665,6 +666,16 @@ public RecoverableWriter createRecoverableWriter() throws
IOException
huyuanfeng2018 commented on PR #879:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/879#issuecomment-2357419920
> Great discussion @huyuanfeng2018 @1996fanrui! I think this is a good
opportunity to unify the logic further and to address a gap with the current
key alignment l
lincoln-lil merged PR #25335:
URL: https://github.com/apache/flink/pull/25335
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.a
zhuzhurk closed pull request #25256: [FLINK-36249][streaming-java] Remove
RestartStrategy-related configuration getters/setters that return/set complex
Java objects.
URL: https://github.com/apache/flink/pull/25256
--
This is an automated message from the Apache Git Service.
To respond to the
Zakelly commented on PR #25345:
URL: https://github.com/apache/flink/pull/25345#issuecomment-2357359574
@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.
Zakelly commented on PR #25345:
URL: https://github.com/apache/flink/pull/25345#issuecomment-2357359791
The CI failure related to https://issues.apache.org/jira/browse/FLINK-36166
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
Sxnan merged PR #25314:
URL: https://github.com/apache/flink/pull/25314
--
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.
nateab commented on code in PR #25115:
URL: https://github.com/apache/flink/pull/25115#discussion_r1764243768
##
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java:
##
@@ -448,6 +448,15 @@ void testDescribeModel() {
sql("d
nateab commented on code in PR #25115:
URL: https://github.com/apache/flink/pull/25115#discussion_r1764243005
##
docs/content/docs/dev/table/sql/describe.md:
##
@@ -26,7 +26,7 @@ under the License.
# DESCRIBE Statements
-DESCRIBE statements are used to describe the schema o
nateab commented on code in PR #25115:
URL: https://github.com/apache/flink/pull/25115#discussion_r1764239002
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlRichDescribeModel.java:
##
@@ -41,7 +41,7 @@ public class SqlRichDescribeModel extends S
nateab commented on code in PR #25115:
URL: https://github.com/apache/flink/pull/25115#discussion_r1764237227
##
flink-table/flink-sql-client/src/test/resources/sql/function.q:
##
@@ -1,4 +1,4 @@
-# function.q - CREATE/DROP/ALTER FUNCTION
+# function.q - CREATE/DROP/ALTER/SHOW/D
nateab commented on code in PR #25115:
URL: https://github.com/apache/flink/pull/25115#discussion_r1764237227
##
flink-table/flink-sql-client/src/test/resources/sql/function.q:
##
@@ -1,4 +1,4 @@
-# function.q - CREATE/DROP/ALTER FUNCTION
+# function.q - CREATE/DROP/ALTER/SHOW/D
boring-cyborg[bot] commented on PR #142:
URL:
https://github.com/apache/flink-connector-jdbc/pull/142#issuecomment-2357222740
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
ferenc-csaky commented on PR #25339:
URL: https://github.com/apache/flink/pull/25339#issuecomment-2356959667
cc @mateczagany
--
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.
AHeise merged PR #25292:
URL: https://github.com/apache/flink/pull/25292
--
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
jnh5y commented on code in PR #25115:
URL: https://github.com/apache/flink/pull/25115#discussion_r1764002232
##
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java:
##
@@ -448,6 +448,15 @@ void testDescribeModel() {
sql("de
jnh5y commented on code in PR #25115:
URL: https://github.com/apache/flink/pull/25115#discussion_r1764001398
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlRichDescribeTable.java:
##
@@ -39,7 +39,7 @@ public class SqlRichDescribeTable extends Sq
jnh5y commented on code in PR #25115:
URL: https://github.com/apache/flink/pull/25115#discussion_r1764000979
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlRichDescribeModel.java:
##
@@ -41,7 +41,7 @@ public class SqlRichDescribeModel extends Sq
jnh5y commented on code in PR #25115:
URL: https://github.com/apache/flink/pull/25115#discussion_r1763999075
##
flink-table/flink-sql-client/src/test/resources/sql/function.q:
##
@@ -1,4 +1,4 @@
-# function.q - CREATE/DROP/ALTER FUNCTION
+# function.q - CREATE/DROP/ALTER/SHOW/DE
jnh5y commented on code in PR #25115:
URL: https://github.com/apache/flink/pull/25115#discussion_r1763997897
##
docs/content/docs/dev/table/sql/describe.md:
##
@@ -26,7 +26,7 @@ under the License.
# DESCRIBE Statements
-DESCRIBE statements are used to describe the schema of
AHeise commented on PR #25292:
URL: https://github.com/apache/flink/pull/25292#issuecomment-2356464478
@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.
T
ferenc-csaky merged PR #25286:
URL: https://github.com/apache/flink/pull/25286
--
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.
flinkbot commented on PR #25345:
URL: https://github.com/apache/flink/pull/25345#issuecomment-2356294825
## CI report:
* 6ad92fb2dd01579e35993a8bf9ce70091703c6d1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly opened a new pull request, #25345:
URL: https://github.com/apache/flink/pull/25345
## 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
dylanhz commented on PR #25335:
URL: https://github.com/apache/flink/pull/25335#issuecomment-2356124774
@lincoln-lil I've made some updates about descriptions. Could you please
review this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
davidradl commented on code in PR #25336:
URL: https://github.com/apache/flink/pull/25336#discussion_r1762908443
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java:
##
@@ -1971,7 +1967,7 @@ private TypeInformation
privateGetForClass(
}
xiaochen-zhou commented on PR #116:
URL:
https://github.com/apache/flink-connector-kafka/pull/116#issuecomment-2355956742
Friendly ping, passed ci. If you have time, pls help to review it again.
thanks a lot. @AHeise
--
This is an automated message from the Apache Git Service.
To respo
mbalassi commented on PR #25342:
URL: https://github.com/apache/flink/pull/25342#issuecomment-2355827442
> Thanks. Overall, I think the tone is a bit too much like a blog post, and
a not enough like a documentation that you use as a reference.
Thanks, updated accordingly.
--
This i
boring-cyborg[bot] commented on PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#issuecomment-2355822850
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
AHeise merged PR #100:
URL: https://github.com/apache/flink-connector-kafka/pull/100
--
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...@
mbalassi commented on code in PR #25342:
URL: https://github.com/apache/flink/pull/25342#discussion_r1763256681
##
docs/content/docs/deployment/java_compatibility.md:
##
@@ -50,7 +50,8 @@ The following Flink features have not been tested with Java
11:
## Java 17
-Experimen
AHeise commented on code in PR #25292:
URL: https://github.com/apache/flink/pull/25292#discussion_r1763233550
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/AbstractStreamingWriter.java:
##
@@ -149,15 +190,20 @@ public void p
AHeise commented on code in PR #25292:
URL: https://github.com/apache/flink/pull/25292#discussion_r1763232011
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/AbstractStreamingWriter.java:
##
@@ -123,6 +142,27 @@ public void bu
TomiFG commented on code in PR #25343:
URL: https://github.com/apache/flink/pull/25343#discussion_r1763163971
##
docs/content/docs/connectors/table/hive/overview.md:
##
@@ -237,7 +237,7 @@ hive_catalog = HiveCatalog(catalog_name, default_database,
hive_conf_dir)
t_env.register
fapaul commented on code in PR #25292:
URL: https://github.com/apache/flink/pull/25292#discussion_r1763062367
##
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/stream/AbstractStreamingWriter.java:
##
@@ -123,6 +142,27 @@ public void bu
davidradl commented on code in PR #25275:
URL: https://github.com/apache/flink/pull/25275#discussion_r1762912702
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/ArrayAggr.java:
##
@@ -0,0 +1,81 @@
+package org.apache.flink.table.utils;
+
+import org.
davidradl commented on code in PR #25336:
URL: https://github.com/apache/flink/pull/25336#discussion_r1762908443
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java:
##
@@ -1971,7 +1967,7 @@ private TypeInformation
privateGetForClass(
}
davidradl commented on code in PR #25343:
URL: https://github.com/apache/flink/pull/25343#discussion_r1762819715
##
docs/content/docs/connectors/table/hive/overview.md:
##
@@ -237,7 +237,7 @@ hive_catalog = HiveCatalog(catalog_name, default_database,
hive_conf_dir)
t_env.regis
AHeise commented on PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#issuecomment-2355026088
Changes all LGTM. I'm running CI and merge when it's green.
Thank you very much for this much needed fix!
--
This is an automated message from the Apache Git Service.
To
AHeise commented on code in PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#discussion_r1762809895
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceITCase.java:
##
@@ -369,6 +370,38 @@ public void testConsumingTopi
vahmed-hamdy commented on PR #155:
URL:
https://github.com/apache/flink-connector-aws/pull/155#issuecomment-2354877068
@hlteoh37 Thanks for the review, Addressed now!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
1996fanrui commented on PR #25344:
URL: https://github.com/apache/flink/pull/25344#issuecomment-2354875613
Thanks @hackergin for pointing it out. Let me close this PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
1996fanrui closed pull request #25344: [hotfix][doc] Fix the wrong link of
materialized table
URL: https://github.com/apache/flink/pull/25344
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the spec
hackergin commented on PR #25344:
URL: https://github.com/apache/flink/pull/25344#issuecomment-2354868964
@1996fanrui There is similar pr https://github.com/apache/flink/pull/25315
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
gguptp commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762623393
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -250,6 +2
vahmed-hamdy commented on code in PR #155:
URL:
https://github.com/apache/flink-connector-aws/pull/155#discussion_r1762620710
##
flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsConnectorOptions.java:
##
@@ -0,0 +1,52 @@
+/*
+ * Lice
gguptp commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762621737
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -250,6 +2
hlteoh37 commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762617573
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -250,6
hlteoh37 commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762616322
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -250,6
vahmed-hamdy commented on code in PR #155:
URL:
https://github.com/apache/flink-connector-aws/pull/155#discussion_r1762615947
##
flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsDynamicSink.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed
gguptp commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762610714
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -185,7 +1
hlteoh37 commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762608231
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -185,7
gguptp commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762602286
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java:
##
@
hlteoh37 commented on code in PR #166:
URL:
https://github.com/apache/flink-connector-aws/pull/166#discussion_r1762594562
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/DynamoDbStreamsSourceEnumerator.java:
##
hlteoh37 commented on code in PR #165:
URL:
https://github.com/apache/flink-connector-aws/pull/165#discussion_r1762592327
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisSourceConfigOptions.java:
#
hlteoh37 commented on code in PR #165:
URL:
https://github.com/apache/flink-connector-aws/pull/165#discussion_r1762587971
##
flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigOptions.java:
##
@@ -0,0 +1,187 @@
+/*
+ * Licensed to the Apache S
hlteoh37 commented on code in PR #165:
URL:
https://github.com/apache/flink-connector-aws/pull/165#discussion_r1762587467
##
flink-connector-aws-base/pom.xml:
##
@@ -87,6 +87,12 @@ under the License.
test
+
+software.amazon.awssdk
+
hlteoh37 commented on PR #150:
URL:
https://github.com/apache/flink-connector-aws/pull/150#issuecomment-2354810490
Closed as replaced by this PR
https://github.com/apache/flink-connector-aws/pull/165
--
This is an automated message from the Apache Git Service.
To respond to the message,
hlteoh37 closed pull request #150: [FLINK-31922][Connectors/AWS] Port over
Kinesis Client configurations for retry and backoff
URL: https://github.com/apache/flink-connector-aws/pull/150
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
gguptp opened a new pull request, #166:
URL: https://github.com/apache/flink-connector-aws/pull/166
## Purpose of the change
Adds incremental shard discovery for DDB Streams source. Since full
describestream discovery can take a longer time, having incremental shard
d
flinkbot commented on PR #25344:
URL: https://github.com/apache/flink/pull/25344#issuecomment-2354728877
## CI report:
* 8239f405e28f45a0143c4ae3df5b22ec84b5bb50 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
1996fanrui opened a new pull request, #25344:
URL: https://github.com/apache/flink/pull/25344
## What is the purpose of the change
The link has 2 `https://` prefixes.
## Brief change log
[hotfix][doc] Fix the wrong link of materialized table
--
This is an autom
1996fanrui merged PR #25333:
URL: https://github.com/apache/flink/pull/25333
--
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.ap
dongwoo6kim commented on PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#issuecomment-2354460790
@AHeise Thanks for the feedback. I've left some comments and made updates.
Please have a look.
--
This is an automated message from the Apache Git Service.
To respond t
dongwoo6kim commented on PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#issuecomment-2354458757
> Seems like the deleted arch unit rule was still needed. What was your
intent when you deleted it?
It was automatically deleted after running `mvn clean verify` lo
dongwoo6kim commented on code in PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#discussion_r1762233642
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceITCase.java:
##
@@ -369,6 +370,38 @@ public void testConsumin
dongwoo6kim commented on code in PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#discussion_r1762233642
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceITCase.java:
##
@@ -369,6 +370,38 @@ public void testConsumin
dongwoo6kim commented on code in PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#discussion_r1762220365
##
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java:
##
@@ -188,6 +190,66 @@ public void tes
dongwoo6kim commented on code in PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#discussion_r1762219777
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceITCase.java:
##
@@ -369,6 +370,38 @@ public void testConsumin
github-actions[bot] commented on PR #2061:
URL: https://github.com/apache/flink-cdc/pull/2061#issuecomment-2354238716
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
github-actions[bot] commented on PR #3415:
URL: https://github.com/apache/flink-cdc/pull/3415#issuecomment-2354238674
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
flinkbot commented on PR #25343:
URL: https://github.com/apache/flink/pull/25343#issuecomment-2353927053
## CI report:
* d723c7beb1d7734f8353c467109e8a4a8251438d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
rmetzger commented on PR #25342:
URL: https://github.com/apache/flink/pull/25342#issuecomment-2353900424
Thanks. Overall, I think the tone is a bit too much like a blog post, and a
not enough like a documentation that you use as a reference.
--
This is an automated message from the Apache
rmetzger commented on code in PR #25342:
URL: https://github.com/apache/flink/pull/25342#discussion_r1761871634
##
docs/content/docs/deployment/java_compatibility.md:
##
@@ -50,7 +50,8 @@ The following Flink features have not been tested with Java
11:
## Java 17
-Experimen
rmetzger commented on code in PR #25342:
URL: https://github.com/apache/flink/pull/25342#discussion_r1761865441
##
docs/content/docs/deployment/java_compatibility.md:
##
@@ -50,7 +50,8 @@ The following Flink features have not been tested with Java
11:
## Java 17
-Experimen
TomiFG opened a new pull request, #25343:
URL: https://github.com/apache/flink/pull/25343
Fix python example variable `t_env` being mistakenly referenced as
`tableEnv`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
XComp merged PR #25250:
URL: https://github.com/apache/flink/pull/25250
--
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.
XComp commented on PR #25250:
URL: https://github.com/apache/flink/pull/25250#issuecomment-2353308496
force-pushed a rebase to master after FLINK-36279 was merged.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
XComp merged PR #25341:
URL: https://github.com/apache/flink/pull/25341
--
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.
jnh5y commented on code in PR #25211:
URL: https://github.com/apache/flink/pull/25211#discussion_r1761393374
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java:
##
@@ -476,11 +578,12 @@ public CatalogFunction getFunction(
jnh5y commented on code in PR #25211:
URL: https://github.com/apache/flink/pull/25211#discussion_r1761390457
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -1341,6 +1352,293 @@ private void dropTableInternal(
jnh5y commented on code in PR #25211:
URL: https://github.com/apache/flink/pull/25211#discussion_r1761332241
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -1341,6 +1352,293 @@ private void dropTableInternal(
jnh5y commented on code in PR #25211:
URL: https://github.com/apache/flink/pull/25211#discussion_r1761329016
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -1341,6 +1352,293 @@ private void dropTableInternal(
jnh5y commented on code in PR #25211:
URL: https://github.com/apache/flink/pull/25211#discussion_r1761326715
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -888,7 +899,7 @@ public Set listSchemas() {
* NOTE:It is
jnh5y commented on code in PR #25211:
URL: https://github.com/apache/flink/pull/25211#discussion_r1761325334
##
flink-python/pyflink/table/catalog.py:
##
@@ -15,9 +15,8 @@
# See the License for the specific language governing permissions and
# limitations under the License.
karubian opened a new pull request, #165:
URL: https://github.com/apache/flink-connector-aws/pull/165
## Purpose of the change
Port over Kinesis Client configurations for retry and backoff
## Verifying this change
- *Added unit tests*
## Significant changes
*(Pl
fapaul commented on PR #119:
URL:
https://github.com/apache/flink-connector-kafka/pull/119#issuecomment-2353092492
Looking at the current test failures of this PR the log size
(https://github.com/apache/flink-connector-kafka/actions/runs/10881066111/job/30189211552?pr=119)
is still 50MB+.
dzikosc commented on code in PR #76:
URL:
https://github.com/apache/flink-connector-aws/pull/76#discussion_r1761179807
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/fanout/StreamConsumerRegistrar.java:
karubian commented on code in PR #150:
URL:
https://github.com/apache/flink-connector-aws/pull/150#discussion_r1758962947
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java:
##
@@ -226,4 +
karubian commented on code in PR #150:
URL:
https://github.com/apache/flink-connector-aws/pull/150#discussion_r1761182118
##
flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigOptions.java:
##
@@ -0,0 +1,187 @@
+/*
+ * Licensed to the Apache S
karubian commented on code in PR #150:
URL:
https://github.com/apache/flink-connector-aws/pull/150#discussion_r1761179260
##
flink-connector-aws-base/pom.xml:
##
@@ -87,6 +87,12 @@ under the License.
test
+
+software.amazon.awssdk
+
dzikosc commented on code in PR #76:
URL:
https://github.com/apache/flink-connector-aws/pull/76#discussion_r1760919190
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java:
##
@@ -178,6 +185
zoltar9264 commented on PR #24879:
URL: https://github.com/apache/flink/pull/24879#issuecomment-2352836545
@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
flinkbot commented on PR #25342:
URL: https://github.com/apache/flink/pull/25342#issuecomment-2352764203
## CI report:
* ba05a7d2ae38b1c1e4219978cbaae3ae6737b252 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
601 - 700 of 5348 matches
Mail list logo
