kisimple opened a new pull request #7195: [hotfix][test][streaming] Add an
empty side output test to WindowOperatorTest.
URL: https://github.com/apache/flink/pull/7195
I think it is necessary to add an empty side output test when we set
`allowedLateness=Long.MAX_VALUE` using `TumblingEvent
[
https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702807#comment-16702807
]
he peng commented on FLINK-10999:
-
Hi [~x1q1j1], thank you very much for your attenti
[
https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702802#comment-16702802
]
ASF GitHub Bot commented on FLINK-11015:
yanghua commented on issue #7182: [FLIN
yanghua commented on issue #7182: [FLINK-11015] Remove deprecated methods and
classes about table from all the Kafka connectors
URL: https://github.com/apache/flink/pull/7182#issuecomment-442730853
@twalthr Any other changes? If not, I look forward to merging it as soon as
possible to adva
Matrix42 opened a new pull request #7194: [doc] fix missing comma in cep sql
URL: https://github.com/apache/flink/pull/7194
## 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 avo
[
https://issues.apache.org/jira/browse/FLINK-10999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702784#comment-16702784
]
xuqianjin commented on FLINK-10999:
---
hi [~harbby] After tracking, two problems were fo
[
https://issues.apache.org/jira/browse/FLINK-11023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11023:
Assignee: vinoyang
> Update LICENSE and NOTICE files for flink-connectors
> -
[
https://issues.apache.org/jira/browse/FLINK-11022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11022:
Assignee: vinoyang
> Update LICENSE and NOTICE files for older releases
> ---
[
https://issues.apache.org/jira/browse/FLINK-11024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702768#comment-16702768
]
ASF GitHub Bot commented on FLINK-11024:
liu-zhaokun opened a new pull request #
[
https://issues.apache.org/jira/browse/FLINK-11024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11024:
---
Labels: pull-request-available (was: )
> Overwrite yarn configuration by setting configurat
liu-zhaokun opened a new pull request #7193: [FLINK-11024]Overwrite yarn
configuration by setting configuration started with "flink.yarn." in
flink-conf.yaml
URL: https://github.com/apache/flink/pull/7193
[https://issues.apache.org/jira/browse/FLINK-11024](https://issues.apache.org/jira/b
liuzhaokun created FLINK-11024:
--
Summary: Overwrite yarn configuration by setting configuration
started with "flink.yarn." in flink-conf.yaml
Key: FLINK-11024
URL: https://issues.apache.org/jira/browse/FLINK-11024
[
https://issues.apache.org/jira/browse/FLINK-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702683#comment-16702683
]
ASF GitHub Bot commented on FLINK-10665:
TisonKun commented on issue #6917: [FLI
[
https://issues.apache.org/jira/browse/FLINK-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702682#comment-16702682
]
ASF GitHub Bot commented on FLINK-10665:
TisonKun removed a comment on issue #69
TisonKun commented on issue #6917: [FLINK-10665] [tests] Port
YARNSessionFIFOITCase#testJavaAPI to new c…
URL: https://github.com/apache/flink/pull/6917#issuecomment-442696454
@zentol I have resolved travis issue. Could you review this when you're
free? There are little changes though.
--
[
https://issues.apache.org/jira/browse/FLINK-10665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702680#comment-16702680
]
ASF GitHub Bot commented on FLINK-10665:
TisonKun removed a comment on issue #69
TisonKun removed a comment on issue #6917: [FLINK-10665] [tests] Port
YARNSessionFIFOITCase#testJavaAPI to new c…
URL: https://github.com/apache/flink/pull/6917#issuecomment-433074450
@zentol I fix the checkstyle issue. Can you review this?
-
TisonKun removed a comment on issue #6917: [FLINK-10665] [tests] Port
YARNSessionFIFOITCase#testJavaAPI to new c…
URL: https://github.com/apache/flink/pull/6917#issuecomment-440876707
cc @GJL @StefanRRichter
This is an autom
kisimple opened a new pull request #7192: [hotfix][test][streaming] Fix a test
failure in Windows 7 environment.
URL: https://github.com/apache/flink/pull/7192
Running
org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializerTest
Tests run: 4, Failures: 3, Errors: 0
[
https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702649#comment-16702649
]
ASF GitHub Bot commented on FLINK-8577:
---
hequn8128 commented on a change in pull re
hequn8128 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_r237328473
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/p
[
https://issues.apache.org/jira/browse/FLINK-11016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wong closed FLINK-11016.
Resolution: Not A Bug
> flink chain have a bug？？？
> -
>
> Key: FLINK-11016
[
https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702631#comment-16702631
]
TisonKun commented on FLINK-10333:
--
[~StephanEwen] infer your original proposal is to m
[
https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702618#comment-16702618
]
ASF GitHub Bot commented on FLINK-8577:
---
hequn8128 commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702619#comment-16702619
]
ASF GitHub Bot commented on FLINK-8577:
---
hequn8128 commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702617#comment-16702617
]
ASF GitHub Bot commented on FLINK-8577:
---
hequn8128 commented on a change in pull re
[
https://issues.apache.org/jira/browse/FLINK-8577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702620#comment-16702620
]
ASF GitHub Bot commented on FLINK-8577:
---
hequn8128 commented on a change in pull re
hequn8128 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_r237328431
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/c
hequn8128 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_r237328203
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/a
hequn8128 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_r237328473
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/p
hequn8128 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_r237329703
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/p
[
https://issues.apache.org/jira/browse/FLINK-11013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702606#comment-16702606
]
ASF GitHub Bot commented on FLINK-11013:
dianfu commented on issue #7181: [FLINK
dianfu commented on issue #7181: [FLINK-11013] [table] Fix distinct aggregates
for group window in Table API
URL: https://github.com/apache/flink/pull/7181#issuecomment-442674317
@walterddr Thanks a lot for your review. The comments make sense to me and
have updated accordingly.
-
[
https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702604#comment-16702604
]
Xiaogang Shi commented on FLINK-10333:
--
I think so. We can wrap all the access to Z
[
https://issues.apache.org/jira/browse/FLINK-11013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702565#comment-16702565
]
ASF GitHub Bot commented on FLINK-11013:
walterddr commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702571#comment-16702571
]
ASF GitHub Bot commented on FLINK-10461:
klion26 commented on issue #6777: [FLIN
klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing]
Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777#issuecomment-442662282
@azagrebin thanks for your reviewing, i'vs just addressed the comments,
please help to review
[
https://issues.apache.org/jira/browse/FLINK-11013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702566#comment-16702566
]
ASF GitHub Bot commented on FLINK-11013:
walterddr commented on a change in pull
walterddr commented on a change in pull request #7181: [FLINK-11013] [table]
Fix distinct aggregates for group window in Table API
URL: https://github.com/apache/flink/pull/7181#discussion_r237316354
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/ap
walterddr commented on a change in pull request #7181: [FLINK-11013] [table]
Fix distinct aggregates for group window in Table API
URL: https://github.com/apache/flink/pull/7181#discussion_r237316435
##
File path:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/ap
[
https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702184#comment-16702184
]
Till Rohrmann commented on FLINK-10842:
---
Should we also back port this fix for {{r
[
https://issues.apache.org/jira/browse/FLINK-11003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-11003.
-
Resolution: Fixed
Fix Version/s: (was: 1.8.0)
> Document of Java Lambda Expressions h
[
https://issues.apache.org/jira/browse/FLINK-11003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-11003:
---
> Document of Java Lambda Expressions has a mistake
> --
[
https://issues.apache.org/jira/browse/FLINK-10992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10992.
-
Resolution: Fixed
Fix Version/s: (was: 1.7.1)
1.7.0
> Jepsen: Do n
[
https://issues.apache.org/jira/browse/FLINK-10992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-10992:
---
> Jepsen: Do not use /tmp as HDFS Data Directory
> -
[
https://issues.apache.org/jira/browse/FLINK-10946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702186#comment-16702186
]
Till Rohrmann commented on FLINK-10946:
---
Would this fix also be relevant for {{rel
[
https://issues.apache.org/jira/browse/FLINK-10951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10951.
-
Resolution: Fixed
Fix Version/s: (was: 1.7.1)
1.7.0
> Disable enfo
[
https://issues.apache.org/jira/browse/FLINK-10951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-10951:
---
> Disable enforcing of YARN container virtual memory limits in tests
> -
[
https://issues.apache.org/jira/browse/FLINK-10763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10763.
-
Resolution: Fixed
Fix Version/s: (was: 1.7.1)
1.7.0
> Interval joi
[
https://issues.apache.org/jira/browse/FLINK-10763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-10763:
---
> Interval join produces wrong result type in Scala API
> --
[
https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702174#comment-16702174
]
Stephan Ewen commented on FLINK-10333:
--
If ZK has a transactional mechanism so that
[
https://issues.apache.org/jira/browse/FLINK-10987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10987.
-
Resolution: Fixed
Fixed via
master:
6a6a8ddd15
5056907c33
ea8cd6ddad
2885b7d19a
b765e0774c
515b2
[
https://issues.apache.org/jira/browse/FLINK-10955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702113#comment-16702113
]
ASF GitHub Bot commented on FLINK-10955:
tillrohrmann closed pull request #7150:
Till Rohrmann created FLINK-11023:
-
Summary: Update LICENSE and NOTICE files for flink-connectors
Key: FLINK-11023
URL: https://issues.apache.org/jira/browse/FLINK-11023
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-10987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-10987:
--
Fix Version/s: (was: shaded-6.0)
(was: 1.5.6)
Till Rohrmann created FLINK-11022:
-
Summary: Update LICENSE and NOTICE files for older releases
Key: FLINK-11022
URL: https://issues.apache.org/jira/browse/FLINK-11022
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-10955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-10955.
-
Resolution: Fixed
Fix Version/s: (was: 1.7.1)
1.7.0
Fixed via
mast
tillrohrmann closed pull request #7151: [BP-1.7][FLINK-10955] Extend release
notes for Apache Flink 1.7.0
URL: https://github.com/apache/flink/pull/7151
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 provenan
tillrohrmann closed pull request #7150: [FLINK-10955] Extend release notes for
Apache Flink 1.7.0
URL: https://github.com/apache/flink/pull/7150
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
[
https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702103#comment-16702103
]
Andrey Zagrebin commented on FLINK-10945:
-
Hi [~zhuzh], the idea sounds really g
[
https://issues.apache.org/jira/browse/FLINK-10987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702098#comment-16702098
]
ASF GitHub Bot commented on FLINK-10987:
tillrohrmann commented on issue #7191:
tillrohrmann commented on issue #7191: [FLINK-10987] Update LICENSE & NOTICE
files for Flink's source and binary releases
URL: https://github.com/apache/flink/pull/7191#issuecomment-442509407
Thanks for the review @zentol. Merging once Travis gives green light.
[
https://issues.apache.org/jira/browse/FLINK-10987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702093#comment-16702093
]
ASF GitHub Bot commented on FLINK-10987:
tillrohrmann commented on a change in p
tillrohrmann commented on a change in pull request #7191: [FLINK-10987] Update
LICENSE & NOTICE files for Flink's source and binary releases
URL: https://github.com/apache/flink/pull/7191#discussion_r237157244
##
File path: tools/releasing/collect_license_files.sh
##
@@ -0
[
https://issues.apache.org/jira/browse/FLINK-10987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702060#comment-16702060
]
ASF GitHub Bot commented on FLINK-10987:
zentol commented on a change in pull re
zentol commented on a change in pull request #7191: [FLINK-10987] Update
LICENSE & NOTICE files for Flink's source and binary releases
URL: https://github.com/apache/flink/pull/7191#discussion_r237141463
##
File path: tools/releasing/collect_license_files.sh
##
@@ -0,0 +1,
[
https://issues.apache.org/jira/browse/FLINK-10963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702042#comment-16702042
]
ASF GitHub Bot commented on FLINK-10963:
kl0u commented on a change in pull requ
kl0u commented on a change in pull request #7161: [FLINK-10963][fs-connector,
s3] Cleanup tmp S3 objects uploaded as backups of in-progress files.
URL: https://github.com/apache/flink/pull/7161#discussion_r237140259
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/
[
https://issues.apache.org/jira/browse/FLINK-10987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10987:
---
Labels: pull-request-available (was: )
> LICENSE and NOTICE files are not correct
> ---
[
https://issues.apache.org/jira/browse/FLINK-10987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702023#comment-16702023
]
ASF GitHub Bot commented on FLINK-10987:
tillrohrmann opened a new pull request
tillrohrmann opened a new pull request #7191: [FLINK-10987] Update LICENSE &
NOTICE files for Flink's source and binary releases
URL: https://github.com/apache/flink/pull/7191
## What is the purpose of the change
This PR updates Flink's LICENSE & NOTICE files for the source and binar
[
https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702017#comment-16702017
]
ASF GitHub Bot commented on FLINK-11015:
yanghua commented on a change in pull r
yanghua commented on a change in pull request #7182: [FLINK-11015] Remove
deprecated methods and classes about table from all the Kafka connectors
URL: https://github.com/apache/flink/pull/7182#discussion_r237131756
##
File path: flink-connectors/flink-connector-kafka-0.10/pom.xml
[
https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16702014#comment-16702014
]
ASF GitHub Bot commented on FLINK-11015:
yanghua commented on a change in pull r
yanghua commented on a change in pull request #7182: [FLINK-11015] Remove
deprecated methods and classes about table from all the Kafka connectors
URL: https://github.com/apache/flink/pull/7182#discussion_r237131756
##
File path: flink-connectors/flink-connector-kafka-0.10/pom.xml
kisimple opened a new pull request #7190: [hotfix][test][table] Fix the misuse
of assertEquals
URL: https://github.com/apache/flink/pull/7190
The expected result and the actual result should be interchanged.
This is an automa
[
https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701985#comment-16701985
]
ASF GitHub Bot commented on FLINK-11015:
yanghua commented on a change in pull r
[
https://issues.apache.org/jira/browse/FLINK-11015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701997#comment-16701997
]
ASF GitHub Bot commented on FLINK-11015:
twalthr commented on a change in pull r
twalthr commented on a change in pull request #7182: [FLINK-11015] Remove
deprecated methods and classes about table from all the Kafka connectors
URL: https://github.com/apache/flink/pull/7182#discussion_r237124239
##
File path: flink-connectors/flink-connector-kafka-0.10/pom.xml
yanghua commented on a change in pull request #7182: [FLINK-11015] Remove
deprecated methods and classes about table from all the Kafka connectors
URL: https://github.com/apache/flink/pull/7182#discussion_r237120052
##
File path: flink-connectors/flink-connector-kafka-0.10/pom.xml
[
https://issues.apache.org/jira/browse/FLINK-10597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701970#comment-16701970
]
ASF GitHub Bot commented on FLINK-10597:
dawidwys opened a new pull request #718
[
https://issues.apache.org/jira/browse/FLINK-10597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10597:
---
Labels: pull-request-available (was: )
> Enable UDFs support in MATCH_RECOGNIZE
> -
dawidwys opened a new pull request #7189: [FLINK-10597] Enabled UDFs support in
MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/7189
## What is the purpose of the change
This PR enables user defined scalar function in MATCH_RECOGNIZE
## Does this pull request potenti
Christina created FLINK-11021:
-
Summary: ZoneOffset objects don't appear to be serialized correctly
Key: FLINK-11021
URL: https://issues.apache.org/jira/browse/FLINK-11021
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701960#comment-16701960
]
ASF GitHub Bot commented on FLINK-10461:
azagrebin commented on a change in pull
[
https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-10966:
-
Comment: was deleted
(was: [~StephanEwen], i am interested in the actor-style stream task you
mentioned
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701961#comment-16701961
]
ASF GitHub Bot commented on FLINK-10461:
azagrebin commented on a change in pull
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_r237104577
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/
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_r237105565
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/
[
https://issues.apache.org/jira/browse/FLINK-10601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin reassigned FLINK-10601:
Assignee: Paul Lin
> Make user home dir consistent with Flink default filesystem
> --
[
https://issues.apache.org/jira/browse/FLINK-10680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin reassigned FLINK-10680:
Assignee: Paul Lin
> Unable to set negative offsets for TumblingEventTimeWindow
> ---
[
https://issues.apache.org/jira/browse/FLINK-10943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin reassigned FLINK-10943:
Assignee: Paul Lin
> Flink runtime test failed caused by curator dependency conflicts
> -
[
https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701950#comment-16701950
]
ASF GitHub Bot commented on FLINK-10461:
azagrebin commented on a change in pull
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_r236202672
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/
[
https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701939#comment-16701939
]
ASF GitHub Bot commented on FLINK-10473:
azagrebin opened a new pull request #71
[
https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-10473:
---
Labels: pull-request-available (was: )
> State TTL incremental cleanup using Heap backend k
azagrebin opened a new pull request #7188: [FLINK-10473][State TTL] TTL state
incremental cleanup for heap backend
URL: https://github.com/apache/flink/pull/7188
## What is the purpose of the change
Introduce TTL state incremental cleanup for heap backend.
See docs in PR for high-
[
https://issues.apache.org/jira/browse/FLINK-8159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701924#comment-16701924
]
ASF GitHub Bot commented on FLINK-8159:
---
dawidwys closed pull request #7110: [FLINK
[
https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-10966:
Assignee: zhijiang (was: vinoyang)
> Optimize the release blocking logic in BarrierBuffer
>
[
https://issues.apache.org/jira/browse/FLINK-10966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16701935#comment-16701935
]
zhijiang commented on FLINK-10966:
--
[~StephanEwen], i am interested in the actor-style
1 - 100 of 241 matches
Mail list logo
