Tzu-Li (Gordon) Tai created FLINK-3211:
--
Summary: Add AWS Kinesis streaming connector
Key: FLINK-3211
URL: https://issues.apache.org/jira/browse/FLINK-3211
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15090429#comment-15090429
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1397#issuecomment-170200015
Hi @rawkintrevo, you can convert scala Enum to Int like following:
```scala
object Parameter extends Enumeration {
type Parameter = Value
val P
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15090246#comment-15090246
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user rawkintrevo commented on the pu
Github user rawkintrevo commented on the pull request:
https://github.com/apache/flink/pull/1397#issuecomment-170162685
on your second point- I agree that Enum would be better for human readable
variable setting, but if one was doing a grid parameter search it would be
easier to searc
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2765:
--
Description:
Currently 0.98.11 is used:
{code}
0.98.11-hadoop2
{code}
Stable release for hadoop-
[
https://issues.apache.org/jira/browse/FLINK-3058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089798#comment-15089798
]
ASF GitHub Bot commented on FLINK-3058:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-170103132
There are some build instabilities with the new Kafka 0.9 code. I'll look
into it soon.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089649#comment-15089649
]
ASF GitHub Bot commented on FLINK-1870:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1483#issuecomment-170083592
I am big time skeptic when it comes to putting this into the
`RuntimeContext`.
If we really need to expose that beyond the `StreamInputProcessor`, it
would
[
https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089600#comment-15089600
]
ASF GitHub Bot commented on FLINK-1870:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1483#issuecomment-170073172
If you implement a Bolt you can retrieve this information from Storm. Thus,
the compatibility layer should provide this information, too.
---
If your project is set up fo
[
https://issues.apache.org/jira/browse/FLINK-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089572#comment-15089572
]
Ted Yu commented on FLINK-3210:
---
bq. The key can still contain something
I agree.
But why d
[
https://issues.apache.org/jira/browse/FLINK-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089566#comment-15089566
]
Robert Metzger commented on FLINK-3210:
---
I think this issue is invalid. A null value
Ted Yu created FLINK-3210:
-
Summary: Unnecessary call to deserializer#deserialize() in
LegacyFetcher#SimpleConsumerThread#run()
Key: FLINK-3210
URL: https://issues.apache.org/jira/browse/FLINK-3210
Project: F
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089529#comment-15089529
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r49211433
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala
---
@@ -54,14 +54,15 @@ abstract class GradientDe
[
https://issues.apache.org/jira/browse/FLINK-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089525#comment-15089525
]
ASF GitHub Bot commented on FLINK-1737:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1078
---
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-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089481#comment-15089481
]
ASF GitHub Bot commented on FLINK-1737:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1078#issuecomment-170050950
Looks really good :-) Thanks for your contribution @daniel-pape. Will merge
it.
---
If your project is set up for it, you can reply to this email and have your
rep
[
https://issues.apache.org/jira/browse/FLINK-3058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089436#comment-15089436
]
ASF GitHub Bot commented on FLINK-3058:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-170044651
Test cases `Kafka09ITCase.testMultipleSourcesOnePartition` and
`Kafka08ITCase.testOffsetInZookeeper` are failing in Travis build.
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089432#comment-15089432
]
ASF GitHub Bot commented on FLINK-1870:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1483#issuecomment-170044112
The user code should not deal with what channel an element came from. It
wires assumptions about the parallelism of the predecessor into the user code.
Adjustments o
[
https://issues.apache.org/jira/browse/FLINK-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089430#comment-15089430
]
ASF GitHub Bot commented on FLINK-3197:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1494#discussion_r49205022
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/BinaryInputFormat.java
---
@@ -213,9 +213,10 @@ protected SequentialStatistics
create
[
https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089428#comment-15089428
]
ASF GitHub Bot commented on FLINK-2125:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1491#issuecomment-170043300
Thanks for your contribution @ajaybhat.
The PR contains many whitespace changes. Would be good to avoid them.
I had a question concerning the implem
[
https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089426#comment-15089426
]
ASF GitHub Bot commented on FLINK-2125:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1491#discussion_r49204456
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java
---
@@ -84,25 +84,25 @@ publi
[
https://issues.apache.org/jira/browse/FLINK-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089368#comment-15089368
]
ASF GitHub Bot commented on FLINK-3189:
---
Github user mjsax commented on the pull req
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1493#issuecomment-170035218
Sure. Will do that.
---
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 feat
[
https://issues.apache.org/jira/browse/FLINK-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089354#comment-15089354
]
ASF GitHub Bot commented on FLINK-1712:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1492#issuecomment-170033507
Can you summarize what the changes from this pull request are? The set of
changes is too large for github to display.
---
If your project is set up for it, you can
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1493#issuecomment-170032469
Can you add a test case that guards this 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-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089344#comment-15089344
]
ASF GitHub Bot commented on FLINK-3189:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1494#discussion_r49199370
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/BinaryInputFormat.java
---
@@ -213,9 +213,10 @@ protected SequentialStatistics
createS
[
https://issues.apache.org/jira/browse/FLINK-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089343#comment-15089343
]
ASF GitHub Bot commented on FLINK-3197:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089155#comment-15089155
]
ASF GitHub Bot commented on FLINK-3192:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1477#issuecomment-169987537
I added two small comments in-line.
But there is another thing that came to my mind. A `Table` can be
constructed from any type of `DataSet` not just a `DataSource`.
[
https://issues.apache.org/jira/browse/FLINK-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089138#comment-15089138
]
ASF GitHub Bot commented on FLINK-3192:
---
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/1477#discussion_r49183864
--- Diff:
flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/explain/PlanJsonParser.java
---
@@ -0,0 +1,148 @@
+/*
+ * Licensed to t
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1477#discussion_r49183832
--- Diff:
flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/explain/PlanJsonParser.java
---
@@ -0,0 +1,148 @@
+/*
+ * Licensed to t
[
https://issues.apache.org/jira/browse/FLINK-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089141#comment-15089141
]
ASF GitHub Bot commented on FLINK-3192:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089075#comment-15089075
]
ASF GitHub Bot commented on FLINK-3192:
---
Github user gallenvara commented on the pul
Github user gallenvara commented on the pull request:
https://github.com/apache/flink/pull/1477#issuecomment-169967055
@ChengXiangLi @fhueske @rmetzger , thanks a lot for your suggestions. The
codes have been modified.
---
If your project is set up for it, you can reply to this emai
[
https://issues.apache.org/jira/browse/FLINK-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15088905#comment-15088905
]
ASF GitHub Bot commented on FLINK-3197:
---
Github user ramkrish86 commented on a diff
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1494#discussion_r49168115
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/BinaryInputFormat.java
---
@@ -213,9 +213,10 @@ protected SequentialStatistics
createSt
49 matches
Mail list logo
