flinkbot edited a comment on pull request #8952:
URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324
## CI report:
* d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN
* c6cd36a8dfd854ecf63b2d248a4a28f889c873ec Azure:
HuangZhenQiu edited a comment on pull request #8952:
URL: https://github.com/apache/flink/pull/8952#issuecomment-751315528
@xintongsong
Thanks for the comments. I do like the simplified version after grouping
classes and utils together. For the TimestampBasedFailureRater, I would
[
https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254943#comment-17254943
]
yang gang edited comment on FLINK-20743 at 12/26/20, 4:11 AM:
--
[~zjwang] Hi
[
https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254943#comment-17254943
]
yang gang edited comment on FLINK-20743 at 12/26/20, 4:10 AM:
--
[~zjwang] Hi
flinkbot edited a comment on pull request #8952:
URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324
## CI report:
* d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN
* 67e9e1e4c013b78eaee9fc9d215ef400bba5cc59 Azure:
[
https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254943#comment-17254943
]
yang gang commented on FLINK-20743:
---
[~zjwang] Hi
Thank you very much for your reply, can you assign
HuangZhenQiu commented on pull request #8952:
URL: https://github.com/apache/flink/pull/8952#issuecomment-751315528
@xintongsong
Thanks for the comments. I do like the simplified version after grouping
classes and utils together. For the TimestampBasedFailureRater, I would prefer
to
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r548939375
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/ResourceManagerOptions.java
##
@@ -67,6 +69,33 @@
"for
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r548939317
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricNames.java
##
@@ -67,6 +67,7 @@ private MetricNames() {
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r548939312
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r548939286
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r548939285
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r548938231
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/TimestampBasedFailureRater.java
##
@@ -0,0 +1,93 @@
+/*
+ * Licensed
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r548938212
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/ThresholdMeter.java
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r548938183
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/failurerate/FailureRaterUtil.java
##
@@ -0,0 +1,37 @@
+/*
+ * Licensed to the
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r548938104
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/execution/ThresholdExceedException.java
##
@@ -0,0 +1,31 @@
+/*
+ * Licensed to
HuangZhenQiu commented on a change in pull request #8952:
URL: https://github.com/apache/flink/pull/8952#discussion_r548938069
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/execution/ThresholdExceedException.java
##
@@ -0,0 +1,31 @@
+/*
+ * Licensed to
flinkbot edited a comment on pull request #8952:
URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324
## CI report:
* d083b630115604e34b0a74498890aedbff61b2a7 UNKNOWN
* 67e9e1e4c013b78eaee9fc9d215ef400bba5cc59 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254938#comment-17254938
]
Huang Xingbo commented on FLINK-17482:
--
[
https://issues.apache.org/jira/browse/FLINK-20762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Liu closed FLINK-20762.
---
Resolution: Duplicate
> Remove unused checkpointStorage path after job finished
>
[
https://issues.apache.org/jira/browse/FLINK-20762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254936#comment-17254936
]
Liu commented on FLINK-20762:
-
[~yunta] Thank you for your information. I have read the FLINK-15012. It is
[
https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaozilong updated FLINK-20773:
---
Description:
Can we add an option `allow-unescaped-control-chars` for json format because of
it
[
https://issues.apache.org/jira/browse/FLINK-20736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-20736.
--
Resolution: Fixed
Fixed in 1.13.0: 677d392a..a25b9b84
> Separate the implementation of
godfreyhe closed pull request #14472:
URL: https://github.com/apache/flink/pull/14472
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
xintongsong opened a new pull request #405:
URL: https://github.com/apache/flink-web/pull/405
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
flinkbot edited a comment on pull request #14466:
URL: https://github.com/apache/flink/pull/14466#issuecomment-749592580
## CI report:
* cfb29832f3281af5b385f0ef87f17875224f474e Azure:
[
https://issues.apache.org/jira/browse/FLINK-20771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254876#comment-17254876
]
zhuxiaoshang commented on FLINK-20771:
--
Hi [~hehuiyuan],this is dumplicated to
flinkbot edited a comment on pull request #14496:
URL: https://github.com/apache/flink/pull/14496#issuecomment-751242619
## CI report:
* b320965a86dfb89ae406cf19c77dd2e5f294d95f Azure:
flinkbot edited a comment on pull request #13800:
URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623
## CI report:
* bfbae787e414d2cd1c9dec08f5bbfb3a9b91e6ce Azure:
blublinsky commented on pull request #14281:
URL: https://github.com/apache/flink/pull/14281#issuecomment-751265666
We could, which creates a lot of code, which not really add clarity or
simplicity. Right now it is just 9 lines of code. What is the point of creation
additional class, that
flinkbot edited a comment on pull request #14472:
URL: https://github.com/apache/flink/pull/14472#issuecomment-750005686
## CI report:
* b04180b32ac8950c9dabaa7f8142ed6bff033304 Azure:
flinkbot edited a comment on pull request #14493:
URL: https://github.com/apache/flink/pull/14493#issuecomment-751222472
## CI report:
* 179ea826af4470c6c1d9a94da5f4270f16e81f40 Azure:
flinkbot edited a comment on pull request #14466:
URL: https://github.com/apache/flink/pull/14466#issuecomment-749592580
## CI report:
* 265349b7e273ffcc388f37fd31248eb37e271550 Azure:
godfreyhe commented on pull request #14472:
URL: https://github.com/apache/flink/pull/14472#issuecomment-751252395
Thanks for the update, LGTM except some minor adjustments, I will do this in
my local and then merge the pr once azure is green
flinkbot edited a comment on pull request #14466:
URL: https://github.com/apache/flink/pull/14466#issuecomment-749592580
## CI report:
* 265349b7e273ffcc388f37fd31248eb37e271550 Azure:
kezhuw commented on pull request #14466:
URL: https://github.com/apache/flink/pull/14466#issuecomment-751249646
@wuchong I have squashed and rebased all commits on latest master. Please
take another look.
This is an
kezhuw commented on a change in pull request #14466:
URL: https://github.com/apache/flink/pull/14466#discussion_r548872516
##
File path:
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/connection/JdbcConnectionProvider.java
##
@@
[
https://issues.apache.org/jira/browse/FLINK-20706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-20706.
--
Resolution: Fixed
Fixed in 1.13.0: 4f323bac..f3d03eb4
> Separate the implementation of
godfreyhe closed pull request #14455:
URL: https://github.com/apache/flink/pull/14455
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
flinkbot edited a comment on pull request #14496:
URL: https://github.com/apache/flink/pull/14496#issuecomment-751242619
## CI report:
* b320965a86dfb89ae406cf19c77dd2e5f294d95f Azure:
flinkbot edited a comment on pull request #13800:
URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623
## CI report:
* f5e7891cc45eba2d0d8f28dabdf596834faf0f0a Azure:
[
https://issues.apache.org/jira/browse/FLINK-20766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-20766:
--
Assignee: Wenlong Lyu
> Separate the implementation of stream sort nodes
>
[
https://issues.apache.org/jira/browse/FLINK-20738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-20738:
--
Assignee: godfrey he
> Separate the implementation of batch group aggregate nodes
>
[
https://issues.apache.org/jira/browse/FLINK-20507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-20507:
Summary: Support aggregate operation in Python Table API (was: Support
Aggregate Operation in Python
[
https://issues.apache.org/jira/browse/FLINK-20702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-20702:
Summary: Support map operation chained together in Python Table API (was:
Support Map Operation Chained
[
https://issues.apache.org/jira/browse/FLINK-20702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-20702.
---
Resolution: Fixed
Merged to master via febce3597bc927a839bcd7dae679c531401b6ad7
> Support Map Operation
dianfu closed pull request #14473:
URL: https://github.com/apache/flink/pull/14473
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
[
https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaozilong updated FLINK-20773:
---
Description:
Can we add an option `allow-unquoted-ctrl-char` for json format because of it
will
[
https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254818#comment-17254818
]
xiaozilong commented on FLINK-20773:
cc [~jark]
> Support allow-unescaped-control-chars option for
[
https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xiaozilong updated FLINK-20773:
---
Description:
Can we add an option `allow-unquoted-ctrl-char` for json format because of it
will
xiaozilong created FLINK-20773:
--
Summary: Support allow-unescaped-control-chars option for JSON
format
Key: FLINK-20773
URL: https://issues.apache.org/jira/browse/FLINK-20773
Project: Flink
flinkbot commented on pull request #14496:
URL: https://github.com/apache/flink/pull/14496#issuecomment-751242619
## CI report:
* b320965a86dfb89ae406cf19c77dd2e5f294d95f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #13800:
URL: https://github.com/apache/flink/pull/13800#issuecomment-717132623
## CI report:
* f5e7891cc45eba2d0d8f28dabdf596834faf0f0a Azure:
flinkbot commented on pull request #14496:
URL: https://github.com/apache/flink/pull/14496#issuecomment-751240803
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
HuangXingBo commented on pull request #14496:
URL: https://github.com/apache/flink/pull/14496#issuecomment-751240558
@godfreyhe @dianfu Could you help review it? Thanks.
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-20620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20620:
---
Labels: pull-request-available (was: )
> Port BatchExecPythonCalc and StreamExecPythonCalc
HuangXingBo opened a new pull request #14496:
URL: https://github.com/apache/flink/pull/14496
## What is the purpose of the change
This pull request will Port BatchExecPythonCalc and StreamExecPythonCalc to
Java
## Brief change log
- *Introduce `CommonPythonUtil`*
[
https://issues.apache.org/jira/browse/FLINK-20768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254807#comment-17254807
]
Jark Wu commented on FLINK-20768:
-
Hi [~wangsan], before submitting a pull request, we should discuss
[
https://issues.apache.org/jira/browse/FLINK-20768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20768:
Component/s: Table SQL / Ecosystem
> Support routing field for Elasticsearch connector
>
flinkbot edited a comment on pull request #14494:
URL: https://github.com/apache/flink/pull/14494#issuecomment-751222501
## CI report:
* 87391a27aaaf4a4ca2bc15d6043c831348279de4 UNKNOWN
* 8c529ec8d1edb62ba45784709f3d313b7ef37c4c Azure:
flinkbot edited a comment on pull request #14492:
URL: https://github.com/apache/flink/pull/14492#issuecomment-751194123
## CI report:
* 8d7ba4cf9f64e73076055013e3ccb18b7bd9ec3c Azure:
Seongbae Chang created FLINK-20772:
--
Summary: [DISCUSS] RocksDBValueState with TTL occurs
NullPointerException when calling update(null) method
Key: FLINK-20772
URL:
[
https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254799#comment-17254799
]
Rui Li commented on FLINK-20416:
[~shared_ptr] Thanks for the design doc. Instead of adding a wrapper of
flinkbot edited a comment on pull request #14495:
URL: https://github.com/apache/flink/pull/14495#issuecomment-751225470
## CI report:
* 06d95b81212492278e8bc45f78a86e720b739f0d Azure:
flinkbot edited a comment on pull request #14494:
URL: https://github.com/apache/flink/pull/14494#issuecomment-751222501
## CI report:
* 87391a27aaaf4a4ca2bc15d6043c831348279de4 UNKNOWN
* 8c529ec8d1edb62ba45784709f3d313b7ef37c4c Azure:
flinkbot edited a comment on pull request #14472:
URL: https://github.com/apache/flink/pull/14472#issuecomment-750005686
## CI report:
* 9135cbb7f107ee96b15de4b0a3453d60ee5b9de6 Azure:
xiaoHoly commented on pull request #14495:
URL: https://github.com/apache/flink/pull/14495#issuecomment-751227923
hi,@zhisheng17 .I have learned some information, and I think this idea makes
sense. Share with you
now。https://blog.csdn.net/weixin_39525007/article/details/110726349
[
https://issues.apache.org/jira/browse/FLINK-20771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-20771:
--
Description:
Hive partition is not added when the data is huge .
[
https://issues.apache.org/jira/browse/FLINK-20771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-20771:
--
Description:
Hive partition is not added when the data is huge .
[
https://issues.apache.org/jira/browse/FLINK-20771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hehuiyuan updated FLINK-20771:
--
Attachment: image-2020-12-25-18-19-53-746.png
> Hive partition is not added when there is a lot of
hehuiyuan created FLINK-20771:
-
Summary: Hive partition is not added when there is a lot of data
Key: FLINK-20771
URL: https://issues.apache.org/jira/browse/FLINK-20771
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-20743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254795#comment-17254795
]
Zhijiang commented on FLINK-20743:
--
Thanks for creating this issue [~清月].
I remembered I also
flinkbot commented on pull request #14495:
URL: https://github.com/apache/flink/pull/14495#issuecomment-751225470
## CI report:
* 06d95b81212492278e8bc45f78a86e720b739f0d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #14494:
URL: https://github.com/apache/flink/pull/14494#issuecomment-751222501
## CI report:
* 87391a27aaaf4a4ca2bc15d6043c831348279de4 UNKNOWN
* 8c529ec8d1edb62ba45784709f3d313b7ef37c4c UNKNOWN
Bot commands
The
flinkbot edited a comment on pull request #14493:
URL: https://github.com/apache/flink/pull/14493#issuecomment-751222472
## CI report:
* 179ea826af4470c6c1d9a94da5f4270f16e81f40 Azure:
flinkbot edited a comment on pull request #14472:
URL: https://github.com/apache/flink/pull/14472#issuecomment-750005686
## CI report:
* 9135cbb7f107ee96b15de4b0a3453d60ee5b9de6 Azure:
shmyer commented on pull request #14084:
URL: https://github.com/apache/flink/pull/14084#issuecomment-751224702
Hi @leonardBang I would have time next week if that's not too late
This is an automated message from the Apache
zhisheng17 commented on pull request #14495:
URL: https://github.com/apache/flink/pull/14495#issuecomment-751224512
what about use class instead of enum? @tillrohrmann
This is an automated message from the Apache Git
zhisheng17 commented on pull request #14495:
URL: https://github.com/apache/flink/pull/14495#issuecomment-751224053
the code will error if remove the `;`
This is an automated message from the Apache Git Service.
To respond
Yang Wang created FLINK-20770:
-
Summary: Incorrect description for config option
kubernetes.rest-service.exposed.type
Key: FLINK-20770
URL: https://issues.apache.org/jira/browse/FLINK-20770
Project:
[
https://issues.apache.org/jira/browse/FLINK-20764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-20764.
Resolution: Fixed
Fixed via:
* master (1.13): b474d2872f4a82d838ac23252254253df4ca2309
*
flinkbot commented on pull request #14494:
URL: https://github.com/apache/flink/pull/14494#issuecomment-751222501
## CI report:
* 87391a27aaaf4a4ca2bc15d6043c831348279de4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #14493:
URL: https://github.com/apache/flink/pull/14493#issuecomment-751222472
## CI report:
* 179ea826af4470c6c1d9a94da5f4270f16e81f40 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-20764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-20764:
-
Fix Version/s: 1.13.0
> BatchGroupedReduceOperator does not emit results for singleton inputs
>
[
https://issues.apache.org/jira/browse/FLINK-20764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song updated FLINK-20764:
-
Affects Version/s: 1.12.0
> BatchGroupedReduceOperator does not emit results for singleton
flinkbot commented on pull request #14495:
URL: https://github.com/apache/flink/pull/14495#issuecomment-751222385
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
xintongsong closed pull request #14489:
URL: https://github.com/apache/flink/pull/14489
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
xintongsong commented on pull request #14489:
URL: https://github.com/apache/flink/pull/14489#issuecomment-751222183
Thanks @aljoscha for opening the PR and @gaoyunhaii for the review.
LGTM. Merging this now.
This is an
zhisheng17 opened a new pull request #14495:
URL: https://github.com/apache/flink/pull/14495
## What is the purpose of the change
fix typo in HistoryServerUtils class
This is an automated message
WeiZhong94 commented on a change in pull request #14492:
URL: https://github.com/apache/flink/pull/14492#discussion_r548843229
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/PythonCalcSplitRule.scala
##
@@
flinkbot commented on pull request #14494:
URL: https://github.com/apache/flink/pull/14494#issuecomment-751221444
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
sv3ndk opened a new pull request #14494:
URL: https://github.com/apache/flink/pull/14494
## What is the purpose of the change
*Illustrate java 8's lambda style usage in `.filter()` instead of
`FilterFunction` in the first example of the "Learn Flink" section*
Java 8
flinkbot commented on pull request #14493:
URL: https://github.com/apache/flink/pull/14493#issuecomment-751218776
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-20768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-20768:
---
Labels: pull-request-available (was: )
> Support routing field for Elasticsearch connector
flinkbot edited a comment on pull request #14473:
URL: https://github.com/apache/flink/pull/14473#issuecomment-750013641
## CI report:
* 8700f3fff87a3b634fda6a74ac7e1430a4c60ae0 Azure:
jrthe42 opened a new pull request #14493:
URL: https://github.com/apache/flink/pull/14493
## What is the purpose of the change
This pull request add support for routing field in ElasticSearch connector.
## Brief change log
- Add `routing.filed-name` option to ES
[
https://issues.apache.org/jira/browse/FLINK-20505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17254788#comment-17254788
]
zoucao commented on FLINK-20505:
[~xintongsong]，
Maybe close this ticket is a better choice, beacuse
flinkbot edited a comment on pull request #14473:
URL: https://github.com/apache/flink/pull/14473#issuecomment-750013641
## CI report:
* 8700f3fff87a3b634fda6a74ac7e1430a4c60ae0 Azure:
[
https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-20664.
Resolution: Fixed
Fixed via
* master (1.13): 4e5448cc332090d7bd2664f60278534d945e1211
*
JackWangCS edited a comment on pull request #14452:
URL: https://github.com/apache/flink/pull/14452#issuecomment-751214826
Hi @JingsongLi , thank you for your reply. I will create a ticket to
implement the feature. And there are some design decisions that need to be
discussed. I will ping
1 - 100 of 106 matches
Mail list logo
