[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933174#comment-14933174
]
Wilmer DAZA edited comment on FLINK-2168 at 9/29/15 6:53 AM:
-
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1189#issuecomment-143916305
Looks like fail on unrelated Kafka partition error
---
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-2775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14934448#comment-14934448
]
ASF GitHub Bot commented on FLINK-2775:
---
Github user hsaputra commented on the pull
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1188#issuecomment-143909415
+1
Looks good 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 h
Github user rerngvit commented on the pull request:
https://github.com/apache/flink/pull/1188#issuecomment-143905322
@hsaputra Thank you for reviewing this PR. I squashed the commits into one
as per your comment. Please have a look.
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14934235#comment-14934235
]
ASF GitHub Bot commented on FLINK-2561:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1183
---
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
Maximilian Michels created FLINK-2776:
-
Summary: Print job id to standard out on CLI job submission
Key: FLINK-2776
URL: https://issues.apache.org/jira/browse/FLINK-2776
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-2773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933984#comment-14933984
]
Fabian Hueske commented on FLINK-2773:
--
Nope, but I can easily reproduce the issue. W
[
https://issues.apache.org/jira/browse/FLINK-2774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933975#comment-14933975
]
Maximilian Michels commented on FLINK-2774:
---
+1
> Import Java API classes auto
[
https://issues.apache.org/jira/browse/FLINK-2773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-2773:
-
Assignee: Maximilian Michels
> OutOfMemoryError on YARN Session
> ---
[
https://issues.apache.org/jira/browse/FLINK-2773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933970#comment-14933970
]
Maximilian Michels commented on FLINK-2773:
---
The maximum direct memory size appe
[
https://issues.apache.org/jira/browse/FLINK-2762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-2762:
-
Assignee: Maximilian Michels
> Job Runtime: -1 ms
> --
>
>
Henry Saputra created FLINK-2775:
Summary: [CLEANUP] Cleanup code as part of theme to be more
consistent on Utils classes
Key: FLINK-2775
URL: https://issues.apache.org/jira/browse/FLINK-2775
Project:
[
https://issues.apache.org/jira/browse/FLINK-2775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933920#comment-14933920
]
Henry Saputra commented on FLINK-2775:
--
PR: https://github.com/apache/flink/pull/1189
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1188#issuecomment-143862641
Could you squash the commits into one please?
---
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
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/1188#issuecomment-143862604
+1
LGTM
---
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
GitHub user hsaputra opened a pull request:
https://github.com/apache/flink/pull/1189
[CLEANUP] Cleanup code as part of theme to be more consistent
As part of the theme to help make the code more consistent, add cleanup to
Utils classes:
-) Add final class modifier to the XXXUti
[
https://issues.apache.org/jira/browse/FLINK-2748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-2748:
-
Assignee: Maximilian Michels
> Accumulator fetch failure leads to duplicate job r
[
https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martin Liesenberg updated FLINK-2731:
-
Assignee: Piotr Godek (was: Martin Liesenberg)
> Add JobManager log file access
> ---
[
https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martin Liesenberg reassigned FLINK-2732:
Assignee: Martin Liesenberg
> Add access to the TaskManagers' log file and out file
[
https://issues.apache.org/jira/browse/FLINK-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933817#comment-14933817
]
rerngvit yanggratoke commented on FLINK-2169:
-
[~fhueske] I have a question. T
GitHub user rerngvit opened a pull request:
https://github.com/apache/flink/pull/1188
[Flink-2768][Documentation] Fix wrong java version requirement in quickstart
Fix wrong java version requirement in quickstart (1.6 -> 1.7)
You can merge this pull request into a Git repository by r
Github user rerngvit closed the pull request at:
https://github.com/apache/flink/pull/1187
---
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-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933753#comment-14933753
]
rerngvit yanggratoke commented on FLINK-2768:
-
[~chiwanpark] I have a PR for t
GitHub user rerngvit opened a pull request:
https://github.com/apache/flink/pull/1187
[Flink-2751][Documentation] Fix wrong java version requirement in quickstart
Fix wrong java version requirement in quickstart (1.6 -> 1.7)
You can merge this pull request into a Git repository by r
[
https://issues.apache.org/jira/browse/FLINK-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933746#comment-14933746
]
Fabian Hueske commented on FLINK-2768:
--
Cool! I assigned the issue to you.
Let us kn
[
https://issues.apache.org/jira/browse/FLINK-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2768:
-
Assignee: rerngvit yanggratoke
> Wrong Java version requirements in "Quickstart: Scala API" page
>
[
https://issues.apache.org/jira/browse/FLINK-2768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933730#comment-14933730
]
rerngvit yanggratoke commented on FLINK-2768:
-
I would like to work on this is
Till Rohrmann created FLINK-2774:
Summary: Import Java API classes automatically in Flink's Scala
shell
Key: FLINK-2774
URL: https://issues.apache.org/jira/browse/FLINK-2774
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-2753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-2753.
-
Resolution: Fixed
Implemented in
https://github.com/apache/flink/commit/dd51c97741b336d3a
[
https://issues.apache.org/jira/browse/FLINK-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-2677.
-
Resolution: Fixed
Resolved in
https://github.com/apache/flink/commit/dd51c97741b336d3a11e
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1184
---
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-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933507#comment-14933507
]
ASF GitHub Bot commented on FLINK-2677:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-2712:
Assignee: Fabian Hueske (was: Chiwan Park)
> Add some description about tests to "How to C
[
https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933491#comment-14933491
]
Aljoscha Krettek commented on FLINK-2600:
-
This sounds good. But then we should mo
Fabian Hueske created FLINK-2773:
Summary: OutOfMemoryError on YARN Session
Key: FLINK-2773
URL: https://issues.apache.org/jira/browse/FLINK-2773
Project: Flink
Issue Type: Bug
Comp
[
https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933418#comment-14933418
]
Stephan Ewen commented on FLINK-2600:
-
How about we start a new maven project for "man
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1184#issuecomment-143764435
I assume global windows here means something different than the old API
implied with global windows (= discretization across streams, before grouping).
From
[
https://issues.apache.org/jira/browse/FLINK-2613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933402#comment-14933402
]
ASF GitHub Bot commented on FLINK-2613:
---
Github user nikste closed the pull request
Github user nikste closed the pull request at:
https://github.com/apache/flink/pull/1106
---
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-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933388#comment-14933388
]
ASF GitHub Bot commented on FLINK-2677:
---
Github user StephanEwen commented on the pu
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1181#issuecomment-143749079
If no objections I will merge this.
---
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 no
[
https://issues.apache.org/jira/browse/FLINK-2764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933310#comment-14933310
]
ASF GitHub Bot commented on FLINK-2764:
---
Github user mjsax commented on the pull req
[
https://issues.apache.org/jira/browse/FLINK-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933254#comment-14933254
]
ASF GitHub Bot commented on FLINK-2677:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1184#issuecomment-143735489
One thing to note here is that you cannot use the old `TriggerPolicy` and
`EvictionPolicy` anymore. The old concept of windowing helpers is replaced by
windowing polici
[
https://issues.apache.org/jira/browse/FLINK-2766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933247#comment-14933247
]
Stephan Ewen commented on FLINK-2766:
-
All calls to create InetAddress URL representat
[
https://issues.apache.org/jira/browse/FLINK-2766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-2766:
Priority: Blocker (was: Critical)
> Bad ipv6 urls
> -
>
> Key: FLINK-27
[
https://issues.apache.org/jira/browse/FLINK-2766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-2766:
Priority: Critical (was: Major)
> Bad ipv6 urls
> -
>
> Key: FLINK-2766
[
https://issues.apache.org/jira/browse/FLINK-2763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933239#comment-14933239
]
Stephan Ewen commented on FLINK-2763:
-
If the join tries to spill a partition with onl
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1184#issuecomment-143728731
Event-time windowing is supported if you manually enable watermarks using
`setWatermarkInterval` (it is still called `setAutoWatermarkInterval` but I
want to change thi
[
https://issues.apache.org/jira/browse/FLINK-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933231#comment-14933231
]
ASF GitHub Bot commented on FLINK-2677:
---
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933227#comment-14933227
]
ASF GitHub Bot commented on FLINK-2167:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1127#issuecomment-143728302
Don't worry, everyone was once a starter in Scala. :smiley:
You can also leave the `supports*` methods in if you think that they might
be necessary in the fut
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1127#discussion_r40545392
--- Diff: flink-staging/flink-table/pom.xml ---
@@ -37,7 +37,7 @@ under the License.
com.google.guava
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933224#comment-14933224
]
ASF GitHub Bot commented on FLINK-2167:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933225#comment-14933225
]
ASF GitHub Bot commented on FLINK-2167:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1127#discussion_r40545360
--- Diff: flink-staging/flink-table/pom.xml ---
@@ -59,6 +59,12 @@ under the License.
+ org.apac
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1183#issuecomment-143725226
Thank you for the review @StephanEwen! I'll address your comments and merge
later.
---
If your project is set up for it, you can reply to this email and have your
reply a
[
https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933216#comment-14933216
]
ASF GitHub Bot commented on FLINK-2561:
---
Github user vasia commented on the pull req
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1183#discussion_r40544282
--- Diff:
flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple2ToVertexMap.scala
---
@@ -0,0 +1,31 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933213#comment-14933213
]
ASF GitHub Bot commented on FLINK-2561:
---
Github user vasia commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933189#comment-14933189
]
ASF GitHub Bot commented on FLINK-2677:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933188#comment-14933188
]
ASF GitHub Bot commented on FLINK-2677:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1184#issuecomment-143718922
A follow-up question: How far do the implementations support event-time
based windowing so far?
---
If your project is set up for it, you can reply to this email an
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1184#issuecomment-143718845
Very nice. Just tried this out, the examples seem to work nicely.
+1 to merge this!
---
If your project is set up for it, you can reply to this email and ha
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1127#issuecomment-143718074
Thanks @aljoscha for reviewing my code! Sorry for the bad Scala style. This
was my first really large Scala code project I wrote (not just small scripts),
I'm still lear
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933183#comment-14933183
]
ASF GitHub Bot commented on FLINK-2167:
---
Github user twalthr commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933180#comment-14933180
]
ASF GitHub Bot commented on FLINK-1719:
---
Github user JonathanH5 commented on a diff
Github user JonathanH5 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1156#discussion_r40541853
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/MultinomialNaiveBayes.scala
---
@@ -0,0 +1,900 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933174#comment-14933174
]
Wilmer DAZA commented on FLINK-2168:
I saw this as an starter issue, and I want to sta
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1183#issuecomment-143714240
Looks good to me!
One style comment: I think that `collect()` should be written with
parenthesis. In Scala, you use parenthesis if the methods are not purely
[
https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933167#comment-14933167
]
ASF GitHub Bot commented on FLINK-2561:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933164#comment-14933164
]
ASF GitHub Bot commented on FLINK-2167:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1127#discussion_r40540522
--- Diff: flink-staging/flink-table/pom.xml ---
@@ -59,6 +59,12 @@ under the License.
+ org.apach
[
https://issues.apache.org/jira/browse/FLINK-2561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933162#comment-14933162
]
ASF GitHub Bot commented on FLINK-2561:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1183#discussion_r40540447
--- Diff:
flink-staging/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/utils/Tuple2ToVertexMap.scala
---
@@ -0,0 +1,31 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933157#comment-14933157
]
ASF GitHub Bot commented on FLINK-2167:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933158#comment-14933158
]
ASF GitHub Bot commented on FLINK-2769:
---
Github user StephanEwen commented on the pu
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1127#discussion_r40540138
--- Diff: flink-staging/flink-table/pom.xml ---
@@ -37,7 +37,7 @@ under the License.
com.google.guava
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1185#issuecomment-143713277
+1, looks good.
I think the ports / URLs were in there, because originally we had two
backend servers running (the old one and the new one) while gradually
Till Rohrmann created FLINK-2772:
Summary: Introduce dedicated garbage collector config parameter
and set default values for batch and streaming
Key: FLINK-2772
URL: https://issues.apache.org/jira/browse/FLINK-277
Till Rohrmann created FLINK-2771:
Summary: IterateTest.testSimpleIteration fails on Travis
Key: FLINK-2771
URL: https://issues.apache.org/jira/browse/FLINK-2771
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-2695:
--
Doesn't seem to have made the test fully stable:
https://s3.amazonaws.com/archive.travis-ci.org/job
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933139#comment-14933139
]
ASF GitHub Bot commented on FLINK-1719:
---
Github user JonathanH5 commented on the pul
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933137#comment-14933137
]
ASF GitHub Bot commented on FLINK-1719:
---
Github user JonathanH5 commented on a diff
Github user JonathanH5 commented on the pull request:
https://github.com/apache/flink/pull/1156#issuecomment-143705252
FYI: styling issues fixed, I will now extend my documentation and have a
look at the mapWithBcSet method.
---
If your project is set up for it, you can reply to this
Github user JonathanH5 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1156#discussion_r40538554
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/classification/MultinomialNaiveBayes.scala
---
@@ -0,0 +1,900 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933135#comment-14933135
]
Till Rohrmann commented on FLINK-2392:
--
Another one with the master from Friday, the
GitHub user sachingoel0101 opened a pull request:
https://github.com/apache/flink/pull/1186
[FLINK-1966][ml]Add support for Predictive Model Markup Language
1. Adds an interface to allow exporting of models to PMML format.
2. Implements export methods for the existing SVM and Reg
[
https://issues.apache.org/jira/browse/FLINK-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933133#comment-14933133
]
ASF GitHub Bot commented on FLINK-1966:
---
GitHub user sachingoel0101 opened a pull re
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933128#comment-14933128
]
ASF GitHub Bot commented on FLINK-2167:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1127#issuecomment-143703367
Hi,
I like the work. :smile:
Some remarks about Scala style. We are trying to make our Scala code more
consistent. Mostly, I didn't comment everything, jus
[
https://issues.apache.org/jira/browse/FLINK-7?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933125#comment-14933125
]
Chengxiang Li commented on FLINK-7:
---
The sample operator has been enabled at
[FLINK-1901|h
[
https://issues.apache.org/jira/browse/FLINK-2690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-2690.
--
Resolution: Fixed
Fixed via 501a9b0854995b3de1c293b3391eeb3048daeef0
> CsvInputFormat cannot fi
[
https://issues.apache.org/jira/browse/FLINK-2690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933122#comment-14933122
]
ASF GitHub Bot commented on FLINK-2690:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1141
---
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-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933117#comment-14933117
]
ASF GitHub Bot commented on FLINK-2167:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/1127#discussion_r40536932
--- Diff:
flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/expressions/analysis/PredicateFilter.scala
---
@@ -0,0 +1,88 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14933110#comment-14933110
]
ASF GitHub Bot commented on FLINK-2167:
---
Github user aljoscha commented on a diff in
1 - 100 of 116 matches
Mail list logo