[
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
[
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 ^
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
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230443#comment-15230443
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230445#comment-15230445
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-3640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230383#comment-15230383
]
ASF GitHub Bot commented on FLINK-3640:
---
GitHub user vasia opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230430#comment-15230430
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on a diff in the pull
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230124#comment-15230124
]
Konstantin Knauf commented on FLINK-3713:
-
I will give that a try and report.
> DisposeSavepoint
[
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
>
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
[
https://issues.apache.org/jira/browse/FLINK-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230270#comment-15230270
]
ASF GitHub Bot commented on FLINK-3697:
---
Github user asfgit closed the pull request at:
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
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
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-3634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230170#comment-15230170
]
ASF GitHub Bot commented on FLINK-3634:
---
Github user fhueske commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230182#comment-15230182
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230257#comment-15230257
]
ASF GitHub Bot commented on FLINK-3697:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230145#comment-15230145
]
ASF GitHub Bot commented on FLINK-2732:
---
Github user zentol commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230103#comment-15230103
]
Ufuk Celebi commented on FLINK-3713:
It applies for any custom state (I don't know for sure whether it
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-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230107#comment-15230107
]
ASF GitHub Bot commented on FLINK-2732:
---
Github user zentol commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230468#comment-15230468
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230822#comment-15230822
]
ASF GitHub Bot commented on FLINK-3664:
---
Github user zentol commented on the pull request:
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-3712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230462#comment-15230462
]
ASF GitHub Bot commented on FLINK-3712:
---
GitHub user rmetzger opened a pull request:
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
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 =
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=15230668#comment-15230668
]
ASF GitHub Bot commented on FLINK-3664:
---
Github user tlisonbee commented on the pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230464#comment-15230464
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230536#comment-15230536
]
ASF GitHub Bot commented on FLINK-3640:
---
Github user rmetzger commented on the pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-3665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230460#comment-15230460
]
ASF GitHub Bot commented on FLINK-3665:
---
Github user fhueske commented on a diff in the pull
[
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
[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15231024#comment-15231024
]
Todd Lisonbee commented on FLINK-3716:
--
Increasing timeout from 60 seconds to 5 minutes allowed the
[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15231041#comment-15231041
]
Todd Lisonbee commented on FLINK-3716:
--
Most time is being spent at this point in the logs. Seems
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230891#comment-15230891
]
Konstantin Knauf commented on FLINK-3669:
-
I have a first draft here:
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230927#comment-15230927
]
ASF GitHub Bot commented on FLINK-3398:
---
Github user wanderingbort commented on the pull request:
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
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:
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15231061#comment-15231061
]
ASF GitHub Bot commented on FLINK-2909:
---
Github user greghogan commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15231380#comment-15231380
]
Todd Lisonbee commented on FLINK-3716:
--
I enabled more logging to see what was happening during the
[
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=15229941#comment-15229941
]
ASF GitHub Bot commented on FLINK-3711:
---
Github user asfgit closed the pull request at:
[
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
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
[
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://issues.apache.org/jira/browse/FLINK-3711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15229936#comment-15229936
]
ASF GitHub Bot commented on FLINK-3711:
---
Github user aljoscha commented on 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
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:
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
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230043#comment-15230043
]
Ufuk Celebi commented on FLINK-3713:
This is unfortunately a known limitation
[
https://issues.apache.org/jira/browse/FLINK-3688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230059#comment-15230059
]
ASF GitHub Bot commented on FLINK-3688:
---
GitHub user knaufk opened a pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230050#comment-15230050
]
Robert Metzger commented on FLINK-3713:
---
One possible workaround for the issue is the following: You
[
https://issues.apache.org/jira/browse/FLINK-3654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230052#comment-15230052
]
ASF GitHub Bot commented on FLINK-3654:
---
Github user aljoscha commented on the pull request:
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-3654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230051#comment-15230051
]
ASF GitHub Bot commented on FLINK-3654:
---
Github user aljoscha closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15230058#comment-15230058
]
Konstantin Knauf commented on FLINK-3713:
-
Just for my understanding:
It says there
{quote}
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
73 matches
Mail list logo
