[
https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630832#comment-17630832
]
Matthias Pohl commented on FLINK-29405:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630827#comment-17630827
]
Matthias Pohl edited comment on FLINK-24119 at 11/9/22 8:00 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-28394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630834#comment-17630834
]
Matthias Pohl commented on FLINK-28394:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-29952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630836#comment-17630836
]
Hang HOU commented on FLINK-29952:
--
[~yzl]Hi! I'm glad to do this and I'm fixing this n
tsreaper commented on code in PR #361:
URL: https://github.com/apache/flink-table-store/pull/361#discussion_r1017509266
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FullChangelogStoreWriteOperator.java:
##
@@ -0,0 +1,224 @@
+/*
+ * Lic
tsreaper merged PR #366:
URL: https://github.com/apache/flink-table-store/pull/366
--
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...@fl
[
https://issues.apache.org/jira/browse/FLINK-29840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-29840.
---
Resolution: Fixed
master: f54008c98f51e419fa4a80d6fe0e62ab97358c54
release-0.2: fe0f333f5289081ca210
[
https://issues.apache.org/jira/browse/FLINK-29943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng closed FLINK-29943.
---
Resolution: Fixed
release-0.2: 1de91d059cd4ec5e094f52d08b016582e030e944
> Bump Table Store 0.2 Flin
[
https://issues.apache.org/jira/browse/FLINK-28394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630840#comment-17630840
]
Matthias Pohl commented on FLINK-28394:
---
[~hxbks2ks] can you give some guidance he
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu updated FLINK-29852:
--
Attachment: image-2022-11-09-16-09-44-233.png
> The operator is repeatedly displayed on the Flink Web
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630841#comment-17630841
]
Weihua Hu commented on FLINK-29852:
---
I can't reproduce this with this jar.{*}{*}
*
[
https://issues.apache.org/jira/browse/FLINK-28395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630843#comment-17630843
]
Matthias Pohl commented on FLINK-28395:
---
Was this actually fixed in the end? I cou
dannycranmer opened a new pull request, #17:
URL: https://github.com/apache/flink-connector-aws/pull/17
## What is the purpose of the change
Improve DynamoDB Connector Sample Code
(https://lists.apache.org/thread/lhvhsyrl3o88lsb6so8158nz6qogsqvn)
## Brief change log
* Mo
[
https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reopened FLINK-28177:
---
I'm reopening the issue. We experienced this error again in a more recent 1.16
build that inclu
[
https://issues.apache.org/jira/browse/FLINK-29954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29954:
---
Labels: pull-request-available (was: )
> Improve DynamoDB Connector Sample Code
> -
dannycranmer opened a new pull request, #18:
URL: https://github.com/apache/flink-connector-aws/pull/18
## What is the purpose of the change
Rename `DynamoDBEnhancedElementConverter` to `DynamoDbBeanElementConverter`
and general tidy
## Brief change log
- Rename `DynamoD
[
https://issues.apache.org/jira/browse/FLINK-29835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630849#comment-17630849
]
Matthias Pohl commented on FLINK-29835:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-28394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630851#comment-17630851
]
Matthias Pohl commented on FLINK-28394:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630827#comment-17630827
]
Matthias Pohl edited comment on FLINK-24119 at 11/9/22 8:25 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-29952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630852#comment-17630852
]
yuzelin commented on FLINK-29952:
-
Thanks for your contribution. [~fsk119] can you take
[
https://issues.apache.org/jira/browse/FLINK-29952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630852#comment-17630852
]
yuzelin edited comment on FLINK-29952 at 11/9/22 8:27 AM:
--
[~St
JingsongLi closed pull request #367: Revert "[FLINK-29933] Bump Flink version
to 1.16.0"
URL: https://github.com/apache/flink-table-store/pull/367
--
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
XComp commented on PR #21259:
URL: https://github.com/apache/flink/pull/21259#issuecomment-1308394398
@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.
To
JingsongLi merged PR #368:
URL: https://github.com/apache/flink-table-store/pull/368
--
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...@
tsreaper commented on code in PR #361:
URL: https://github.com/apache/flink-table-store/pull/361#discussion_r1017618639
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FullChangelogStoreWriteOperator.java:
##
@@ -0,0 +1,224 @@
+/*
+ * Lic
gyfora merged PR #432:
URL: https://github.com/apache/flink-kubernetes-operator/pull/432
--
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
dingweiqings commented on code in PR #20755:
URL: https://github.com/apache/flink/pull/20755#discussion_r1017621223
##
flink-formats/flink-hadoop-bulk/src/test/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPartFileWriterTest.java:
##
@@ -82,13 +83,13 @@ public void te
[
https://issues.apache.org/jira/browse/FLINK-28395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630856#comment-17630856
]
KurtDing commented on FLINK-28395:
--
I am going to work with this issue today later
> E
gyfora commented on PR #357:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/357#issuecomment-1308401310
Hi @Grypse
I am closing this PR due to inactivity, please feel free to re-open it once
you have the FLIP for this feature up for discussion on the mailing list!
--
Th
gyfora closed pull request #357: [FLINK-29110] Use StatefulSet instead of
Deployment to deploy JM and …
URL: https://github.com/apache/flink-kubernetes-operator/pull/357
--
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-29860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630857#comment-17630857
]
Noel O'Connor commented on FLINK-29860:
---
[~syhily] PR updated
> Pulsar connector
dannycranmer merged PR #18:
URL: https://github.com/apache/flink-connector-aws/pull/18
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr..
[
https://issues.apache.org/jira/browse/FLINK-29937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630643#comment-17630643
]
Danny Cranmer edited comment on FLINK-29937 at 11/9/22 8:57 AM:
--
dannycranmer merged PR #17:
URL: https://github.com/apache/flink-connector-aws/pull/17
--
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..
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1017645688
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumStateSerializer.java:
##
@@ -0,0 +1,114 @@
+/
[
https://issues.apache.org/jira/browse/FLINK-29954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630862#comment-17630862
]
Danny Cranmer commented on FLINK-29954:
---
Merged commit
[{{bd1edd6}}|https://githu
[
https://issues.apache.org/jira/browse/FLINK-29954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-29954.
---
Resolution: Fixed
> Improve DynamoDB Connector Sample Code
> ---
[
https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630867#comment-17630867
]
Xintong Song commented on FLINK-8712:
-
[~huwh], what about batch jobs? Say you have 1
tsreaper commented on code in PR #361:
URL: https://github.com/apache/flink-table-store/pull/361#discussion_r1017662573
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FullChangelogStoreWriteOperator.java:
##
@@ -0,0 +1,224 @@
+/*
+ * Lic
tsreaper commented on code in PR #361:
URL: https://github.com/apache/flink-table-store/pull/361#discussion_r1017662573
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/FullChangelogStoreWriteOperator.java:
##
@@ -0,0 +1,224 @@
+/*
+ * Lic
yuchenECNU opened a new pull request, #21269:
URL: https://github.com/apache/flink/pull/21269
## What is the purpose of the change
*Savepoint format is not exposed on the Web UI, thus users should remember
how they triggered it.
This PR introduce savepoint format type to Ch
[
https://issues.apache.org/jira/browse/FLINK-29322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29322:
---
Labels: pull-request-available (was: )
> Expose savepoint format on Web UI
> --
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630872#comment-17630872
]
JasonLee commented on FLINK-29852:
--
Hi [~huwh] That's a little weird,I submit the task
[ https://issues.apache.org/jira/browse/FLINK-29852 ]
JasonLee deleted comment on FLINK-29852:
--
was (Author: jasonlee):
Hi [~huwh] That's a little weird,I submit the task with the following command:
{code:java}
./flink run-application -t yarn-appli
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1017685301
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java:
##
@@ -0,0 +1,233 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JasonLee updated FLINK-29852:
-
Attachment: image-2022-11-09-17-32-27-377.png
> The operator is repeatedly displayed on the Flink Web UI
flinkbot commented on PR #21269:
URL: https://github.com/apache/flink/pull/21269#issuecomment-1308471168
## CI report:
* f6a646eb77546ecd9322b3fd0746bf9a0e38ba31 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630875#comment-17630875
]
Gyula Fora commented on FLINK-29939:
Sounds good +1
> Add metrics for Kubernetes Cl
Jeff Yang created FLINK-29955:
-
Summary: Upgrade hogo version to v0.104.0
Key: FLINK-29955
URL: https://issues.apache.org/jira/browse/FLINK-29955
Project: Flink
Issue Type: Improvement
zentol merged PR #21259:
URL: https://github.com/apache/flink/pull/21259
--
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-29927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-29927.
Resolution: Fixed
master: 304122eadc52dd6ee8c04d9777d97eb66aec5e0e
1.16: 313e30483e9770d18
zentol commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1017697303
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config/MongoConnectionOptions.java:
##
@@ -0,0 +1,128 @@
+/*
+ * Licensed t
zentol commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1017698998
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java:
##
@@ -0,0 +1,233 @@
+/*
+ * Licensed to the A
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1017704601
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config/MongoConnectionOptions.java:
##
@@ -0,0 +1,128 @@
+/*
+ * Licens
yangjf2019 opened a new pull request, #433:
URL: https://github.com/apache/flink-kubernetes-operator/pull/433
## What is the purpose of the change
* The current version is two years old, consider upgrading to the latest
stable version.I upgraded the version of hogo to version
[
https://issues.apache.org/jira/browse/FLINK-29955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29955:
---
Labels: pull-request-available (was: )
> Upgrade hogo version to v0.104.0
> ---
vahmed-hamdy commented on PR #21265:
URL: https://github.com/apache/flink/pull/21265#issuecomment-1308492524
Thanks @dannycranmer , LGTM
--
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 specif
zentol commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1017713074
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java:
##
@@ -0,0 +1,233 @@
+/*
+ * Licensed to the A
vahmed-hamdy commented on PR #21265:
URL: https://github.com/apache/flink/pull/21265#issuecomment-1308496518
Are we going to have follow up PRs for `KinesisStreamsSinkElementConverter`
and `KinesisFirehoseSinkElementConverter`?
--
This is an automated message from the Apache Git Service.
zentol commented on code in PR #21128:
URL: https://github.com/apache/flink/pull/21128#discussion_r1017717297
##
pom.xml:
##
@@ -437,6 +445,14 @@ under the License.
org.slf4j
slf4j-l
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1017723597
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java:
##
@@ -0,0 +1,233 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-29852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630900#comment-17630900
]
JasonLee commented on FLINK-29852:
--
Hi [~huwh] That's a little weird,I submit the task
tisonkun commented on PR #21262:
URL: https://github.com/apache/flink/pull/21262#issuecomment-1308526284
cc @syhily
--
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 unsu
Jiabao-Sun commented on code in PR #1:
URL:
https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1017744379
##
flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java:
##
@@ -0,0 +1,233 @@
+/*
+ * Licensed to t
XComp commented on code in PR #21247:
URL: https://github.com/apache/flink/pull/21247#discussion_r1017711266
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReaderTest.java:
##
@@ -88,8 +88,11 @@ public class Kafk
zentol closed pull request #12947: [FLINK-16957][hive] Bump 1.2.X/2.0.X patch
versions
URL: https://github.com/apache/flink/pull/12947
--
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
[
https://issues.apache.org/jira/browse/FLINK-16957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-16957.
Resolution: Fixed
Support for these version has been removed.
> Bump Hive 1.2.X to 1.2.2
XComp commented on code in PR #21252:
URL: https://github.com/apache/flink/pull/21252#discussion_r1016457270
##
flink-connectors/flink-connector-pulsar/src/test/java/org/apache/flink/connector/pulsar/testutils/function/ControlSource.java:
##
@@ -183,37 +191,58 @@ public List get
[
https://issues.apache.org/jira/browse/FLINK-29944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630989#comment-17630989
]
hk__lrzy commented on FLINK-29944:
--
[~luoyuxia] this is from
[FLIP-27|https://cwiki.ap
Matthias Pohl created FLINK-29956:
-
Summary: Kafka-related test infrastructure code is scattered over
multiple classes/environments
Key: FLINK-29956
URL: https://issues.apache.org/jira/browse/FLINK-29956
XComp commented on PR #21247:
URL: https://github.com/apache/flink/pull/21247#issuecomment-1308575925
FYI: I created a follow-up Jira issue for the Kafka environment topic:
FLINK-29956
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-28177:
-
Fix Version/s: elasticsearch-4.0.0
(was: elasticsearch-3.0.0)
> E
[
https://issues.apache.org/jira/browse/FLINK-29320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29320:
-
Fix Version/s: elasticsearch-4.0.0
(was: elasticsearch-3.0.0)
> S
[
https://issues.apache.org/jira/browse/FLINK-29471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29471:
-
Fix Version/s: elasticsearch-4.0.0
(was: elasticsearch-3.0.0)
> C
[
https://issues.apache.org/jira/browse/FLINK-29279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-29279:
-
Fix Version/s: elasticsearch-4.0.0
(was: elasticsearch-3.0.0)
> E
zentol commented on code in PR #21269:
URL: https://github.com/apache/flink/pull/21269#discussion_r1017804090
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java:
##
@@ -390,6 +390,8 @@ public static final class Restored
[
https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631003#comment-17631003
]
Weijie Guo commented on FLINK-8712:
---
[~huwh] In my opinion, JobGraph#getMaximumParallel
[
https://issues.apache.org/jira/browse/FLINK-25802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17623197#comment-17623197
]
Runkang He edited comment on FLINK-25802 at 11/9/22 11:20 AM:
dannycranmer commented on PR #21265:
URL: https://github.com/apache/flink/pull/21265#issuecomment-1308623242
@vahmed-hamdy good shout, TBH I did not check if this would be useful for
KDF/KDS, but looking, it will. So I will update this PR.
--
This is an automated message from the Apache G
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-24119:
-
Assignee: Gabor Somogyi (was: Qingsheng Ren)
> KafkaITCase.testTimestamps fails due to
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17630827#comment-17630827
]
Matthias Pohl edited comment on FLINK-24119 at 11/9/22 11:47 AM:
-
XComp commented on PR #21247:
URL: https://github.com/apache/flink/pull/21247#issuecomment-1308632876
@PatrickRen can you have a look at it as well since it covers FLINK-24119
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
[
https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631023#comment-17631023
]
Weihua Hu commented on FLINK-8712:
--
[~xtsong],
IMO, there are two options for batch jo
gaborgsomogyi commented on code in PR #21247:
URL: https://github.com/apache/flink/pull/21247#discussion_r1017847657
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaInternalProducerITCase.java:
##
@@ -204,7 +204,7 @@
gaborgsomogyi commented on code in PR #21247:
URL: https://github.com/apache/flink/pull/21247#discussion_r1017854901
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReaderTest.java:
##
@@ -88,8 +88,11 @@ public cl
gaborgsomogyi commented on code in PR #21247:
URL: https://github.com/apache/flink/pull/21247#discussion_r1017857996
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestBase.java:
##
@@ -135,8 +134,16 @@ public
gaborgsomogyi commented on PR #21247:
URL: https://github.com/apache/flink/pull/21247#issuecomment-1308681238
* Some have still timeouts included (e.g.
[KafkaSinkITCase:438](https://github.com/apache/flink/blob/e95897694d59126d1949a7f2337bcc3b7ce49747/flink-connectors/flink-connector-kafka/s
[
https://issues.apache.org/jira/browse/FLINK-29956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631046#comment-17631046
]
Gabor Somogyi commented on FLINK-29956:
---
As mentioned I've time pressured works to
mbalassi commented on PR #20206:
URL: https://github.com/apache/flink/pull/20206#issuecomment-1308692217
Closing in favor of #21140.
--
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 c
mbalassi closed pull request #20206: [FLINK-25909][runtime][security] Add
HBaseDelegationTokenProvider
URL: https://github.com/apache/flink/pull/20206
--
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
mbalassi merged PR #21140:
URL: https://github.com/apache/flink/pull/21140
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apac
[
https://issues.apache.org/jira/browse/FLINK-25909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-25909.
--
Fix Version/s: 1.17.0
Resolution: Fixed
[{{82170c8}}|https://github.com/apache/flink/co
[
https://issues.apache.org/jira/browse/FLINK-29854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-29854:
-
Assignee: Ahmed Hamdy (was: Ahmed Hamdy)
> Make Record Size Flush Strategy Optional fo
MartijnVisser commented on code in PR #21128:
URL: https://github.com/apache/flink/pull/21128#discussion_r1017892553
##
pom.xml:
##
@@ -437,6 +445,14 @@ under the License.
org.slf4j
XComp commented on code in PR #21247:
URL: https://github.com/apache/flink/pull/21247#discussion_r1017896227
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReaderTest.java:
##
@@ -88,8 +88,11 @@ public class Kafk
XComp commented on code in PR #21247:
URL: https://github.com/apache/flink/pull/21247#discussion_r1017896227
##
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReaderTest.java:
##
@@ -88,8 +88,11 @@ public class Kafk
[
https://issues.apache.org/jira/browse/FLINK-8712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17631058#comment-17631058
]
Weihua Hu commented on FLINK-8712:
--
[~Weijie Guo] I agree with you, change JobGraph::get
[ https://issues.apache.org/jira/browse/FLINK-8712 ]
Weihua Hu deleted comment on FLINK-8712:
--
was (Author: huwh):
[~xtsong],
IMO, there are two options for batch job:
1. Calculate the accurate min required slot number according to whether the
Chesnay Schepler created FLINK-29957:
Summary: Rework connector docs integration
Key: FLINK-29957
URL: https://issues.apache.org/jira/browse/FLINK-29957
Project: Flink
Issue Type: Technic
Chesnay Schepler created FLINK-29958:
Summary: Add new connector_artifact shortcode
Key: FLINK-29958
URL: https://issues.apache.org/jira/browse/FLINK-29958
Project: Flink
Issue Type: Tech
1 - 100 of 247 matches
Mail list logo
