[
https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenqiu Huang updated FLINK-12342:
--
Attachment: flink-1.6.png
flink-1.4.png
> Yarn Resource Manager Acquires Too
[
https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenqiu Huang updated FLINK-12342:
--
Attachment: Screen Shot 2019-04-29 at 12.06.23 AM.png
> Yarn Resource Manager Acquires Too
[
https://issues.apache.org/jira/browse/FLINK-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829603#comment-16829603
]
Dominik Wosiński commented on FLINK-12279:
--
AFAIK, it will provide same delivery guarantees as
[
https://issues.apache.org/jira/browse/FLINK-12367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Wosiński closed FLINK-12367.
Resolution: Invalid
> Create rich versions of functions for Scala
>
flinkbot commented on issue #8314: [FLINK-12365][table] Add stats related
catalog APIs
URL: https://github.com/apache/flink/pull/8314#issuecomment-487671263
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
[
https://issues.apache.org/jira/browse/FLINK-12312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao closed FLINK-12312.
Resolution: Fixed
1.9: 566d10d958d71fd113f8f7ecc08fa9b63a072919
> Remove CLI command for rescaling
>
xuefuz opened a new pull request #8314: [FLINK-12365][table] Add stats related
catalog APIs
URL: https://github.com/apache/flink/pull/8314
## What is the purpose of the change
Added stats related catalog APIs. Made table/column stats first-level meta
object in catalog.
asfgit closed pull request #8260: [FLINK-12312][runtime] Remove CLI command for
rescaling
URL: https://github.com/apache/flink/pull/8260
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-12312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-12312:
-
Fix Version/s: 1.9.0
> Remove CLI command for rescaling
>
>
>
bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database
related operations in GenericHiveMetastoreCatalog and setup
flink-connector-hive module
URL: https://github.com/apache/flink/pull/8205#issuecomment-487665834
@flinkbot attention @zentol
bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database
related operations in GenericHiveMetastoreCatalog and setup
flink-connector-hive module
URL: https://github.com/apache/flink/pull/8205#issuecomment-487665669
> Stephan pointed you in a good direction, we will have
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive]
Support database related operations in GenericHiveMetastoreCatalog and setup
flink-connector-hive module
URL: https://github.com/apache/flink/pull/8205#discussion_r279454577
##
File path:
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive]
Support database related operations in GenericHiveMetastoreCatalog and setup
flink-connector-hive module
URL: https://github.com/apache/flink/pull/8205#discussion_r279454577
##
File path:
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive]
Support database related operations in GenericHiveMetastoreCatalog and setup
flink-connector-hive module
URL: https://github.com/apache/flink/pull/8205#discussion_r279450999
##
File path:
zhijiangW commented on issue #8310: [FLINK-12331][network] Introduce
partition/gate setup to decouple task registration with NetworkEnvironment
URL: https://github.com/apache/flink/pull/8310#issuecomment-487657881
Thanks for reviews @azagrebin !
I think your suggestion of migrating the
zhijiangW commented on a change in pull request #8310: [FLINK-12331][network]
Introduce partition/gate setup to decouple task registration with
NetworkEnvironment
URL: https://github.com/apache/flink/pull/8310#discussion_r279447428
##
File path:
zhijiangW commented on a change in pull request #8310: [FLINK-12331][network]
Introduce partition/gate setup to decouple task registration with
NetworkEnvironment
URL: https://github.com/apache/flink/pull/8310#discussion_r279447428
##
File path:
zhijiangW commented on a change in pull request #8310: [FLINK-12331][network]
Introduce partition/gate setup to decouple task registration with
NetworkEnvironment
URL: https://github.com/apache/flink/pull/8310#discussion_r279446413
##
File path:
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive]
Support database related operations in GenericHiveMetastoreCatalog and setup
flink-connector-hive module
URL: https://github.com/apache/flink/pull/8205#discussion_r279444906
##
File path:
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive]
Support database related operations in GenericHiveMetastoreCatalog and setup
flink-connector-hive module
URL: https://github.com/apache/flink/pull/8205#discussion_r279444868
##
File path:
zhijiangW commented on a change in pull request #8310: [FLINK-12331][network]
Introduce partition/gate setup to decouple task registration with
NetworkEnvironment
URL: https://github.com/apache/flink/pull/8310#discussion_r279442622
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829427#comment-16829427
]
Rong Rong commented on FLINK-11921:
---
Closing to the end of this issue. Found out that one of the
hequn8128 edited a comment on issue #8230: [FLINK-10977][table] Add streaming
non-window FlatAggregate to Table API
URL: https://github.com/apache/flink/pull/8230#issuecomment-487645008
@sunjincheng121 Hi, Thank you very much for your review and great
suggestions. I think the pr has been
hequn8128 commented on issue #8230: [FLINK-10977][table] Add streaming
non-window FlatAggregate to Table API
URL: https://github.com/apache/flink/pull/8230#issuecomment-487645008
@sunjincheng121 Hi, Thank you very much for your review and great
suggestions. I think the pr improved a lot
hequn8128 commented on a change in pull request #8230: [FLINK-10977][table] Add
streaming non-window FlatAggregate to Table API
URL: https://github.com/apache/flink/pull/8230#discussion_r279434307
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-9787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829396#comment-16829396
]
Robert Metzger commented on FLINK-9787:
---
+1 to address this.
> Change
[
https://issues.apache.org/jira/browse/FLINK-12358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829395#comment-16829395
]
Yun Tang commented on FLINK-12358:
--
[~Zentol] Thanks for your suggestion, I would try to fix this
[
https://issues.apache.org/jira/browse/FLINK-10446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu resolved FLINK-10446.
Resolution: Won't Fix
> Use the "guava beta checker" plugin to keep off of @Beta API
>
[
https://issues.apache.org/jira/browse/FLINK-10446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829390#comment-16829390
]
Robert Metzger commented on FLINK-10446:
I'm proposing to close this Jira ticket, as it makes
[
https://issues.apache.org/jira/browse/FLINK-12353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829387#comment-16829387
]
Yun Tang commented on FLINK-12353:
--
[~Zentol] This sounds more reasonable, I would like to try to
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829386#comment-16829386
]
Rong Rong commented on FLINK-11935:
---
I think this issue should not block calcite upgrade, we can still
[
https://issues.apache.org/jira/browse/FLINK-12293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-12293.
--
Resolution: Cannot Reproduce
I'm closing this Jira ticket.
It doesn't explain the problem
flinkbot commented on issue #8313:
[FLINK-12184][coordinator]HistoryServerArchieFetcher incompatible with old
version
URL: https://github.com/apache/flink/pull/8313#issuecomment-487639936
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the
klion26 opened a new pull request #8313:
[FLINK-12184][coordinator]HistoryServerArchieFetcher incompatible with old
version
URL: https://github.com/apache/flink/pull/8313
## What is the purpose of the change
If we have old verison json files in history server, the
rmetzger commented on issue #8240: [FLINK-12293][docs, datastream]Fix some
comment typos in flink-streaming-java.
URL: https://github.com/apache/flink/pull/8240#issuecomment-487639163
Thank you for opening this PR to Flink. I would like to close this pull
request, without merging it, as
[
https://issues.apache.org/jira/browse/FLINK-10900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829381#comment-16829381
]
Seth Wiesman commented on FLINK-10900:
--
[~till.rohrmann] Is the universal Kafka connector still
azagrebin commented on a change in pull request #8310: [FLINK-12331][network]
Introduce partition/gate setup to decouple task registration with
NetworkEnvironment
URL: https://github.com/apache/flink/pull/8310#discussion_r279417805
##
File path:
azagrebin commented on a change in pull request #8310: [FLINK-12331][network]
Introduce partition/gate setup to decouple task registration with
NetworkEnvironment
URL: https://github.com/apache/flink/pull/8310#discussion_r279426797
##
File path:
azagrebin commented on a change in pull request #8310: [FLINK-12331][network]
Introduce partition/gate setup to decouple task registration with
NetworkEnvironment
URL: https://github.com/apache/flink/pull/8310#discussion_r279410838
##
File path:
azagrebin commented on a change in pull request #8310: [FLINK-12331][network]
Introduce partition/gate setup to decouple task registration with
NetworkEnvironment
URL: https://github.com/apache/flink/pull/8310#discussion_r279410097
##
File path:
azagrebin commented on a change in pull request #8310: [FLINK-12331][network]
Introduce partition/gate setup to decouple task registration with
NetworkEnvironment
URL: https://github.com/apache/flink/pull/8310#discussion_r279398673
##
File path:
flinkbot edited a comment on issue #8303: [FLINK-12343]add file replication
config for yarn configuration
URL: https://github.com/apache/flink/pull/8303#issuecomment-487385120
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
rmetzger commented on issue #8303: [FLINK-12343]add file replication config for
yarn configuration
URL: https://github.com/apache/flink/pull/8303#issuecomment-487632182
I tend to disagree. I think the problem is well defined, the configuration
parameter name is okay (not great) and the
[
https://issues.apache.org/jira/browse/FLINK-8640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8640.
---
Resolution: Fixed
Fix Version/s: 1.9.0
master:
zentol merged pull request #8271: [FLINK-8640][build][travis] Enable japicmp
on Java 9
URL: https://github.com/apache/flink/pull/8271
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/FLINK-12353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829352#comment-16829352
]
Chesnay Schepler commented on FLINK-12353:
--
This is one of those scripts that maybe shouldn't
walterddr commented on a change in pull request #8248: [FLINK-12309][JDBC]
JDBCOoutputFormat and JDBCAppendTableSink float behavior is not align
URL: https://github.com/apache/flink/pull/8248#discussion_r279415433
##
File path:
walterddr commented on a change in pull request #8248: [FLINK-12309][JDBC]
JDBCOoutputFormat and JDBCAppendTableSink float behavior is not align
URL: https://github.com/apache/flink/pull/8248#discussion_r279414601
##
File path:
walterddr commented on a change in pull request #8248: [FLINK-12309][JDBC]
JDBCOoutputFormat and JDBCAppendTableSink float behavior is not align
URL: https://github.com/apache/flink/pull/8248#discussion_r279414202
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-12202:
-
Component/s: Runtime / Metrics
> Consider introducing batch metric register in
tillrohrmann closed pull request #8227: [FLINK-12180][Tests] Port
ExecutionVertexCancelTest to new codebase
URL: https://github.com/apache/flink/pull/8227
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/FLINK-12180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-12180.
---
Resolution: Fixed
Fixed via 7054a8b05738fb43ca856849299263bf4f584067
> Port
[
https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829324#comment-16829324
]
Robert Metzger commented on FLINK-12343:
The PR proposes to set {{yarn.file-replication}}, which
wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink]
Support Temporal Table Join in blink planner and runtime
URL: https://github.com/apache/flink/pull/8302#discussion_r279395163
##
File path:
wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink]
Support Temporal Table Join in blink planner and runtime
URL: https://github.com/apache/flink/pull/8302#discussion_r279395068
##
File path:
flinkbot edited a comment on issue #8290: [FLINK-12070] [network] Implement new
bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#issuecomment-487296924
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
flinkbot edited a comment on issue #8300: [FLINK-11638][docs-zh] Translate
Savepoints page into Chinese
URL: https://github.com/apache/flink/pull/8300#issuecomment-487363436
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
rmetzger commented on issue #8290: [FLINK-12070] [network] Implement new
bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#issuecomment-487606252
@flinkbot approve description
This is an automated
flinkbot edited a comment on issue #8305: [hotfix] regenerate rest-docs to
latest code
URL: https://github.com/apache/flink/pull/8305#issuecomment-487389173
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
rmetzger commented on issue #8300: [FLINK-11638][docs-zh] Translate Savepoints
page into Chinese
URL: https://github.com/apache/flink/pull/8300#issuecomment-487605966
@flinkbot approve description
This is an automated
rmetzger commented on issue #8305: [hotfix] regenerate rest-docs to latest code
URL: https://github.com/apache/flink/pull/8305#issuecomment-487605589
@flinkbot attention @zentol
@flinkbot approve description
This is an
flinkbot edited a comment on issue #8307: [FLINK-12359][metrics][tests] Harden
SystemResourcesMetricsITCase
URL: https://github.com/apache/flink/pull/8307#issuecomment-487392775
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
rmetzger commented on issue #8307: [FLINK-12359][metrics][tests] Harden
SystemResourcesMetricsITCase
URL: https://github.com/apache/flink/pull/8307#issuecomment-487604812
@flinkbot approve description consensus
This is an
flinkbot edited a comment on issue #8311: [FLINK-10976][table] Add Aggregate
operator to Table API
URL: https://github.com/apache/flink/pull/8311#issuecomment-487553255
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
flinkbot edited a comment on issue #8117: [FLINK-12115] [filesystems]: Add
support for AzureFS
URL: https://github.com/apache/flink/pull/8117#issuecomment-480408700
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
rmetzger commented on issue #8311: [FLINK-10976][table] Add Aggregate operator
to Table API
URL: https://github.com/apache/flink/pull/8311#issuecomment-487604013
@flinkbot approve description
This is an automated message
rmetzger commented on issue #8117: [FLINK-12115] [filesystems]: Add support for
AzureFS
URL: https://github.com/apache/flink/pull/8117#issuecomment-487603641
@flinkbot approve description
This is an automated message from
wuchong commented on a change in pull request #8302: [FLINK-12269][table-blink]
Support Temporal Table Join in blink planner and runtime
URL: https://github.com/apache/flink/pull/8302#discussion_r279386668
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829298#comment-16829298
]
Jark Wu commented on FLINK-12351:
-
[~rmetzger] Thanks for the reminder.
> AsyncWaitOperator should
[
https://issues.apache.org/jira/browse/FLINK-12367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dominik Wosiński updated FLINK-12367:
-
Description:
Currently for some of the functions like for example _AsyncFunctions_ have
XuQianJin-Stars commented on issue #8300: [FLINK-11638][docs-zh] Translate
Savepoints page into Chinese
URL: https://github.com/apache/flink/pull/8300#issuecomment-487597420
hi @Leev Thank you for review this PR. I have modified it.
Dominik Wosiński created FLINK-12367:
Summary: Create rich versions of functions for Scala
Key: FLINK-12367
URL: https://issues.apache.org/jira/browse/FLINK-12367
Project: Flink
Issue
flinkbot commented on issue #8312: [FLINK-12366][table] Clean up Catalog APIs
to make them more consiste…
URL: https://github.com/apache/flink/pull/8312#issuecomment-487587486
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
azagrebin commented on a change in pull request #8226: [FLINK-12181][Tests]
Port ExecutionGraphRestartTest to new codebase
URL: https://github.com/apache/flink/pull/8226#discussion_r279341488
##
File path:
azagrebin commented on a change in pull request #8226: [FLINK-12181][Tests]
Port ExecutionGraphRestartTest to new codebase
URL: https://github.com/apache/flink/pull/8226#discussion_r279342636
##
File path:
azagrebin commented on a change in pull request #8226: [FLINK-12181][Tests]
Port ExecutionGraphRestartTest to new codebase
URL: https://github.com/apache/flink/pull/8226#discussion_r279345597
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12366:
---
Labels: pull-request-available (was: )
> Clean up Catalog APIs to make them more
xuefuz opened a new pull request #8312: [FLINK-12366][table] Clean up Catalog
APIs to make them more consiste…
URL: https://github.com/apache/flink/pull/8312
…nt and coherent
## What is the purpose of the change
Clean up existing catalog APIs to make them more
[
https://issues.apache.org/jira/browse/FLINK-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829273#comment-16829273
]
Andrey Zagrebin commented on FLINK-12203:
-
Hey [~rmetzger], thanks for correction. I will try to
becketqin commented on a change in pull request #7677: [FLINK-11249][kafka] Add
migration tests for FlinkKafkaProdcuer and FlinkKafkaProducer011
URL: https://github.com/apache/flink/pull/7677#discussion_r279369052
##
File path:
Xuefu Zhang created FLINK-12366:
---
Summary: Clean up Catalog APIs to make them more consistent and
coherent
Key: FLINK-12366
URL: https://issues.apache.org/jira/browse/FLINK-12366
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-12365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuefu Zhang updated FLINK-12365:
Description: This is to support (table and column) stats for
table/partition with related to
Xuefu Zhang created FLINK-12365:
---
Summary: Add stats related catalog APIs
Key: FLINK-12365
URL: https://issues.apache.org/jira/browse/FLINK-12365
Project: Flink
Issue Type: Sub-task
fhueske commented on issue #8034: [FLINK-11733] Provide HadoopMapFunction for
org.apache.hadoop.mapreduce.Mapper
URL: https://github.com/apache/flink/pull/8034#issuecomment-487579573
Sorry, I was out for a few days vacation. Will continue with my review soon.
Thanks, Fabian
fhueske commented on issue #8064: [FLINK-7244] Add parquet table source
URL: https://github.com/apache/flink/pull/8064#issuecomment-487579379
Sorry, I was out for a few days vacation. Will continue with my review soon.
Thanks, Fabian
[
https://issues.apache.org/jira/browse/FLINK-12293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12293:
---
Component/s: API / DataStream
> Fix some comment typos in flink-streaming-java.
>
[
https://issues.apache.org/jira/browse/FLINK-12352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12352:
---
Component/s: Table SQL / API
> [FLIP-36] [Phase 1] Support cache() / invalidateCache() in
[
https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829245#comment-16829245
]
Robert Metzger commented on FLINK-12351:
Hey [~jark], thanks a lot for opening a ticket in the
[
https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12351:
---
Component/s: API / DataStream
> AsyncWaitOperator should deep copy StreamElement when
[
https://issues.apache.org/jira/browse/FLINK-12338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12338:
---
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
> Update Apache Avro test to
[
https://issues.apache.org/jira/browse/FLINK-12364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12364:
---
Component/s: Runtime / Checkpointing
> Introduce a CheckpointFailureManager to centralized
[
https://issues.apache.org/jira/browse/FLINK-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829244#comment-16829244
]
Robert Metzger commented on FLINK-12279:
I'm not sure if we want to have such a connector in
[
https://issues.apache.org/jira/browse/FLINK-12299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12299:
---
Component/s: Runtime / Coordination
> ExecutionConfig#setAutoWatermarkInterval should check
[
https://issues.apache.org/jira/browse/FLINK-12279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12279:
---
Component/s: Connectors / Common
> Create source to allow streaming data from websocket.
>
[
https://issues.apache.org/jira/browse/FLINK-12225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829240#comment-16829240
]
Robert Metzger commented on FLINK-12225:
Hey [~Fokko], thanks a lot for opening a ticket in the
[
https://issues.apache.org/jira/browse/FLINK-12250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12250:
---
Component/s: Connectors / FileSystem
> Rewrite assembleNewPartPath to let it return a new
[
https://issues.apache.org/jira/browse/FLINK-12225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12225:
---
Component/s: Connectors / FileSystem
> Simplify the interface of the PartFileWriter
>
[
https://issues.apache.org/jira/browse/FLINK-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829239#comment-16829239
]
Robert Metzger commented on FLINK-12203:
Hey [~azagrebin], thanks a lot for opening a ticket in
[
https://issues.apache.org/jira/browse/FLINK-12203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12203:
---
Component/s: Runtime / Network
> Refactor ResultPartitionManager to break tie with Task
>
[
https://issues.apache.org/jira/browse/FLINK-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16829232#comment-16829232
]
Yun Tang commented on FLINK-12333:
--
[~till.rohrmann] I have already refactored
101 - 200 of 344 matches
Mail list logo