[
https://issues.apache.org/jira/browse/FLINK-5612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837648#comment-15837648
]
ASF GitHub Bot commented on FLINK-5612:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837633#comment-15837633
]
Greg Hogan commented on FLINK-5635:
---
[~jgrier], will this subsume FLINK-4326?
> Improve Docker tooling
[
https://issues.apache.org/jira/browse/FLINK-5546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837603#comment-15837603
]
ASF GitHub Bot commented on FLINK-5546:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3190
@shijinkui:
[delete](http://junit.org/junit4/javadoc/latest/org/junit/rules/TemporaryFolder.html#delete())
is "usually not called directly, since it is automatically applied by the
Rule".
---
[
https://issues.apache.org/jira/browse/FLINK-5639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5639.
---
> Clarify License implications of RabbitMQ Connector
> --
[
https://issues.apache.org/jira/browse/FLINK-5639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5639.
-
Resolution: Fixed
Fixed in
- 1.1.5 via 743aaf6f82fdaa6cf8ba258ebc0f54ba5436afc2 and
[
https://issues.apache.org/jira/browse/FLINK-4548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837583#comment-15837583
]
Aljoscha Krettek commented on FLINK-4548:
-
I assigned it to you but I think you should also be
[
https://issues.apache.org/jira/browse/FLINK-4548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-4548:
Assignee: Pattarawat Chormai
> Refactor ContinuousFileMonitoringTest to use OneShotLatch
>
Stephan Ewen created FLINK-5639:
---
Summary: Clarify License implications of RabbitMQ Connector
Key: FLINK-5639
URL: https://issues.apache.org/jira/browse/FLINK-5639
Project: Flink
Issue Type:
Till Rohrmann created FLINK-5638:
Summary: Deadlock when closing two chained async I/O operators
Key: FLINK-5638
URL: https://issues.apache.org/jira/browse/FLINK-5638
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-5336:
-
Assignee: (was: Anton Solovev)
> Make Path immutable
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-5384:
-
Assignee: (was: Anton Solovev)
> clean up jira issues
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-5384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-5384:
-
Description:
h4. must be closed:
FLINK-37 -> from stratosphere;
FLINK-87 -> from stratosphere;
[
https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5636:
Affects Version/s: 1.3.0
1.2.0
> IO Metric for
[
https://issues.apache.org/jira/browse/FLINK-5636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5636:
Component/s: Metrics
> IO Metric for StreamTwoInputProcessor
>
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837554#comment-15837554
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the issue:
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
@fhueske , @tonycox , @wuchong - FYI.
---
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-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837551#comment-15837551
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on the issue:
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3149
Updated the code with the comments and have pushed again. I think I have
addressed all the comments here. Feedback/comments welcome. I also found that
it is better to use the TableInputSplit to
[
https://issues.apache.org/jira/browse/FLINK-5602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837547#comment-15837547
]
ASF GitHub Bot commented on FLINK-5602:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/3200
OK thanks! Makes sense with the UnsupportedOpException. I thought that
duplicate is called somewhere maybe. I'll merge this as soon as Travis gives
the green light.
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-5602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837540#comment-15837540
]
ASF GitHub Bot commented on FLINK-5602:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3200
Thanks for the review @uce ! I changed my PR according to your suggestions
(except for only throwing an unsupported op exception on the duplicate
function).
---
If your project is set up
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3206#discussion_r97746636
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/GlobFilePathFilter.java
---
@@ -69,8 +75,8 @@ public GlobFilePathFilter() {
*
[
https://issues.apache.org/jira/browse/FLINK-5612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837526#comment-15837526
]
ASF GitHub Bot commented on FLINK-5612:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837525#comment-15837525
]
ASF GitHub Bot commented on FLINK-5612:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-5620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-5620.
-
Resolution: Fixed
> Fix unstable ContinuousFileProcessingTest
>
[
https://issues.apache.org/jira/browse/FLINK-5612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837524#comment-15837524
]
ASF GitHub Bot commented on FLINK-5612:
---
Github user zentol commented on a diff in the pull request:
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/3201
---
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 zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3206#discussion_r97746573
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/GlobFilePathFilter.java
---
@@ -106,12 +112,27 @@ public boolean filterPath(Path filePath)
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/3206#discussion_r97746438
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/io/GlobFilePathFilter.java
---
@@ -52,8 +53,13 @@
private static final long
Robert Metzger created FLINK-5637:
-
Summary: Default Flink configuration contains whitespace
characters, causing parser WARNings
Key: FLINK-5637
URL: https://issues.apache.org/jira/browse/FLINK-5637
[
https://issues.apache.org/jira/browse/FLINK-5620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837521#comment-15837521
]
ASF GitHub Bot commented on FLINK-5620:
---
Github user kl0u closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837520#comment-15837520
]
ASF GitHub Bot commented on FLINK-5620:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3201
Merged. Could you please close 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 feature
[
https://issues.apache.org/jira/browse/FLINK-5620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837509#comment-15837509
]
ASF GitHub Bot commented on FLINK-5620:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3201
@aljoscha Thanks!
---
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
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/3207
Agg follow ups
Issues fixed in this PR:
- Add a `RichAggregateFunction`
- Document generic type parameters
- Document methods of the `AggregateFunction`
- Adds the
[
https://issues.apache.org/jira/browse/FLINK-5620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837505#comment-15837505
]
ASF GitHub Bot commented on FLINK-5620:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3201
This looks good, I'm merging. ð
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837496#comment-15837496
]
ASF GitHub Bot commented on FLINK-5626:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837495#comment-15837495
]
ASF GitHub Bot commented on FLINK-5626:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837498#comment-15837498
]
ASF GitHub Bot commented on FLINK-5626:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3198
Alright, then I am changing this first.
---
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-5492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reopened FLINK-5492:
---
I need to reopen this issue because one of the changes in this JIRA are not
correct.
I now see
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3198
Renaming is not part of this PR/Jira Issue, though, so with the changes to
ownership of the RocksDB options I would like to merge this quickly. We can
then open another issue for the renaming, if
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3198
I would call this `AbstractStateBackendFactory`, because that is what it
is...an abstract factory for state backends.
---
If your project is set up for it, you can reply to this email and
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3198
The is already `StateBackendFactory`. ð Both are used in the "public"
APIs: `StateBackendFactory` is used for setting a backend in the config while
`AbstractStateBackend` appears in a public
[
https://issues.apache.org/jira/browse/FLINK-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837488#comment-15837488
]
ASF GitHub Bot commented on FLINK-5626:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837475#comment-15837475
]
Stephan Ewen commented on FLINK-5633:
-
This is covered in that section of the
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837459#comment-15837459
]
ASF GitHub Bot commented on FLINK-4905:
---
Github user StephanEwen commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3198
If the caching is optional, then I would also prefer to keep it out of the
factory. Different question: if there is no other reason against it, wouldn't
that also be an opportunity to rename
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3035
Quick question: I am not sure if this scenario can happen like that:
> But in this approach an unlikely bug will be still occurred:
zkHandler.prepareAndCommitOffsets(offsets); throws
[
https://issues.apache.org/jira/browse/FLINK-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837456#comment-15837456
]
ASF GitHub Bot commented on FLINK-5626:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837448#comment-15837448
]
ASF GitHub Bot commented on FLINK-5626:
---
Github user tillrohrmann commented on the issue:
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/3198
Aljoscha's proposal sounds reasonable to me :-)
---
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
[
https://issues.apache.org/jira/browse/FLINK-5612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837427#comment-15837427
]
ASF GitHub Bot commented on FLINK-5612:
---
GitHub user mushketyk opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837425#comment-15837425
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on a diff in the pull
GitHub user mushketyk opened a pull request:
https://github.com/apache/flink/pull/3206
[FLINK-5612] Fix GlobPathFilter not-serializable exception
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r97738061
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java
---
@@ -0,0 +1,135 @@
+/*
+ * Licensed
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r97736554
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java
---
@@ -0,0 +1,135 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837420#comment-15837420
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ramkrish86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837415#comment-15837415
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2761
@ch33hau, sure!
Just drop a comment when you updated the PR (a simple push does not trigger
a notification but a comment does).
Thanks, Fabian
---
If your project is set up for it, you
Github user ex00 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3149#discussion_r97734069
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java
---
@@ -0,0 +1,135 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837402#comment-15837402
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ex00 commented on a diff in the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/6342d6db1de5f38a921732e35abd83e6c5b9305a#commitcomment-20606338
In
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java:
In
[
https://issues.apache.org/jira/browse/FLINK-5626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837387#comment-15837387
]
ASF GitHub Bot commented on FLINK-5626:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3198
I think we can keep from having to close the `AbstractStateBackend` by not
caching the `dbOptions` and `columnOptions` and instead giving new ones to the
`RocksDBKeyedStateBackend`. The keyed
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837384#comment-15837384
]
ASF GitHub Bot commented on FLINK-2168:
---
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/3149#discussion_r97730820
--- Diff:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTableSchema.java
---
@@ -0,0 +1,135 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837379#comment-15837379
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user ex00 commented on a diff in the pull request:
david.wang created FLINK-5636:
-
Summary: IO Metric for StreamTwoInputProcessor
Key: FLINK-5636
URL: https://issues.apache.org/jira/browse/FLINK-5636
Project: Flink
Issue Type: Bug
Github user ex00 commented on the issue:
https://github.com/apache/flink/pull/3205
Hi @jgrier. Thaks for your PR!
Could you update
[README.md](https://github.com/apache/flink/blob/master/flink-contrib/docker-flink/README.md)
in accordance with your changes?
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-5635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15837365#comment-15837365
]
ASF GitHub Bot commented on FLINK-5635:
---
Github user ex00 commented on the issue:
301 - 375 of 375 matches
Mail list logo
