[
https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
fanrui updated FLINK-26803:
---
Attachment: image-2022-05-05-12-36-09-969.png
> Merge small ChannelState file for Unaligned Checkpoint
>
[
https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532058#comment-17532058
]
fanrui commented on FLINK-26803:
Hi [~pnowojski] [~akalashnikov] , I want to add some information about
[
https://issues.apache.org/jira/browse/FLINK-27438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532054#comment-17532054
]
Roman Boyko commented on FLINK-27438:
-
I've created a PR to master. [~martijnvisser] [~zhongwei]
flinkbot commented on PR #19648:
URL: https://github.com/apache/flink/pull/19648#issuecomment-1118149300
## CI report:
* 4663578db1897a588c35e45d2cc0d5f03eb5d1cf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27438:
---
Labels: pull-request-available (was: )
> SQL validation failed when constructing a map
rovboyko opened a new pull request, #19648:
URL: https://github.com/apache/flink/pull/19648
## What is the purpose of the change
This pull request fixes the ValidationException appears while trying to
construct the array of maps. The bug appeared after adding explicit casting
zhipeng93 commented on code in PR #90:
URL: https://github.com/apache/flink-ml/pull/90#discussion_r865540818
##
flink-ml-lib/src/main/java/org/apache/flink/ml/common/optimizer/Optimizer.java:
##
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
zhipeng93 commented on code in PR #90:
URL: https://github.com/apache/flink-ml/pull/90#discussion_r865539963
##
flink-ml-lib/src/main/java/org/apache/flink/ml/common/optimizer/Optimizer.java:
##
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
zhipeng93 commented on code in PR #90:
URL: https://github.com/apache/flink-ml/pull/90#discussion_r865539013
##
flink-ml-lib/src/main/java/org/apache/flink/ml/common/optimizer/RegularizationUtils.java:
##
@@ -0,0 +1,95 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532003#comment-17532003
]
Yun Gao edited comment on FLINK-27492 at 5/5/22 3:36 AM:
-
cc [~twalthr]
zoltar9264 commented on PR #19616:
URL: https://github.com/apache/flink/pull/19616#issuecomment-1118132654
> Sorry for missed the part of Stopping a Job with Savepoint, the English
doc for this part was added after this issue was created, I didn't notice. I
will add it soon.
Done.
[
https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529866#comment-17529866
]
Xintong Song edited comment on FLINK-27420 at 5/5/22 3:30 AM:
--
Fixed via
-
[
https://issues.apache.org/jira/browse/FLINK-27372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27372:
---
Labels: pull-request-available (was: )
> Make SstFileMeta and ManifestFileMeta schemaless
JingsongLi opened a new pull request, #107:
URL: https://github.com/apache/flink-table-store/pull/107
Currently these meta need key and value schema to serialize and deserialize
- schema binding makes the construction of serializers difficult and prone
to problems
- Not conducive to
[
https://issues.apache.org/jira/browse/FLINK-27420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532016#comment-17532016
]
Xintong Song commented on FLINK-27420:
--
Thanks [~gaoyunhaii] for fixing the broken branches, and
stevenzwu commented on code in PR #19645:
URL: https://github.com/apache/flink/pull/19645#discussion_r865530568
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/SerializableAvroSchema.java:
##
@@ -21,13 +21,13 @@
import
gaoyunhaii closed pull request #19584: release notes for the 1.15 release
URL: https://github.com/apache/flink/pull/19584
--
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
gaoyunhaii commented on PR #19584:
URL: https://github.com/apache/flink/pull/19584#issuecomment-1118127863
Merged on master via 1.15
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
[
https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532015#comment-17532015
]
Yun Gao commented on FLINK-27492:
-
I'm not fully sure if this is by-design and now we require users to
[
https://issues.apache.org/jira/browse/FLINK-27372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-27372:
-
Description:
Currently these meta need key and value schema to serialize and deserialize
*
[
https://issues.apache.org/jira/browse/FLINK-27372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-27372:
-
Parent: (was: FLINK-27365)
Issue Type: Bug (was: Sub-task)
> Make SstFileMeta and
zoltar9264 commented on PR #19616:
URL: https://github.com/apache/flink/pull/19616#issuecomment-1118125619
Sorry for missed the part of `Stopping a Job with Savepoint`, the English
doc for this part was added after this issue was created, I didn't notice. I
will add it soon.
--
This is
zoltar9264 commented on code in PR #19616:
URL: https://github.com/apache/flink/pull/19616#discussion_r865524920
##
docs/content.zh/docs/ops/state/savepoints.md:
##
@@ -116,14 +116,31 @@ mapper-id | State of StatefulMapper
**注意:** 不建议移动或删除正在运行作业的最后一个 Savepoint
[
https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532003#comment-17532003
]
Yun Gao commented on FLINK-27492:
-
cc [~twalthr] for a double confirmation.
> Flink table / sql scala
[
https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-27492:
Priority: Critical (was: Major)
> Flink table / sql scala API is missing in the binary package
>
[
https://issues.apache.org/jira/browse/FLINK-27492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Gao updated FLINK-27492:
Fix Version/s: 1.16.0
1.15.1
> Flink table / sql scala API is missing in the binary
Yun Gao created FLINK-27492:
---
Summary: Flink table / sql scala API is missing in the binary
package
Key: FLINK-27492
URL: https://issues.apache.org/jira/browse/FLINK-27492
Project: Flink
Issue
zhipeng93 commented on code in PR #90:
URL: https://github.com/apache/flink-ml/pull/90#discussion_r865520528
##
flink-ml-core/src/main/java/org/apache/flink/ml/common/datastream/DataStreamUtils.java:
##
@@ -67,6 +72,28 @@ public static DataStream mapPartition(
Myasuka commented on code in PR #19616:
URL: https://github.com/apache/flink/pull/19616#discussion_r865517671
##
docs/content.zh/docs/ops/state/savepoints.md:
##
@@ -116,14 +116,31 @@ mapper-id | State of StatefulMapper
**注意:** 不建议移动或删除正在运行作业的最后一个 Savepoint
zhuzhurk commented on PR #19613:
URL: https://github.com/apache/flink/pull/19613#issuecomment-1118102003
Thanks for reviewing and merging this PR! @zentol
--
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
[
https://issues.apache.org/jira/browse/FLINK-26803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531603#comment-17531603
]
fanrui edited comment on FLINK-26803 at 5/5/22 2:07 AM:
Hi [~pnowojski] Thanks
Myasuka commented on code in PR #19600:
URL: https://github.com/apache/flink/pull/19600#discussion_r865511866
##
flink-end-to-end-tests/test-scripts/common.sh:
##
@@ -305,6 +305,10 @@ function wait_dispatcher_running {
}
function start_cluster {
+ # After FLINK-24785,
[
https://issues.apache.org/jira/browse/FLINK-27386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531995#comment-17531995
]
luoyuxia commented on FLINK-27386:
--
To fix it is quite simple and I have submited a pr. But I would
flinkbot commented on PR #19647:
URL: https://github.com/apache/flink/pull/19647#issuecomment-1118088646
## CI report:
* 161fdba4c2356ef523f7aebb3e4f26065f4b5cca UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27387:
---
Labels: pull-request-available (was: )
> Support Insert Multi-Table
>
luoyuxia opened a new pull request, #19647:
URL: https://github.com/apache/flink/pull/19647
## What is the purpose of the change
To support multi-insert statement for Hive dialect.
## Brief change log
- Construct `ModifyOperation` separately for each insert
Yang Wang created FLINK-27491:
-
Summary: Support env replacement in flink-kubernetes-operator CR
Key: FLINK-27491
URL: https://issues.apache.org/jira/browse/FLINK-27491
Project: Flink
Issue
gaoyunhaii commented on PR #19584:
URL: https://github.com/apache/flink/pull/19584#issuecomment-1118084320
Very thanks @zentol for the review! will merge~
--
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
yunfengzhou-hub commented on code in PR #86:
URL: https://github.com/apache/flink-ml/pull/86#discussion_r864421566
##
flink-ml-lib/src/main/java/org/apache/flink/ml/evaluation/binaryeval/BinaryClassificationEvaluatorParams.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the
yunfengzhou-hub commented on PR #87:
URL: https://github.com/apache/flink-ml/pull/87#issuecomment-1118082139
Thanks for the comments. I have updated the PR according to the comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
luoyuxia commented on PR #19573:
URL: https://github.com/apache/flink/pull/19573#issuecomment-1118078947
@leonardBang Cound you please help review & merge?
--
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
flinkbot commented on PR #19646:
URL: https://github.com/apache/flink/pull/19646#issuecomment-1118078381
## CI report:
* 61df03b4901c94318bb8e6a2b7f894b88c48f4f2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
baugarten opened a new pull request, #19646:
URL: https://github.com/apache/flink/pull/19646
See https://github.com/apache/flink/pull/19607
This is the same PR, but based on release-1.15
## What is the purpose of the change
Fix bug identified in
stevenzwu commented on code in PR #19645:
URL: https://github.com/apache/flink/pull/19645#discussion_r865464452
##
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/utils/AvroTestUtils.java:
##
@@ -259,6 +265,51 @@ public static Tuple3
getGenericTestData() {
stevenzwu commented on code in PR #19645:
URL: https://github.com/apache/flink/pull/19645#discussion_r865463606
##
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/utils/AvroTestUtils.java:
##
@@ -259,6 +265,51 @@ public static Tuple3
getGenericTestData() {
stevenzwu commented on code in PR #19645:
URL: https://github.com/apache/flink/pull/19645#discussion_r865462563
##
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/GenericRecordAvroTypeInfo.java:
##
@@ -104,10 +105,15 @@ public boolean
flinkbot commented on PR #19645:
URL: https://github.com/apache/flink/pull/19645#issuecomment-1118014837
## CI report:
* 33a1153e3726f3728ef5bc3074ac2900bb54aa29 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-27255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-27255:
---
Labels: pull-request-available (was: )
> Flink-avro does not support serialization and
haizhou-zhao opened a new pull request, #19645:
URL: https://github.com/apache/flink/pull/19645
## 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
flinkbot commented on PR #19644:
URL: https://github.com/apache/flink/pull/19644#issuecomment-1117955029
## CI report:
* 8e6a7c570915b2a492c9621731db58a12e33aa8a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
mans2singh opened a new pull request, #19644:
URL: https://github.com/apache/flink/pull/19644
## What is the purpose of the change
* Updated argument for method call from **Flink Path** to **File Paths**
## Brief change log
* Updated argument in example
##
flinkbot commented on PR #19643:
URL: https://github.com/apache/flink/pull/19643#issuecomment-1117887445
## CI report:
* 91a46083a0ab62604fc1b232865bff1e56f1083c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JingGe opened a new pull request, #19643:
URL: https://github.com/apache/flink/pull/19643
## What is the purpose of the change
backport 1.15 of #19365, #19376
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/FLINK-24614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531913#comment-17531913
]
Philip commented on FLINK-24614:
Hi [~sujun1020] , I just found this Jira issue, I would really love to
snuyanzin commented on PR #19638:
URL: https://github.com/apache/flink/pull/19638#issuecomment-1117775485
@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
snuyanzin commented on PR #19637:
URL: https://github.com/apache/flink/pull/19637#issuecomment-1117691150
@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-24766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-24766:
--
Assignee: Sergey Nuyanzin
> Ceiling/flooring dates to day return wrong results
>
CrynetLogistics commented on code in PR #517:
URL: https://github.com/apache/flink-web/pull/517#discussion_r865134700
##
_posts/2022-03-16-async-sink-base.md:
##
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "The Generic Asynchronous Base Sink"
+date: 2022-04-30 16:00:00
MartijnVisser commented on PR #17677:
URL: https://github.com/apache/flink/pull/17677#issuecomment-1117657193
@snuyanzin Thanks for the contribution and @matriv thanks for the review!
--
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-24766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-24766.
--
Fix Version/s: 1.16.0
Resolution: Fixed
Fixed in master:
MartijnVisser merged PR #17677:
URL: https://github.com/apache/flink/pull/17677
--
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:
CrynetLogistics commented on code in PR #517:
URL: https://github.com/apache/flink-web/pull/517#discussion_r865131263
##
_posts/2022-03-16-async-sink-base.md:
##
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "The Generic Asynchronous Base Sink"
+date: 2022-04-30 16:00:00
CrynetLogistics commented on code in PR #517:
URL: https://github.com/apache/flink-web/pull/517#discussion_r865128751
##
_posts/2022-03-16-async-sink-base.md:
##
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "The Generic Asynchronous Base Sink"
+date: 2022-04-30 16:00:00
[
https://issues.apache.org/jira/browse/FLINK-27465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved FLINK-27465.
--
Fix Version/s: 1.16.0
Resolution: Fixed
>
CrynetLogistics commented on code in PR #517:
URL: https://github.com/apache/flink-web/pull/517#discussion_r865124321
##
_posts/2022-03-16-async-sink-base.md:
##
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "The Generic Asynchronous Base Sink"
+date: 2022-04-30 16:00:00
CrynetLogistics commented on code in PR #517:
URL: https://github.com/apache/flink-web/pull/517#discussion_r865121801
##
_posts/2022-03-16-async-sink-base.md:
##
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "The Generic Asynchronous Base Sink"
+date: 2022-04-30 16:00:00
[
https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531875#comment-17531875
]
Yaroslav Tkachenko commented on FLINK-25205:
Hey everyone, I was going to open a similar
tweise merged PR #19627:
URL: https://github.com/apache/flink/pull/19627
--
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:
tweise commented on PR #19627:
URL: https://github.com/apache/flink/pull/19627#issuecomment-1117639778
@matriv I agree that it would be nice to have that test, but given the class
is deprecated probably not worth the effort. Let me know if you think otherwise
and we can do a follow-up PR.
CrynetLogistics commented on code in PR #517:
URL: https://github.com/apache/flink-web/pull/517#discussion_r865116715
##
_posts/2022-03-16-async-sink-base.md:
##
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "The Generic Asynchronous Base Sink"
+date: 2022-04-30 16:00:00
CrynetLogistics commented on code in PR #517:
URL: https://github.com/apache/flink-web/pull/517#discussion_r865115959
##
_posts/2022-03-16-async-sink-base.md:
##
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "The Generic Asynchronous Base Sink"
+date: 2022-04-30 16:00:00
[
https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yaroslav Tkachenko updated FLINK-25205:
---
Attachment: flamegraph-final.html
> Optimize SinkUpsertMaterializer
>
CrynetLogistics commented on code in PR #517:
URL: https://github.com/apache/flink-web/pull/517#discussion_r865112489
##
_posts/2022-03-16-async-sink-base.md:
##
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "The Generic Asynchronous Base Sink"
+date: 2022-04-30 16:00:00
[
https://issues.apache.org/jira/browse/FLINK-25205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yaroslav Tkachenko updated FLINK-25205:
---
Attachment: without-SinkUpsertMaterializer.png
CrynetLogistics commented on code in PR #517:
URL: https://github.com/apache/flink-web/pull/517#discussion_r865109841
##
_posts/2022-03-16-async-sink-base.md:
##
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "The Generic Asynchronous Base Sink"
+date: 2022-04-30 16:00:00
CrynetLogistics commented on code in PR #517:
URL: https://github.com/apache/flink-web/pull/517#discussion_r865105110
##
_posts/2022-03-16-async-sink-base.md:
##
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "The Generic Asynchronous Base Sink"
+date: 2022-04-30 16:00:00
flinkbot commented on PR #19642:
URL: https://github.com/apache/flink/pull/19642#issuecomment-1117612746
## CI report:
* 1497c41d25520ec11e9207e7dadd92c9adcea19f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #19641:
URL: https://github.com/apache/flink/pull/19641#issuecomment-1117609587
## CI report:
* 9d7662dde6c926c1a62f08bb345f1ac3e7c0ec79 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #19640:
URL: https://github.com/apache/flink/pull/19640#issuecomment-1117609507
## CI report:
* 19811a41342df770290d1b8e331753d461da888a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #19639:
URL: https://github.com/apache/flink/pull/19639#issuecomment-1117609422
## CI report:
* b9e42e315227b5c899b15b341da4a904ab01ada2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
MartijnVisser opened a new pull request, #19642:
URL: https://github.com/apache/flink/pull/19642
## What is the purpose of the change
* Make sure that Hugo Modules files (which can be created while working on
the current `master` branch) will be ignored when working with the
MartijnVisser opened a new pull request, #19641:
URL: https://github.com/apache/flink/pull/19641
## What is the purpose of the change
* Make sure that Hugo Modules files (which can be created while working on
the current `master` branch) will be ignored when working with the
MartijnVisser opened a new pull request, #19640:
URL: https://github.com/apache/flink/pull/19640
Unchanged backport of https://github.com/apache/flink/pull/19635
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
MartijnVisser opened a new pull request, #19639:
URL: https://github.com/apache/flink/pull/19639
Unchanged backport of https://github.com/apache/flink/pull/19635
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
gyfora commented on PR #195:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/195#issuecomment-1117602335
We could add a config option to blacklist FlinkDeployments that the operator
should not touch, that would solve this in a more general way, but it still
feels a bit
gyfora commented on PR #195:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/195#issuecomment-1117600634
@tweise hm, thats a good question.
In general my logic for making the default behaviour to recover (at least
from Flink 1.15 onward), is this is how operators
zentol commented on code in PR #517:
URL: https://github.com/apache/flink-web/pull/517#discussion_r865039865
##
_posts/2022-03-16-async-sink-base.md:
##
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "The Generic Asynchronous Base Sink"
+date: 2022-04-30 16:00:00
+authors:
+-
MartijnVisser merged PR #19635:
URL: https://github.com/apache/flink/pull/19635
--
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:
tweise commented on PR #195:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/195#issuecomment-1117586637
@gyfora one question regarding the motivations to delete a deployment
externally: This could be used as escape hatch by users that want to term a
misbehaving deployment
infoverload commented on code in PR #516:
URL: https://github.com/apache/flink-web/pull/516#discussion_r865009425
##
_posts/2022-04-01-tidying-snapshots-up.md:
##
@@ -0,0 +1,213 @@
+---
+layout: post
+title: "Tidying up snapshots"
+date: 2022-04-01T00:00:00.000Z
+authors:
+-
infoverload commented on code in PR #516:
URL: https://github.com/apache/flink-web/pull/516#discussion_r865006723
##
_posts/2022-04-01-tidying-snapshots-up.md:
##
@@ -0,0 +1,213 @@
+---
+layout: post
+title: "Tidying up snapshots"
+date: 2022-04-01T00:00:00.000Z
+authors:
+-
infoverload commented on code in PR #516:
URL: https://github.com/apache/flink-web/pull/516#discussion_r865006302
##
_posts/2022-04-01-tidying-snapshots-up.md:
##
@@ -0,0 +1,213 @@
+---
+layout: post
+title: "Tidying up snapshots"
+date: 2022-04-01T00:00:00.000Z
+authors:
+-
infoverload commented on code in PR #516:
URL: https://github.com/apache/flink-web/pull/516#discussion_r865004669
##
_posts/2022-04-01-tidying-snapshots-up.md:
##
@@ -0,0 +1,213 @@
+---
+layout: post
+title: "Tidying up snapshots"
+date: 2022-04-01T00:00:00.000Z
+authors:
+-
infoverload commented on code in PR #516:
URL: https://github.com/apache/flink-web/pull/516#discussion_r865000653
##
_posts/2022-04-01-tidying-snapshots-up.md:
##
@@ -0,0 +1,213 @@
+---
+layout: post
+title: "Tidying up snapshots"
+date: 2022-04-01T00:00:00.000Z
+authors:
+-
CrynetLogistics commented on code in PR #517:
URL: https://github.com/apache/flink-web/pull/517#discussion_r864998597
##
_posts/2022-03-16-async-sink-base.md:
##
@@ -0,0 +1,169 @@
+---
+layout: post
+title: "The Generic Asynchronous Base Sink"
+date: 2022-04-30 16:00:00
healchow commented on code in PR #19631:
URL: https://github.com/apache/flink/pull/19631#discussion_r864990555
##
docs/content.zh/docs/connectors/table/firehose.md:
##
@@ -57,255 +57,255 @@ WITH (
);
```
-Connector Options
+连接器选项
-
-
healchow commented on code in PR #19631:
URL: https://github.com/apache/flink/pull/19631#discussion_r864988226
##
docs/content.zh/docs/connectors/table/firehose.md:
##
@@ -57,255 +57,255 @@ WITH (
);
```
-Connector Options
+连接器选项
-
-
infoverload commented on code in PR #516:
URL: https://github.com/apache/flink-web/pull/516#discussion_r864938905
##
_posts/2022-04-01-tidying-snapshots-up.md:
##
@@ -0,0 +1,213 @@
+---
+layout: post
+title: "Tidying up snapshots"
+date: 2022-04-01T00:00:00.000Z
+authors:
+-
healchow commented on code in PR #19631:
URL: https://github.com/apache/flink/pull/19631#discussion_r864985191
##
docs/content.zh/docs/connectors/table/firehose.md:
##
@@ -57,255 +57,255 @@ WITH (
);
```
-Connector Options
+连接器选项
-
-
healchow commented on code in PR #19631:
URL: https://github.com/apache/flink/pull/19631#discussion_r864984012
##
docs/content.zh/docs/connectors/table/firehose.md:
##
@@ -57,255 +57,255 @@ WITH (
);
```
-Connector Options
+连接器选项
-
-
1 - 100 of 254 matches
Mail list logo
