[
https://issues.apache.org/jira/browse/FLINK-11608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shengjk1 reassigned FLINK-11608:
Assignee: shengjk1
> Translate the "Local Setup Tutorial" page into Chinese
> ---
carp84 commented on a change in pull request #7674: [FLINK-10043] [State
Backends] Refactor RocksDBKeyedStateBackend object
construction/initialization/restore code
URL: https://github.com/apache/flink/pull/7674#discussion_r256719361
##
File path:
flink-runtime/src/main/java/org/a
[
https://issues.apache.org/jira/browse/FLINK-11159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767938#comment-16767938
]
vinoyang commented on FLINK-11159:
--
Just finished my vacation and saw an improved desig
carp84 commented on a change in pull request #7674: [FLINK-10043] [State
Backends] Refactor RocksDBKeyedStateBackend object
construction/initialization/restore code
URL: https://github.com/apache/flink/pull/7674#discussion_r256718752
##
File path:
flink-state-backends/flink-stateb
[
https://issues.apache.org/jira/browse/FLINK-11607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-11607:
--
Assignee: Benchao Li
> Translate the "DataStream API Tutorial" page into Chinese
> --
Jark Wu created FLINK-11614:
---
Summary: Translate the "Configuring Dependencies" page into Chinese
Key: FLINK-11614
URL: https://issues.apache.org/jira/browse/FLINK-11614
Project: Flink
Issue Type:
Jark Wu created FLINK-11605:
---
Summary: Translate the "Dataflow Programming Model" page into
Chinese
Key: FLINK-11605
URL: https://issues.apache.org/jira/browse/FLINK-11605
Project: Flink
Issue Typ
[
https://issues.apache.org/jira/browse/FLINK-11610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shenlei reassigned FLINK-11610:
---
Assignee: shenlei
> Translate the "Examples" page into Chinese
> --
[
https://issues.apache.org/jira/browse/FLINK-11605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xueyu reassigned FLINK-11605:
-
Assignee: xueyu
> Translate the "Dataflow Programming Model" page into Chinese
> --
Jark Wu created FLINK-11613:
---
Summary: Translate the "Project Template for Scala" page into
Chinese
Key: FLINK-11613
URL: https://issues.apache.org/jira/browse/FLINK-11613
Project: Flink
Issue Typ
Jark Wu created FLINK-11608:
---
Summary: Translate the "Local Setup Tutorial" page into Chinese
Key: FLINK-11608
URL: https://issues.apache.org/jira/browse/FLINK-11608
Project: Flink
Issue Type: Sub-
Jark Wu created FLINK-11612:
---
Summary: Translate the "Project Template for Java" page into
Chinese
Key: FLINK-11612
URL: https://issues.apache.org/jira/browse/FLINK-11612
Project: Flink
Issue Type
Jark Wu created FLINK-11611:
---
Summary: Translate the "Batch Examples" page into Chinese
Key: FLINK-11611
URL: https://issues.apache.org/jira/browse/FLINK-11611
Project: Flink
Issue Type: Sub-task
Jark Wu created FLINK-11607:
---
Summary: Translate the "DataStream API Tutorial" page into Chinese
Key: FLINK-11607
URL: https://issues.apache.org/jira/browse/FLINK-11607
Project: Flink
Issue Type: S
Jark Wu created FLINK-11610:
---
Summary: Translate the "Examples" page into Chinese
Key: FLINK-11610
URL: https://issues.apache.org/jira/browse/FLINK-11610
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-11608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-11608:
Description:
The page url is
https://ci.apache.org/projects/flink/flink-docs-master/tutorials/local_setup
Jark Wu created FLINK-11609:
---
Summary: Translate the "Running Flink on Windows" page into Chinese
Key: FLINK-11609
URL: https://issues.apache.org/jira/browse/FLINK-11609
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-11055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767922#comment-16767922
]
vinoyang commented on FLINK-11055:
--
Hi [~galenwarren] I think your proposal is valuable
[
https://issues.apache.org/jira/browse/FLINK-11606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huadong Sun reassigned FLINK-11606:
---
Assignee: Huadong Sun
> Translate the "Distributed Runtime Environment" page into Chinese
>
Jark Wu created FLINK-11606:
---
Summary: Translate the "Distributed Runtime Environment" page into
Chinese
Key: FLINK-11606
URL: https://issues.apache.org/jira/browse/FLINK-11606
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksei Izmalkin closed FLINK-10418.
Resolution: Won't Fix
> Add COTH math function supported in Table API and SQL
> --
[
https://issues.apache.org/jira/browse/FLINK-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767910#comment-16767910
]
Aleksei Izmalkin commented on FLINK-10472:
--
The PR is closed. So I close the JI
[
https://issues.apache.org/jira/browse/FLINK-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767911#comment-16767911
]
Aleksei Izmalkin commented on FLINK-10418:
--
The PR is closed. So I close the JI
[
https://issues.apache.org/jira/browse/FLINK-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksei Izmalkin reopened FLINK-10472:
--
> Add CBRT math function supported in Table API and SQL
>
[
https://issues.apache.org/jira/browse/FLINK-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksei Izmalkin reopened FLINK-10418:
--
> Add COTH math function supported in Table API and SQL
>
[
https://issues.apache.org/jira/browse/FLINK-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksei Izmalkin closed FLINK-10472.
Resolution: Won't Fix
> Add CBRT math function supported in Table API and SQL
> --
[
https://issues.apache.org/jira/browse/FLINK-10418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksei Izmalkin closed FLINK-10418.
Resolution: Fixed
> Add COTH math function supported in Table API and SQL
> --
[
https://issues.apache.org/jira/browse/FLINK-10472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aleksei Izmalkin closed FLINK-10472.
Resolution: Fixed
> Add CBRT math function supported in Table API and SQL
> --
igalshilman edited a comment on issue #7695: [FLINK-11591][core] Support legacy
TypeSerializerSnapshot transformations
URL: https://github.com/apache/flink/pull/7695#issuecomment-463507844
Thanks for the review @tzulitai .
Th
igalshilman commented on issue #7695: [FLINK-11591][core] Support legacy
TypeSerializerSnapshot transformations
URL: https://github.com/apache/flink/pull/7695#issuecomment-463507844
Thanks for the review @tzulita.
This is an
zhijiangW commented on issue #7593: [FLINK-11441][network] Remove the schedule
mode property from RPDD to TDD
URL: https://github.com/apache/flink/pull/7593#issuecomment-463504624
Considering future extending schedule module which might result in different
`sendScheduleOrUpdateConsumers` f
zhijiangW closed pull request #7593: [FLINK-11441][network] Remove the schedule
mode property from RPDD to TDD
URL: https://github.com/apache/flink/pull/7593
This is an automated message from the Apache Git Service.
To respo
[
https://issues.apache.org/jira/browse/FLINK-11604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11604:
---
Labels: pull-request-available (was: )
> Extend the necessary methods in ResultPartitionWri
[
https://issues.apache.org/jira/browse/FLINK-11567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767892#comment-16767892
]
xulinjie commented on FLINK-11567:
--
Hello, would you mind rerecognising the issue?
> T
flinkbot commented on issue #7704: [FLINK-11604][network] Extend the necessary
methods in ResultPartitionWriter interface
URL: https://github.com/apache/flink/pull/7704#issuecomment-463504080
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the comm
zhijiangW opened a new pull request #7704: [FLINK-11604][network] Extend the
necessary methods in ResultPartitionWriter interface
URL: https://github.com/apache/flink/pull/7704
## What is the purpose of the change
*This is a preparation work for future creating `ResultPartitionWriter
flinkbot commented on issue #7703: [FLINK-11589][Security] Service provider for
security module and context discovery
URL: https://github.com/apache/flink/pull/7703#issuecomment-463486243
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the communit
[
https://issues.apache.org/jira/browse/FLINK-11589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11589:
---
Labels: pull-request-available (was: )
> Introduce service provider pattern for user to dyn
walterddr opened a new pull request #7703: [FLINK-11589][Security] Service
provider for security module and context discovery
URL: https://github.com/apache/flink/pull/7703
## What is the purpose of the change
This PR refactors `SecurityUtils.class` in `flink-runtime` and replace wit
flinkbot edited a comment on issue #7695: [FLINK-11591][core] Support legacy
TypeSerializerSnapshot transformations
URL: https://github.com/apache/flink/pull/7695#issuecomment-463298582
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
tzulitai commented on a change in pull request #7695: [FLINK-11591][core]
Support legacy TypeSerializerSnapshot transformations
URL: https://github.com/apache/flink/pull/7695#discussion_r256686727
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/LegacySe
tzulitai commented on a change in pull request #7695: [FLINK-11591][core]
Support legacy TypeSerializerSnapshot transformations
URL: https://github.com/apache/flink/pull/7695#discussion_r256686830
##
File path:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/shared
tzulitai commented on issue #7695: [FLINK-11591][core] Support legacy
TypeSerializerSnapshot transformations
URL: https://github.com/apache/flink/pull/7695#issuecomment-463484676
@flinkbot approve quality
@flinkbot approve architecture
---
tzulitai commented on a change in pull request #7695: [FLINK-11591][core]
Support legacy TypeSerializerSnapshot transformations
URL: https://github.com/apache/flink/pull/7695#discussion_r256686616
##
File path:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/Composit
becketqin commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r256687206
##
File path:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/stre
flinkbot commented on issue #7702: [FLINK-11088][Security][YARN] Allow YARN to
discover pre-installed keytab files
URL: https://github.com/apache/flink/pull/7702#issuecomment-463484443
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
becketqin commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r256686663
##
File path:
flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/stre
walterddr opened a new pull request #7702: [FLINK-11088][Security][YARN] Allow
YARN to discover pre-installed keytab files
URL: https://github.com/apache/flink/pull/7702
## What is the purpose of the change
* This PR introduces two new configuration keys in the YARN configuration to
[
https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11088:
---
Labels: pull-request-available (was: )
> Allow pre-install Kerberos authentication keytab d
[
https://issues.apache.org/jira/browse/FLINK-11589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong updated FLINK-11589:
--
Description:
Currently there are only 3 security modules in Flink - Hadoop, Zookeeper and
JaaS, all o
flinkbot edited a comment on issue #7695: [FLINK-11591][core] Support legacy
TypeSerializerSnapshot transformations
URL: https://github.com/apache/flink/pull/7695#issuecomment-463298582
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
tzulitai commented on issue #7695: [FLINK-11591][core] Support legacy
TypeSerializerSnapshot transformations
URL: https://github.com/apache/flink/pull/7695#issuecomment-463479601
@flinkbot approve description
@flinkbot approve consensus
--
carp84 commented on a change in pull request #7674: [FLINK-10043] [State
Backends] Refactor RocksDBKeyedStateBackend object
construction/initialization/restore code
URL: https://github.com/apache/flink/pull/7674#discussion_r256683639
##
File path:
flink-state-backends/flink-stateb
zhijiang created FLINK-11604:
Summary: Extend the necessary methods in ResultPartitionWriter
interface
Key: FLINK-11604
URL: https://issues.apache.org/jira/browse/FLINK-11604
Project: Flink
Issu
carp84 commented on a change in pull request #7674: [FLINK-10043] [State
Backends] Refactor RocksDBKeyedStateBackend object
construction/initialization/restore code
URL: https://github.com/apache/flink/pull/7674#discussion_r256681305
##
File path:
flink-state-backends/flink-stateb
carp84 commented on a change in pull request #7674: [FLINK-10043] [State
Backends] Refactor RocksDBKeyedStateBackend object
construction/initialization/restore code
URL: https://github.com/apache/flink/pull/7674#discussion_r256681092
##
File path:
flink-streaming-java/src/main/jav
carp84 commented on a change in pull request #7674: [FLINK-10043] [State
Backends] Refactor RocksDBKeyedStateBackend object
construction/initialization/restore code
URL: https://github.com/apache/flink/pull/7674#discussion_r256681007
##
File path:
flink-state-backends/flink-stateb
carp84 commented on a change in pull request #7674: [FLINK-10043] [State
Backends] Refactor RocksDBKeyedStateBackend object
construction/initialization/restore code
URL: https://github.com/apache/flink/pull/7674#discussion_r256675562
##
File path:
flink-streaming-java/src/main/jav
carp84 commented on a change in pull request #7674: [FLINK-10043] [State
Backends] Refactor RocksDBKeyedStateBackend object
construction/initialization/restore code
URL: https://github.com/apache/flink/pull/7674#discussion_r256675319
##
File path:
flink-runtime/src/main/java/org/a
wujinhu commented on issue #7599: [FLINK-11442] upgrade oss sdk version
URL: https://github.com/apache/flink/pull/7599#issuecomment-463467815
@StefanRRichter Please help to review this PR, thanks :)
This is an automated messag
FaxianZhao commented on issue #7675: [FLINK-8297] [flink-rocksdb] A plan store
elements of ListState as multiple key-values in rocksdb
URL: https://github.com/apache/flink/pull/7675#issuecomment-463467316
@klion26 thanks for your help. It looks good to me.
-
[
https://issues.apache.org/jira/browse/FLINK-9700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
leesf closed FLINK-9700.
Resolution: Fixed
> Document FlinkKafkaProducer behaviour for Kafka versions > 0.11
> -
[
https://issues.apache.org/jira/browse/FLINK-11430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767800#comment-16767800
]
leesf commented on FLINK-11430:
---
[~sinadoom], hi sina, it seems all right with spaces in A
liu-zhaokun commented on issue #7257: [FLINK-11089]Log filecache directory
removed messages
URL: https://github.com/apache/flink/pull/7257#issuecomment-463450318
@rmetzger Thanks for your reply.I have update the patch,could help me to
review it?
---
[
https://issues.apache.org/jira/browse/FLINK-11334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767771#comment-16767771
]
Congxian Qiu commented on FLINK-11334:
--
Hi, [~kisimple], What's the status of this
[
https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chunhui Shi updated FLINK-11421:
Summary: Add compilation options to allow compiling generated code with JDK
compiler (was: Provi
[
https://issues.apache.org/jira/browse/FLINK-11601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-11601:
-
Summary: Remove legacy JobManagerGateway (was: Remove legacy
AkkaJobManagerGateway)
> Remove legacy Jo
TisonKun created FLINK-11603:
Summary: Ported the MetricQueryService to the new RpcEndpoint
Key: FLINK-11603
URL: https://issues.apache.org/jira/browse/FLINK-11603
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-11603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-11603:
-
Summary: Port the MetricQueryService to the new RpcEndpoint (was: Ported
the MetricQueryService to the
[
https://issues.apache.org/jira/browse/FLINK-11602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11602:
---
Labels: pull-request-available (was: )
> Remove legacy AkkaJobManagerRetriever
> --
flinkbot commented on issue #7701: [FLINK-11602] Remove legacy
AkkaJobManagerRetriever
URL: https://github.com/apache/flink/pull/7701#issuecomment-463426863
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull reques
[
https://issues.apache.org/jira/browse/FLINK-10495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-10495.
---
Resolution: Won't Fix
The master code is changed, and the PR is closed. So I close the JIRA.
> Add
TisonKun opened a new pull request #7701: [FLINK-11602] Remove legacy
AkkaJobManagerRetriever
URL: https://github.com/apache/flink/pull/7701
## What is the purpose of the change
Remove legacy `AkkaJobManagerRetriever`
## Verifying this change
This change is a trivial re
TisonKun created FLINK-11602:
Summary: Remove legacy AkkaJobManagerRetriever
Key: FLINK-11602
URL: https://issues.apache.org/jira/browse/FLINK-11602
Project: Flink
Issue Type: Sub-task
Affect
sunjincheng121 commented on issue #6797: [FLINK-10495] [table] Add HYPOT math
function supported in Table API and SQL
URL: https://github.com/apache/flink/pull/6797#issuecomment-463426141
Thanks for check the code and close the PR. @aai95
--
TisonKun created FLINK-11601:
Summary: Remove legacy AkkaJobManagerGateway
Key: FLINK-11601
URL: https://issues.apache.org/jira/browse/FLINK-11601
Project: Flink
Issue Type: Sub-task
Co
TisonKun created FLINK-11600:
Summary: Remove legacy JobListeningContext
Key: FLINK-11600
URL: https://issues.apache.org/jira/browse/FLINK-11600
Project: Flink
Issue Type: Sub-task
Comp
TisonKun created FLINK-11599:
Summary: Remove legacy JobClientActor
Key: FLINK-11599
URL: https://issues.apache.org/jira/browse/FLINK-11599
Project: Flink
Issue Type: Sub-task
Component
TisonKun created FLINK-11598:
Summary: Remove legacy JobSubmissionClientActor
Key: FLINK-11598
URL: https://issues.apache.org/jira/browse/FLINK-11598
Project: Flink
Issue Type: Sub-task
TisonKun opened a new pull request #7700: [FILNK-11597][test] Remove legacy
JobManagerActorTestUtils
URL: https://github.com/apache/flink/pull/7700
## What is the purpose of the change
Remove legacy `JobManagerActorTestUtils`
## Verifying this change
This change is a tr
flinkbot commented on issue #7700: [FILNK-11597][test] Remove legacy
JobManagerActorTestUtils
URL: https://github.com/apache/flink/pull/7700#issuecomment-463419212
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
TisonKun created FLINK-11597:
Summary: Remove legacy JobManagerActorTestUtils
Key: FLINK-11597
URL: https://issues.apache.org/jira/browse/FLINK-11597
Project: Flink
Issue Type: Sub-task
flinkbot commented on issue #7699: [hotfix] Remove legacy ResourceManagerRunner
URL: https://github.com/apache/flink/pull/7699#issuecomment-463418201
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 wi
TisonKun opened a new pull request #7699: [hotfix] Remove legacy
ResourceManagerRunner
URL: https://github.com/apache/flink/pull/7699
## What is the purpose of the change
Now a ResourceManager use FatalErrorHandler implementation in
ClusterEntrypoint. No use point of
`ResourceMa
[
https://issues.apache.org/jira/browse/FLINK-11596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11596:
---
Labels: pull-request-available (was: )
> Check & port ResourceManagerTest to new code base
flinkbot commented on issue #7698: [FLINK-11596][test] Remove legacy
ResourceManagerTest
URL: https://github.com/apache/flink/pull/7698#issuecomment-463410663
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull requ
TisonKun opened a new pull request #7698: [FLINK-11596][test] Remove legacy
ResourceManagerTest
URL: https://github.com/apache/flink/pull/7698
## What is the purpose of the change
Remove legacy `ResourceManagerTest`
`testJobManagerRegistrationAndReconciliation` → Invalid, now
[
https://issues.apache.org/jira/browse/FLINK-11596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun reassigned FLINK-11596:
Assignee: TisonKun
> Check & port ResourceManagerTest to new code base
>
TisonKun created FLINK-11596:
Summary: Check & port ResourceManagerTest to new code base
Key: FLINK-11596
URL: https://issues.apache.org/jira/browse/FLINK-11596
Project: Flink
Issue Type: Sub-tas
Calvin Han created FLINK-11595:
--
Summary: Gelly addEdge in certain circumstances still include
duplicate vertices.
Key: FLINK-11595
URL: https://issues.apache.org/jira/browse/FLINK-11595
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Calvin Han updated FLINK-11595:
---
Summary: Gelly's addEdge() in certain circumstances still includes
duplicate vertices. (was: Gelly
[
https://issues.apache.org/jira/browse/FLINK-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16767618#comment-16767618
]
Hao Dang commented on FLINK-6966:
-
Hi [~hequn8128],
Understand this work didn't start as
azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle]
Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor
URL: https://github.com/apache/flink/pull/7631#discussion_r256595763
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime
azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle]
Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor
URL: https://github.com/apache/flink/pull/7631#discussion_r256598926
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime
azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle]
Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor
URL: https://github.com/apache/flink/pull/7631#discussion_r256595763
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime
azagrebin commented on a change in pull request #7631: [FLINK-11391][shuffle]
Introduce PartitionShuffleDescriptor and ShuffleDeploymentDescriptor
URL: https://github.com/apache/flink/pull/7631#discussion_r256595763
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime
flinkbot commented on issue #7697: [FLINK-11578][tests] Port
BackPressureStatsTrackerImplITCase to new code base
URL: https://github.com/apache/flink/pull/7697#issuecomment-463356048
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
GJL opened a new pull request #7697: [FLINK-11578][tests] Port
BackPressureStatsTrackerImplITCase to new code base
URL: https://github.com/apache/flink/pull/7697
## What is the purpose of the change
*Port BackPressureStatsTrackerImplITCase to new code base*
## Brief change log
flinkbot commented on issue #7696: [FLINK-11588][core] Migrating the
CopyableValueSerializer
URL: https://github.com/apache/flink/pull/7696#issuecomment-463303562
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-11588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11588:
---
Labels: pull-request-available (was: )
> Migrate CopyableValueSerializer to use new seriali
1 - 100 of 284 matches
Mail list logo