Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1908#discussion_r60186786
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobCache.java ---
@@ -200,10 +200,14 @@ public void delete(BlobKey key) throws IOException{
[
https://issues.apache.org/jira/browse/FLINK-3781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247338#comment-15247338
]
ASF GitHub Bot commented on FLINK-3781:
---
Github user uce commented on a diff in the
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1908#issuecomment-211782356
Thanks for the contribution! I had an inline comment. If that's fixed, this
looks good.
---
If your project is set up for it, you can reply to this email and have your
repl
[
https://issues.apache.org/jira/browse/FLINK-3781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247341#comment-15247341
]
ASF GitHub Bot commented on FLINK-3781:
---
Github user uce commented on the pull reque
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1906#discussion_r60187290
--- Diff:
flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkILoop.scala ---
@@ -72,7 +72,12 @@ class FlinkILoop(
// create our e
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1906#discussion_r60187361
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java
---
@@ -90,7 +90,7 @@ public RemoteStreamEnv
[
https://issues.apache.org/jira/browse/FLINK-3778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247344#comment-15247344
]
ASF GitHub Bot commented on FLINK-3778:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247345#comment-15247345
]
ASF GitHub Bot commented on FLINK-3778:
---
Github user uce commented on a diff in the
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1906#issuecomment-211783962
Changes look good to me. +1 to merge (I did not try it out though).
---
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-3778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247347#comment-15247347
]
ASF GitHub Bot commented on FLINK-3778:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1905#issuecomment-211784417
Thank you for this great contributio! I think that CEP and a concise Scala
API go very well together. :-) I'm not a Scala expert, but I'll also have a
look later.
---
If y
[
https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247350#comment-15247350
]
ASF GitHub Bot commented on FLINK-3708:
---
Github user uce commented on the pull reque
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1893
---
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-3748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247353#comment-15247353
]
ASF GitHub Bot commented on FLINK-3748:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-3748.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in 4be297ec29601a25ee5c12268d38b5f4f6203bd6.
Sergio RamÃrez created FLINK-3784:
-
Summary: Unexpected results using collect() in
RichMapPartitionFunction
Key: FLINK-3784
URL: https://issues.apache.org/jira/browse/FLINK-3784
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247406#comment-15247406
]
Flavio Pompermaier commented on FLINK-3777:
---
I issued a PR yesterday (https://gi
Github user StefanRRichter commented on the pull request:
https://github.com/apache/flink/pull/1905#issuecomment-211819580
Thanks Ufuk! I just saw that the build actually failed and it seems to me
that the problem is indeed related to removing the dependency to asm from the
pom.xml as
[
https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247413#comment-15247413
]
ASF GitHub Bot commented on FLINK-3708:
---
Github user StefanRRichter commented on the
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1910
[FLINK-3230] Add producer for Amazon Kinesis Streams into Flink
I've tested this connector against two kinesis streams. Since Kinesis is a
hosted service, I can not implement a full integration tes
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247437#comment-15247437
]
ASF GitHub Bot commented on FLINK-3230:
---
GitHub user rmetzger opened a pull request:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60202074
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -0,0 +1
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247440#comment-15247440
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247449#comment-15247449
]
ASF GitHub Bot commented on FLINK-3230:
---
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/1910#discussion_r60202840
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -0
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60203894
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -0,0 +1
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247457#comment-15247457
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60204277
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/KinesisSerializationSchema.java
---
@@ -
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247461#comment-15247461
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60204401
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/examples/ProduceIntoKinesis.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247463#comment-15247463
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247472#comment-15247472
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60204721
--- Diff: flink-streaming-connectors/flink-connector-twitter/pom.xml ---
@@ -35,6 +35,11 @@ under the License.
jar
+
+ 2.2
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60204861
--- Diff: flink-streaming-connectors/flink-connector-twitter/pom.xml ---
@@ -35,6 +35,11 @@ under the License.
jar
+
+
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1905#issuecomment-211840791
Does anybody know why we needed to add the asm dependency for gelly scala?
@tillrohrmann @vasia ?
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247476#comment-15247476
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247478#comment-15247478
]
ASF GitHub Bot commented on FLINK-3708:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247480#comment-15247480
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60205005
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -0,0 +1
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60205778
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -0,0 +1
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/1905#issuecomment-211843938
It looks like it was added as part of
[FLINK-3136](https://issues.apache.org/jira/browse/FLINK-3136).
---
If your project is set up for it, you can reply to this email an
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247488#comment-15247488
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3708?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247487#comment-15247487
]
ASF GitHub Bot commented on FLINK-3708:
---
Github user vasia commented on the pull req
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60205881
--- Diff: flink-streaming-connectors/flink-connector-twitter/pom.xml ---
@@ -35,6 +35,11 @@ under the License.
jar
+
+ 2.2
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247492#comment-15247492
]
ASF GitHub Bot commented on FLINK-3229:
---
GitHub user tzulitai opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247489#comment-15247489
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user uce commented on a diff in the
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/1911
[FLINK-3229] Flink streaming consumer for AWS Kinesis
I've been using this consumer for a while in off-production environments.
I understand we should have good test coverage for each PR, but si
[
https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247406#comment-15247406
]
Flavio Pompermaier edited comment on FLINK-3777 at 4/19/16 10:19 AM:
---
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60206533
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -0,0 +1
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247500#comment-15247500
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user uce commented on a diff in the
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1911#issuecomment-211846349
Thank you for opening a pull request for the consumer.
How about we proceed like this:
- I'm trying to get the producer code merged within the next 24 hours (feel
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60206857
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -0,0 +1
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247501#comment-15247501
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on the pull
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60206929
--- Diff: docs/apis/streaming/connectors/kinesis.md ---
@@ -0,0 +1,92 @@
+---
+title: "Amazon AWS Kinesis Streams Connector"
+
+# Sub-level navigat
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247504#comment-15247504
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247502#comment-15247502
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247506#comment-15247506
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-3368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3368:
--
Affects Version/s: (was: 1.0.0)
> Kafka 0.8 consumer fails to recover from broker shutdowns
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60207039
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -0,0
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60207207
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/examples/ProduceIntoKinesis.java
---
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247508#comment-15247508
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user zentol commented on a diff in t
Github user tzulitai commented on the pull request:
https://github.com/apache/flink/pull/1911#issuecomment-211847140
@rmetzger Sure, that seems reasonable. I'll wait until the producer is
merged and resubmit a new PR for the integrated consumer.
---
If your project is set up for it,
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60207331
--- Diff: flink-streaming-connectors/flink-connector-twitter/pom.xml ---
@@ -35,6 +35,11 @@ under the License.
jar
+
+
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247509#comment-15247509
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user tzulitai commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1911#issuecomment-211847420
Cool. You don't need to resubmit a new PR. By pushing new commits to your
`FLINK-3229` branch, the pull request will update automatically.
---
If your project is set u
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247511#comment-15247511
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user zentol commented on a diff in t
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1910#issuecomment-211847621
Great addition to have a producer to Kinesis. The changes look good
overall, I had some minor inline comments.
The main concern is that we can only test this with a
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247512#comment-15247512
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247514#comment-15247514
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user uce commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247540#comment-15247540
]
Chesnay Schepler commented on FLINK-1146:
-
was this issue resolved with the implem
[
https://issues.apache.org/jira/browse/FLINK-1394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247548#comment-15247548
]
Chesnay Schepler commented on FLINK-1394:
-
does this test still exist?
> TachyonF
Konstantin Knauf created FLINK-3785:
---
Summary: Add REST resource to query information about checkpointing
Key: FLINK-3785
URL: https://issues.apache.org/jira/browse/FLINK-3785
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247549#comment-15247549
]
Chesnay Schepler commented on FLINK-1427:
-
can we close this issue? ti appears tha
[
https://issues.apache.org/jira/browse/FLINK-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247554#comment-15247554
]
Chesnay Schepler commented on FLINK-2265:
-
The failure causing test no longer exis
[
https://issues.apache.org/jira/browse/FLINK-2344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler resolved FLINK-2344.
-
Resolution: Fixed
This class was removed in FLINK-3169.
> Deprecate/Remove the old Pact P
[
https://issues.apache.org/jira/browse/FLINK-2848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-2848.
---
Resolution: Invalid
The JMH license is not ASL compliant. Further discussions regarding a
fli
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1894#issuecomment-211872883
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 not have this feature
enable
[
https://issues.apache.org/jira/browse/FLINK-3764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247596#comment-15247596
]
ASF GitHub Bot commented on FLINK-3764:
---
Github user zentol commented on the pull re
Github user rawkintrevo commented on the pull request:
https://github.com/apache/flink/pull/1909#issuecomment-211873070
Nice. If this gets merged before https://github.com/apache/flink/pull/1898
I'll integrate it in. Otherwise I'll open a seperate PR after.
---
If your project is s
[
https://issues.apache.org/jira/browse/FLINK-3783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247597#comment-15247597
]
ASF GitHub Bot commented on FLINK-3783:
---
Github user rawkintrevo commented on the pu
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/1912
[FLINK-3086] [table] ExpressionParser does not support concatenation of
suffix operations
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check
[
https://issues.apache.org/jira/browse/FLINK-3086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247608#comment-15247608
]
ASF GitHub Bot commented on FLINK-3086:
---
GitHub user twalthr opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247613#comment-15247613
]
ASF GitHub Bot commented on FLINK-3764:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1894
---
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-3764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-3764.
---
Resolution: Fixed
Fixed in 716d832098b47ec19c6f5c675eb461d3ba96f60a
> LeaderChangeStateCleanu
[
https://issues.apache.org/jira/browse/FLINK-1427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-1427.
-
Resolution: Won't Fix
Thanks, closing for now.
> Configuration through environment variab
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/1904#discussion_r60217702
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java ---
@@ -133,26 +137,31 @@ public RemoteEnvironment(String host, int port,
[
https://issues.apache.org/jira/browse/FLINK-3774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247621#comment-15247621
]
ASF GitHub Bot commented on FLINK-3774:
---
Github user zentol commented on a diff in t
Timo Walther created FLINK-3786:
---
Summary: Add BigDecimal and BigInteger as Basic types
Key: FLINK-3786
URL: https://issues.apache.org/jira/browse/FLINK-3786
Project: Flink
Issue Type: New Feat
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1881#issuecomment-211892621
@vasia and @fhueske: I have opened FLINK-3786 for a long-term solution ;-)
I will start working on this issue.
---
If your project is set up for it, you can reply to
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60219525
--- Diff: flink-streaming-connectors/flink-connector-twitter/pom.xml ---
@@ -35,6 +35,11 @@ under the License.
jar
+
+
[
https://issues.apache.org/jira/browse/FLINK-3749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247635#comment-15247635
]
ASF GitHub Bot commented on FLINK-3749:
---
Github user twalthr commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247636#comment-15247636
]
ASF GitHub Bot commented on FLINK-3230:
---
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/1910#discussion_r60219813
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -0
[
https://issues.apache.org/jira/browse/FLINK-3230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247639#comment-15247639
]
ASF GitHub Bot commented on FLINK-3230:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-3701:
-
Assignee: Maximilian Michels
> Cant call execute after first execution
>
[
https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247644#comment-15247644
]
Maximilian Michels commented on FLINK-3701:
---
The issue is that the serializer li
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1913
[FLINK-3701] reuse serializer lists in ExecutionConfig
https://issues.apache.org/jira/browse/FLINK-3701
You can merge this pull request into a Git repository by running:
$ git pull https://github.c
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1910#discussion_r60220590
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
---
@@ -0
[
https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247645#comment-15247645
]
ASF GitHub Bot commented on FLINK-3701:
---
GitHub user mxm opened a pull request:
1 - 100 of 158 matches
Mail list logo
