wuchong commented on a change in pull request #11959:
URL: https://github.com/apache/flink/pull/11959#discussion_r418922875
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java
##
@@ -0,0 +1,570 @@
+/*
+ * Licensed to the
flinkbot edited a comment on pull request #11725:
URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882
## CI report:
* a9c54057daa5bb907302534b04be5f4742d1b586 Travis:
[FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162928464) Azure:
[FAILURE](http
[
https://issues.apache.org/jira/browse/FLINK-17027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097831#comment-17097831
]
Jark Wu commented on FLINK-17027:
-
Hi [~molsion], this issue is still blocked by FLIP-95
[
https://issues.apache.org/jira/browse/FLINK-17028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097830#comment-17097830
]
Jark Wu commented on FLINK-17028:
-
Hi [~molsion], this issue is still blocked by FLIP-95
flinkbot edited a comment on pull request #11974:
URL: https://github.com/apache/flink/pull/11974#issuecomment-622652948
## CI report:
* 4261809a08f0cfb516ea52db15de27f154b3ad73 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-12675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097822#comment-17097822
]
Akshay Aggarwal commented on FLINK-12675:
-
Thanks [~thw]. I've raised a PR, can
[
https://issues.apache.org/jira/browse/FLINK-17027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097813#comment-17097813
]
molsion mo commented on FLINK-17027:
i want to take this task if no one work for it.
flinkbot edited a comment on pull request #11975:
URL: https://github.com/apache/flink/pull/11975#issuecomment-622662116
## CI report:
* 89d8665ddbcdd11cff8652f39fea4d0601f809ac Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-17028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097803#comment-17097803
]
molsion mo commented on FLINK-17028:
I have read and understood FLIP-95 and i was co
flinkbot commented on pull request #11975:
URL: https://github.com/apache/flink/pull/11975#issuecomment-622662116
## CI report:
* 89d8665ddbcdd11cff8652f39fea4d0601f809ac UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #11975:
URL: https://github.com/apache/flink/pull/11975#issuecomment-622660356
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 pro
tweise opened a new pull request #11975:
URL: https://github.com/apache/flink/pull/11975
## What is the purpose of the change
Kinesis producer 0.13.1 introduced a performance regression that can be
addressed with the upgrade to 0.14.0
## Verifying this change
The proble
[
https://issues.apache.org/jira/browse/FLINK-17496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17496:
---
Labels: pull-request-available (was: )
> Performance regression with amazon-kinesis-produce
Thomas Weise created FLINK-17496:
Summary: Performance regression with amazon-kinesis-producer
0.13.1 in Flink 1.10.x
Key: FLINK-17496
URL: https://issues.apache.org/jira/browse/FLINK-17496
Project: F
flinkbot edited a comment on pull request #11974:
URL: https://github.com/apache/flink/pull/11974#issuecomment-622652948
## CI report:
* 4261809a08f0cfb516ea52db15de27f154b3ad73 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #11974:
URL: https://github.com/apache/flink/pull/11974#issuecomment-622652948
## CI report:
* 4261809a08f0cfb516ea52db15de27f154b3ad73 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
wanglijie95 commented on pull request #11499:
URL: https://github.com/apache/flink/pull/11499#issuecomment-622651532
@LakeShen Hi LakeShen, flink release 1.11 will enter the code freeze period
on May 15. Maybe you can finish this PR before May 15 and merge to 1.11 .
--
flinkbot commented on pull request #11974:
URL: https://github.com/apache/flink/pull/11974#issuecomment-622650910
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 pro
molsionmo opened a new pull request #11974:
URL: https://github.com/apache/flink/pull/11974
## What is the purpose of the change
*Bundle JMXReporter separately from dist jar,and put it in folder /opt*
## Verifying this change
This change is a trivial rework / cod
flinkbot edited a comment on pull request #11963:
URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588
## CI report:
* e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN
* 994fb5984ec6312126d76b75206d0023e8ae4212 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #11973:
URL: https://github.com/apache/flink/pull/11973#issuecomment-622555129
## CI report:
* ccb23fef7822524883d71a604d4ef9e673307bc7 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #11963:
URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588
## CI report:
* e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN
* 7401f5580774397bd121736b1068f03009a2d980 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #11963:
URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588
## CI report:
* e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN
* 7401f5580774397bd121736b1068f03009a2d980 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #11971:
URL: https://github.com/apache/flink/pull/11971#issuecomment-622521983
## CI report:
* f4082786bad837955dea7f68fce466c6b7719912 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-16478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097714#comment-17097714
]
Xingxing Di commented on FLINK-16478:
-
{quote}In general I think such a feature woul
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097696#comment-17097696
]
Kyle Weaver commented on FLINK-10672:
-
Hi Yun, sorry I haven't had much time to look
edu05 commented on pull request #11952:
URL: https://github.com/apache/flink/pull/11952#issuecomment-622582457
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, please lo
flinkbot edited a comment on pull request #11973:
URL: https://github.com/apache/flink/pull/11973#issuecomment-622555129
## CI report:
* ccb23fef7822524883d71a604d4ef9e673307bc7 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #11973:
URL: https://github.com/apache/flink/pull/11973#issuecomment-622555129
## CI report:
* ccb23fef7822524883d71a604d4ef9e673307bc7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot commented on pull request #11973:
URL: https://github.com/apache/flink/pull/11973#issuecomment-622550880
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 pro
pavel-hp opened a new pull request #11973:
URL: https://github.com/apache/flink/pull/11973
- Now JdbcConnectionOptions supports autoCommit control
Default behaviour hasn't changed.
- Added logging information to be able to track batches
## What is the purpose of the c
[
https://issues.apache.org/jira/browse/FLINK-17488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17488:
---
Labels: pull-request-available (was: )
> JdbcSink has to support setting autoCommit mode of
flinkbot edited a comment on pull request #11972:
URL: https://github.com/apache/flink/pull/11972#issuecomment-622529341
## CI report:
* c06b5ebbdbe753d44ce2111dfde996ff9e0868f5 Travis:
[FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/163266345) Azure:
[FAILURE](http
flinkbot edited a comment on pull request #11971:
URL: https://github.com/apache/flink/pull/11971#issuecomment-622521983
## CI report:
* f4082786bad837955dea7f68fce466c6b7719912 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot commented on pull request #11972:
URL: https://github.com/apache/flink/pull/11972#issuecomment-622529341
## CI report:
* c06b5ebbdbe753d44ce2111dfde996ff9e0868f5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
[
https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097624#comment-17097624
]
Roey Shem Tov commented on FLINK-17058:
---
[~aljoscha] sorry for late response, took
[
https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-17289:
---
Description: This is one of the new tutorials, and it needs translation.
The file is docs/tr
[
https://issues.apache.org/jira/browse/FLINK-17291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-17291:
---
Description: Translate docs/training/event_driven.zh.md to Chinese. (was:
Translate docs/tu
[
https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-17271:
---
Description: docs/training/datastream_api.zh.md needs to be translated.
(was: docs/tutorial
[
https://issues.apache.org/jira/browse/FLINK-17290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-17290:
---
Description: The file to be translated is
docs/training/streaming-analytics.zh.md. The conte
[
https://issues.apache.org/jira/browse/FLINK-17292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson updated FLINK-17292:
---
Description: This ticket is about translating the new tutorial in
docs/training/fault_tolera
[
https://issues.apache.org/jira/browse/FLINK-17292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097618#comment-17097618
]
David Anderson commented on FLINK-17292:
Yes, [~xbaith], that's right.
> Trans
flinkbot commented on pull request #11972:
URL: https://github.com/apache/flink/pull/11972#issuecomment-622522199
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 pro
flinkbot commented on pull request #11971:
URL: https://github.com/apache/flink/pull/11971#issuecomment-622521983
## CI report:
* f4082786bad837955dea7f68fce466c6b7719912 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
flinkbot edited a comment on pull request #11952:
URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853
## CI report:
* 2113227fdc0076eb9e2f72ae7883c2d5d245cbab Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
roeyshemtov opened a new pull request #11972:
URL: https://github.com/apache/flink/pull/11972
## What is the purpose of the change
Adding new feature of ProcessingTimeoutTrigger as mention in FLINK-17058
jira page.
## Verifying this change
Adding UnitTests to the new code.
[
https://issues.apache.org/jira/browse/FLINK-17292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097611#comment-17097611
]
Bai Xu edited comment on FLINK-17292 at 5/1/20, 7:02 PM:
-
Hi [~a
[
https://issues.apache.org/jira/browse/FLINK-17292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097611#comment-17097611
]
Bai Xu commented on FLINK-17292:
Hi [~alpinegizmo].It's me again.Let me drive this simpl
[
https://issues.apache.org/jira/browse/FLINK-17058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17058:
---
Labels: pull-request-available (was: )
> Adding TimeoutTrigger support nested triggers
> --
[
https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097585#comment-17097585
]
Bai Xu edited comment on FLINK-17271 at 5/1/20, 6:39 PM:
-
[~alpi
[
https://issues.apache.org/jira/browse/FLINK-17404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097587#comment-17097587
]
Kostas Kloudas commented on FLINK-17404:
Thanks [~rmetzger]
> Running HA per-jo
[
https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097585#comment-17097585
]
Bai Xu commented on FLINK-17271:
[~alpinegizmo] Thanks for your patient!
I have finshed
flinkbot commented on pull request #11971:
URL: https://github.com/apache/flink/pull/11971#issuecomment-622508565
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 pro
[
https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17271:
---
Labels: pull-request-available (was: )
> Translate new DataStream API tutorial
> --
XBaith opened a new pull request #11971:
URL: https://github.com/apache/flink/pull/11971
## What is the purpose of the change
*This pull request translates new "DataStream API tutorial" page into
Chinese.*
## Verifying this change
*This change is a docs work without any
flinkbot edited a comment on pull request #11952:
URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853
## CI report:
* cb00ba58dee155aceb27bd4b8bab837a77265699 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Anderson reassigned FLINK-17271:
--
Assignee: Bai Xu
> Translate new DataStream API tutorial
> --
flinkbot edited a comment on pull request #11936:
URL: https://github.com/apache/flink/pull/11936#issuecomment-620683562
## CI report:
* a02867a0bce8f1a0174a6a3133b50b76167dbcc9 Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/163208458) Azure:
[SUCCESS](http
flinkbot edited a comment on pull request #11952:
URL: https://github.com/apache/flink/pull/11952#issuecomment-621589853
## CI report:
* cb00ba58dee155aceb27bd4b8bab837a77265699 Azure:
[FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
edu05 commented on pull request #11952:
URL: https://github.com/apache/flink/pull/11952#issuecomment-622489226
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/FLINK-17488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Khokhlov Pavel updated FLINK-17488:
---
Priority: Major (was: Critical)
> JdbcSink has to support setting autoCommit mode of DB
> -
flinkbot edited a comment on pull request #11844:
URL: https://github.com/apache/flink/pull/11844#issuecomment-617177959
## CI report:
* 135e33f23db360cbb1b4cbc4870e7640e78241cf Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/163211195)
Bot comman
flinkbot edited a comment on pull request #11687:
URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542
## CI report:
* 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN
* d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN
* cba096ae3d8eba4a0d39c64659f76ad10a62
flinkbot edited a comment on pull request #11936:
URL: https://github.com/apache/flink/pull/11936#issuecomment-620683562
## CI report:
* a02867a0bce8f1a0174a6a3133b50b76167dbcc9 Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/163208458) Azure:
[PENDING](http
[
https://issues.apache.org/jira/browse/FLINK-17271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097473#comment-17097473
]
Bai Xu commented on FLINK-17271:
Hi,[~alpinegizmo] .Could you please assign this to me?T
[
https://issues.apache.org/jira/browse/FLINK-17291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097467#comment-17097467
]
RocMarshal commented on FLINK-17291:
[~alpinegizmo] I will translate the "docs/trai
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r418596170
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaShuffleProducer.java
##
@@ -0,0 +
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r418596170
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaShuffleProducer.java
##
@@ -0,0 +
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r418595393
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
##
@@ -1333,6 +1334,32 @@ public ExecutionConfi
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r418595542
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SinkTransformation.java
##
@@ -67,6 +68,22 @@ public SinkT
sjwiesman commented on pull request #11878:
URL: https://github.com/apache/flink/pull/11878#issuecomment-622433861
Sure
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
flinkbot edited a comment on pull request #11963:
URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588
## CI report:
* e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN
* 7401f5580774397bd121736b1068f03009a2d980 Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #11969:
URL: https://github.com/apache/flink/pull/11969#issuecomment-622355748
## CI report:
* ddc6ff6bc782c78bae1688b8b61e51038e9c2fb9 Azure:
[SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
flinkbot edited a comment on pull request #11844:
URL: https://github.com/apache/flink/pull/11844#issuecomment-617177959
## CI report:
* ebadc9001eb68754a95b3eee329b26c7590dfdfc Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/163020392)
* 135e33f23db360cb
flinkbot edited a comment on pull request #11936:
URL: https://github.com/apache/flink/pull/11936#issuecomment-620683562
## CI report:
* 1dcd163a3f869576f9504233e152a2e76baef51c Travis:
[FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/163136724) Azure:
[FAILURE](http
flinkbot edited a comment on pull request #11963:
URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588
## CI report:
* e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN
* 7359ca7d6960774eb8294b49d915cbd1563644fe Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #11844:
URL: https://github.com/apache/flink/pull/11844#issuecomment-617177959
## CI report:
* ebadc9001eb68754a95b3eee329b26c7590dfdfc Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/163020392)
* 135e33f23db360cb
HuangXingBo commented on pull request #11878:
URL: https://github.com/apache/flink/pull/11878#issuecomment-622409672
Thanks a lot for the fix @sjwiesman . I have cherry-pick these commits to
release-1.10 https://github.com/apache/flink/pull/11844 and change the content
of `Adding Jar Files
flinkbot edited a comment on pull request #11936:
URL: https://github.com/apache/flink/pull/11936#issuecomment-620683562
## CI report:
* 1dcd163a3f869576f9504233e152a2e76baef51c Travis:
[FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/163136724) Azure:
[FAILURE](http
flinkbot edited a comment on pull request #11963:
URL: https://github.com/apache/flink/pull/11963#issuecomment-621969588
## CI report:
* e07ec1bd9c216cdac0ac4faa79bc5509ab4129b6 UNKNOWN
* 7359ca7d6960774eb8294b49d915cbd1563644fe Azure:
[FAILURE](https://dev.azure.com/apache-fl
flinkbot edited a comment on pull request #11970:
URL: https://github.com/apache/flink/pull/11970#issuecomment-622395974
## CI report:
* 151f32be272c47867647c3ef9877534c37887900 Azure:
[PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result
[
https://issues.apache.org/jira/browse/FLINK-16868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097390#comment-17097390
]
Jark Wu commented on FLINK-16868:
-
This is a new feature, not a bug. So I removed the fi
[
https://issues.apache.org/jira/browse/FLINK-16868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-16868:
Fix Version/s: (was: 1.9.4)
(was: 1.10.2)
(was: 1.11.0)
[
https://issues.apache.org/jira/browse/FLINK-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17097389#comment-17097389
]
Jark Wu commented on FLINK-17466:
-
Yes. I checked in master and this is still another bu
[
https://issues.apache.org/jira/browse/FLINK-17466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-17466:
Fix Version/s: 1.10.2
1.11.0
> toRetractStream doesn't work correctly with Pojo convers
[
https://issues.apache.org/jira/browse/FLINK-16868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-16868:
--
Fix Version/s: (was: 1.9.2)
(was: 1.9.1)
(was: 1.9.0)
[
https://issues.apache.org/jira/browse/FLINK-16612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-16612:
--
Fix Version/s: (was: 1.9.2)
1.10.2
1.11.0
It's a little bit weird th
[
https://issues.apache.org/jira/browse/FLINK-16901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li closed FLINK-16901.
-
Resolution: Fixed
Closing the issue since all work done.
> Flink Kinesis connector NOTICE should have contents
[
https://issues.apache.org/jira/browse/FLINK-16901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-16901:
--
Issue Type: Bug (was: Improvement)
Labels: legal pull-request-available (was: pull-request-available)
[
https://issues.apache.org/jira/browse/FLINK-16901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Li updated FLINK-16901:
--
Fix Version/s: 1.11.0
Checked and confirmed master branch also has the same issue, and merged the fix
into ma
jinhai created FLINK-17495:
--
Summary: Add custom labels on PrometheusReporter like
PrometheusPushGatewayReporter's groupingKey
Key: FLINK-17495
URL: https://issues.apache.org/jira/browse/FLINK-17495
Project:
flinkbot commented on pull request #11970:
URL: https://github.com/apache/flink/pull/11970#issuecomment-622395974
## CI report:
* 151f32be272c47867647c3ef9877534c37887900 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot r
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r418544339
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java
##
@@ -52,6 +54,20 @@ default void invoke
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r418544086
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamShuffleSink.java
##
@@ -0,0 +1,104 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-14816.
---
Resolution: Fixed
Fixed via
02944090d7d267790aa9265ddce3d8a56d324878
4dc1f7e8c22b970cd0656d
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r418543715
##
File path: flink-core/src/main/java/org/apache/flink/util/PropertiesUtil.java
##
@@ -19,6 +19,7 @@
Review comment:
Oh, yep, used as a HashTabl
nobleyd created FLINK-17494:
---
Summary: Possible direct memory leak in cassandra sink
Key: FLINK-17494
URL: https://issues.apache.org/jira/browse/FLINK-17494
Project: Flink
Issue Type: Bug
flinkbot commented on pull request #11970:
URL: https://github.com/apache/flink/pull/11970#issuecomment-622389283
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 pro
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r418541284
##
File path: flink-core/src/main/java/org/apache/flink/util/PropertiesUtil.java
##
@@ -108,6 +109,27 @@ public static boolean getBoolean(Properties config
carp84 commented on pull request #11970:
URL: https://github.com/apache/flink/pull/11970#issuecomment-622388870
CC @zentol @rmetzger
This is an automated message from the Apache Git Service.
To respond to the message, please
1 - 100 of 193 matches
Mail list logo