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
[
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:
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=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
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-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
[
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
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-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 @@
+/*
+
[
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-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-5023:
---
Assignee: Xiaogang Shi
> Add get() method in State interface
>
[
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
[
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:
[
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 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-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:
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-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
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 @@
+/*
Github user coveralls commented on the issue:
https://github.com/apache/flink/pull/534
[![Coverage
Status](https://coveralls.io/builds/8712921/badge)](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:
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15645371#comment-15645371
]
ASF GitHub Bot commented on FLINK-3871:
---
Github user mushketyk commented on the issue:
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2762
@fhueske I've split the PR according to your suggestion. Now this PR only
contains serializer, deserializer and table source.
Since sink part depends on this PR I cannot publish it now, so I'll
GitHub user mikedias opened a pull request:
https://github.com/apache/flink/pull/2767
[FLINK-4988] Elasticsearch 5.x support
Provides Elasticsearch 5.x support based on previous 2.x codebase.
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15645352#comment-15645352
]
ASF GitHub Bot commented on FLINK-4988:
---
GitHub user mikedias opened a pull request:
[
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:
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
[
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-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
>
Eron Wright created FLINK-5029:
---
Summary: Implement KvState SSL
Key: FLINK-5029
URL: https://issues.apache.org/jira/browse/FLINK-5029
Project: Flink
Issue Type: Sub-task
Reporter:
[
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
[
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-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:49 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-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-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-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=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-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=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-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=15644807#comment-15644807
]
Jamie Grier commented on FLINK-5026:
+1 - I agree that TimelyFlatMap is a cumbersome name.
> Rename
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:
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:
[
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/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-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:
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-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
[
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-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-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
[
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:
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
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-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
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
[
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-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-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-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
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
[
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://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-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-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-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-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
[
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
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-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:
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-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:
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-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 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-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:
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-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:
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-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
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,
[
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:
[
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.
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-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-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-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:
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
1 - 100 of 156 matches
Mail list logo