Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/603#discussion_r28488904
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.java
---
@@ -709,4 +
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/603#issuecomment-93665013
LGTM besides that one question.
---
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 h
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497668#comment-14497668
]
ASF GitHub Bot commented on FLINK-1753:
---
Github user mbalassi commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497667#comment-14497667
]
ASF GitHub Bot commented on FLINK-1753:
---
Github user mbalassi commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/603#discussion_r28489103
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.java
---
@@ -709,4 +
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497671#comment-14497671
]
ASF GitHub Bot commented on FLINK-1753:
---
Github user rmetzger commented on a diff in
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/604
[FLINK-1875] Add figure explaining slots and parallelism
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink flink1875
Alternatively
[
https://issues.apache.org/jira/browse/FLINK-1875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497674#comment-14497674
]
ASF GitHub Bot commented on FLINK-1875:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-1875:
-
Assignee: Robert Metzger
> Add figure to documentation describing slots and parallelism
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/603
---
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497687#comment-14497687
]
ASF GitHub Bot commented on FLINK-1753:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497691#comment-14497691
]
Robert Metzger commented on FLINK-1753:
---
Added large record test in
http://git-wip-
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1753:
--
Description:
The current {{KafkaITCase}} is only doing a single test.
We need to refactor that
Github user andralungu commented on the pull request:
https://github.com/apache/flink/pull/537#issuecomment-93696531
Hi @vasia ,
The PR was updated to include your suggestions. Last test fails for some
reason, but that shouldn't get in the way of reviewers :)
As you c
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497855#comment-14497855
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user andralungu commented on the pul
Kostas Tzoumas created FLINK-1892:
-
Summary: Local job execution does not exit.
Key: FLINK-1892
URL: https://issues.apache.org/jira/browse/FLINK-1892
Project: Flink
Issue Type: Bug
Kostas Tzoumas created FLINK-1893:
-
Summary: Add Scala support for Flink on Tez
Key: FLINK-1893
URL: https://issues.apache.org/jira/browse/FLINK-1893
Project: Flink
Issue Type: Improvement
Kostas Tzoumas created FLINK-1894:
-
Summary: Add Tez execution mode to Flink command-line tools
Key: FLINK-1894
URL: https://issues.apache.org/jira/browse/FLINK-1894
Project: Flink
Issue Type
Kostas Tzoumas created FLINK-1895:
-
Summary: Add task chaining to Flink on Tez
Key: FLINK-1895
URL: https://issues.apache.org/jira/browse/FLINK-1895
Project: Flink
Issue Type: Improvement
Kostas Tzoumas created FLINK-1896:
-
Summary: Add broadcast variables feature to Flink on Tez
Key: FLINK-1896
URL: https://issues.apache.org/jira/browse/FLINK-1896
Project: Flink
Issue Type: I
Kostas Tzoumas created FLINK-1897:
-
Summary: Add accummulators and counters feature to Flink on Tez
Key: FLINK-1897
URL: https://issues.apache.org/jira/browse/FLINK-1897
Project: Flink
Issue
Kostas Tzoumas created FLINK-1898:
-
Summary: Add support for self-joins to Flink on Tez
Key: FLINK-1898
URL: https://issues.apache.org/jira/browse/FLINK-1898
Project: Flink
Issue Type: Bug
GitHub user tammymendt opened a pull request:
https://github.com/apache/flink/pull/605
[FLINK-1297] Added OperatorStatsAccumulator for tracking operator related
stats
The accumulator tracks min and max values, and estimates for count distinct
and heavy hitters.
The count d
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497903#comment-14497903
]
ASF GitHub Bot commented on FLINK-1297:
---
GitHub user tammymendt opened a pull reques
Felix Neutatz created FLINK-1899:
Summary: Table API Bug
Key: FLINK-1899
URL: https://issues.apache.org/jira/browse/FLINK-1899
Project: Flink
Issue Type: Bug
Components: Expression
[
https://issues.apache.org/jira/browse/FLINK-1899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497972#comment-14497972
]
Timo Walther commented on FLINK-1899:
-
You need to define a new name for your aggregat
[
https://issues.apache.org/jira/browse/FLINK-1899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497977#comment-14497977
]
Felix Neutatz commented on FLINK-1899:
--
Thanks Timo. That worked :)
> Table API Bug
[
https://issues.apache.org/jira/browse/FLINK-1899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Felix Neutatz resolved FLINK-1899.
--
Resolution: Fixed
> Table API Bug
> -
>
> Key: FLINK-1899
>
Timo Walther created FLINK-1900:
---
Summary: Table API documentation example does not work
Key: FLINK-1900
URL: https://issues.apache.org/jira/browse/FLINK-1900
Project: Flink
Issue Type: Bug
Github user aalexandrov commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-93719337
:+1: thanks for the great work! I'll review that (probably over the
weekend) and will appreciate if some of the core Flink committers (@sewen,
@rmetzger, @fhueske) can
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14497982#comment-14497982
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user aalexandrov commented on the pu
Github user balidani commented on the pull request:
https://github.com/apache/flink/pull/491#issuecomment-93723421
Hi!
This PR was closed, but the commit right after mine removes the part that
fixed the windows issue.
https://github.com/apache/flink/commit/23fe00629e4b36e
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/491#issuecomment-93728544
This issue is discussed in FLINK-1848.
---
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-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14498021#comment-14498021
]
ASF GitHub Bot commented on FLINK-1848:
---
Github user fhueske commented on the pull r
Github user balidani commented on the pull request:
https://github.com/apache/flink/pull/491#issuecomment-93728981
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 have this feature
enabled
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-93730879
Nice, statistics collection :-)
I'll have a look at this PR.
It might take a few days as I am traveling.
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14498034#comment-14498034
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1753:
--
Description:
The current {{KafkaITCase}} is only doing a single test.
We need to refactor that
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/601#discussion_r28508734
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java ---
@@ -64,15 +64,19 @@
* @return the storage directory used by a B
[
https://issues.apache.org/jira/browse/FLINK-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14498044#comment-14498044
]
ASF GitHub Bot commented on FLINK-1891:
---
Github user fhueske commented on a diff in
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/601#issuecomment-93734377
Thanks for the PR.
Looks good to me, except for a possible minor improvement.
---
If your project is set up for it, you can reply to this email and have your
reply ap
[
https://issues.apache.org/jira/browse/FLINK-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14498045#comment-14498045
]
ASF GitHub Bot commented on FLINK-1891:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14498055#comment-14498055
]
Theodore Vasiloudis commented on FLINK-1807:
We need to be able to sample from
Theodore Vasiloudis created FLINK-1901:
--
Summary: Create sample operator for Dataset
Key: FLINK-1901
URL: https://issues.apache.org/jira/browse/FLINK-1901
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Theodore Vasiloudis closed FLINK-1901.
--
Resolution: Fixed
> Create sample operator for Dataset
> ---
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Theodore Vasiloudis reopened FLINK-1901:
> Create sample operator for Dataset
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-1742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14498115#comment-14498115
]
Theodore Vasiloudis commented on FLINK-1742:
The sample operator on Dataset co
Github user mjsax commented on a diff in the pull request:
https://github.com/apache/flink/pull/573#discussion_r28517070
--- Diff:
flink-staging/flink-streaming/flink-storm-compatibility/src/main/java/org/apache/flink/stormcompatibility/api/FlinkClient.java
---
@@ -0,0 +1,362 @@
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/606
[docs] Change doc layout
This is not completely done yet, but should suffice to give a feeling of
the new layout. I think this is a good improvement over our current state.
- Changed layout (sim
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/606#issuecomment-93763019
:+1: Looks much much better.
---
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
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/607
Make PersistentKafkaSource more configurable
The `PersistentKafkaSource` contained some hardcoded configuration values.
With this change I'm using more config values from the `ConsumerConfig`
Yo
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14498283#comment-14498283
]
ASF GitHub Bot commented on FLINK-1297:
---
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/605#discussion_r28528023
--- Diff: flink-core/pom.xml ---
@@ -63,6 +63,19 @@ under the License.
guava
${guava.version}
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/605#discussion_r28528360
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/accumulators/OperatorStatsAccumulator.java
---
@@ -0,0 +1,98 @@
+/*
+ * Licensed to th
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14498302#comment-14498302
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user rmetzger commented on a diff in
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/595#issuecomment-93798071
Thanks @mxm, appreciate the additional information about the PR
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Github user ktzoumas commented on the pull request:
https://github.com/apache/flink/pull/606#issuecomment-93837926
This is one of the best project documentations that I have seen. Thanks a
lot Ufuk for doing this! I would merge this as is.
Few minor thoughts I had when skimmin
57 matches
Mail list logo
