[
https://issues.apache.org/jira/browse/FLINK-30219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638798#comment-17638798
]
Aiden Gong commented on FLINK-30219:
Hi , [~Leonard] , I'm willing to fix this issue
Aiden Gong created FLINK-30219:
--
Summary: Fetch results api in sql gateway return error result.
Key: FLINK-30219
URL: https://issues.apache.org/jira/browse/FLINK-30219
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638796#comment-17638796
]
liwei li commented on FLINK-29828:
--
hi, [~zjureel] , Why not we use SQL Hints? IMO, it
[
https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638774#comment-17638774
]
Gyula Fora commented on FLINK-30213:
The same issue already existed Flink with the r
[
https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-30213:
---
Attachment: image-2022-11-25-21-58-48-968.png
> The edge is wrong when the vertex parallelism is cha
gaborgsomogyi commented on PR #21392:
URL: https://github.com/apache/flink/pull/21392#issuecomment-1327832635
Well, seems like it's in `target/test/data/` for god knows why.
--
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-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638614#comment-17638614
]
Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 7:21 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638614#comment-17638614
]
Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 7:20 PM:
-
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1032654791
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitState.java:
##
@@ -0,0 +1,46 @@
+/*
+ * Licensed
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1032653087
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoSourceSplitReader.java:
##
@@ -0,0 +1,33 @@
+/*
+ * L
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1032644671
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSink.java:
##
@@ -0,0 +1,132 @@
+/*
+ * Licensed to the
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1032635261
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoConnectorOptions.java:
##
@@ -0,0 +1,143 @@
+/*
+ * Licensed to the
zentol commented on code in PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#discussion_r1032611085
##
flink-connector-cassandra/pom.xml:
##
@@ -78,6 +78,12 @@ under the License.
provided
+
+
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1032603066
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java:
##
@@ -0,0 +1,202 @@
+/*
+ * Licensed to
RyanSkraba commented on PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#issuecomment-1327674570
I'm taking a look! Thanks for the ping :+1:
--
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-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638690#comment-17638690
]
Maximilian Michels commented on FLINK-29856:
I think the reason why Flink do
1996fanrui commented on PR #21398:
URL: https://github.com/apache/flink/pull/21398#issuecomment-1327654213
@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
[
https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-29856:
---
Affects Version/s: 1.15.0
> Triggering savepoint does not trigger operator notifyChe
[
https://issues.apache.org/jira/browse/FLINK-29987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29987:
---
Labels: pull-request-available (was: )
> PartialUpdateITCase.testForeignKeyJo is unstable
>
Ge opened a new pull request, #404:
URL: https://github.com/apache/flink-table-store/pull/404
This patch stabilizes `PartialUpdateITCase#testForeignKeyJoin` and
introduces a new test dependency -
[Awaitility](https://github.com/awaitility/awaitility) that can be conveniently
used to pr
[
https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-30214:
Component/s: Runtime / Configuration
> The resource is not enough
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-30054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-30054:
--
Assignee: Yufan Sheng
> Move existing Pulsar connector code from Flink repo to dedica
[
https://issues.apache.org/jira/browse/FLINK-30217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xljtswf updated FLINK-30217:
Component/s: API / DataStream
> Use ListState#update() to replace clear + add mode.
>
[
https://issues.apache.org/jira/browse/FLINK-30218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lukas Mahl updated FLINK-30218:
---
Description:
Hello!
I'm running a Flink application on AWS EMR which consumes from a Kafka Topic
u
Lukas Mahl created FLINK-30218:
--
Summary: [Kafka Connector] java.lang.OutOfMemoryError: Metaspace
Key: FLINK-30218
URL: https://issues.apache.org/jira/browse/FLINK-30218
Project: Flink
Issue Typ
xljtswf created FLINK-30217:
---
Summary: Use ListState#update() to replace clear + add mode.
Key: FLINK-30217
URL: https://issues.apache.org/jira/browse/FLINK-30217
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-30202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-30202:
Assignee: Chesnay Schepler
> DataGeneratorSourceITCase.testGatedRateLimiter faile
[
https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638673#comment-17638673
]
Maximilian Michels commented on FLINK-30213:
Thanks for reporting this [~fan
sazzad16 commented on PR #5:
URL:
https://github.com/apache/flink-connector-redis-streams/pull/5#issuecomment-1327541752
@MartijnVisser Sure. But please understand that it would take some time as
at this moment it is difficult to dedicate time.
--
This is an automated message from the Ap
dannycranmer merged PR #29:
URL: https://github.com/apache/flink-connector-aws/pull/29
--
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..
echauchot commented on PR #21035:
URL: https://github.com/apache/flink/pull/21035#issuecomment-1327525295
@zentol what do you want that we do with this PR?
Having no safe guard in the test waiting loop seems dangerous to me: during
the implementation of a source, it could happen that the
pnowojski commented on code in PR #20137:
URL: https://github.com/apache/flink/pull/20137#discussion_r1032479797
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriteRequestExecutorImpl.java:
##
@@ -51,27 +64,46 @@ class ChannelStateWriteRe
echauchot commented on PR #3:
URL:
https://github.com/apache/flink-connector-cassandra/pull/3#issuecomment-1327516095
R: @zentol
R: @RyanSkraba you mentioned that you already started to review this PR
(when it was in the main flink repo) car you send your review comments ?
--
This is
[
https://issues.apache.org/jira/browse/FLINK-30216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30216:
---
Labels: pull-request-available (was: )
> Address tabs/spaces in checkstyle/spotless
> -
darenwkt opened a new pull request, #453:
URL: https://github.com/apache/flink-kubernetes-operator/pull/453
… files
## What is the purpose of the change
This change is to improve the code quality of the repo by standardising
tab/spaces based on [flink code style
guide]
[
https://issues.apache.org/jira/browse/FLINK-30216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daren Wong updated FLINK-30216:
---
Description:
The Flink Kubernetes Operator repo has a mix of tabs and spaces, the quality
config do
echauchot closed pull request #21073: [FLINK-26822] Add Source for Cassandra
connector
URL: https://github.com/apache/flink/pull/21073
--
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 co
echauchot commented on PR #21073:
URL: https://github.com/apache/flink/pull/21073#issuecomment-1327500964
Closing, because this PR was moved to the new cassandra dedicated
repository: https://github.com/apache/flink-connector-cassandra/pull/3
--
This is an automated message from the Apach
Daren Wong created FLINK-30216:
--
Summary: Address tabs/spaces in checkstyle/spotless
Key: FLINK-30216
URL: https://issues.apache.org/jira/browse/FLINK-30216
Project: Flink
Issue Type: Improvemen
echauchot opened a new pull request, #3:
URL: https://github.com/apache/flink-connector-cassandra/pull/3
This PR is the move of https://github.com/apache/flink/pull/21073 to the
cassandra dedicated repo
--
This is an automated message from the Apache Git Service.
To respond to the message
zentol commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-hbase/pull/1#discussion_r1032457087
##
pom.xml:
##
@@ -0,0 +1,545 @@
+
+
+http://maven.apache.org/POM/4.0.0";
+xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+
[
https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-12675.
--
Resolution: Won't Fix
> Event time synchronization in Kafka consumer
> ---
[
https://issues.apache.org/jira/browse/FLINK-10886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-10886.
--
Resolution: Done
> Event time synchronization across sources
> ---
1996fanrui commented on PR #21353:
URL: https://github.com/apache/flink/pull/21353#issuecomment-1327485152
@pnowojski Thanks for your 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 the s
[
https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638662#comment-17638662
]
Thomas Weise commented on FLINK-12675:
--
Partition/split level alignment is supporte
zentol commented on PR #1:
URL:
https://github.com/apache/flink-connector-hbase/pull/1#issuecomment-1327476765
I'm not surprised that dependency convergence is a pain. It is one of the
big reasons why we haven't done it in Flink already.
--
This is an automated message from the Apache Gi
zentol commented on PR #1:
URL:
https://github.com/apache/flink-connector-hbase/pull/1#issuecomment-1327475343
FYI, we'd like to retain the git history. The [externalization
guide](https://cwiki.apache.org/confluence/display/FLINK/Externalized+Connector+development)
contains some hints to
zentol commented on code in PR #26:
URL:
https://github.com/apache/flink-connector-aws/pull/26#discussion_r1032449534
##
docs/content.zh/docs/connectors/datastream/dynamodb.md:
##
@@ -0,0 +1,171 @@
+---
+title: DynamoDB
+weight: 5
+type: docs
+aliases:
+- /zh/dev/connectors/dyn
zentol commented on code in PR #26:
URL:
https://github.com/apache/flink-connector-aws/pull/26#discussion_r1032447973
##
docs/content.zh/docs/connectors/datastream/dynamodb.md:
##
@@ -0,0 +1,171 @@
+---
+title: DynamoDB
+weight: 5
+type: docs
+aliases:
+- /zh/dev/connectors/dyn
zentol commented on code in PR #26:
URL:
https://github.com/apache/flink-connector-aws/pull/26#discussion_r1032447531
##
docs/content.zh/docs/connectors/table/dynamodb.md:
##
@@ -0,0 +1,306 @@
+---
+title: DynamoDB
+weight: 5
+type: docs
+aliases:
+- /zh/dev/table/connectors/dy
gaborgsomogyi commented on PR #21391:
URL: https://github.com/apache/flink/pull/21391#issuecomment-1327467670
@mbalassi success w/ 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 go to the spec
reta commented on PR #1:
URL:
https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1327467520
@zentol thnaks a lot for the review, I think I addressed all your comments,
please let me know if I missed some, thanks!
--
This is an automated message from the Apache Git S
fapaul merged PR #581:
URL: https://github.com/apache/flink-web/pull/581
--
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
[
https://issues.apache.org/jira/browse/FLINK-30100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-30100.
--
Assignee: Rui Fan
Resolution: Fixed
Merged to master as 5e0e0fde630..aa0cd873709
> Remo
pnowojski merged PR #21353:
URL: https://github.com/apache/flink/pull/21353
--
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.apa
Chesnay Schepler created FLINK-30215:
Summary: Deprecated Cassandra explicit Scala support
Key: FLINK-30215
URL: https://issues.apache.org/jira/browse/FLINK-30215
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638655#comment-17638655
]
Piotr Nowojski commented on FLINK-28853:
I think yes, but it looks like [the
do
[
https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-28853:
---
Release Note:
Added support for watermark alignment of source splits.
Since Flink 1.17, so
zjureel commented on PR #402:
URL:
https://github.com/apache/flink-table-store/pull/402#issuecomment-1327448839
Hi @JingsongLi I try to fix this issue and get some problems
Current I convert the database, table and fields names to lower case in
`HiveCatalog`, but there will be probl
[
https://issues.apache.org/jira/browse/FLINK-27117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-27117.
--
Resolution: Duplicate
> FLIP-217: Support watermark alignment of source splits
> -
gaborgsomogyi commented on PR #21392:
URL: https://github.com/apache/flink/pull/21392#issuecomment-1327436272
Now it's pretty clear that
`/__w/1/s/flink-yarn-tests/target/flink-yarn-tests-fifo` dir is never created.
Now the question, where is it then :/
--
This is an automated message fr
fapaul merged PR #21399:
URL: https://github.com/apache/flink/pull/21399
--
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
fapaul merged PR #140:
URL: https://github.com/apache/flink-docker/pull/140
--
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.apa
fapaul opened a new pull request, #21399:
URL: https://github.com/apache/flink/pull/21399
Update japicmp configuration for 1.15.3, as part of finalizing the release
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
fapaul opened a new pull request, #140:
URL: https://github.com/apache/flink-docker/pull/140
Updated the docker images taking
https://github.com/apache/flink-docker/pull/128 as an example.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
dannycranmer merged PR #30:
URL: https://github.com/apache/flink-connector-aws/pull/30
--
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..
hlteoh37 commented on PR #584:
URL: https://github.com/apache/flink-web/pull/584#issuecomment-1327328405
Agreed offline that additional comments are nits, so will go ahead with
current MD!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
dannycranmer opened a new pull request, #30:
URL: https://github.com/apache/flink-connector-aws/pull/30
## What is the purpose of the change
- Fix Flink 1.15/1.16 CI build
## Verifying this change
- Verified in personal account
--
This is an automated message from the
dannycranmer commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-aws/pull/29#discussion_r1032260627
##
flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/client/DynamoDbAsyncClientProvider.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638616#comment-17638616
]
Rui Fan edited comment on FLINK-30214 at 11/25/22 10:29 AM:
ferenc-csaky commented on PR #1:
URL:
https://github.com/apache/flink-connector-hbase/pull/1#issuecomment-1327297981
Frankly, achieving dependency convergence made dependency management and
exclusions quite messy at this point and the main cause of that is some Hadoop
dependencies are the
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638614#comment-17638614
]
Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 10:23 AM:
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638614#comment-17638614
]
Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 10:23 AM:
[
https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638616#comment-17638616
]
Rui Fan commented on FLINK-30214:
-
Hi [~gyfora] , thanks for your quick feedback.
I run
flinkbot commented on PR #21398:
URL: https://github.com/apache/flink/pull/21398#issuecomment-1327289959
## CI report:
* e79c88a8cdbe4d96262754591ed20833b2c0e4b7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638614#comment-17638614
]
Krzysztof Chmielewski edited comment on FLINK-27246 at 11/25/22 10:14 AM:
[
https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30214:
---
Labels: pull-request-available (was: )
> The resource is not enough
> -
1996fanrui opened a new pull request, #21398:
URL: https://github.com/apache/flink/pull/21398
## What is the purpose of the change
When turn up the parallelism, the resources isn't enough for MiniCluster.
## Brief change log
MiniCluster adapt the jobvertex-parallelism-ove
[
https://issues.apache.org/jira/browse/FLINK-27246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638614#comment-17638614
]
Krzysztof Chmielewski commented on FLINK-27246:
---
Hi [~TsReaper]
Im sory fo
[
https://issues.apache.org/jira/browse/FLINK-30056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-30056.
Fix Version/s: 1.17.0
Resolution: Fixed
master: 5e0e0fde6305577192fe8020fcb1fa8ca3b
zentol merged PR #21150:
URL: https://github.com/apache/flink/pull/21150
--
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
[
https://issues.apache.org/jira/browse/FLINK-30156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-30156.
--
Resolution: Fixed
> [FLIP-242] Blogpost about the customisable RateLimitingStrategy in the
>
zentol commented on PR #21394:
URL: https://github.com/apache/flink/pull/21394#issuecomment-1327225053
> Otherwise, we would have seen this error already earlier.
Not necessarily though; you just need 1 step of the shutdown procedure being
slow enough.
--
This is an automated mess
eskabetxe commented on PR #3:
URL:
https://github.com/apache/flink-connector-redis-streams/pull/3#issuecomment-1327224834
Hi @MartijnVisser, it's pretty much at a standstill.
As it is only for streams it does not fit in our use case and it is
difficult to dedicate time to it.
Anyway,
zentol commented on code in PR #21387:
URL: https://github.com/apache/flink/pull/21387#discussion_r1032178749
##
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/ReporterSetup.java:
##
@@ -464,6 +466,21 @@ private static Optional loadViaReflection(
[
https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638602#comment-17638602
]
Gyula Fora commented on FLINK-30214:
Hi [~fanrui],
Thanks for jumping on this and te
LadyForest commented on code in PR #20652:
URL: https://github.com/apache/flink/pull/20652#discussion_r1032175300
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java:
##
@@ -1466,6 +1476,441 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-30213:
--
Assignee: Maximilian Michels
> The edge is wrong when the vertex parallelism
rmetzger merged PR #586:
URL: https://github.com/apache/flink-web/pull/586
--
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
rmetzger commented on PR #586:
URL: https://github.com/apache/flink-web/pull/586#issuecomment-1327207647
Thx for the rebuild. My arm mac book is not yet properly setup for
rebuilding the website.
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
MartijnVisser commented on PR #21386:
URL: https://github.com/apache/flink/pull/21386#issuecomment-1327206680
@HuangXingBo I was expecting that a patch update for py4j would not break
anything, but it seems like it does. If you know a quick fix for this, let me
know, else I'll drop the upda
[
https://issues.apache.org/jira/browse/FLINK-30205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30205:
---
Labels: pull-request-available (was: )
> Modify compact interface for TableWrite and FileSt
tsreaper opened a new pull request, #403:
URL: https://github.com/apache/flink-table-store/pull/403
Currently the compact interface in `TableWrite` and `FileStoreWrite` can
only trigger full compaction. However a separated compact job should not only
perform full compaction, but also perfor
[
https://issues.apache.org/jira/browse/FLINK-30214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638597#comment-17638597
]
Rui Fan commented on FLINK-30214:
-
Hi [~gyfora] [~mxm] , please help take a look, thanks
Rui Fan created FLINK-30214:
---
Summary: The resource is not enough
Key: FLINK-30214
URL: https://issues.apache.org/jira/browse/FLINK-30214
Project: Flink
Issue Type: Bug
Reporter: Rui Fa
MartijnVisser commented on PR #3:
URL:
https://github.com/apache/flink-connector-redis-streams/pull/3#issuecomment-1327197048
@eskabetxe @sazzad16 Is there any update on this process? Also check out
https://cwiki.apache.org/confluence/display/FLINK/Externalized+Connector+development
for so
MartijnVisser commented on PR #5:
URL:
https://github.com/apache/flink-connector-redis-streams/pull/5#issuecomment-1327196394
@sazzad16 Can you have a look at
https://cwiki.apache.org/confluence/display/FLINK/Externalized+Connector+development
and update this PR accordingly?
--
This is
[
https://issues.apache.org/jira/browse/FLINK-30213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638589#comment-17638589
]
Rui Fan commented on FLINK-30213:
-
Hi [~gyfora] [~mxm] , please help take a look, and I
hlteoh37 opened a new pull request, #586:
URL: https://github.com/apache/flink-web/pull/586
Adding a blogpost for
https://github.com/apache/flink-web/commit/0e4b8a20ac88202c8ff5c671014d4c464c86ec8d
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
echauchot commented on PR #2:
URL:
https://github.com/apache/flink-connector-cassandra/pull/2#issuecomment-1327188718
> Couldn't sleep so I just started fixing things myself. Squashed all your
changes into a single commit.
Thanks Chesnay for the review and the night merge :smile: I c
1 - 100 of 141 matches
Mail list logo
