[
https://issues.apache.org/jira/browse/FLINK-5012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643499#comment-15643499
]
Aljoscha Krettek commented on FLINK-5012:
-
The discussion was not about a way to e
[
https://issues.apache.org/jira/browse/FLINK-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643615#comment-15643615
]
Tzu-Li (Gordon) Tai commented on FLINK-5018:
Some updates after thinking about
[
https://issues.apache.org/jira/browse/FLINK-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643615#comment-15643615
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5018 at 11/7/16 9:28 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-4937:
--
Assignee: sunjincheng
> Add incremental group window aggregation for streaming Table API
>
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643637#comment-15643637
]
Zhijiang Wang commented on FLINK-4354:
--
Hi [~till.rohrmann], for heartbeat interactio
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643637#comment-15643637
]
Zhijiang Wang edited comment on FLINK-4354 at 11/7/16 9:41 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643637#comment-15643637
]
Zhijiang Wang edited comment on FLINK-4354 at 11/7/16 9:44 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643637#comment-15643637
]
Zhijiang Wang edited comment on FLINK-4354 at 11/7/16 9:46 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643702#comment-15643702
]
Aljoscha Krettek commented on FLINK-5018:
-
That sounds very reasonable. We could a
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643720#comment-15643720
]
Aljoscha Krettek commented on FLINK-5023:
-
I also thought about this. We shouldn't
Niels Basjes created FLINK-5025:
---
Summary: Job fails because of Optimizer bug
Key: FLINK-5025
URL: https://issues.apache.org/jira/browse/FLINK-5025
Project: Flink
Issue Type: Bug
Affects Ve
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2748
---
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-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643743#comment-15643743
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5018 at 11/7/16 10:20 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-5004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643742#comment-15643742
]
ASF GitHub Bot commented on FLINK-5004:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643743#comment-15643743
]
Tzu-Li (Gordon) Tai commented on FLINK-5018:
Good idea. This would be relevant
[
https://issues.apache.org/jira/browse/FLINK-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643752#comment-15643752
]
Niels Basjes commented on FLINK-5025:
-
See here for a minimal project that does this:
[
https://issues.apache.org/jira/browse/FLINK-5004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5004.
--
Resolution: Implemented
Fix Version/s: 1.2.0
Fixed in {{448d7f0}} (master).
> Add task manager o
[
https://issues.apache.org/jira/browse/FLINK-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-5025.
---
Resolution: Duplicate
> Job fails because of Optimizer bug
> -
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643764#comment-15643764
]
Chesnay Schepler commented on FLINK-2662:
-
[~nielsbasjes] reported another instanc
[
https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643773#comment-15643773
]
Aljoscha Krettek commented on FLINK-5024:
-
The idea sounds reasonable. If you look
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643775#comment-15643775
]
Aljoscha Krettek commented on FLINK-4856:
-
Thanks for taking care of this! Please
[
https://issues.apache.org/jira/browse/FLINK-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643784#comment-15643784
]
Fabian Hueske commented on FLINK-5025:
--
Thanks for reporting the bug [~nielsbasjes].
[
https://issues.apache.org/jira/browse/FLINK-5021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643785#comment-15643785
]
ASF GitHub Bot commented on FLINK-5021:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2763
[FLINK-5021] Makes the ContinuousFileReaderOperator rescalable.
This is the last PR that completes the refactoring of the
`ContinuousFileReaderOperator` so that it can be rescalable. With this, the
r
[
https://issues.apache.org/jira/browse/FLINK-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643788#comment-15643788
]
Fabian Hueske commented on FLINK-5025:
--
OK, [~Zentol] did that already. :-)
> Job fa
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2355#discussion_r86749516
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java
---
@@ -236,6 +236,6 @@ public int compare(Tim
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643804#comment-15643804
]
ASF GitHub Bot commented on FLINK-4282:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643814#comment-15643814
]
Niels Basjes commented on FLINK-5025:
-
Thanks. Jira is so slow right now I couldn't fi
[
https://issues.apache.org/jira/browse/FLINK-2662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643820#comment-15643820
]
Niels Basjes commented on FLINK-2662:
-
I have the full reproduction application availa
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/2764
[FLINK-5008] Update quickstart documentation
This PR updates the outdated quickstart guides regarding IDE setup and the
first example.
You can merge this pull request into a Git repository by running
[
https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643841#comment-15643841
]
ASF GitHub Bot commented on FLINK-5008:
---
GitHub user NicoK opened a pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2759#discussion_r86753077
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/WriteAheadSinkTestBase.java
---
@@ -158,17 +160,151 @@ public void t
[
https://issues.apache.org/jira/browse/FLINK-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643862#comment-15643862
]
ASF GitHub Bot commented on FLINK-5020:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643896#comment-15643896
]
ASF GitHub Bot commented on FLINK-4876:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2680
Thank you! I will check it out later today.
---
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
enab
[
https://issues.apache.org/jira/browse/FLINK-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643900#comment-15643900
]
ASF GitHub Bot commented on FLINK-5020:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2759#discussion_r86754225
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/WriteAheadSinkTestBase.java
---
@@ -158,17 +160,151 @@ public void t
[
https://issues.apache.org/jira/browse/FLINK-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643905#comment-15643905
]
ASF GitHub Bot commented on FLINK-5020:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2759#discussion_r86755620
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
[
https://issues.apache.org/jira/browse/FLINK-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643916#comment-15643916
]
ASF GitHub Bot commented on FLINK-5020:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643919#comment-15643919
]
ASF GitHub Bot commented on FLINK-5020:
---
Github user zentol commented on a diff in t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2759#discussion_r86757078
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java
---
@@ -300,5 +294,10 @@ public int hashC
[
https://issues.apache.org/jira/browse/FLINK-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643920#comment-15643920
]
ASF GitHub Bot commented on FLINK-5020:
---
Github user kl0u commented on a diff in the
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/2759#discussion_r86757109
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@
[
https://issues.apache.org/jira/browse/FLINK-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643923#comment-15643923
]
ASF GitHub Bot commented on FLINK-5020:
---
Github user zentol commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643925#comment-15643925
]
Xiaogang Shi commented on FLINK-5023:
-
The only old method affected is the `value()` m
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2759#discussion_r86757277
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/WriteAheadSinkTestBase.java
---
@@ -158,17 +160,151 @@ public void t
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2759#discussion_r86756773
--- Diff:
flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86759570
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,494 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86759643
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBuffer.java
---
@@ -0,0 +1,494 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643953#comment-15643953
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643954#comment-15643954
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2629
The `notifyCheckpointComplete` will mitigate the problem of adding latency
a little bit but not get rid of it because the tasks are only notified about a
completed checkpoint if the whole checkp
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643969#comment-15643969
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86762586
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -540,15 +540,12 @@ private boolean performC
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15643996#comment-15643996
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644006#comment-15644006
]
Nikolay Vasilishin commented on FLINK-4492:
---
I offer to close this issue as it s
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2759
have you tried the cassandra sink in an actual job?
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644032#comment-15644032
]
ASF GitHub Bot commented on FLINK-5020:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644135#comment-15644135
]
Aljoscha Krettek commented on FLINK-5016:
-
I saw another hanging test, this time f
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5016:
Attachment: testPreAggregatedSlidingTimeWindows[ROCKS_DB_FULLY_ASYNC].txt
> EventTimeWindowC
Aljoscha Krettek created FLINK-5026:
---
Summary: Rename TimelyFlatMap to Process
Key: FLINK-5026
URL: https://issues.apache.org/jira/browse/FLINK-5026
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644176#comment-15644176
]
Aljoscha Krettek commented on FLINK-5026:
-
This depends, of course, on FLINK-4992
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644209#comment-15644209
]
ASF GitHub Bot commented on FLINK-3873:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2762
Hi @mushketyk, thanks for this pull request!
I noticed, it addresses two separate issues: TableSources (FLINK-3871) and
TableSinks (FLINK-3873) for Avro-encoded Kafka topics. Would you mind,
spl
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2764
I haven't yet looked at this PR in detail but it looks to have some much
needed cleanup for the documentation.
Are we certain we need to abandon Eclipse as a viable IDE for Flink
developer
[
https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644239#comment-15644239
]
ASF GitHub Bot commented on FLINK-5008:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2731
@vasia the graphs have been removed.
---
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
enabl
[
https://issues.apache.org/jira/browse/FLINK-4934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644251#comment-15644251
]
ASF GitHub Bot commented on FLINK-4934:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2730
@vasia docs are updated. I also noted the dependence of the algorithm on
implementation of `equals()`. What are your thoughts on requiring vertex types
to implement `Comparable` instead?
---
If y
[
https://issues.apache.org/jira/browse/FLINK-4970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644285#comment-15644285
]
ASF GitHub Bot commented on FLINK-4970:
---
Github user greghogan commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2762
Hi @fhueske
Thank you for pointing this out. I didn't know that there are two separate
issues for that.
I can split this PR into two and put serializer, deserializer and table
sources
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644295#comment-15644295
]
ASF GitHub Bot commented on FLINK-3873:
---
Github user mushketyk commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4876.
--
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in {{718f6e4}} (master).
> Allow web interface to b
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2680
---
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-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644310#comment-15644310
]
ASF GitHub Bot commented on FLINK-4876:
---
Github user asfgit closed the pull request
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2730
Thanks! I agree on `Comparable` for vertex types. Good catch!
---
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 ha
[
https://issues.apache.org/jira/browse/FLINK-4970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644409#comment-15644409
]
ASF GitHub Bot commented on FLINK-4970:
---
Github user vasia commented on the issue:
Till Rohrmann created FLINK-5027:
Summary: FileSource finishes successfully with a wrong path
Key: FLINK-5027
URL: https://issues.apache.org/jira/browse/FLINK-5027
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1569#comment-1569
]
Boris Osipov commented on FLINK-4890:
-
I've reproduced this issue on my environment.
A
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644451#comment-15644451
]
Stephan Ewen commented on FLINK-5023:
-
I agree with [~xiaogang.shi] - do we really nee
[
https://issues.apache.org/jira/browse/FLINK-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644457#comment-15644457
]
Boris Osipov commented on FLINK-4890:
-
It's related to FLINK-3677
> FileInputFormatTe
[
https://issues.apache.org/jira/browse/FLINK-4952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4952.
---
Resolution: Fixed
Fixed in
https://github.com/apache/flink/commit/f0ef370399638689c2e1adc54a3
[
https://issues.apache.org/jira/browse/FLINK-4951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4951.
---
Resolution: Fixed
Fixed in
https://github.com/apache/flink/commit/b9173b355139f007fb840aa6a19
[
https://issues.apache.org/jira/browse/FLINK-4955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4955.
---
Resolution: Fixed
Fix Version/s: (was: 1.2.0)
Fixed in
https://github.com/apache/f
[
https://issues.apache.org/jira/browse/FLINK-4957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-4957.
---
Resolution: Fixed
Fixed in
https://github.com/apache/flink/commit/891950eabaaed1fdfc1c0c88806
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/2715
---
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-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-5011:
Priority: Blocker (was: Major)
> TraversableSerializer does not perform a deep copy of the elements
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644503#comment-15644503
]
Stephan Ewen commented on FLINK-5013:
-
+1
> Flink Kinesis connector doesn't work on o
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-5013:
Priority: Critical (was: Major)
> Flink Kinesis connector doesn't work on old EMR versions
> --
[
https://issues.apache.org/jira/browse/FLINK-5011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-5011:
Fix Version/s: 1.2.0
> TraversableSerializer does not perform a deep copy of the elements it is
> t
[
https://issues.apache.org/jira/browse/FLINK-5027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644507#comment-15644507
]
ASF GitHub Bot commented on FLINK-5027:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/2765
[FLINK-5027] FileSource finishes successfully with a wrong path
Adds a test in the `run()` of the `ContinuousFileMonitoringFunction` that
checks if the user-specified path is valid. If not, the job wil
[
https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644500#comment-15644500
]
Stephan Ewen commented on FLINK-5002:
-
I am skeptical about that - these methods are u
Stephan Ewen created FLINK-5028:
---
Summary: Stream Tasks must not go through clean shutdown logic on
cancellation
Key: FLINK-5028
URL: https://issues.apache.org/jira/browse/FLINK-5028
Project: Flink
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2762
I'd go with the first approach, i.e., two PRs. You should reference the PR
on which the second one refers.
Thanks, Fabian
---
If your project is set up for it, you can reply to this email a
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644623#comment-15644623
]
ASF GitHub Bot commented on FLINK-3873:
---
Github user fhueske commented on the issue:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2765#discussion_r86813824
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java
---
@@ -124,6 +124,9
[
https://issues.apache.org/jira/browse/FLINK-5027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15644665#comment-15644665
]
ASF GitHub Bot commented on FLINK-5027:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-4697:
--
Assignee: Ufuk Celebi (was: Robert Metzger)
> Gather more detailed checkpoint stats in Checkpo
1 - 100 of 158 matches
Mail list logo
