flinkbot commented on pull request #13814:
URL: https://github.com/apache/flink/pull/13814#issuecomment-717715530
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
kl0u commented on pull request #13808:
URL: https://github.com/apache/flink/pull/13808#issuecomment-717715756
Yes @guoweiM , I think it is better to introduce a change with the commit
that uses it. It is nice for commits to be self-contained so that if something
goes wrong, we can easily
[
https://issues.apache.org/jira/browse/FLINK-19839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19839:
---
Labels: pull-request-available (was: )
> e2e test failures are not causing the build to
rmetzger opened a new pull request #13814:
URL: https://github.com/apache/flink/pull/13814
Due to a recent change, the exit code of e2e tests was not forwarded
properly anymore.
This CI build demonstrates that failures are forwarded properly:
flinkbot edited a comment on pull request #13813:
URL: https://github.com/apache/flink/pull/13813#issuecomment-717706259
## CI report:
* 61014eba30b67fc21a965f876d9484dd3873e14d Azure:
flinkbot edited a comment on pull request #13744:
URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975
## CI report:
* 164c8b5b7750ed567813d70f160ef9f064d0a3b0 Azure:
flinkbot edited a comment on pull request #13458:
URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219
## CI report:
* 7311b0d12d19a645391ea0359a9aa6318806363b UNKNOWN
* e18067714e5c3f75ed860f97f7c86ddedc719130 Azure:
guoweiM commented on pull request #13808:
URL: https://github.com/apache/flink/pull/13808#issuecomment-717708815
> I have some comments that have mainly to do with unused methods and base
classes that can be made concrete. I have pushed my changes here (to make sure
that I do not break
flinkbot commented on pull request #13813:
URL: https://github.com/apache/flink/pull/13813#issuecomment-717706259
## CI report:
* 61014eba30b67fc21a965f876d9484dd3873e14d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13812:
URL: https://github.com/apache/flink/pull/13812#issuecomment-717687160
## CI report:
* 4f66617c4540a4987a5852cf0168f7e3a552c91a Azure:
flinkbot edited a comment on pull request #13811:
URL: https://github.com/apache/flink/pull/13811#issuecomment-717686306
## CI report:
* 1f87c59d4ccdac3e91b28aaefebde4cc0e479bdf Azure:
flinkbot edited a comment on pull request #13797:
URL: https://github.com/apache/flink/pull/13797#issuecomment-716854695
## CI report:
* c06b3dcd4eb4045f66352c8b65c14a7b60163ecd UNKNOWN
* 185e46fd046c5f39a87ac3583ad559b065a275e1 UNKNOWN
*
flinkbot edited a comment on pull request #13763:
URL: https://github.com/apache/flink/pull/13763#issuecomment-715195599
## CI report:
* a28669bca9c36dac74f89da177825d73bea0ece0 Azure:
flinkbot edited a comment on pull request #13744:
URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975
## CI report:
* c8f3503c99ec4add43df3d054783f7a48501324c Azure:
gm7y8 commented on a change in pull request #13458:
URL: https://github.com/apache/flink/pull/13458#discussion_r513184682
##
File path:
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/detail/job-checkpoints-detail.component.ts
##
@@ -80,5 +97,9 @@ export class
klion26 commented on a change in pull request #13750:
URL: https://github.com/apache/flink/pull/13750#discussion_r513181496
##
File path: docs/monitoring/checkpoint_monitoring.zh.md
##
@@ -25,105 +25,125 @@ under the License.
* ToC
{:toc}
-## Overview
+
-Flink's web
gm7y8 commented on a change in pull request #13458:
URL: https://github.com/apache/flink/pull/13458#discussion_r513184231
##
File path:
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/detail/job-checkpoints-detail.component.ts
##
@@ -57,9 +60,23 @@ export class
[
https://issues.apache.org/jira/browse/FLINK-19827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19827:
---
Labels: pull-request-available (was: )
> Allow the harness to start with a user provided
tzulitai commented on pull request #167:
URL: https://github.com/apache/flink-statefun/pull/167#issuecomment-717701167
+1 as well, thanks Igal!
Merging this now ...
This is an automated message from the Apache Git
flinkbot edited a comment on pull request #13307:
URL: https://github.com/apache/flink/pull/13307#issuecomment-685763264
## CI report:
* 85867d4ab920f571c1dcad56fea6a89c3b717b13 Azure:
flinkbot edited a comment on pull request #13300:
URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567
## CI report:
* Unknown: [CANCELED](TBD)
* c777052640e6c3005314d8dd284cf0c4785fdf8a Azure:
tzulitai commented on pull request #166:
URL: https://github.com/apache/flink-statefun/pull/166#issuecomment-717699559
Thanks @igalshilman, LGTM. Will merge this now.
This is an automated message from the Apache Git Service.
wuchong commented on a change in pull request #13605:
URL: https://github.com/apache/flink/pull/13605#discussion_r513164938
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/BulkFormatFactory.java
##
@@ -0,0 +1,42 @@
+/*
+ * Licensed
wuchong commented on a change in pull request #13605:
URL: https://github.com/apache/flink/pull/13605#discussion_r513164938
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/BulkFormatFactory.java
##
@@ -0,0 +1,42 @@
+/*
+ * Licensed
flinkbot commented on pull request #13812:
URL: https://github.com/apache/flink/pull/13812#issuecomment-717687160
## CI report:
* 4f66617c4540a4987a5852cf0168f7e3a552c91a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
JingsongLi commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513172411
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
flinkbot commented on pull request #13811:
URL: https://github.com/apache/flink/pull/13811#issuecomment-717686306
## CI report:
* 1f87c59d4ccdac3e91b28aaefebde4cc0e479bdf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #13813:
URL: https://github.com/apache/flink/pull/13813#issuecomment-717685369
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
SteNicholas commented on pull request #13813:
URL: https://github.com/apache/flink/pull/13813#issuecomment-717684935
@AHeise , could you please help to review this pull request if you are
available?
This is an automated
flinkbot edited a comment on pull request #13784:
URL: https://github.com/apache/flink/pull/13784#issuecomment-716153889
## CI report:
* 7e29d587bda45d3ddf213ff70c9b0febbd4f9e9f Azure:
SteNicholas opened a new pull request #13813:
URL: https://github.com/apache/flink/pull/13813
## What is the purpose of the change
*Currently Flink can only handle schemas up to a size of 65535 bytes, and
`AvroSerializerSnapshot` cannot handle large schema. If size of schame exceed
flinkbot edited a comment on pull request #13797:
URL: https://github.com/apache/flink/pull/13797#issuecomment-716854695
## CI report:
* c06b3dcd4eb4045f66352c8b65c14a7b60163ecd UNKNOWN
* 185e46fd046c5f39a87ac3583ad559b065a275e1 UNKNOWN
*
[
https://issues.apache.org/jira/browse/FLINK-19491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19491:
---
Labels: pull-request-available (was: )
> AvroSerializerSnapshot cannot handle large schema
flinkbot edited a comment on pull request #13784:
URL: https://github.com/apache/flink/pull/13784#issuecomment-716153889
## CI report:
* ca695f256a825fdebadf79f576b0875d4faea7cd Azure:
flinkbot edited a comment on pull request #13763:
URL: https://github.com/apache/flink/pull/13763#issuecomment-715195599
## CI report:
* a28669bca9c36dac74f89da177825d73bea0ece0 Azure:
flinkbot edited a comment on pull request #13744:
URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975
## CI report:
* c51d4e8bf5dba50e4cb501fc04a87c924fe27e36 Azure:
JingsongLi commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513169206
##
File path:
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/SinkFunctionProvider.java
##
@@ -20,19
flinkbot edited a comment on pull request #13307:
URL: https://github.com/apache/flink/pull/13307#issuecomment-685763264
## CI report:
* 20fe41449f841cfbbb155c1f1c842c5d814ca934 Azure:
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513169070
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
flinkbot edited a comment on pull request #13300:
URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567
## CI report:
* Unknown: [CANCELED](TBD)
* c777052640e6c3005314d8dd284cf0c4785fdf8a Azure:
JingsongLi commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513168676
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
JingsongLi commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513168776
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
flinkbot edited a comment on pull request #13296:
URL: https://github.com/apache/flink/pull/13296#issuecomment-684611193
## CI report:
* c266341c63cc4cdc28a6585a82294710fd8ebbc5 UNKNOWN
* 441a0e088ad94379c71b49121444ca5ea533a55b Azure:
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513167212
##
File path:
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/SinkFunctionProvider.java
##
@@ -20,19
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513167212
##
File path:
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/SinkFunctionProvider.java
##
@@ -20,19
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513167212
##
File path:
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/SinkFunctionProvider.java
##
@@ -20,19
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513167212
##
File path:
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/SinkFunctionProvider.java
##
@@ -20,19
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513167212
##
File path:
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/SinkFunctionProvider.java
##
@@ -20,19
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513165608
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
[
https://issues.apache.org/jira/browse/FLINK-12884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221944#comment-17221944
]
shravan commented on FLINK-12884:
-
[~fly_in_gis] We have just migrated to Kubernetes (EKS) and setting
leonardBang commented on pull request #13300:
URL: https://github.com/apache/flink/pull/13300#issuecomment-717679762
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message,
flinkbot commented on pull request #13812:
URL: https://github.com/apache/flink/pull/13812#issuecomment-717678848
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 #13810:
URL: https://github.com/apache/flink/pull/13810#issuecomment-717666478
## CI report:
* 2c4d8bab8fac4ca8dea20c7cb326f62ca3dd7817 Azure:
flinkbot edited a comment on pull request #13797:
URL: https://github.com/apache/flink/pull/13797#issuecomment-716854695
## CI report:
* c06b3dcd4eb4045f66352c8b65c14a7b60163ecd UNKNOWN
* 185e46fd046c5f39a87ac3583ad559b065a275e1 UNKNOWN
*
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513165407
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513164185
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
[
https://issues.apache.org/jira/browse/FLINK-19674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19674:
---
Labels: pull-request-available (was: )
> Translate "Docker" of "Clusters & Depolyment"
ShubinRuan opened a new pull request #13812:
URL: https://github.com/apache/flink/pull/13812
## What is the purpose of the change
Translate "Docker" of "Clusters & Depolyment" page into Chinese
The page url is
shouweikun commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513163662
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
guoweiM commented on a change in pull request #13808:
URL: https://github.com/apache/flink/pull/13808#discussion_r513163601
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/sink/GlobalStreamingCommitterOperatorTest.java
##
@@
flinkbot commented on pull request #13811:
URL: https://github.com/apache/flink/pull/13811#issuecomment-717677509
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-19836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19836:
---
Labels: pull-request-available (was: )
> Serialize the committable by the user provided
guoweiM opened a new pull request #13811:
URL: https://github.com/apache/flink/pull/13811
## What is the purpose of the change
The behavior of the committable's serializer that is extracted by the
framework might be different with the serializer provided by the user. As a
danny0405 commented on a change in pull request #13763:
URL: https://github.com/apache/flink/pull/13763#discussion_r513162229
##
File path:
flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java
##
@@ -297,32 +300,53 @@ private
flinkbot edited a comment on pull request #13307:
URL: https://github.com/apache/flink/pull/13307#issuecomment-685763264
## CI report:
* 20fe41449f841cfbbb155c1f1c842c5d814ca934 Azure:
JingsongLi commented on a change in pull request #13685:
URL: https://github.com/apache/flink/pull/13685#discussion_r513158356
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java
##
@@ -214,7 +202,19 @@
[
https://issues.apache.org/jira/browse/FLINK-19628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-19628:
--
Assignee: godfrey he
> Introduce multi-input operator for streaming
>
becketqin commented on pull request #13784:
URL: https://github.com/apache/flink/pull/13784#issuecomment-717670076
@StephanEwen @stevenzwu I have updated the patch with the following changes:
1. Move `CheckpointListener` from `flink-runtime` to `flink-core`. Because
this interface
[
https://issues.apache.org/jira/browse/FLINK-19698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19698:
---
Labels: pull-request-available (was: )
> Add close() method and onCheckpointComplete() to
xiaoHoly commented on a change in pull request #13801:
URL: https://github.com/apache/flink/pull/13801#discussion_r513155682
##
File path: docs/dev/table/connectors/formats/avro-confluent.zh.md
##
@@ -29,27 +29,27 @@ under the License.
* This will be replaced by the TOC
[
https://issues.apache.org/jira/browse/FLINK-19789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-19789.
Resolution: Fixed
master (1.12): 0a14ad1cc47c4c6d4de0d5c90d3cd9578ca2536c
> Migrate Hive
[
https://issues.apache.org/jira/browse/FLINK-19727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-19727:
-
Fix Version/s: 1.12.0
> Implement ParallelismProvider for sink in blink planner
>
[
https://issues.apache.org/jira/browse/FLINK-19727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17221927#comment-17221927
]
Jingsong Lee commented on FLINK-19727:
--
Hi [~neighborhood], you have created PR for this ticket,
[
https://issues.apache.org/jira/browse/FLINK-19836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-19836:
--
Summary: Serialize the committable by the user provided serializer during
network shuffle (was:
JingsongLi commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513153908
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
JingsongLi commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513153207
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
JingsongLi commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513152977
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
JingsongLi commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513152799
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
flinkbot commented on pull request #13810:
URL: https://github.com/apache/flink/pull/13810#issuecomment-717666478
## CI report:
* 2c4d8bab8fac4ca8dea20c7cb326f62ca3dd7817 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
JingsongLi commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513152137
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
JingsongLi commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513152300
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPhysicalSink.scala
##
@@
JingsongLi commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513151741
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/OutputFormatProvider.java
##
@@ -20,19 +20,39 @@
JingsongLi commented on a change in pull request #13789:
URL: https://github.com/apache/flink/pull/13789#discussion_r513151711
##
File path:
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/sink/SinkFunctionProvider.java
##
@@ -20,19
flinkbot edited a comment on pull request #13744:
URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975
## CI report:
* c51d4e8bf5dba50e4cb501fc04a87c924fe27e36 Azure:
flinkbot edited a comment on pull request #13307:
URL: https://github.com/apache/flink/pull/13307#issuecomment-685763264
## CI report:
* 0edbb09cea1b10a677b91c17b889ec74ef8dfbed Azure:
flinkbot edited a comment on pull request #13300:
URL: https://github.com/apache/flink/pull/13300#issuecomment-684957567
## CI report:
* Unknown: [CANCELED](TBD)
* c777052640e6c3005314d8dd284cf0c4785fdf8a Azure:
flinkbot edited a comment on pull request #13296:
URL: https://github.com/apache/flink/pull/13296#issuecomment-684611193
## CI report:
* c266341c63cc4cdc28a6585a82294710fd8ebbc5 UNKNOWN
* d7d795f0085c86a8a170c80a47ef949d5d3dfeb7 Azure:
yuchuanchen edited a comment on pull request #13718:
URL: https://github.com/apache/flink/pull/13718#issuecomment-717663344
Hi @pnowojski, I squashed the commits and opened a new pull request.
https://github.com/apache/flink/pull/13810
flinkbot commented on pull request #13810:
URL: https://github.com/apache/flink/pull/13810#issuecomment-717663534
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
yuchuanchen commented on pull request #13718:
URL: https://github.com/apache/flink/pull/13718#issuecomment-717663344
@pnowojski Is squashed the commits and opened a new pull request.
https://github.com/apache/flink/pull/13810
yuchuanchen opened a new pull request #13810:
URL: https://github.com/apache/flink/pull/13810
…hen creating spill file
## What is the purpose of the change
Pick another disk(tmpDir) for Spilling Channel, rather than throw an
IOException, which causes flink job restart
shuiqiangchen commented on pull request #13756:
URL: https://github.com/apache/flink/pull/13756#issuecomment-717661702
Hi @anonymouscodeholic ， I have updated the pr according to your
suggestions, please have a look at it.
yuchuanchen closed pull request #13718:
URL: https://github.com/apache/flink/pull/13718
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
JingsongLi commented on a change in pull request #13697:
URL: https://github.com/apache/flink/pull/13697#discussion_r513147361
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
##
@@ -251,14
caozhen1937 commented on pull request #13296:
URL: https://github.com/apache/flink/pull/13296#issuecomment-717658890
@HsbcJone "Found null,Expecting row_1" exception appear because avro record
name is repeated. I fix,you can test again.
flinkbot edited a comment on pull request #13763:
URL: https://github.com/apache/flink/pull/13763#issuecomment-715195599
## CI report:
* a28669bca9c36dac74f89da177825d73bea0ece0 Azure:
flinkbot edited a comment on pull request #13760:
URL: https://github.com/apache/flink/pull/13760#issuecomment-715078238
## CI report:
* b1353f7422a706cd50502d62b988b06154d33ffc Azure:
flinkbot edited a comment on pull request #13744:
URL: https://github.com/apache/flink/pull/13744#issuecomment-714369975
## CI report:
* c51d4e8bf5dba50e4cb501fc04a87c924fe27e36 Azure:
wuchong commented on a change in pull request #13801:
URL: https://github.com/apache/flink/pull/13801#discussion_r513141770
##
File path: docs/dev/table/connectors/formats/avro-confluent.zh.md
##
@@ -72,50 +72,50 @@ CREATE TABLE user_behavior (
-Format Options
+Format 参数
JingsongLi commented on a change in pull request #13697:
URL: https://github.com/apache/flink/pull/13697#discussion_r513144820
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketFactory.java
##
@@ -37,6 +39,7 @@
1 - 100 of 644 matches
Mail list logo
