[
https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15766350#comment-15766350
]
ASF GitHub Bot commented on FLINK-2186:
---
Github user tonycox commented on the issue:
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3012
Hi @StephanEwen could you look at 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 project does not have this feature
e
[
https://issues.apache.org/jira/browse/FLINK-5247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rohit Agarwal updated FLINK-5247:
-
Summary: Fix incorrect check in allowedLateness() method. Make it a no-op
for non-event time windo
[
https://issues.apache.org/jira/browse/FLINK-5247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15766088#comment-15766088
]
Rohit Agarwal commented on FLINK-5247:
--
Hi [~aljoscha],
I updated the PR with what b
[
https://issues.apache.org/jira/browse/FLINK-5370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15766023#comment-15766023
]
shijinkui edited comment on FLINK-5370 at 12/21/16 3:52 AM:
ru
[
https://issues.apache.org/jira/browse/FLINK-5370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15766023#comment-15766023
]
shijinkui commented on FLINK-5370:
--
window
> build failure for unit test of FileInputFor
Github user manuzhang commented on the issue:
https://github.com/apache/flink/pull/2756
@aljoscha @VenturaDelMonte This seems to be taking a long time. What is the
progress now ?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
[
https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15765805#comment-15765805
]
ASF GitHub Bot commented on FLINK-4997:
---
Github user manuzhang commented on the issu
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/2976
hi @chermenin , can you try to rebase this first, thanks.
---
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 ha
[
https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15765797#comment-15765797
]
ASF GitHub Bot commented on FLINK-5303:
---
Github user KurtYoung commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-2980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15765794#comment-15765794
]
ASF GitHub Bot commented on FLINK-2980:
---
Github user KurtYoung commented on the issu
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3026
hi @chermenin , can you try to rebase this first, seems consists lots of
conflicts now. I will try to review this after you rebase it.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15765735#comment-15765735
]
ASF GitHub Bot commented on FLINK-4905:
---
GitHub user BrainLogic opened a pull reques
GitHub user BrainLogic opened a pull request:
https://github.com/apache/flink/pull/3035
[ FLINK-4905] Kafka test instability IllegalStateException: Client is not
started
Root cause of the issue:
`notifyCheckpointComplete` can occur during the cancellation or
`runFetchLoop` fa
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15765160#comment-15765160
]
Ivan Mushketyk commented on FLINK-5280:
---
Hi Fabian,
Thank you for your reply.
At f
Ted Yu created FLINK-5376:
-
Summary: Misleading log statements in UnorderedStreamElementQueue
Key: FLINK-5376
URL: https://issues.apache.org/jira/browse/FLINK-5376
Project: Flink
Issue Type: Bug
Fabian Hueske created FLINK-5375:
Summary: Fix watermark documentation
Key: FLINK-5375
URL: https://issues.apache.org/jira/browse/FLINK-5375
Project: Flink
Issue Type: Bug
Component
Aljoscha Krettek created FLINK-5374:
---
Summary: Extend Unit Tests for RegisteredBackendStateMetaInfo
Key: FLINK-5374
URL: https://issues.apache.org/jira/browse/FLINK-5374
Project: Flink
Issu
Aljoscha Krettek created FLINK-5373:
---
Summary: Extend Unit Tests for StateAssignmentOperation
Key: FLINK-5373
URL: https://issues.apache.org/jira/browse/FLINK-5373
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-5367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5367.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in e42a173a62eea6318ad78b11db430d7f34af1711
>
[
https://issues.apache.org/jira/browse/FLINK-5367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5367.
---
> restore updates lost when merging recent doc refactoring
> -
[
https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4669.
---
> scala api createLocalEnvironment() function add default Configuration
> parameter
> ---
[
https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4669.
-
Resolution: Implemented
Fix Version/s: 1.2.0
Implemented in 570ed4e23a22381374c7a009f7cd0d7
[
https://issues.apache.org/jira/browse/FLINK-5369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5369.
---
> Rework jsr305 and logging dependencies
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-5369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5369.
-
Resolution: Fixed
Fixed via cefb8db3525dc25421d41cfcdaaac1bd5540bc68
> Rework jsr305 and logging
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764647#comment-15764647
]
Stephan Ewen commented on FLINK-4861:
-
First part is implemented in 5c76baa1734303a014
[
https://issues.apache.org/jira/browse/FLINK-5367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764643#comment-15764643
]
ASF GitHub Bot commented on FLINK-5367:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764644#comment-15764644
]
ASF GitHub Bot commented on FLINK-4973:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764645#comment-15764645
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764642#comment-15764642
]
ASF GitHub Bot commented on FLINK-4669:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3028
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3014
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2541
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3008
---
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-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4973.
---
> Flakey Yarn tests due to recently added latency marker
> ---
[
https://issues.apache.org/jira/browse/FLINK-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4973.
-
Resolution: Fixed
Fixed via ab2125b82ed10389dafecf1712efc1f8fb977c11
> Flakey Yarn tests due to r
Aljoscha Krettek created FLINK-5372:
---
Summary: Fix
RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()
Key: FLINK-5372
URL: https://issues.apache.org/jira/browse/FLINK-5372
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764555#comment-15764555
]
ASF GitHub Bot commented on FLINK-5363:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3034
R: @klou and @StephanEwen for review, please. (Or anyone who's interested,
of course)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-5363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764548#comment-15764548
]
ASF GitHub Bot commented on FLINK-5363:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/3034
[FLINK-5363] Fire timers when window state is currently empty
Before this change, when a Trigger sets a timer and that timer fires in
the future at a point when there is currently no data in the
[
https://issues.apache.org/jira/browse/FLINK-5293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5293.
---
Resolution: Fixed
Implemented in 216653ad5864302dbcda4be5b88a83c4c039a05c
> Make the Kafka co
[
https://issues.apache.org/jira/browse/FLINK-5294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5294.
---
Resolution: Fixed
Assignee: Kostas Kloudas
Fixed in b0e2a2c175d54346010ee4817d206bbeb403
[
https://issues.apache.org/jira/browse/FLINK-5317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5317.
---
Resolution: Fixed
Implemented in 1220230c624234a5fd5e2ef5855aebb294184462
> Make the continuo
[
https://issues.apache.org/jira/browse/FLINK-5295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5295.
---
Resolution: Fixed
Implemented in e0819dc7b72487670dd3ba06628980e27fdbedb0
> Migrate the Align
[
https://issues.apache.org/jira/browse/FLINK-5366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5366.
---
Resolution: Fixed
Added in 2cbd9f5d1ba43059b8bf748f97d2392b1e8f0ab3
> Add end-to-end tests fo
[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Mushin reassigned FLINK-5256:
---
Assignee: Anton Mushin
> Extend DataSetSingleRowJoin to support Left and Right joins
> --
[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764285#comment-15764285
]
ASF GitHub Bot commented on FLINK-5256:
---
GitHub user ex00 opened a pull request:
GitHub user ex00 opened a pull request:
https://github.com/apache/flink/pull/3033
[FLINK-5256] Extend DataSetSingleRowJoin to support Left and Right joins
add support outer joins with single record via DataSetSingleRowJoin
Thanks for contributing to Apache Flink. Before you
Github user chermenin commented on the issue:
https://github.com/apache/flink/pull/3021
Yep, i'll do a benchmark to test approaches and compare them each other at
this week. I will write the results here. Big thanks for your idea)
---
If your project is set up for it, you can reply t
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15764083#comment-15764083
]
ASF GitHub Bot commented on FLINK-3617:
---
Github user chermenin commented on the issu
Till Rohrmann created FLINK-5371:
Summary: Add documentation for async I/O
Key: FLINK-5371
URL: https://issues.apache.org/jira/browse/FLINK-5371
Project: Flink
Issue Type: Improvement
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3030
+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 th
[
https://issues.apache.org/jira/browse/FLINK-5369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15763889#comment-15763889
]
ASF GitHub Bot commented on FLINK-5369:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3029
(quickstart worked as well!)
---
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 wi
[
https://issues.apache.org/jira/browse/FLINK-5369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15763850#comment-15763850
]
ASF GitHub Bot commented on FLINK-5369:
---
Github user rmetzger commented on the issue
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3029
I've tested the change on a YARN cluster (I know there are tests for that).
I'm currently trying out the quickstarts as well.
---
If your project is set up for it, you can reply to this email and h
[
https://issues.apache.org/jira/browse/FLINK-5369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15763839#comment-15763839
]
ASF GitHub Bot commented on FLINK-5369:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/3029#discussion_r93206487
--- Diff: pom.xml ---
@@ -91,7 +91,6 @@ under the License.
1C
true
log4j-test.properties
- 1.7.7
[
https://issues.apache.org/jira/browse/FLINK-4669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15763828#comment-15763828
]
ASF GitHub Bot commented on FLINK-4669:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2541
Thanks, picking this pull request up and merging it...
---
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 hav
[
https://issues.apache.org/jira/browse/FLINK-5367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15763821#comment-15763821
]
ASF GitHub Bot commented on FLINK-5367:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3028
Thanks for fixing this. Merging...
---
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
enabl
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15763801#comment-15763801
]
ASF GitHub Bot commented on FLINK-3617:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3021
Looks like a good solution.
Since these serializers are very performance critical, I am curious what is
more efficient:
- The if-null-check you implemented here
- a try/catch block
[
https://issues.apache.org/jira/browse/FLINK-5370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15763775#comment-15763775
]
Stephan Ewen commented on FLINK-5370:
-
What OS do you have? The paths look a bit stran
[
https://issues.apache.org/jira/browse/FLINK-5244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Mushketyk reassigned FLINK-5244:
-
Assignee: Ivan Mushketyk
> Implement methods for BipartiteGraph transformations
> ---
[
https://issues.apache.org/jira/browse/FLINK-5370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15763767#comment-15763767
]
Stephan Ewen commented on FLINK-5370:
-
Is it possible that the test does not work prop
[
https://issues.apache.org/jira/browse/FLINK-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15763760#comment-15763760
]
ASF GitHub Bot commented on FLINK-5245:
---
GitHub user mushketyk opened a pull request
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/3032
[FLINK-5245] Implement BipartiteGraph mutations
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your cha
[
https://issues.apache.org/jira/browse/FLINK-5364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15763722#comment-15763722
]
Eron Wright commented on FLINK-5364:
-
Here's a WIP to show how I plan to fix the prob
[
https://issues.apache.org/jira/browse/FLINK-5342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15762989#comment-15762989
]
godfrey he edited comment on FLINK-5342 at 12/20/16 8:51 AM:
-
72 matches
Mail list logo
