[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15231380#comment-15231380
]
Todd Lisonbee commented on FLINK-3716:
--
I enabled more logging to see what was happen
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15231061#comment-15231061
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user greghogan commented on the pull
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1807#issuecomment-207087689
Hi @vasia, I just pushed documentation for the graph generators. I did not
split the Gelly page since that should probably be a separate ticket (and
likely requires br
[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15231041#comment-15231041
]
Todd Lisonbee commented on FLINK-3716:
--
Most time is being spent at this point in the
[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15231024#comment-15231024
]
Todd Lisonbee commented on FLINK-3716:
--
Increasing timeout from 60 seconds to 5 minut
[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Todd Lisonbee updated FLINK-3716:
-
Description:
This is on the latest master 4/7/2016 with `mvn clean verify`.
Test also reliably
Todd Lisonbee created FLINK-3716:
Summary: Kafka08ITCase.testFailOnNoBroker() timing out before it
has a chance to pass
Key: FLINK-3716
URL: https://issues.apache.org/jira/browse/FLINK-3716
Project: F
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf reassigned FLINK-3669:
---
Assignee: Konstantin Knauf
> WindowOperator registers a lot of timers at StreamTask
>
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230927#comment-15230927
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user wanderingbort commented on the
Github user wanderingbort commented on the pull request:
https://github.com/apache/flink/pull/1690#issuecomment-207065222
I just wanted to echo @StephanEwen 's sentiment.
Flink's management of offsets seems to supersede the Kafka concept of
committed offsets (whether to ZK o
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230891#comment-15230891
]
Konstantin Knauf commented on FLINK-3669:
-
I have a first draft here: https://gith
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1859#issuecomment-207049231
It is indeed a flaky kafka test.
You don't have to worry about it, the majority of build passed we're good
on that front.
---
If your project is set up for it,
[
https://issues.apache.org/jira/browse/FLINK-3664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230822#comment-15230822
]
ASF GitHub Bot commented on FLINK-3664:
---
Github user zentol commented on the pull re
Github user tlisonbee commented on the pull request:
https://github.com/apache/flink/pull/1859#issuecomment-207017188
All of the builds are passing except for one, there is a failure in what
seems like a flaky Kafka test.
Does anyone have suggestions on how to get past this?
[
https://issues.apache.org/jira/browse/FLINK-3664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230668#comment-15230668
]
ASF GitHub Bot commented on FLINK-3664:
---
Github user tlisonbee commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230536#comment-15230536
]
ASF GitHub Bot commented on FLINK-3640:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1862#issuecomment-206986445
Awesome! Really cool to see that coming to Flink.
I played a bit around with it and it seems to work ;)
```java
Table table = tableEnv.fromDataSet(input)
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230468#comment-15230468
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1848#issuecomment-206969649
Hi @dawidwys, thanks for the PR. I had a few comments.
Please let me know if you have any questions regarding the nested and
flattened keys.
---
If your project i
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230464#comment-15230464
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1848#discussion_r58897266
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/PartitionITCase.java
---
@@ -546,6 +549,60 @@ public void testRangePartitionInIter
[
https://issues.apache.org/jira/browse/FLINK-3712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230462#comment-15230462
]
ASF GitHub Bot commented on FLINK-3712:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230460#comment-15230460
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1848#discussion_r58897094
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/javaApiOperators/PartitionITCase.java
---
@@ -546,6 +549,60 @@ public void testRangePartitionInIter
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1863
[FLINK-3712] Make all dynamic properties available to the CLI frontend
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink flink371
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230445#comment-15230445
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230443#comment-15230443
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1848#discussion_r58895433
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java
---
@@ -98,6 +101,14 @@ public PartitionOperator(DataSet input,
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1848#discussion_r58895362
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java
---
@@ -98,6 +101,14 @@ public PartitionOperator(DataSet input,
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2765:
--
Summary: Upgrade hbase version for hadoop-2 to 1.2 release (was: Upgrade
hbase version for hadoop-2 to 1.1 rele
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^ (subTaskStats.
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230430#comment-15230430
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1848#discussion_r58894245
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/operators/base/PartitionOperatorBase.java
---
@@ -51,12 +53,19 @@
private Partitioner
[
https://issues.apache.org/jira/browse/FLINK-3640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230383#comment-15230383
]
ASF GitHub Bot commented on FLINK-3640:
---
GitHub user vasia opened a pull request:
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1862
[FLINK-3640] Add support for SQL in DataSet programs
This PR adds basic support for batch SQL queries embedded in Table API
programs.
In order to run a SQL query, a `DataSet` or `Table` needs to b
[
https://issues.apache.org/jira/browse/FLINK-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-3697.
---
Resolution: Resolved
Fix Version/s: 1.1.0
Fixed for 1.1.0 in http://git-wip-us.apache.o
[
https://issues.apache.org/jira/browse/FLINK-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230270#comment-15230270
]
ASF GitHub Bot commented on FLINK-3697:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1851
---
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-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230257#comment-15230257
]
ASF GitHub Bot commented on FLINK-3697:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1851#issuecomment-206915028
I'll address Stephan's comment and merge the change
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If y
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230182#comment-15230182
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1848#issuecomment-206876652
Thanks for working on this issue and opening a PR @dawidwys!
I'll have a look at it and give feedback soon.
---
If your project is set up for it, you can reply to th
[
https://issues.apache.org/jira/browse/FLINK-3634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230170#comment-15230170
]
ASF GitHub Bot commented on FLINK-3634:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1817#issuecomment-206868628
Thanks for the update @greghogan. +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 pr
Aljoscha Krettek created FLINK-3715:
---
Summary: Move Accumulating/Discarding from Trigger to
WindowOperator
Key: FLINK-3715
URL: https://issues.apache.org/jira/browse/FLINK-3715
Project: Flink
Aljoscha Krettek created FLINK-3714:
---
Summary: Add Support for "Allowed Lateness"
Key: FLINK-3714
URL: https://issues.apache.org/jira/browse/FLINK-3714
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230145#comment-15230145
]
ASF GitHub Bot commented on FLINK-2732:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1790#issuecomment-206843425
Test failures should be resolved.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-3643:
Description:
I think there are several shortcomings in the current window system and I
star
[
https://issues.apache.org/jira/browse/FLINK-3643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-3643:
Summary: Improve Windowing (was: Improve Window Triggers)
> Improve Windowing
> ---
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230124#comment-15230124
]
Konstantin Knauf commented on FLINK-3713:
-
I will give that a try and report.
> D
[
https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230107#comment-15230107
]
ASF GitHub Bot commented on FLINK-2732:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1790#issuecomment-206823491
There appears to be a problem with the test, looking into it...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230103#comment-15230103
]
Ufuk Celebi commented on FLINK-3713:
It applies for any custom state (I don't know for
[
https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230059#comment-15230059
]
ASF GitHub Bot commented on FLINK-3688:
---
GitHub user knaufk opened a pull request:
GitHub user knaufk opened a pull request:
https://github.com/apache/flink/pull/1861
[FLINK-3688] WindowOperator.trigger() does not emit Watermark anymore
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into considerati
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230058#comment-15230058
]
Konstantin Knauf commented on FLINK-3713:
-
Just for my understanding:
It says the
[
https://issues.apache.org/jira/browse/FLINK-3654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3654.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Changed in
https://github.com/apache/flink/
[
https://issues.apache.org/jira/browse/FLINK-3654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230051#comment-15230051
]
ASF GitHub Bot commented on FLINK-3654:
---
Github user aljoscha closed the pull reques
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1850#issuecomment-206799977
Manually merged
---
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 featu
[
https://issues.apache.org/jira/browse/FLINK-3654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230052#comment-15230052
]
ASF GitHub Bot commented on FLINK-3654:
---
Github user aljoscha commented on the pull
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/1850
---
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 en
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230050#comment-15230050
]
Robert Metzger commented on FLINK-3713:
---
One possible workaround for the issue is th
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15230043#comment-15230043
]
Ufuk Celebi commented on FLINK-3713:
This is unfortunately a known limitation
(https:
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-3713:
Description:
The {{DisposeSavepoint}} message in the JobManager is using the system
classlo
Robert Metzger created FLINK-3713:
-
Summary: DisposeSavepoint message uses system classloader to
discard state
Key: FLINK-3713
URL: https://issues.apache.org/jira/browse/FLINK-3713
Project: Flink
Robert Metzger created FLINK-3712:
-
Summary: YARN client dynamic properties are not passed correctly
to the leader election service on the client
Key: FLINK-3712
URL: https://issues.apache.org/jira/browse/FLINK-37
[
https://issues.apache.org/jira/browse/FLINK-3711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-3711.
-
Resolution: Fixed
Fixed in
https://github.com/apache/flink/commit/e5b93da0eda610e163a5d4a
[
https://issues.apache.org/jira/browse/FLINK-3699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefano Baghino reassigned FLINK-3699:
--
Assignee: Stefano Baghino
> Allow per-job Kerberos authentication
> --
[
https://issues.apache.org/jira/browse/FLINK-3711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15229941#comment-15229941
]
ASF GitHub Bot commented on FLINK-3711:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1860
---
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-3711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15229936#comment-15229936
]
ASF GitHub Bot commented on FLINK-3711:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1860#issuecomment-206766766
Thanks for the fix! I'm 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
73 matches
Mail list logo
