Fabian Hueske created FLINK-5031:
Summary: Consecutive DataStream.split() ignored
Key: FLINK-5031
URL: https://issues.apache.org/jira/browse/FLINK-5031
Project: Flink
Issue Type: Bug
Github user coveralls commented on the issue:
https://github.com/apache/flink/pull/534
[](https://coveralls.io/builds/8712921)
Changes Unknown when pulling **83db1db1c93b45943a788a8bd61f023b389d4af2 on
[
https://issues.apache.org/jira/browse/FLINK-1775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15645703#comment-15645703
]
ASF GitHub Bot commented on FLINK-1775:
---
Github user coveralls commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15645630#comment-15645630
]
Ufuk Celebi commented on FLINK-5016:
I think you are right, Stephan.
I just had a similar revelation
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2762
@fhueske Thank you for clarification. I'll update the code tonight.
---
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
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644804#comment-15644804
]
ASF GitHub Bot commented on FLINK-3873:
---
Github user mushketyk commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644835#comment-15644835
]
Till Rohrmann commented on FLINK-4354:
--
Hi [~wangzj],
I agree with points 2-6.
But I'm not so sure
[
https://issues.apache.org/jira/browse/FLINK-5026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644931#comment-15644931
]
Jamie Grier commented on FLINK-5026:
Another option here would be apply(), rather than process().
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644949#comment-15644949
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5017 at 11/7/16 6:25 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644993#comment-15644993
]
Tzu-Li (Gordon) Tai commented on FLINK-5017:
I think the main difference in my thinking is
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15643969#comment-15643969
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644877#comment-15644877
]
Aljoscha Krettek commented on FLINK-5017:
-
Oh dear, this is turning out to be quite tricky.
My
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644949#comment-15644949
]
Tzu-Li (Gordon) Tai commented on FLINK-5017:
Hi [~aljoscha],
To ease discussion a bit, I've
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644949#comment-15644949
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5017 at 11/7/16 6:27 PM:
-
[
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
[
https://issues.apache.org/jira/browse/FLINK-5013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644503#comment-15644503
]
Stephan Ewen commented on FLINK-5013:
-
+1
> Flink Kinesis connector doesn't work on old EMR versions
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-5026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644807#comment-15644807
]
Jamie Grier commented on FLINK-5026:
+1 - I agree that TimelyFlatMap is a cumbersome name.
> Rename
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644949#comment-15644949
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5017 at 11/7/16 6:29 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-5012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15643499#comment-15643499
]
Aljoscha Krettek commented on FLINK-5012:
-
The discussion was not about a way to emit an element
[
https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646297#comment-15646297
]
Zhijiang Wang commented on FLINK-4354:
--
Actually the current {{HeartbeatManagerImpl}} can work and be
Boris Osipov created FLINK-5032:
---
Summary: CsvOutputFormatTest fails on Windows OS
Key: FLINK-5032
URL: https://issues.apache.org/jira/browse/FLINK-5032
Project: Flink
Issue Type: Bug
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
[
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://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://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://issues.apache.org/jira/browse/FLINK-5027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644507#comment-15644507
]
ASF GitHub Bot commented on FLINK-5027:
---
GitHub user kl0u opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644500#comment-15644500
]
Stephan Ewen commented on FLINK-5002:
-
I am skeptical about that - these methods are used by metric
[
https://issues.apache.org/jira/browse/FLINK-4970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=1569#comment-1569
]
Boris Osipov commented on FLINK-4890:
-
I've reproduced this issue on my environment.
Also, I found
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644451#comment-15644451
]
Stephan Ewen commented on FLINK-5023:
-
I agree with [~xiaogang.shi] - do we really need another
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644457#comment-15644457
]
Boris Osipov commented on FLINK-4890:
-
It's related to FLINK-3677
>
[
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
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86914170
--- 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=15646236#comment-15646236
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646299#comment-15646299
]
Xiaogang Shi commented on FLINK-5023:
-
I have opened a PR:
Github user bjlovegithub commented on a diff in the pull request:
https://github.com/apache/flink/pull/2629#discussion_r86916022
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/async/AsyncCollectorBufferTest.java
---
@@ -0,0 +1,293 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646294#comment-15646294
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user bjlovegithub commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r86923458
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/EvaluableFunction.scala
---
@@ -0,0 +1,62 @@
+/*
--- End
[
https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-5024:
---
Assignee: Xiaogang Shi
> Add SimpleStateDescriptor to clarify the concepts
>
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646496#comment-15646496
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r86923273
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/api/java/batch/UserDefinedTableFunctionITCase.java
---
@@ -0,0 +1,156 @@
+/*
+
GitHub user shixiaogang opened a pull request:
https://github.com/apache/flink/pull/2768
[FLINK-5023 & FLINK-5024] Add SimpleStateDescriptor to clarify the concepts
Changes in the definition of `State` and `StateDescriptor`:
- Add `get()` in the `State` interface.
- Remove
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646286#comment-15646286
]
ASF GitHub Bot commented on FLINK-5023:
---
GitHub user shixiaogang opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646500#comment-15646500
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-5023:
---
Assignee: Xiaogang Shi
> Add get() method in State interface
>
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2653
Hi @sunjincheng121 , thank you for the reviewing. I will update the PR
according to your comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646516#comment-15646516
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646512#comment-15646512
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r86923855
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/TableEnvironment.scala
---
@@ -152,21 +153,40 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646511#comment-15646511
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r86923816
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/TableFunction.scala
---
@@ -0,0 +1,119 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15643996#comment-15643996
]
ASF GitHub Bot commented on FLINK-4391:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644135#comment-15644135
]
Aljoscha Krettek commented on FLINK-5016:
-
I saw another hanging test, this time for
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-5026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644176#comment-15644176
]
Aljoscha Krettek commented on FLINK-5026:
-
This depends, of course, on FLINK-4992 and FLINK-5012.
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
[
https://issues.apache.org/jira/browse/FLINK-4934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644251#comment-15644251
]
ASF GitHub Bot commented on FLINK-4934:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644285#comment-15644285
]
ASF GitHub Bot commented on FLINK-4970:
---
Github user greghogan commented on the issue:
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
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644006#comment-15644006
]
Nikolay Vasilishin commented on FLINK-4492:
---
I offer to close this issue as it seems to be
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
[
https://issues.apache.org/jira/browse/FLINK-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644032#comment-15644032
]
ASF GitHub Bot commented on FLINK-5020:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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,
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
[
https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644239#comment-15644239
]
ASF GitHub Bot commented on FLINK-5008:
---
Github user greghogan commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644295#comment-15644295
]
ASF GitHub Bot commented on FLINK-3873:
---
Github user mushketyk commented on the issue:
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-4876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644310#comment-15644310
]
ASF GitHub Bot commented on FLINK-4876:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644665#comment-15644665
]
ASF GitHub Bot commented on FLINK-5027:
---
Github user tillrohrmann commented on a diff in the pull
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2757
Merging 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 not have this feature
enabled and wishes so,
[
https://issues.apache.org/jira/browse/FLINK-4410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-4410:
--
Assignee: Ufuk Celebi (was: Robert Metzger)
> Report more information about operator
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2765
@tillrohrmann Thanks for the review. I integrated the comments.
---
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-5027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644694#comment-15644694
]
ASF GitHub Bot commented on FLINK-5027:
---
Github user kl0u commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644772#comment-15644772
]
ASF GitHub Bot commented on FLINK-5022:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2760
Looks good, merging 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 not have this feature
enabled and
[
https://issues.apache.org/jira/browse/FLINK-5014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644787#comment-15644787
]
ASF GitHub Bot commented on FLINK-5014:
---
Github user StephanEwen commented on the issue:
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-4698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-4698:
--
Assignee: Ufuk Celebi (was: Robert Metzger)
> Visualize additional checkpoint information
>
[
https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644623#comment-15644623
]
ASF GitHub Bot commented on FLINK-3873:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15644993#comment-15644993
]
Tzu-Li (Gordon) Tai edited comment on FLINK-5017 at 11/7/16 6:57 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright reopened FLINK-3931:
-
Assignee: Eron Wright (was: Suresh Krishnappa)
Re-opened to address some follow-ups seen in
Eron Wright created FLINK-5030:
---
Summary: Support hostname verification
Key: FLINK-5030
URL: https://issues.apache.org/jira/browse/FLINK-5030
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15645223#comment-15645223
]
ASF GitHub Bot commented on FLINK-4898:
---
GitHub user EronWright opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5028.
-
Resolution: Fixed
Fixed in
- 1.2.0 via 1a578657d078dfb2d26a6f6e60876271d6f4c2ff
- 1.1.4 via
[
https://issues.apache.org/jira/browse/FLINK-5028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5028.
---
> Stream Tasks must not go through clean shutdown logic on cancellation
>
[
https://issues.apache.org/jira/browse/FLINK-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15645088#comment-15645088
]
Stephan Ewen commented on FLINK-5016:
-
The issue reported here has most likely a different cause: The
GitHub user EronWright opened a pull request:
https://github.com/apache/flink/pull/2766
[FLINK-4898] Refactor HTTP handlers and Netty server/client
- added support classes for REST and WebSocket-based protocols
- generalized NettyClient/NettyServer: makes no assumptions
1 - 100 of 156 matches
Mail list logo
