lamber-ken commented on issue #7296: [hotfix][web] fix the desc about restart
strategy in web
URL: https://github.com/apache/flink/pull/7296#issuecomment-447544430
hi，@GJL，cc，thanks
This is an automated message from the Apach
[
https://issues.apache.org/jira/browse/FLINK-6?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-6:
---
Labels: pull-request-available (was: )
> Overwrite outdated in-progress files in StreamingF
kl0u opened a new pull request #7313: [FLINK-6][fs-connector] Removed
randomness from HDFS and Local fs writers.
URL: https://github.com/apache/flink/pull/7313
## What is the purpose of the change
As described in the related jira, this PR targets the in-progress files left
after
Jiayong Mo created FLINK-11169:
--
Summary: [hotfix][runtime] fix the problem of not being reloaded
for jobmanager's log after clicking the refresh button in web ui
Key: FLINK-11169
URL: https://issues.apache.org/jira
[
https://issues.apache.org/jira/browse/FLINK-11169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiayong Mo updated FLINK-11169:
---
Summary: fix the problem of not being reloaded for jobmanager's log after
clicking the refresh butto
[
https://issues.apache.org/jira/browse/FLINK-11169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11169:
---
Labels: pull-request-available (was: )
> [hotfix][runtime] fix the problem of not being re
AlphaGarden opened a new pull request #7312: [FLINK-11169][runtime] fix the
problem of not being reloaded for jobmanager's…
URL: https://github.com/apache/flink/pull/7312
## What is the purpose of the change
*In the Flink web UI page, we can access the log of jobmanager from the tab
[
https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
boshu Zheng reassigned FLINK-9717:
--
Assignee: (was: boshu Zheng)
> Flush state of one side of the join if other side is bounde
[
https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722013#comment-16722013
]
boshu Zheng commented on FLINK-9717:
Just a little thought on it to share. When consi
[
https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16722001#comment-16722001
]
boshu Zheng commented on FLINK-9717:
Hi [~pnowojski], thanks for your comment, I have
[
https://issues.apache.org/jira/browse/FLINK-11166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tony Xintong Song reassigned FLINK-11166:
-
Assignee: Tony Xintong Song
> Slot Placement Constraint
> -
[
https://issues.apache.org/jira/browse/FLINK-10590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721978#comment-16721978
]
bupt_ljy commented on FLINK-10590:
--
It seems that we need to support the group patterns
[
https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721857#comment-16721857
]
Rong Rong commented on FLINK-11088:
---
I further dig into the details on the document on
[
https://issues.apache.org/jira/browse/FLINK-11088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721857#comment-16721857
]
Rong Rong edited comment on FLINK-11088 at 12/14/18 11:03 PM:
TisonKun commented on a change in pull request #7302: [FLINK-11156] [tests]
Reconcile powermock with JDK 9
URL: https://github.com/apache/flink/pull/7302#discussion_r241909198
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpoint
zentol commented on a change in pull request #7302: [FLINK-11156] [tests]
Reconcile powermock with JDK 9
URL: https://github.com/apache/flink/pull/7302#discussion_r241907414
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointSt
zentol commented on a change in pull request #7302: [FLINK-11156] [tests]
Reconcile powermock with JDK 9
URL: https://github.com/apache/flink/pull/7302#discussion_r241906430
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java
zentol commented on a change in pull request #7302: [FLINK-11156] [tests]
Reconcile powermock with JDK 9
URL: https://github.com/apache/flink/pull/7302#discussion_r241907196
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointSt
TisonKun commented on a change in pull request #7302: [FLINK-11156] [tests]
Reconcile powermock with JDK 9
URL: https://github.com/apache/flink/pull/7302#discussion_r241907057
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpoint
TisonKun commented on issue #7302: [FLINK-11156] [tests] Reconcile powermock
with JDK 9
URL: https://github.com/apache/flink/pull/7302#issuecomment-447494914
I've updated the pull request, and the final usage of mockito is to mock
CuratorFramework. I'd like to listen to @tillrohrmann to le
TisonKun commented on issue #7302: [FLINK-11156] [tests] Reconcile powermock
with JDK 9
URL: https://github.com/apache/flink/pull/7302#issuecomment-447485963
@GJL I can do it with a testing constructor. If it is the style that Flink
would be happy with, I will send a commit for it.
--
[
https://issues.apache.org/jira/browse/FLINK-11134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721778#comment-16721778
]
Matt Dailey commented on FLINK-11134:
-
This also affects Flink 1.5.5. I got a simil
StefanRRichter commented on issue #7288: [FLINK-9702] Improvement in
(de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#issuecomment-447403243
@azagrebin Thanks for the review. I addressed most comments as suggested.
Will merge once travis
StefanRRichter commented on a change in pull request #7288: [FLINK-9702]
Improvement in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241839041
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main
tweise commented on issue #7249: [FLINK-11048] Ability to programmatically
execute streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#issuecomment-447403037
@mxm I think the constructor proliferation suffers from its own issues:
besides repetition you
mxm commented on a change in pull request #7249: [FLINK-11048] Ability to
programmatically execute streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#discussion_r241825068
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/stream
mxm commented on a change in pull request #7249: [FLINK-11048] Ability to
programmatically execute streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#discussion_r241822916
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/stream
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r241816667
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/p
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r241811123
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/a
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r241820886
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/a
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r241817741
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/p
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r241820550
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/p
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r241807984
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/a
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r241809269
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/e
pnowojski commented on a change in pull request #6787: [FLINK-8577][table]
Implement proctime DataStream to Table upsert conversion
URL: https://github.com/apache/flink/pull/6787#discussion_r241815618
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/p
zzchun commented on a change in pull request #7291: [hotfix] [docs] Display
Connectors and Formats tables, and fix typo in documentation
URL: https://github.com/apache/flink/pull/7291#discussion_r241819796
##
File path: docs/dev/table/connect.md
##
@@ -58,11 +56,7 @@ The f
GJL commented on issue #7302: [FLINK-11156] [tests] Reconcile powermock with
JDK 9
URL: https://github.com/apache/flink/pull/7302#issuecomment-447380751
Thank you for your contribution to Apache Flink @TisonKun
I think an additional constructor annotated with `@VisibleForTesting` is
mo
azagrebin commented on a change in pull request #6777: [FLINK-10461] [State
Backends, Checkpointing] Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777#discussion_r241815671
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/
azagrebin commented on a change in pull request #7255: [FLINK-10945] Use
InputDependencyConstraint to avoid resource dead…
URL: https://github.com/apache/flink/pull/7255#discussion_r241812506
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Executio
[
https://issues.apache.org/jira/browse/FLINK-10928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Harper updated FLINK-10928:
--
Attachment: Screen Shot 2018-12-10 at 14.13.52.png
> Job unable to stabilise after restart
>
[
https://issues.apache.org/jira/browse/FLINK-10928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721569#comment-16721569
]
Daniel Harper commented on FLINK-10928:
---
Hi [~dawidwys]
Going to be tricky to pr
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9555.
---
Resolution: Fixed
Reverted for 1.7.1 in: d00dd3323d53cba323bde5ebfe390ffdb4d777d4
> Support
[
https://issues.apache.org/jira/browse/FLINK-11168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11168:
-
Affects Version/s: (was: 1.7.0)
1.7.1
> LargePlanTest times o
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-9555:
-
Will be reverted for 1.7.1 since it introduced bugs.
> Support table api in scala shell
> --
[
https://issues.apache.org/jira/browse/FLINK-9555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-9555:
Fix Version/s: (was: 1.7.1)
> Support table api in scala shell
> --
[
https://issues.apache.org/jira/browse/FLINK-9717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721561#comment-16721561
]
Piotr Nowojski commented on FLINK-9717:
---
[~kisimple], this ticket is not as easy as
Chesnay Schepler created FLINK-11168:
Summary: LargePlanTest times out on Travis
Key: FLINK-11168
URL: https://issues.apache.org/jira/browse/FLINK-11168
Project: Flink
Issue Type: Bug
twalthr commented on issue #7289: [FLINK-11001][table] Fix window rowtime
attribute can't be renamed bug in Java
URL: https://github.com/apache/flink/pull/7289#issuecomment-447366595
@hequn8128 have you checked if the docs need to be updated somewhere?
-
twalthr commented on a change in pull request #7291: [hotfix] [docs] Display
Connectors and Formats tables, and fix typo in documentation
URL: https://github.com/apache/flink/pull/7291#discussion_r241799867
##
File path: docs/dev/table/connect.md
##
@@ -58,11 +56,7 @@ The
asfgit closed pull request #7311: [hotfix][docs] Correct the field name in
Connect to External Systems doc
URL: https://github.com/apache/flink/pull/7311
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 provena
azagrebin commented on a change in pull request #7255: [FLINK-10945] Use
InputDependencyConstraint to avoid resource dead…
URL: https://github.com/apache/flink/pull/7255#discussion_r241794342
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/Executio
asfgit closed pull request #7307: [hotfix][docs] Imporve the correctness in
Detecting Patterns doc
URL: https://github.com/apache/flink/pull/7307
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:
As
twalthr commented on a change in pull request #7177: [FLINK-7599] [table]
Support for aggregates in MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/7177#discussion_r241787811
##
File path: docs/dev/table/streaming/match_recognize.md
##
@@ -211,6 +211,65 @@ If a c
[
https://issues.apache.org/jira/browse/FLINK-6?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-6:
---
Description:
In order to guarantee exactly-once semantics, the streaming file sink is
imple
[
https://issues.apache.org/jira/browse/FLINK-6?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-6:
---
Summary: Overwrite outdated in-progress files in StreamingFileSink. (was:
Clean-up temporar
[
https://issues.apache.org/jira/browse/FLINK-11167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Congxian Qiu updated FLINK-11167:
-
Component/s: State Backends, Checkpointing
> Optimize RocksDBList#put for no empty input
> -
KarmaGYZ opened a new pull request #7311: [hotfix][docs] Correct the field name
in Connect to External Systems doc
URL: https://github.com/apache/flink/pull/7311
## What is the purpose of the change
This pr correct the field name in Connect to External Systems doc and add
missing qu
[
https://issues.apache.org/jira/browse/FLINK-10595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721431#comment-16721431
]
bupt_ljy commented on FLINK-10595:
--
[~dawidwys]
I'm very curious about this empty match
[
https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-10566:
---
Affects Version/s: 1.8.0
> Flink Planning is exponential in the number of stages
> -
[
https://issues.apache.org/jira/browse/FLINK-10566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-10566.
Resolution: Fixed
Fix Version/s: 1.8.0
1.7.1
mxm closed pull request #7276: [FLINK-10566] Fix exponential planning time of
large programs
URL: https://github.com/apache/flink/pull/7276
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:
As this
mxm commented on issue #7276: [FLINK-10566] Fix exponential planning time of
large programs
URL: https://github.com/apache/flink/pull/7276#issuecomment-447323623
All green this time. Merging.
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-10594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10594:
---
Labels: pull-request-available (was: )
> Support SUBSETS
> ---
>
>
buptljy opened a new pull request #7310: [FLINK-10594][table] Add Subsets for
CEP
URL: https://github.com/apache/flink/pull/7310
## What is the purpose of the change
- Add subsets for CEP
## Brief change log
- Add subsets as the parameter of the MatchCodeGenerator
-
twalthr commented on a change in pull request #7177: [FLINK-7599] [table]
Support for aggregates in MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/7177#discussion_r241741665
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate
twalthr commented on a change in pull request #7177: [FLINK-7599] [table]
Support for aggregates in MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/7177#discussion_r241742837
##
File path: docs/dev/table/streaming/match_recognize.md
##
@@ -211,6 +211,65 @@ If a c
[
https://issues.apache.org/jira/browse/FLINK-11161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721350#comment-16721350
]
Timo Walther commented on FLINK-11161:
--
CC [~sunjincheng121]
> Unable to import ja
[
https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721348#comment-16721348
]
Tzu-Li (Gordon) Tai commented on FLINK-11046:
-
I propose the following fix:
[
https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721330#comment-16721330
]
Timo Walther commented on FLINK-11067:
--
Sorry, [~dian.fu] and [~sunjincheng121] I f
wangyang0918 commented on issue #7144: [FLINK-10932] [ResourceManager] Initial
flink-kubernetes module with empty implementation
URL: https://github.com/apache/flink/pull/7144#issuecomment-447307319
@isunjin It’s great to start the kubernetes integration with flink. I am
glad to get involv
[
https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721330#comment-16721330
]
Timo Walther edited comment on FLINK-11067 at 12/14/18 12:07 PM:
-
zentol closed pull request #7309: Release 1.7
URL: https://github.com/apache/flink/pull/7309
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to g
klion26 edited a comment on issue #7309: Release 1.7
URL: https://github.com/apache/flink/pull/7309#issuecomment-447302388
Hi, @westkiller, the pr wants to merge 232 commits from release-1.7 to
master, maybe we could close this.
-
[
https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721314#comment-16721314
]
Tzu-Li (Gordon) Tai commented on FLINK-11046:
-
Ah , I think I understand
[
https://issues.apache.org/jira/browse/FLINK-11040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-11040.
Resolution: Fixed
Fix Version/s: 1.8.0
Fixed via: bc4194ab756e86c5883b272e97f6825d7
klion26 commented on issue #7309: Release 1.7
URL: https://github.com/apache/flink/pull/7309#issuecomment-447302388
@westkiller Why do you want to create this pr?
This is an automated message from the Apache Git Service.
To re
dawidwys closed pull request #7205: [FLINK-11040][docs] fixed the Incorrect
generic type in broadcast_state.md
URL: https://github.com/apache/flink/pull/7205
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 pro
[
https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16721296#comment-16721296
]
Tzu-Li (Gordon) Tai commented on FLINK-11046:
-
This seems a bit odd.
While
zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use
InputDependencyConstraint to avoid resource dead…
URL: https://github.com/apache/flink/pull/7255#discussion_r241636524
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution
zzchun commented on a change in pull request #7291: [hotfix] [docs] Display
Connectors and Formats tables, and fix typo in documentation
URL: https://github.com/apache/flink/pull/7291#discussion_r241627373
##
File path: docs/dev/table/connect.md
##
@@ -58,11 +56,7 @@ The f
westkiller opened a new pull request #7309: Release 1.7
URL: https://github.com/apache/flink/pull/7309
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transfe
[
https://issues.apache.org/jira/browse/FLINK-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
boshu Zheng reassigned FLINK-9142:
--
Assignee: boshu Zheng
> Lower the minimum number of buffers for incoming channels to 1
> -
azagrebin commented on a change in pull request #7288: [FLINK-9702] Improvement
in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241457640
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java
azagrebin commented on a change in pull request #7288: [FLINK-9702] Improvement
in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241465279
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java
azagrebin commented on a change in pull request #7288: [FLINK-9702] Improvement
in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241456301
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java
azagrebin commented on a change in pull request #7288: [FLINK-9702] Improvement
in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241709684
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java
azagrebin commented on a change in pull request #7288: [FLINK-9702] Improvement
in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241709422
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java
azagrebin commented on a change in pull request #7288: [FLINK-9702] Improvement
in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241707867
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/test/java
azagrebin commented on a change in pull request #7288: [FLINK-9702] Improvement
in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241699307
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java
azagrebin commented on a change in pull request #7288: [FLINK-9702] Improvement
in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241453092
##
File path:
flink-core/src/main/java/org/apache/flink/core/memory/DataOut
azagrebin commented on a change in pull request #7288: [FLINK-9702] Improvement
in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241708059
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/test/java
azagrebin commented on a change in pull request #7288: [FLINK-9702] Improvement
in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241464119
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java
azagrebin commented on a change in pull request #7288: [FLINK-9702] Improvement
in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241699417
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java
azagrebin commented on a change in pull request #7288: [FLINK-9702] Improvement
in (de)serialization of keys and values for RocksDB state
URL: https://github.com/apache/flink/pull/7288#discussion_r241716805
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/main/java
Congxian Qiu created FLINK-11167:
Summary: Optimize RocksDBList#put for no empty input
Key: FLINK-11167
URL: https://issues.apache.org/jira/browse/FLINK-11167
Project: Flink
Issue Type: Impro
[
https://issues.apache.org/jira/browse/FLINK-11165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11165:
---
Labels: pull-request-available (was: )
> Refine the deploying log for easier finding of tas
zhuzhurk opened a new pull request #7308: [FLINK-11165] Refine the task
deploying log for easier finding of tas…
URL: https://github.com/apache/flink/pull/7308
…k locations
## What is the purpose of the change
Currently there is not a straight forward way to find in which TM a
dikei commented on a change in pull request #7078: [FLINK-10848][YARN] properly
remove YARN ContainerRequest upon container allocation success
URL: https://github.com/apache/flink/pull/7078#discussion_r241702906
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/YarnFlink
[
https://issues.apache.org/jira/browse/FLINK-11167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Congxian Qiu reassigned FLINK-11167:
Assignee: Congxian Qiu
> Optimize RocksDBList#put for no empty input
> --
[
https://issues.apache.org/jira/browse/FLINK-11165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-11165:
Description:
Currently there is not a straight forward way to find in which TM a task
locates in, especia
1 - 100 of 118 matches
Mail list logo
