Manu Zhang created FLINK-4953:
-
Summary: Allow querying time in window functions
Key: FLINK-4953
URL: https://issues.apache.org/jira/browse/FLINK-4953
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15614425#comment-15614425
]
Jark Wu commented on FLINK-4469:
Hi all,
I have proposed CROSS/OUTER APPLY syntax to Calc
[
https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-4928:
---
Assignee: shuai.xu
> Implement FLIP-6 YARN Application Master Runner
> --
[
https://issues.apache.org/jira/browse/FLINK-4927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shuai.xu reassigned FLINK-4927:
---
Assignee: shuai.xu
> Implement FLI-6 YARN Resource Manager
> -
>
Manu Zhang created FLINK-4952:
-
Summary: Add Scala API for KeyedStream.flatMap
Key: FLINK-4952
URL: https://issues.apache.org/jira/browse/FLINK-4952
Project: Flink
Issue Type: Improvement
Manu Zhang created FLINK-4951:
-
Summary: Better Javadocs for KeyedStream.flatMap
Key: FLINK-4951
URL: https://issues.apache.org/jira/browse/FLINK-4951
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15614076#comment-15614076
]
ASF GitHub Bot commented on FLINK-4378:
---
Github user wenlong88 commented on the issu
Github user wenlong88 commented on the issue:
https://github.com/apache/flink/pull/2356
all of the test in travis have passed. thanks for merging this. ^_^
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project d
[
https://issues.apache.org/jira/browse/FLINK-4923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15614058#comment-15614058
]
ASF GitHub Bot commented on FLINK-4923:
---
Github user zhuhaifengleon commented on a d
Github user zhuhaifengleon commented on a diff in the pull request:
https://github.com/apache/flink/pull/2693#discussion_r85463825
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -347,6 +348,12 @@ public Task(
// fin
Vijay Srinivasaraghavan created FLINK-4950:
--
Summary: Add support to include multiple Yarn application entries
in Yarn properties file
Key: FLINK-4950
URL: https://issues.apache.org/jira/browse/FLINK-4950
Greg Hogan created FLINK-4949:
-
Summary: Refactor Gelly driver inputs
Key: FLINK-4949
URL: https://issues.apache.org/jira/browse/FLINK-4949
Project: Flink
Issue Type: Improvement
Compon
[
https://issues.apache.org/jira/browse/FLINK-4946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15613223#comment-15613223
]
ASF GitHub Bot commented on FLINK-4946:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/2708
[FLINK-4946] [scripts] Load jar files from subdirectories of lib
The Flink classpath is a concatenation of jar files in lib/. This commit
includes files from subdirectories of lib/ in the classpat
[
https://issues.apache.org/jira/browse/FLINK-4948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15613064#comment-15613064
]
Jamie Grier commented on FLINK-4948:
Makes sense. Maybe a scheme where we can verify
[
https://issues.apache.org/jira/browse/FLINK-4948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612892#comment-15612892
]
Gyula Fora commented on FLINK-4948:
---
I think in general this would be very nice but what
Jamie Grier created FLINK-4948:
--
Summary: Consider using checksums or similar to detect bad
checkpoints
Key: FLINK-4948
URL: https://issues.apache.org/jira/browse/FLINK-4948
Project: Flink
Issu
Jamie Grier created FLINK-4947:
--
Summary: Make all configuration possible via flink-conf.yaml and
CLI.
Key: FLINK-4947
URL: https://issues.apache.org/jira/browse/FLINK-4947
Project: Flink
Issue
Greg Hogan created FLINK-4946:
-
Summary: Load jar files from subdirectories of lib
Key: FLINK-4946
URL: https://issues.apache.org/jira/browse/FLINK-4946
Project: Flink
Issue Type: Improvement
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2664
@StephanEwen latest commit assembles connectors into separate directories.
I'll create a ticket for loading jar files from subdirectories of`lib`.
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612777#comment-15612777
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user greghogan commented on the issu
Github user Makman2 commented on the issue:
https://github.com/apache/flink/pull/2704
Feel free to cherry-pick my commit into your branch and close this PR :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your projec
[
https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612697#comment-15612697
]
ASF GitHub Bot commented on FLINK-4943:
---
Github user Makman2 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612673#comment-15612673
]
ASF GitHub Bot commented on FLINK-4887:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612675#comment-15612675
]
ASF GitHub Bot commented on FLINK-4887:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612690#comment-15612690
]
ASF GitHub Bot commented on FLINK-4943:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2704
I keep an `_minutiae` branch and push that every few months, typically
after a release. There are fixed costs at each level of Flink's ticketing /
pull request / verify / commit process.
---
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2699#discussion_r85392726
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/messages/StackTrace.java
---
@@ -0,0 +1,41 @@
+/*
+ * Licensed to the Apache Softw
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2699#discussion_r85386607
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java
---
@@ -0,0 +1,91 @@
+/*
+ * Licensed to the Apache So
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2699#discussion_r85390985
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/messages/StackTraceSampleResponse.java
---
@@ -0,0 +1,57 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612672#comment-15612672
]
ASF GitHub Bot commented on FLINK-4887:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2699#discussion_r85383836
--- Diff: flink-tests/src/test/resources/log4j-test.properties ---
@@ -18,7 +18,7 @@
# Set root logger level to OFF to not flood build logs
[
https://issues.apache.org/jira/browse/FLINK-4887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612674#comment-15612674
]
ASF GitHub Bot commented on FLINK-4887:
---
Github user StephanEwen commented on a diff
Github user Makman2 commented on the issue:
https://github.com/apache/flink/pull/2704
Though I wouldn't fix more than this one (except I stumble over some typos
again) :3
Is there already a larger ticket? @greghogan
---
If your project is set up for it, you can reply to this ema
[
https://issues.apache.org/jira/browse/FLINK-4943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612618#comment-15612618
]
ASF GitHub Bot commented on FLINK-4943:
---
Github user Makman2 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612488#comment-15612488
]
ASF GitHub Bot commented on FLINK-4939:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2707
[FLINK-4939] GenericWriteAheadSink: Decouple the creating from the
committing subtask for a pending checkpoint
So far the GenericWriteAheadSink expected that the subtask that wrote a
temporary buffer
[
https://issues.apache.org/jira/browse/FLINK-4889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612480#comment-15612480
]
ASF GitHub Bot commented on FLINK-4889:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2698
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612477#comment-15612477
]
ASF GitHub Bot commented on FLINK-4945:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2706
R @rmetzger
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, o
[
https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4939:
--
Summary: GenericWriteAheadSink: Decouple the creating from the committing
subtask for a pending
[
https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612472#comment-15612472
]
ASF GitHub Bot commented on FLINK-4945:
---
GitHub user StefanRRichter opened a pull re
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/2706
[FLINK-4945] KafkaConsumer logs wrong warning about confirmation for â¦
This PR fixes an unjustified warning about unknown checkpoints in
FlinkKafkaConsumerBase.
You can merge this pull req
[
https://issues.apache.org/jira/browse/FLINK-4939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4939:
--
Summary: GenericWriteAheadSink: Decouple the subtask creating a pending
checkpoint from the one
[
https://issues.apache.org/jira/browse/FLINK-4823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612467#comment-15612467
]
Greg Hogan commented on FLINK-4823:
---
How are you creating your {{Graph}}? Each vertex re
[
https://issues.apache.org/jira/browse/FLINK-4889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612452#comment-15612452
]
ASF GitHub Bot commented on FLINK-4889:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2698
Looks good
+1 to merge this
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
[
https://issues.apache.org/jira/browse/FLINK-4945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter reassigned FLINK-4945:
-
Assignee: Stefan Richter
> KafkaConsumer logs wrong warning about confirmation for unknow
Stefan Richter created FLINK-4945:
-
Summary: KafkaConsumer logs wrong warning about confirmation for
unknown checkpoint
Key: FLINK-4945
URL: https://issues.apache.org/jira/browse/FLINK-4945
Project: F
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612315#comment-15612315
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user chermenin commented on a diff i
Github user chermenin commented on a diff in the pull request:
https://github.com/apache/flink/pull/2623#discussion_r85369265
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java
---
@@ -710,7 +712,103 @@ public String toString()
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612306#comment-15612306
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2623
I like this approach. One minor question, otherwise +1 to go here
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project d
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612301#comment-15612301
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2623#discussion_r85368023
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/util/CollectionDataSets.java
---
@@ -710,7 +712,103 @@ public String toString(
[
https://issues.apache.org/jira/browse/FLINK-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612284#comment-15612284
]
ASF GitHub Bot commented on FLINK-4733:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2616
I tested the change locally, it works. +1 to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612219#comment-15612219
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a d
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2690
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612217#comment-15612217
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612273#comment-15612273
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2652
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4715.
--
Resolution: Fixed
Fix Version/s: 1.1.4
Fixed in cc6655b (release-1.1), 27fd249 (master).
> TaskM
[
https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612253#comment-15612253
]
ASF GitHub Bot commented on FLINK-4894:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4894.
--
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
Fixed in 529534f (release-1.1), c
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reopened FLINK-4510:
> Always create CheckpointCoordinator
> ---
>
> Key: FLI
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612226#comment-15612226
]
Ufuk Celebi commented on FLINK-4510:
Fixed in {{b420750}} (release-1.1).
> Always cre
[
https://issues.apache.org/jira/browse/FLINK-4510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4510.
--
Resolution: Fixed
Fix Version/s: 1.1.4
> Always create CheckpointCoordinator
> --
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1561#comment-1561
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612221#comment-15612221
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612215#comment-15612215
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85360067
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/EventTimeSessionWindowsWindowsTest.java
---
@@ -0,
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85361303
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TriggerTestHarness.java
---
@@ -0,0 +1,369 @@
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85360454
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/EventTimeTriggerTest.java
---
@@ -0,0 +1,153 @@
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612218#comment-15612218
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85359630
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/CountTriggerTest.java
---
@@ -0,0 +1,123 @@
+/
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85361208
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/TriggerTestHarness.java
---
@@ -0,0 +1,369 @@
[
https://issues.apache.org/jira/browse/FLINK-4552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612216#comment-15612216
]
ASF GitHub Bot commented on FLINK-4552:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85359406
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/CountTriggerTest.java
---
@@ -0,0 +1,123 @@
+/
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2572#discussion_r85360968
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/PurgingTriggerTest.java
---
@@ -0,0 +1,149 @@
[
https://issues.apache.org/jira/browse/FLINK-4733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612172#comment-15612172
]
ASF GitHub Bot commented on FLINK-4733:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2616
Thank you for rebasing.
This run:
had the following error:
https://s3.amazonaws.com/archive.travis-ci.org/jobs/170428661/log.txt
```
Failed tests:
CoordinatorShutdownTest.test
[
https://issues.apache.org/jira/browse/FLINK-4756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruwen Moos resolved FLINK-4756.
---
Resolution: Not A Bug
Version of flink for the cluster and in the maven project were to far apart.
If
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2694
+1 to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if t
[
https://issues.apache.org/jira/browse/FLINK-4925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612162#comment-15612162
]
ASF GitHub Bot commented on FLINK-4925:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612146#comment-15612146
]
ASF GitHub Bot commented on FLINK-2597:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/2705
[FLINK-2597][FLINK-4050] Add wrappers for Kafka serializers, test for
partitioner and documentation
This pull requests addresses the following JIRAs:
- [FLINK-2597
Add a test for Avro-seria
[
https://issues.apache.org/jira/browse/FLINK-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612123#comment-15612123
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user chermenin commented on the issu
Github user chermenin commented on the issue:
https://github.com/apache/flink/pull/2623
I exclude Kryo as a dependency from Chill and add simple test to check Java
collections. Tests added to `flink-tests` because it is depends on
`flink-runtime` (where used Chill).
---
If your proj
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2696
Thanks for the review @StephanEwen. Yes let's do it as you've proposed.
I've opened an [issue](https://issues.apache.org/jira/browse/FLINK-4944) for
replacing Akka's death watch with our own hea
[
https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-4037.
---
Resolution: Fixed
Fix Version/s: 1.2.0
> Introduce ArchivedExecutionGraph without any u
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2697
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature i
[
https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612084#comment-15612084
]
ASF GitHub Bot commented on FLINK-3347:
---
Github user tillrohrmann commented on the i
Till Rohrmann created FLINK-4944:
Summary: Replace Akka's deatch watch with own heartbeat on the TM
side
Key: FLINK-4944
URL: https://issues.apache.org/jira/browse/FLINK-4944
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15612066#comment-15612066
]
ASF GitHub Bot commented on FLINK-3347:
---
Github user tillrohrmann closed the pull re
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2691
Thanks for the reviews @StephanEwen and @aljoscha ! I addressed your
comments in my last commit.
---
If your project is set up for it, you can reply to this email and have your
reply appear o
[
https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15611984#comment-15611984
]
ASF GitHub Bot commented on FLINK-4910:
---
Github user StefanRRichter commented on the
[
https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15611981#comment-15611981
]
ASF GitHub Bot commented on FLINK-4876:
---
Github user attachmentgenie commented on th
Github user attachmentgenie commented on the issue:
https://github.com/apache/flink/pull/2680
@StephanEwen seems reasonable thing to do, i updated the code to use the
new ConfigOption method
---
If your project is set up for it, you can reply to this email and have your
reply appear
1 - 100 of 209 matches
Mail list logo
