[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526170#comment-15526170
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user wuchong closed the pull request at:
Github user wuchong closed the pull request at:
https://github.com/apache/flink/pull/2102
---
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-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526169#comment-15526169
]
ASF GitHub Bot commented on FLINK-4695:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2555#discussion_r80695131
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryConfiguration.java
---
@@ -0,0 +1,168 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526121#comment-15526121
]
ASF GitHub Bot commented on FLINK-4361:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2554
This is very nice, +1 to merge this.
Will come in very handy!
I like that this is pretty much aligned with the Java 8 futures.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526109#comment-15526109
]
ASF GitHub Bot commented on FLINK-4695:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2555#discussion_r80688384
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryConfiguration.java
---
@@ -0,0 +1,168 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526103#comment-15526103
]
ASF GitHub Bot commented on FLINK-4695:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2555
I don't really see the benefit here. Instead of the MetricRegistry being
coupled got the globalconfig the MetricRegistryConfiguration now is. This looks
a lot like moving code around for the sake of
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526083#comment-15526083
]
Aljoscha Krettek commented on FLINK-3674:
-
Correct, we could also have {{onProcessingTimeTimer()}}
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526077#comment-15526077
]
ASF GitHub Bot commented on FLINK-3322:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2510
There are a bunch of quite pressing issues (hard requirements for some use
cases) that I am working on these weeks. I'll try to come back to this after we
have gotten those done...
---
If your
[
https://issues.apache.org/jira/browse/FLINK-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4684.
---
> Remove obsolete classloader from CheckpointCoordinator
>
[
https://issues.apache.org/jira/browse/FLINK-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4684.
-
Resolution: Fixed
Fixed in 70e71c16177b40c2418e6a8ca0838bf117f6a926
> Remove obsolete
[
https://issues.apache.org/jira/browse/FLINK-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526054#comment-15526054
]
Stephan Ewen commented on FLINK-4684:
-
This was actually merged yesterday already. I think it should
[
https://issues.apache.org/jira/browse/FLINK-4690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526027#comment-15526027
]
ASF GitHub Bot commented on FLINK-4690:
---
Github user tillrohrmann commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-3154:
Description:
Flink's Kryo version is outdated and could be updated to a newer version, e.g.
[
https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4387.
--
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in f791680 (forgot to close the issue before).
>
Stephan Ewen created FLINK-4696:
---
Summary: Limit the number of Akka Dispatcher Threads in
LocalMiniCluster
Key: FLINK-4696
URL: https://issues.apache.org/jira/browse/FLINK-4696
Project: Flink
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2552
Changes look good to me. Thanks for your contribution @KurtYoung. Will
merge it first with the master branch and then I will rebase the flip-6 branch.
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526018#comment-15526018
]
Stephan Ewen commented on FLINK-2600:
-
This seems to not have occurred in a while. Any updates here?
[
https://issues.apache.org/jira/browse/FLINK-4387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526016#comment-15526016
]
Stephan Ewen commented on FLINK-4387:
-
Is this fixed now?
> Instability in
[
https://issues.apache.org/jira/browse/FLINK-4695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526004#comment-15526004
]
ASF GitHub Bot commented on FLINK-4695:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15526007#comment-15526007
]
ASF GitHub Bot commented on FLINK-4687:
---
Github user tillrohrmann closed the pull request at:
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/2551
---
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
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2555
[FLINK-4695] Introduce MetricRegistryConfiguration to encapsulate
MetricRegistry parameters
In order to decouple the MetricRegistry object instantiation from the
global configuration
the
Till Rohrmann created FLINK-4695:
Summary: Separate configuration parsing from MetricRegistry
Key: FLINK-4695
URL: https://issues.apache.org/jira/browse/FLINK-4695
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525983#comment-15525983
]
Stephan Ewen commented on FLINK-3674:
-
I assume {{TimeDomain}} is "processing time" or "event time"?
[
https://issues.apache.org/jira/browse/FLINK-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525884#comment-15525884
]
ASF GitHub Bot commented on FLINK-4361:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2554
[FLINK-4361] Introduce Flink's own future abstraction
Flink's future abstraction whose API is similar to Java 8's
CompletableFuture.
That's in order to ease a future transition to this
[
https://issues.apache.org/jira/browse/FLINK-4687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4687.
Resolution: Fixed
Added via 93775cef67b1903a8f462da924f97df5ae6819c4
> Add getAddress method to
[
https://issues.apache.org/jira/browse/FLINK-4687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525873#comment-15525873
]
ASF GitHub Bot commented on FLINK-4687:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2551
Travis passed locally. Will merge this PR.
---
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-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525871#comment-15525871
]
Stephan Ewen commented on FLINK-4684:
-
I think that savepoints are loaded and added to the
[
https://issues.apache.org/jira/browse/FLINK-4606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525719#comment-15525719
]
ASF GitHub Bot commented on FLINK-4606:
---
Github user mxm commented on a diff in the pull request:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2540#discussion_r80663028
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -324,6 +337,158 @@ public void handleError(final
[
https://issues.apache.org/jira/browse/FLINK-4684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525715#comment-15525715
]
Aljoscha Krettek commented on FLINK-4684:
-
I think this one is tricky because we might still need
[
https://issues.apache.org/jira/browse/FLINK-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525713#comment-15525713
]
Anton Mushin commented on FLINK-4563:
-
Hello.
Do I correct undestand this issue, what next tests will
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525712#comment-15525712
]
Fabian Hueske commented on FLINK-2765:
--
At the moment, we have two open PRs that use HBase:
-
[
https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-3398:
Priority: Blocker (was: Major)
> Flink Kafka consumer should support auto-commit opt-outs
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525685#comment-15525685
]
Stephan Ewen commented on FLINK-2765:
-
[~nielsbasjes] What are your thoughts on this? Are HBase 1.1
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525561#comment-15525561
]
Aljoscha Krettek commented on FLINK-3674:
-
I want to implement this using two new interfaces:
-
[
https://issues.apache.org/jira/browse/FLINK-4686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525556#comment-15525556
]
ASF GitHub Bot commented on FLINK-4686:
---
GitHub user wuchong opened a pull request:
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2553
[FLINK-4686] [table] Add possibility to get column names
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2461
Thanks for your contribution @wangzhijiang999. I'll merge it.
---
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
Till Rohrmann created FLINK-4694:
Summary: Add wait for termination function to RpcEndpoints
Key: FLINK-4694
URL: https://issues.apache.org/jira/browse/FLINK-4694
Project: Flink
Issue Type:
Timo Walther created FLINK-4693:
---
Summary: Add session group-windows for batch tables
Key: FLINK-4693
URL: https://issues.apache.org/jira/browse/FLINK-4693
Project: Flink
Issue Type:
Timo Walther created FLINK-4692:
---
Summary: Add tumbling and sliding group-windows for batch tables
Key: FLINK-4692
URL: https://issues.apache.org/jira/browse/FLINK-4692
Project: Flink
Issue
Timo Walther created FLINK-4691:
---
Summary: Add group-windows for streaming tables
Key: FLINK-4691
URL: https://issues.apache.org/jira/browse/FLINK-4691
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525488#comment-15525488
]
ASF GitHub Bot commented on FLINK-4671:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4671.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in e5d62da2c98ad9c6a5ca9c0782a7fea8a01d639a.
[
https://issues.apache.org/jira/browse/FLINK-4686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4686:
--
Assignee: Jark Wu
> Add possibility to get column names
> ---
>
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2549
---
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-4606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525486#comment-15525486
]
ASF GitHub Bot commented on FLINK-4606:
---
Github user mxm commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525483#comment-15525483
]
Till Rohrmann commented on FLINK-4630:
--
Hi Shijinkui, what do you wanna use this source for? Is it
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2540#discussion_r80642652
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -66,15 +67,16 @@
* {@link
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525425#comment-15525425
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2332
Thanks for these discussions @delding and @ramkrish86. I think this is
getting a bit hard to follow. What do you think about writing a design doc that
describes the supported HBase features and
[
https://issues.apache.org/jira/browse/FLINK-3841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MaGuowei reassigned FLINK-3841:
---
Assignee: MaGuowei
> RocksDB statebackend creates empty dbs for stateless operators
>
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2369
Just found some minor issues that can be fixed when 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
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525284#comment-15525284
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525278#comment-15525278
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r80629075
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525277#comment-15525277
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r80629176
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java
---
@@
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r80628475
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525262#comment-15525262
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
Github user ex00 commented on the issue:
https://github.com/apache/flink/pull/2517
zentol, thanks!
I am pushed edited implementation again.
---
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-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525242#comment-15525242
]
ASF GitHub Bot commented on FLINK-4564:
---
Github user ex00 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525190#comment-15525190
]
ASF GitHub Bot commented on FLINK-4339:
---
Github user KurtYoung commented on the issue:
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/2497
rebased to the latest flip-6 and use flink's own Future instead of scala's
Future
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-4606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525181#comment-15525181
]
ASF GitHub Bot commented on FLINK-4606:
---
Github user beyond1920 commented on the issue:
Github user beyond1920 commented on the issue:
https://github.com/apache/flink/pull/2540
@mxm , thanks for your review, I modified the pr based on your advices:
1. fIx checkstyle error, `AkkaRpcActorTest` testcase and
`RpcCompletenessTest` testcase. Sorry for those mistakes, I
[
https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15525179#comment-15525179
]
ASF GitHub Bot commented on FLINK-2055:
---
Github user ramkrish86 commented on the issue:
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2332
Ok. Then it should be clearly documented now. that the sink supports only
Puts/Deletes. So in future can the sink be updated with new APIs? I don't know
the procedure here in case new APIs have
101 - 176 of 176 matches
Mail list logo
