zhijiangW commented on issue #6833: [FLINK-10537][network] Fix network small
performance degradation after merging [FLINK-9913]
URL: https://github.com/apache/flink/pull/6833#issuecomment-429729793
@pnowojski , thanks for finding this potential issue which would bring
regression in some ca
[
https://issues.apache.org/jira/browse/FLINK-10537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649816#comment-16649816
]
ASF GitHub Bot commented on FLINK-10537:
zhijiangW commented on issue #6833: [FL
[
https://issues.apache.org/jira/browse/FLINK-10537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649804#comment-16649804
]
ASF GitHub Bot commented on FLINK-10537:
zhijiangW commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649805#comment-16649805
]
ASF GitHub Bot commented on FLINK-10537:
zhijiangW commented on a change in pull
zhijiangW commented on a change in pull request #6833: [FLINK-10537][network]
Fix network small performance degradation after merging [FLINK-9913]
URL: https://github.com/apache/flink/pull/6833#discussion_r225031331
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime
zhijiangW commented on a change in pull request #6833: [FLINK-10537][network]
Fix network small performance degradation after merging [FLINK-9913]
URL: https://github.com/apache/flink/pull/6833#discussion_r225030697
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime
TisonKun opened a new pull request #6842: Flink 10549
URL: https://github.com/apache/flink/pull/6842
## What is the purpose of the change
This pull request covers the removal of tests based on legacy mode and
starting with "LegacyXXX" while covered by a test named "XXX" .
[
https://issues.apache.org/jira/browse/FLINK-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10549:
-
Description:
This Jira tracks the removal of tests based on legacy mode and starting with
"LegacyXXX" w
[
https://issues.apache.org/jira/browse/FLINK-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10549:
-
Description:
This Jira tracks the removal of tests based on legacy mode and starting with
"LegacyXXX" w
vinoyang created FLINK-10550:
Summary: Remove LegacyYarnClusterDescriptor
Key: FLINK-10550
URL: https://issues.apache.org/jira/browse/FLINK-10550
Project: Flink
Issue Type: Sub-task
R
[
https://issues.apache.org/jira/browse/FLINK-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10549:
-
Description:
This Jira tracks the removal of tests based on legacy mode and starting with
"LegacyXXX" w
[
https://issues.apache.org/jira/browse/FLINK-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10549:
-
Description:
This Jira tracks the removal of tests based on legacy mode and starting with
"LegacyXXX" w
[
https://issues.apache.org/jira/browse/FLINK-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10549:
-
Description:
This Jira tracks the removal of tests based on legacy mode and starting with
"LegacyXXX" w
[
https://issues.apache.org/jira/browse/FLINK-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10549:
-
Description:
This Jira tracks the removal of tests based on legacy mode and starting with
"LegacyXXX" w
[
https://issues.apache.org/jira/browse/FLINK-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10549:
-
Description:
This Jira tracks the removal of tests based on legacy mode and starting with
"LegacyXXX" w
[
https://issues.apache.org/jira/browse/FLINK-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10549:
-
Summary: Remove Legacy* Tests based on legacy mode (was: Remove Legacy*
Tests)
> Remove Legacy* Tests
[
https://issues.apache.org/jira/browse/FLINK-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10549:
-
Description:
This Jira tracks the removal of tests that start with "LegacyXXX" and covered
by a test na
[
https://issues.apache.org/jira/browse/FLINK-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10549:
-
Description:
This Jira tracks the removal of tests that start with "LegacyXXX" and covered
by a test na
[
https://issues.apache.org/jira/browse/FLINK-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10549:
-
Description:
This Jira tracks the removal of tests that start with "LegacyXXX" and covered
by a test na
[
https://issues.apache.org/jira/browse/FLINK-10549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10549:
-
Summary: Remove Legacy* Tests (was: Remove LegacyJobRetrievalITCase)
> Remove Legacy* Tests
> -
TisonKun created FLINK-10549:
Summary: Remove LegacyJobRetrievalITCase
Key: FLINK-10549
URL: https://issues.apache.org/jira/browse/FLINK-10549
Project: Flink
Issue Type: Sub-task
Compon
vinoyang created FLINK-10548:
Summary: Remove LegacyStandaloneClusterDescriptor
Key: FLINK-10548
URL: https://issues.apache.org/jira/browse/FLINK-10548
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-10547:
Summary: Remove LegacyCLI
Key: FLINK-10547
URL: https://issues.apache.org/jira/browse/FLINK-10547
Project: Flink
Issue Type: Sub-task
Reporter: vinoyang
[
https://issues.apache.org/jira/browse/FLINK-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649753#comment-16649753
]
Chesnay Schepler commented on FLINK-10135:
--
master: 4ff6483f367591b894726ed1874
[
https://issues.apache.org/jira/browse/FLINK-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-10135:
-
Fix Version/s: 1.5.5
1.6.2
1.7.0
> Certain cluster
zentol closed pull request #6702: [FLINK-10135] The JobManager does not report
the cluster-level metrics
URL: https://github.com/apache/flink/pull/6702
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenanc
[
https://issues.apache.org/jira/browse/FLINK-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649752#comment-16649752
]
ASF GitHub Bot commented on FLINK-10135:
zentol closed pull request #6702: [FLIN
[
https://issues.apache.org/jira/browse/FLINK-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-10135:
-
Summary: Certain cluster-level metrics are no longer exposed (was: The
JobManager doesn
[
https://issues.apache.org/jira/browse/FLINK-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10540:
-
Description: {{FlinkMiniCluster}} is based on legacy cluster mode and
should be no longer used. (was: {
[
https://issues.apache.org/jira/browse/FLINK-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10540:
-
Summary: Remove legacy FlinkMiniCluster (was: Remove legacy
LocalFlinkMiniCluster)
> Remove legacy Fli
[
https://issues.apache.org/jira/browse/FLINK-10546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-10546:
-
Description:
Before doing as title, I want to check that is the {{StandaloneMiniCluster}}
still in use?
TisonKun created FLINK-10546:
Summary: Remove StandaloneMiniCluster
Key: FLINK-10546
URL: https://issues.apache.org/jira/browse/FLINK-10546
Project: Flink
Issue Type: Task
Components: J
[
https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649729#comment-16649729
]
ASF GitHub Bot commented on FLINK-10253:
yanghua commented on issue #6839: [FLIN
yanghua commented on issue #6839: [FLINK-10253] Run MetricQueryService with
lower priority
URL: https://github.com/apache/flink/pull/6839#issuecomment-429710107
> One more question, should we expose the threads priority configuration to
the user? The purpose of this pr is to lower the prio
[
https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649728#comment-16649728
]
ASF GitHub Bot commented on FLINK-10253:
yanghua commented on issue #6839: [FLIN
yanghua commented on issue #6839: [FLINK-10253] Run MetricQueryService with
lower priority
URL: https://github.com/apache/flink/pull/6839#issuecomment-429709386
> Thanks for your contribution @yanghua . Please refer to the README in
flink-docs to regenerate the doc after your modify the op
[
https://issues.apache.org/jira/browse/FLINK-10405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10405:
---
Labels: pull-request-available (was: )
> Port JobManagerFailsITCase to new code base
>
[
https://issues.apache.org/jira/browse/FLINK-10405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649708#comment-16649708
]
ASF GitHub Bot commented on FLINK-10405:
TisonKun opened a new pull request #684
TisonKun opened a new pull request #6841: [FLINK-10405] [tests] Port
JobManagerFailsITCase to new code base
URL: https://github.com/apache/flink/pull/6841
## What is the purpose of the change
Port `JobManagerFailsITCase` to new code base. Basically I think that
taskmanager c
[
https://issues.apache.org/jira/browse/FLINK-10545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649702#comment-16649702
]
ASF GitHub Bot commented on FLINK-10545:
TisonKun opened a new pull request #684
[
https://issues.apache.org/jira/browse/FLINK-10545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10545:
---
Labels: pull-request-available (was: )
> Remove JobManagerLeaderSessionIDITCase
> -
TisonKun opened a new pull request #6840: [FLINK-10545] [tests] Remove
JobManagerLeaderSessionIDITCase
URL: https://github.com/apache/flink/pull/6840
## What is the purpose of the change
{{JobManagerLeaderSessionIDITCase.scala}} is based on legacy mode and I
think we now hav
TisonKun created FLINK-10545:
Summary: Remove JobManagerLeaderSessionIDITCase
Key: FLINK-10545
URL: https://issues.apache.org/jira/browse/FLINK-10545
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649693#comment-16649693
]
ASF GitHub Bot commented on FLINK-10253:
Clark commented on issue #6839: [FL
Clark commented on issue #6839: [FLINK-10253] Run MetricQueryService with
lower priority
URL: https://github.com/apache/flink/pull/6839#issuecomment-429700906
One more question, should we expose the threads priority configuration to
the user? The purpose of this pr is to lower the prio
[
https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649692#comment-16649692
]
ASF GitHub Bot commented on FLINK-10253:
Clark commented on issue #6839: [FL
Clark commented on issue #6839: [FLINK-10253] Run MetricQueryService with
lower priority
URL: https://github.com/apache/flink/pull/6839#issuecomment-429700148
Thanks for your contribution @yanghua . Please refer to the README in
flink-docs to regenerate the doc after your modify the op
[
https://issues.apache.org/jira/browse/FLINK-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng reassigned FLINK-5726:
--
Assignee: yuemeng
> Add the RocketMQ plugin for the Apache Flink
> ---
[
https://issues.apache.org/jira/browse/FLINK-10095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649655#comment-16649655
]
aitozi commented on FLINK-10095:
Hi, [~azagrebin]
I have a little question here:
If we u
[
https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649650#comment-16649650
]
ASF GitHub Bot commented on FLINK-10253:
yanghua commented on issue #6839: [FLIN
yanghua commented on issue #6839: [FLINK-10253] Run MetricQueryService with
lower priority
URL: https://github.com/apache/flink/pull/6839#issuecomment-429688635
The `DefaultDispatcherPrerequisites` is a final class now. So we can not
extend it. I implemented the `PriorityThreadsDispatcherP
[
https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10251:
Assignee: vinoyang
> Handle oversized response messages in AkkaRpcActor
> ---
[
https://issues.apache.org/jira/browse/FLINK-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649648#comment-16649648
]
vinoyang commented on FLINK-9607:
-
hi [~guibopan] , [~mingleizhang] has released this iss
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649645#comment-16649645
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua commented on issue #6703: [FLINK-9
yanghua commented on issue #6703: [FLINK-9697] Provide connector for Kafka 2.0.0
URL: https://github.com/apache/flink/pull/6703#issuecomment-429687222
> Can deserializer access ConsumerRecord to get headers and timestamp? Or it
will be PR on top this PR?
@alexeyt820 I agree with @alj
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649640#comment-16649640
]
ASF GitHub Bot commented on FLINK-9697:
---
yanghua commented on a change in pull requ
yanghua commented on a change in pull request #6703: [FLINK-9697] Provide
connector for Kafka 2.0.0
URL: https://github.com/apache/flink/pull/6703#discussion_r225022890
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/table/descriptors/KafkaV
[
https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649613#comment-16649613
]
ASF GitHub Bot commented on FLINK-6437:
---
yanghua commented on issue #6542: [FLINK-6
yanghua commented on issue #6542: [FLINK-6437][History Server] Move history
server configuration to a separate file
URL: https://github.com/apache/flink/pull/6542#issuecomment-429680654
@zentol OK, so what do you think is the correct way to handle it? How to
separate History Server? If you
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649532#comment-16649532
]
ASF GitHub Bot commented on FLINK-9697:
---
eliaslevy commented on a change in pull re
eliaslevy commented on a change in pull request #6703: [FLINK-9697] Provide
connector for Kafka 2.0.0
URL: https://github.com/apache/flink/pull/6703#discussion_r225008944
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/
[
https://issues.apache.org/jira/browse/FLINK-10544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-10544.
Resolution: Fixed
Fix Version/s: 1.5.5
1.6.2
1
[
https://issues.apache.org/jira/browse/FLINK-9990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui resolved FLINK-9990.
Resolution: Implemented
Implemented in 1.7.0 5dc360984143005f73b8f70f97ed6b1c2afd7dc3
> Add regexp
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649454#comment-16649454
]
ASF GitHub Bot commented on FLINK-9697:
---
aljoscha commented on issue #6703: [FLINK-
aljoscha commented on issue #6703: [FLINK-9697] Provide connector for Kafka
2.0.0
URL: https://github.com/apache/flink/pull/6703#issuecomment-429640076
@yanghua Which one needs discussion with me?
@alexeyt820 I would suggest to do that change on top of this PR. But we have
to move q
[
https://issues.apache.org/jira/browse/FLINK-10544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649435#comment-16649435
]
Chesnay Schepler commented on FLINK-10544:
--
master: bab4ec161b2119dbaa6188910ab
Chesnay Schepler created FLINK-10544:
Summary: Remove custom settings.xml for snapshot deployments
Key: FLINK-10544
URL: https://issues.apache.org/jira/browse/FLINK-10544
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649430#comment-16649430
]
ASF GitHub Bot commented on FLINK-9697:
---
alexeyt820 commented on issue #6703: [FLIN
alexeyt820 commented on issue #6703: [FLINK-9697] Provide connector for Kafka
2.0.0
URL: https://github.com/apache/flink/pull/6703#issuecomment-429635177
Can deserializer access ConsumerRecord to get headers and timestamp? Or it
will be PR on top this PR?
-
[
https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10253:
---
Labels: pull-request-available (was: )
> Run MetricQueryService with lower priority
> -
[
https://issues.apache.org/jira/browse/FLINK-10253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649364#comment-16649364
]
ASF GitHub Bot commented on FLINK-10253:
yanghua opened a new pull request #6839
yanghua opened a new pull request #6839: [FLINK-10253] Run MetricQueryService
with lower priority
URL: https://github.com/apache/flink/pull/6839
## What is the purpose of the change
*This pull request makes MetricQueryService run with lower priority*
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-10518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guibo Pan reassigned FLINK-10518:
-
Assignee: Guibo Pan
> Inefficient design in ContinuousFileMonitoringFunction
>
[
https://issues.apache.org/jira/browse/FLINK-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649354#comment-16649354
]
Guibo Pan commented on FLINK-9607:
--
[~mingleizhang] I wonder what the status of this iss
[
https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649327#comment-16649327
]
ouyangzhe edited comment on FLINK-10534 at 10/14/18 10:13 AM:
[
https://issues.apache.org/jira/browse/FLINK-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649327#comment-16649327
]
ouyangzhe commented on FLINK-10534:
---
[~gjy] , If I want to get job result back or ru
[
https://issues.apache.org/jira/browse/FLINK-10152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649319#comment-16649319
]
ASF GitHub Bot commented on FLINK-10152:
Guibo-Pan commented on issue #6773: [FL
Guibo-Pan commented on issue #6773: [FLINK-10152] [table] Add reverse function
in Table API and SQL
URL: https://github.com/apache/flink/pull/6773#issuecomment-429611382
@pnowojski Could you help review this PR? Thanks.
This
[
https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649311#comment-16649311
]
ASF GitHub Bot commented on FLINK-6437:
---
zentol commented on issue #6542: [FLINK-64
zentol commented on issue #6542: [FLINK-6437][History Server] Move history
server configuration to a separate file
URL: https://github.com/apache/flink/pull/6542#issuecomment-429609834
My opinion hasn't changed, I still don't think that it is worth it.
Separating the HistoryServer fr
Fabian Hueske created FLINK-10543:
-
Summary: Leverage efficient timer deletion in relational operators
Key: FLINK-10543
URL: https://issues.apache.org/jira/browse/FLINK-10543
Project: Flink
I
GJL closed pull request #4356: [FLINK-5486] Fix lacking of synchronization in
BucketingSink#handleRe…
URL: https://github.com/apache/flink/pull/4356
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649305#comment-16649305
]
ASF GitHub Bot commented on FLINK-5486:
---
GJL commented on issue #4356: [FLINK-5486]
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649306#comment-16649306
]
ASF GitHub Bot commented on FLINK-5486:
---
GJL closed pull request #4356: [FLINK-5486
GJL commented on issue #4356: [FLINK-5486] Fix lacking of synchronization in
BucketingSink#handleRe…
URL: https://github.com/apache/flink/pull/4356#issuecomment-429608448
I am closing this PR because
[FLINK-5486](https://issues.apache.org/jira/browse/FLINK-5486?focusedCommentId=16649304&pa
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-5486.
---
Resolution: Not A Problem
> Lack of synchronization in BucketingSink#handleRestoredBucketState()
> --
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16649304#comment-16649304
]
Gary Yao edited comment on FLINK-5486 at 10/14/18 9:02 AM:
---
Clo
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reopened FLINK-5486:
-
> Lack of synchronization in BucketingSink#handleRestoredBucketState()
>
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-5486.
---
Resolution: Not A Problem
Closed for the same reason as explained
[here|https://issues.apache.org/jira/brows
89 matches
Mail list logo
