[
https://issues.apache.org/jira/browse/FLINK-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-9263.
-
Resolution: Fixed
Merged in:
master: c11f11359b
release 1.5: de4f283087
> Kafka010ITCase failed
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460879#comment-16460879
]
Aljoscha Krettek commented on FLINK-8500:
-
[~tzulitai] I thought about that second
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9269:
Fix Version/s: (was: 1.5.0)
1.6.0
> Concurrency problem in HeapKeyedS
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3359
@shixiaogang Thank you very much, appreciate your efforts on this feature!
There is no need to rush this if you are busy right now, the cycle for the 1.6
release is just beginning.
---
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460884#comment-16460884
]
ASF GitHub Bot commented on FLINK-5544:
---
Github user StefanRRichter commented on the
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-9043:
-
> Flink recover from checkpoint like Spark Streaming
> --
[
https://issues.apache.org/jira/browse/FLINK-9101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9101:
Fix Version/s: 1.5.1
1.6.0
> HAQueryableStateRocksDBBackendITCase failed
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460891#comment-16460891
]
Tzu-Li (Gordon) Tai commented on FLINK-9178:
[~app-tarush]
Sorry for slow late
[
https://issues.apache.org/jira/browse/FLINK-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460891#comment-16460891
]
Tzu-Li (Gordon) Tai edited comment on FLINK-9178 at 5/2/18 11:22 AM:
---
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5934#discussion_r185464970
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -3594,6 +3599,58 @@ public String fold(String a
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460901#comment-16460901
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5934#discussion_r185465142
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460902#comment-16460902
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5934#discussion_r185465407
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460904#comment-16460904
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-5372:
-
Reopen to change fixVersion
> Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()
[
https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5372.
---
Resolution: Fixed
Fix Version/s: (was: 1.6.0)
> Fix RocksDBAsyncSnapshotTest.testCa
[
https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460905#comment-16460905
]
Aljoscha Krettek commented on FLINK-7484:
-
cc [~srichter]
> CaseClassSerializer.d
[
https://issues.apache.org/jira/browse/FLINK-7484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460907#comment-16460907
]
Stefan Richter commented on FLINK-7484:
---
[~joshlemer] this looks like a different pr
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5922
Thanks a lot for the reviews! I pushed a commit that integrates your
comments. Let me know if now it looks ok.
---
[
https://issues.apache.org/jira/browse/FLINK-8780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460920#comment-16460920
]
ASF GitHub Bot commented on FLINK-8780:
---
Github user kl0u commented on the issue:
David Anderson created FLINK-9288:
-
Summary: clarify a few points in the event time / watermark docs
Key: FLINK-9288
URL: https://issues.apache.org/jira/browse/FLINK-9288
Project: Flink
Issue
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5934#discussion_r185470576
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
---
@@ -622,20 +622,23 @@ public HeapSnapshotStr
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460924#comment-16460924
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5934
Thanks for your work! Besides my comments, this looks good ð
---
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460925#comment-16460925
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user StefanRRichter commented on the
GitHub user alpinegizmo opened a pull request:
https://github.com/apache/flink/pull/5949
[FLINK-9288][docs] clarify the event time / watermark docs
This PR only affects the documentation (for event time and watermarks). I
wanted to make a couple of things clearer, and to provide a c
[
https://issues.apache.org/jira/browse/FLINK-9288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460927#comment-16460927
]
ASF GitHub Bot commented on FLINK-9288:
---
GitHub user alpinegizmo opened a pull reque
[
https://issues.apache.org/jira/browse/FLINK-9122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460930#comment-16460930
]
Aljoscha Krettek commented on FLINK-9122:
-
You could try applying the PR for FLINK
[
https://issues.apache.org/jira/browse/FLINK-9271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460932#comment-16460932
]
Martin Grigorov commented on FLINK-9271:
The downloaded file is not gzipped when I
[
https://issues.apache.org/jira/browse/FLINK-9271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martin Grigorov resolved FLINK-9271.
Resolution: Not A Problem
> flink-1.4.2-bin-scala_2.11.tgz is not in gzip format
> -
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5817
Looks very good to merge! ð
---
[
https://issues.apache.org/jira/browse/FLINK-9136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460933#comment-16460933
]
ASF GitHub Bot commented on FLINK-9136:
---
Github user aljoscha commented on the issue
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5932
---
[
https://issues.apache.org/jira/browse/FLINK-9188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460935#comment-16460935
]
ASF GitHub Bot commented on FLINK-9188:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5889
---
[
https://issues.apache.org/jira/browse/FLINK-9266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460936#comment-16460936
]
ASF GitHub Bot commented on FLINK-9266:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-9188.
Resolution: Fixed
Assignee: Thomas Weise
Fix Version/s: 1.5.0
Thanks
[
https://issues.apache.org/jira/browse/FLINK-9266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-9266.
Resolution: Fixed
Fix Version/s: 1.5.0
Release Note:
The default version
[
https://issues.apache.org/jira/browse/FLINK-9266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-9266:
---
Release Note: The default versions for AWS SDKs used in the Flink Kinesis
connector ha
[
https://issues.apache.org/jira/browse/FLINK-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-9148.
---
Resolution: Cannot Reproduce
Fix Version/s: (was: 1.6.0)
Seems to be a configuratio
[
https://issues.apache.org/jira/browse/FLINK-9266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-9266:
--
Assignee: Thomas Moser
> Upgrade AWS Kinesis Client version to 1.9.0 to reduce
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9201:
Fix Version/s: 1.6.0
> same merge window will be fired twice if watermark already passed the
[
https://issues.apache.org/jira/browse/FLINK-9226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-9226.
---
Resolution: Duplicate
> Add Bucketing e2e test script to run-nightly-tests.sh
> --
[
https://issues.apache.org/jira/browse/FLINK-9238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-9238.
---
Resolution: Duplicate
Fix Version/s: (was: 1.4.2)
Unfortunately, the current bucket
[
https://issues.apache.org/jira/browse/FLINK-9251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460959#comment-16460959
]
Aljoscha Krettek commented on FLINK-9251:
-
I don't think we have to do this. This
[
https://issues.apache.org/jira/browse/FLINK-9251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-9251.
---
Resolution: Not A Problem
Fix Version/s: (was: 1.6.0)
Closing for now but please co
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9043:
Description:
I know a flink job can reovery from checkpoint with restart strategy, but can
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9043:
Summary: Introduce a friendly way to resume the job from externalized
checkpoints automatica
[
https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-9043:
---
Assignee: Sihua Zhou
> Introduce a friendly way to resume the job from externalized c
[
https://issues.apache.org/jira/browse/FLINK-9260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-9260.
---
Resolution: Duplicate
Fix Version/s: (was: 1.6.0)
Please resume any discussion on F
[
https://issues.apache.org/jira/browse/FLINK-9262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9262:
Priority: Blocker (was: Major)
> KeyedOneInputStreamOperatorTestHarness throws NPE creating
[
https://issues.apache.org/jira/browse/FLINK-9245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9245:
Fix Version/s: 1.6.0
> Can't create a BucketingSink with a provided Configuration if no hado
[
https://issues.apache.org/jira/browse/FLINK-9262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9262:
Fix Version/s: 1.6.0
> KeyedOneInputStreamOperatorTestHarness throws NPE creating snapshot
>
[
https://issues.apache.org/jira/browse/FLINK-9278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460972#comment-16460972
]
Fabian Hueske commented on FLINK-9278:
--
Hi [~ahains],
This sounds like a very valuab
[
https://issues.apache.org/jira/browse/FLINK-9278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460972#comment-16460972
]
Fabian Hueske edited comment on FLINK-9278 at 5/2/18 12:49 PM:
-
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5934#discussion_r185485401
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -3594,6 +3599,58 @@ public String fold(String acc, I
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5934#discussion_r185485532
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -198
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460982#comment-16460982
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460983#comment-16460983
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user sihuazhou commented on a diff i
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5934#discussion_r185486196
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
---
@@ -198
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5934#discussion_r185486283
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java
---
@@ -622,20 +622,23 @@ public HeapSnapshotStrategy
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460988#comment-16460988
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16460989#comment-16460989
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user sihuazhou commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-9270.
---
Resolution: Won't Fix
Fix Version/s: (was: 1.6.0)
> Upgrade RocksDB to 5.11.3, and
[
https://issues.apache.org/jira/browse/FLINK-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-9270:
-
Reopen to remove fixVersion
> Upgrade RocksDB to 5.11.3, and resolve concurrent test invocati
[
https://issues.apache.org/jira/browse/FLINK-9278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9278:
Component/s: Table API & SQL
> Allow restore savepoint with some SQL queries added/removed
>
Fabian Hueske created FLINK-9289:
Summary: Parallelism of generated operators should have max
parallism of input
Key: FLINK-9289
URL: https://issues.apache.org/jira/browse/FLINK-9289
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-9289:
-
Description:
The DataSet API aims to chain generated operators such as key extraction
mappers to
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5906
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5904
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5912
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5833
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5822
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5903
---
[
https://issues.apache.org/jira/browse/FLINK-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9211.
---
Resolution: Fixed
master: e884a3a4f6ba738fac66846488f931cf85f2e2fc
1.5: f4bef6fc51c297b372b95c
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5878
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5919
---
[
https://issues.apache.org/jira/browse/FLINK-8743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-8743.
---
Resolution: Fixed
master: c7d59105c0dfae172db8d70820077d81040b3f6d
1.5: d83e19fbb20e4e04b65260
[
https://issues.apache.org/jira/browse/FLINK-8743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461014#comment-16461014
]
ASF GitHub Bot commented on FLINK-8743:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461013#comment-16461013
]
ASF GitHub Bot commented on FLINK-9249:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461011#comment-16461011
]
ASF GitHub Bot commented on FLINK-9216:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461012#comment-16461012
]
ASF GitHub Bot commented on FLINK-9041:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461010#comment-16461010
]
ASF GitHub Bot commented on FLINK-9213:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461016#comment-16461016
]
ASF GitHub Bot commented on FLINK-9154:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461015#comment-16461015
]
ASF GitHub Bot commented on FLINK-9211:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-9154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9154.
---
Resolution: Fixed
master: fa321ea96bc5a58d53c0cf29dbd8fb04ace3c2a8
1.5: 1c48e32446363e903f5084
[
https://issues.apache.org/jira/browse/FLINK-9249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9249.
---
Resolution: Fixed
master: 678ab6cb2f810a93c9b9599cde56d821d09801af
1.5: 45354899cef40ed6ce8a38
[
https://issues.apache.org/jira/browse/FLINK-9216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461020#comment-16461020
]
Chesnay Schepler commented on FLINK-9216:
-
master: 3242214bac3719d057aeaeb34259039
[
https://issues.apache.org/jira/browse/FLINK-9041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9041.
---
Resolution: Fixed
Fix Version/s: 1.6.0
master: 40e412ae233046a5f6f38cf86288ab5185d9d194
[
https://issues.apache.org/jira/browse/FLINK-9213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-9213.
---
Resolution: Fixed
master: dee63946904fa7f1c82f4d482cb8a425935e8ef6
1.5: 547152eadd54f2b0d827b9
[
https://issues.apache.org/jira/browse/FLINK-9273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461060#comment-16461060
]
Fabian Hueske commented on FLINK-9273:
--
Hi [~bob365],
Flink cannot automatically ext
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5887
Thanks for the update @bowenli86.
I'll merge the PR later.
---
[
https://issues.apache.org/jira/browse/FLINK-6719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461075#comment-16461075
]
ASF GitHub Bot commented on FLINK-6719:
---
Github user fhueske commented on the issue:
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5934#discussion_r185508430
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java
---
@@ -3594,6 +3599,58 @@ public String fold(String a
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5934
Thanks! Will merge once my travis run is green.
---
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461076#comment-16461076
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-9269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16461077#comment-16461077
]
ASF GitHub Bot commented on FLINK-9269:
---
Github user StefanRRichter commented on the
[
https://issues.apache.org/jira/browse/FLINK-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui reassigned FLINK-9289:
--
Assignee: Xingcan Cui
> Parallelism of generated operators should have max parallism of input
>
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/5580#discussion_r185517079
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/filecache/FileCacheDirectoriesTest.java
---
@@ -0,0 +1,209 @@
+/*
+ * Licensed to th
101 - 200 of 280 matches
Mail list logo