AHeise merged pull request #17054:
URL: https://github.com/apache/flink/pull/17054
--
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:
fapaul opened a new pull request #17069:
URL: https://github.com/apache/flink/pull/17069
Unchanged backport of #17052
--
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
[
https://issues.apache.org/jira/browse/FLINK-23768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407265#comment-17407265
]
Martijn Visser commented on FLINK-23768:
[~dianfu] Can someone on your end test this?
> Test
[
https://issues.apache.org/jira/browse/FLINK-24076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias closed FLINK-24076.
Resolution: Won't Fix
My mistake - the walkthrough is supposed to be implemented by the user.
Initially,
flinkbot edited a comment on pull request #17022:
URL: https://github.com/apache/flink/pull/17022#issuecomment-907158087
## CI report:
* dd573c4bb1475210822d64e5df8b659f7ecc3546 Azure:
flinkbot edited a comment on pull request #16988:
URL: https://github.com/apache/flink/pull/16988#issuecomment-905730008
## CI report:
* 680f8172bea8a9b7396604e8f0c5dcaf4efff5f9 Azure:
[
https://issues.apache.org/jira/browse/FLINK-24081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-24081:
Affects Version/s: 1.13.0
> OVER window throws exception when the rowtime is timestamp_ltz type
>
flinkbot commented on pull request #17077:
URL: https://github.com/apache/flink/pull/17077#issuecomment-909236529
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-24063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407347#comment-17407347
]
Till Rohrmann commented on FLINK-24063:
---
I agree that if the {{ClusterEntrypoint.runCluster}}
fapaul commented on pull request #17071:
URL: https://github.com/apache/flink/pull/17071#issuecomment-909253263
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
[
https://issues.apache.org/jira/browse/FLINK-24005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407372#comment-17407372
]
Till Rohrmann commented on FLINK-24005:
---
{quote}In practice this is currently the case, but if the
alpinegizmo merged pull request #31:
URL: https://github.com/apache/flink-training/pull/31
--
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 edited a comment on pull request #17071:
URL: https://github.com/apache/flink/pull/17071#issuecomment-909190390
## CI report:
* 5f6b9cba775dee77385bdd4506aaae9660801ba4 Azure:
flinkbot edited a comment on pull request #17074:
URL: https://github.com/apache/flink/pull/17074#issuecomment-909240894
## CI report:
* 3a29aa6e7ce0cd8c5c4a46615378b7eb36bea78d Azure:
flinkbot edited a comment on pull request #17075:
URL: https://github.com/apache/flink/pull/17075#issuecomment-909241018
## CI report:
* ccdf9bfaaa9e6d6eefb728b07ccf69df8233e93a Azure:
flinkbot commented on pull request #17077:
URL: https://github.com/apache/flink/pull/17077#issuecomment-909283338
## CI report:
* 87fe6f2b508bb6923b16345e95204bade06af980 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
twalthr opened a new pull request #17079:
URL: https://github.com/apache/flink/pull/17079
## What is the purpose of the change
This ensures a correct changelog after the `SinkUpsertMaterializer` without
introducing additional runtime overhead.
## Brief change log
It
flinkbot commented on pull request #17079:
URL: https://github.com/apache/flink/pull/17079#issuecomment-909298595
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
flinkbot edited a comment on pull request #17064:
URL: https://github.com/apache/flink/pull/17064#issuecomment-908893945
--
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
dmvk commented on a change in pull request #17000:
URL: https://github.com/apache/flink/pull/17000#discussion_r698686629
##
File path:
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java
##
@@ -147,35 +146,34 @@
zentol commented on a change in pull request #17059:
URL: https://github.com/apache/flink/pull/17059#discussion_r698580248
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java
##
@@ -354,30 +369,49 @@ public
flinkbot edited a comment on pull request #16723:
URL: https://github.com/apache/flink/pull/16723#issuecomment-893364145
--
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
Airblader commented on a change in pull request #16805:
URL: https://github.com/apache/flink/pull/16805#discussion_r688288352
##
File path: docs/data/sql_functions.yml
##
@@ -83,7 +83,7 @@ logical:
table: BOOLEAN1 && BOOLEAN2
description: Returns TRUE if BOOLEAN1 and
gaoyunhaii commented on pull request #17062:
URL: https://github.com/apache/flink/pull/17062#issuecomment-908916557
@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
dmvk commented on pull request #17000:
URL: https://github.com/apache/flink/pull/17000#issuecomment-908711529
@tillrohrmann Thanks for the review! I've incorporated your suggestions, PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
twalthr closed pull request #17060:
URL: https://github.com/apache/flink/pull/17060
--
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 pull request #17065:
URL: https://github.com/apache/flink/pull/17065#issuecomment-908909475
--
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
sjwiesman closed pull request #463:
URL: https://github.com/apache/flink-web/pull/463
--
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 pull request #17056:
URL: https://github.com/apache/flink/pull/17056#issuecomment-908431706
--
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
flinkbot edited a comment on pull request #17022:
URL: https://github.com/apache/flink/pull/17022#issuecomment-907158087
--
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
[
https://issues.apache.org/jira/browse/FLINK-24079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407269#comment-17407269
]
Jark Wu commented on FLINK-24079:
-
[~fabian.paul] I commented in FLINK-23875.
>
fapaul closed pull request #17072:
URL: https://github.com/apache/flink/pull/17072
--
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:
AHeise commented on a change in pull request #17019:
URL: https://github.com/apache/flink/pull/17019#discussion_r699253994
##
File path:
flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java
##
@@ -226,11 +236,12 @@
[
https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407279#comment-17407279
]
lixu commented on FLINK-23857:
--
insert overwrite table t1 partition(f2=1) select * from t2 where 1 != 1
I
[
https://issues.apache.org/jira/browse/FLINK-24080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
leishuiyu updated FLINK-24080:
--
Description:
* Symptom After submitting a batch task for several times, the task is abnormal
,Caused
[
https://issues.apache.org/jira/browse/FLINK-24064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-24064:
-
Fix Version/s: 1.14.0
> HybridSource recovery from savepoint fails
>
Leonard Xu created FLINK-24081:
--
Summary: OVER window throws exception when the rowtime is
timestamp_ltz type
Key: FLINK-24081
URL: https://issues.apache.org/jira/browse/FLINK-24081
Project: Flink
flinkbot edited a comment on pull request #16723:
URL: https://github.com/apache/flink/pull/16723#issuecomment-893364145
## CI report:
* ce83c52813ef9b754a0aded512e80503507b1547 Azure:
[
https://issues.apache.org/jira/browse/FLINK-24084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman closed FLINK-24084.
Resolution: Fixed
> The example in sql join document is incorrect
>
[
https://issues.apache.org/jira/browse/FLINK-24084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407361#comment-17407361
]
Seth Wiesman commented on FLINK-24084:
--
fixed in master: 04e7433cc4ea4ffc8f254212f0d6a4355a4c051a
[
https://issues.apache.org/jira/browse/FLINK-24084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman updated FLINK-24084:
-
Fix Version/s: 1.15.0
1.14.0
> The example in sql join document is incorrect
[
https://issues.apache.org/jira/browse/FLINK-24085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-24085:
Fix Version/s: 1.15.0
1.14.0
> The `versioned table` and `Timezone` pages missed the
[
https://issues.apache.org/jira/browse/FLINK-24085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-24085:
---
Assignee: Leonard Xu
> The `versioned table` and `Timezone` pages missed the first class subject
[
https://issues.apache.org/jira/browse/FLINK-24081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-24081:
Fix Version/s: 1.15.0
1.13.3
1.14.0
> OVER window throws exception
[
https://issues.apache.org/jira/browse/FLINK-24081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-24081:
---
Assignee: Leonard Xu
> OVER window throws exception when the rowtime is timestamp_ltz type
>
RocMarshal commented on pull request #16723:
URL: https://github.com/apache/flink/pull/16723#issuecomment-909273188
@wuchong Thank you so much for the comments. And I updated it based on your
suggestions. PTAL.
--
This is an automated message from the Apache Git Service.
To respond to
AHeise commented on pull request #17067:
URL: https://github.com/apache/flink/pull/17067#issuecomment-909060257
> LGTM % do you know if the KafkaSource implements all the listed metrics?
Thanks for reminding. I actually found 3 metrics that are currently not
supported.
--
This is
flinkbot commented on pull request #17074:
URL: https://github.com/apache/flink/pull/17074#issuecomment-909201603
--
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
twalthr closed pull request #17048:
URL: https://github.com/apache/flink/pull/17048
--
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:
HuangXingBo closed pull request #17010:
URL: https://github.com/apache/flink/pull/17010
--
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 pull request #17053:
URL: https://github.com/apache/flink/pull/17053#issuecomment-908335697
--
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
fapaul commented on a change in pull request #17058:
URL: https://github.com/apache/flink/pull/17058#discussion_r699022014
##
File path: docs/content/docs/connectors/datastream/kafka.md
##
@@ -613,134 +613,89 @@ Otherwise, the watermarks of the whole application
cannot
flinkbot edited a comment on pull request #17074:
URL: https://github.com/apache/flink/pull/17074#issuecomment-909240894
## CI report:
* 3a29aa6e7ce0cd8c5c4a46615378b7eb36bea78d Azure:
flinkbot edited a comment on pull request #17062:
URL: https://github.com/apache/flink/pull/17062#issuecomment-908868024
--
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
Matthias created FLINK-24088:
Summary: "Internal server error" when quitting a SELECT query in
the SqlClient
Key: FLINK-24088
URL: https://issues.apache.org/jira/browse/FLINK-24088
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-23797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Kalashnikov reassigned FLINK-23797:
-
Assignee: Anton Kalashnikov
>
sjwiesman closed pull request #17076:
URL: https://github.com/apache/flink/pull/17076
--
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:
hililiwei commented on pull request #17056:
URL: https://github.com/apache/flink/pull/17056#issuecomment-908772017
@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
dianfu closed pull request #17045:
URL: https://github.com/apache/flink/pull/17045
--
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:
twalthr closed pull request #17011:
URL: https://github.com/apache/flink/pull/17011
--
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:
RocMarshal commented on pull request #16723:
URL: https://github.com/apache/flink/pull/16723#issuecomment-909273188
@wuchong Thank you so much for the comments. And I updated it based on your
suggestions. PTAL.
--
This is an automated message from the Apache Git Service.
To respond to
flinkbot edited a comment on pull request #16966:
URL: https://github.com/apache/flink/pull/16966#issuecomment-904741081
## CI report:
* 0b725628d29c9cab3dd35929bc3e10e0231920fd Azure:
flinkbot commented on pull request #17073:
URL: https://github.com/apache/flink/pull/17073#issuecomment-909190473
## CI report:
* 64652a612587229163e00d740031f8b303308c86 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #17071:
URL: https://github.com/apache/flink/pull/17071#issuecomment-909190390
## CI report:
* 5f6b9cba775dee77385bdd4506aaae9660801ba4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-24082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-24082:
Description:
For job:
{code}
flinkbot edited a comment on pull request #17070:
URL: https://github.com/apache/flink/pull/17070#issuecomment-909190301
## CI report:
* 3700dfa72cd72d384bf6d69376321fb7ef9eaab9 UNKNOWN
* 4aac2774925e49df9f75903734eb4a98f7f9f3bc UNKNOWN
Bot commands
The
flinkbot edited a comment on pull request #17069:
URL: https://github.com/apache/flink/pull/17069#issuecomment-909162379
## CI report:
* aed06a7ed1fb587d27ca6b1e86bebdbfc7a887da Azure:
flinkbot edited a comment on pull request #17019:
URL: https://github.com/apache/flink/pull/17019#issuecomment-907120059
## CI report:
* fa25b27d642ab7e6af356ca1e9738a006d48 UNKNOWN
* 60655804ce59530d485c1ae939f9b005b1ef5ede Azure:
flinkbot edited a comment on pull request #17050:
URL: https://github.com/apache/flink/pull/17050#issuecomment-908295316
## CI report:
* a4c9501964a166055517eeead5bdebe58cb466a8 UNKNOWN
* 7c20e7910b5f15eb88d6d2b25733c50a8c214f14 Azure:
flinkbot edited a comment on pull request #17071:
URL: https://github.com/apache/flink/pull/17071#issuecomment-909190390
## CI report:
* 5f6b9cba775dee77385bdd4506aaae9660801ba4 Azure:
flinkbot edited a comment on pull request #17073:
URL: https://github.com/apache/flink/pull/17073#issuecomment-909190473
## CI report:
* 64652a612587229163e00d740031f8b303308c86 Azure:
Airblader commented on a change in pull request #460:
URL: https://github.com/apache/flink-web/pull/460#discussion_r699159814
##
File path: _posts/2021-08-16-connector-table-sql-api-part2.md
##
@@ -0,0 +1,497 @@
+---
+layout: post
+title: "Implementing a custom source
[
https://issues.apache.org/jira/browse/FLINK-23389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407326#comment-17407326
]
Danny Cranmer commented on FLINK-23389:
---
We have missed Flink 1.14 so will need to target 1.15 now
flinkbot commented on pull request #17076:
URL: https://github.com/apache/flink/pull/17076#issuecomment-909232576
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
flinkbot edited a comment on pull request #16192:
URL: https://github.com/apache/flink/pull/16192#issuecomment-863860019
## CI report:
* 6bfa8ca05323eca73531adb548f84c0c222afd30 Azure:
[
https://issues.apache.org/jira/browse/FLINK-13172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-13172:
---
Priority: Not a Priority (was: Minor)
> JVM crash with dynamic netty-tcnative wrapper to
[
https://issues.apache.org/jira/browse/FLINK-23468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17407359#comment-17407359
]
Chesnay Schepler commented on FLINK-23468:
--
FYI this is also what we do in Flink:
wsry commented on a change in pull request #16988:
URL: https://github.com/apache/flink/pull/16988#discussion_r699354935
##
File path: docs/content/docs/deployment/network_buffer.md
##
@@ -0,0 +1,125 @@
+---
+title: "Network Tuning"
+weight: 100
+type: docs
+aliases:
+ -
[
https://issues.apache.org/jira/browse/FLINK-24087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-24087:
-
Description: Table dependencies are marked as {{optional}} for the Kafka
connector. We should
Myasuka merged pull request #16992:
URL: https://github.com/apache/flink/pull/16992
--
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 edited a comment on pull request #17024:
URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537
--
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
Timo Walther created FLINK-24087:
Summary: Kafka connector StartupMode requires a table dependency
Key: FLINK-24087
URL: https://issues.apache.org/jira/browse/FLINK-24087
Project: Flink
wuchong commented on pull request #16852:
URL: https://github.com/apache/flink/pull/16852#issuecomment-908881206
Thanks @RocMarshal and @hapihu .
Will merge it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
fapaul commented on pull request #17071:
URL: https://github.com/apache/flink/pull/17071#issuecomment-909253263
@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
flinkbot edited a comment on pull request #17051:
URL: https://github.com/apache/flink/pull/17051#issuecomment-908310738
--
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
flinkbot edited a comment on pull request #16192:
URL: https://github.com/apache/flink/pull/16192#issuecomment-863860019
--
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
xintongsong closed pull request #465:
URL: https://github.com/apache/flink-web/pull/465
--
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 edited a comment on pull request #17073:
URL: https://github.com/apache/flink/pull/17073#issuecomment-909190473
## CI report:
* 64652a612587229163e00d740031f8b303308c86 Azure:
RocMarshal commented on a change in pull request #16723:
URL: https://github.com/apache/flink/pull/16723#discussion_r698603916
##
File path:
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala
##
@@ -808,6 +808,162 @@ class
flinkbot edited a comment on pull request #17025:
URL: https://github.com/apache/flink/pull/17025#issuecomment-907189639
--
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
zentol commented on a change in pull request #17051:
URL: https://github.com/apache/flink/pull/17051#discussion_r698607055
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java
##
@@ -30,14 +30,23 @@
import
wsry commented on a change in pull request #16988:
URL: https://github.com/apache/flink/pull/16988#discussion_r699354935
##
File path: docs/content/docs/deployment/network_buffer.md
##
@@ -0,0 +1,125 @@
+---
+title: "Network Tuning"
+weight: 100
+type: docs
+aliases:
+ -
AHeise merged pull request #17052:
URL: https://github.com/apache/flink/pull/17052
--
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 edited a comment on pull request #17065:
URL: https://github.com/apache/flink/pull/17065#issuecomment-908917839
--
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
zentol merged pull request #17057:
URL: https://github.com/apache/flink/pull/17057
--
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 edited a comment on pull request #17010:
URL: https://github.com/apache/flink/pull/17010#issuecomment-906989888
--
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
AHeise merged pull request #17054:
URL: https://github.com/apache/flink/pull/17054
--
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:
NicoK commented on a change in pull request #31:
URL: https://github.com/apache/flink-training/pull/31#discussion_r699187127
##
File path:
hourly-tips/src/main/java/org/apache/flink/training/exercises/hourlytips/HourlyTipsExercise.java
##
@@ -56,8 +55,8 @@ public
Fabian Paul created FLINK-24079:
---
Summary: BufferedUpsertSinkFunction can loose records during
failover
Key: FLINK-24079
URL: https://issues.apache.org/jira/browse/FLINK-24079
Project: Flink
AHeise commented on a change in pull request #17067:
URL: https://github.com/apache/flink/pull/17067#discussion_r699231139
##
File path: docs/content/docs/connectors/datastream/kafka.md
##
@@ -213,26 +213,115 @@ Note that Kafka source does **NOT** rely on committed
offsets
1 - 100 of 798 matches
Mail list logo
