Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-93653085
Ah yes, it should be fine. I should have replied this as more generic
comment for future PRs.
Sorry if I confused you @gyfora
---
If your project is set up
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-93653375
Haha no problem. I will make sure it is more reviewable in the future PRs.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-93652334
It is already 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-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14497671#comment-14497671
]
ASF GitHub Bot commented on FLINK-1753:
---
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/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-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
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14497667#comment-14497667
]
ASF GitHub Bot commented on FLINK-1753:
---
Github user mbalassi commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14497668#comment-14497668
]
ASF GitHub Bot commented on FLINK-1753:
---
Github user mbalassi commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14497855#comment-14497855
]
ASF GitHub Bot commented on FLINK-1523:
---
Github user andralungu commented on the
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
[
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
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 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
[
https://issues.apache.org/jira/browse/FLINK-1875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14497674#comment-14497674
]
ASF GitHub Bot commented on FLINK-1875:
---
GitHub user rmetzger opened a pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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-tabpanelfocusedCommentId=14497691#comment-14497691
]
Robert Metzger commented on FLINK-1753:
---
Added large record test 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
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-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
[
https://issues.apache.org/jira/browse/FLINK-1899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14497972#comment-14497972
]
Timo Walther commented on FLINK-1899:
-
You need to define a new name for your
[
https://issues.apache.org/jira/browse/FLINK-1899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14497977#comment-14497977
]
Felix Neutatz commented on FLINK-1899:
--
Thanks Timo. That worked :)
Table API Bug
[
https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14498021#comment-14498021
]
ASF GitHub Bot commented on FLINK-1848:
---
Github user fhueske commented on the pull
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
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:all-tabpanel
]
Felix Neutatz resolved FLINK-1899.
--
Resolution: Fixed
Table API Bug
-
Key: FLINK-1899
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.
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
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 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
[
https://issues.apache.org/jira/browse/FLINK-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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/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-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
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14498055#comment-14498055
]
Theodore Vasiloudis commented on FLINK-1807:
We need to be able to sample from
[
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
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 @@
[
https://issues.apache.org/jira/browse/FLINK-1742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14498115#comment-14498115
]
Theodore Vasiloudis commented on FLINK-1742:
The sample operator on Dataset
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
[
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
--
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
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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_r28528360
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/accumulators/OperatorStatsAccumulator.java
---
@@ -0,0 +1,98 @@
+/*
+ * Licensed to
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`
[
https://issues.apache.org/jira/browse/FLINK-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14498045#comment-14498045
]
ASF GitHub Bot commented on FLINK-1891:
---
Github user fhueske commented on the pull
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:
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
49 matches
Mail list logo
