[
https://issues.apache.org/jira/browse/FLINK-4155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4155:
---
Fix Version/s: 1.2.0
> Get Kafka producer partition info in open method instead of con
[
https://issues.apache.org/jira/browse/FLINK-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389029#comment-15389029
]
Tzu-Li (Gordon) Tai commented on FLINK-4023:
Solving this together with FLINK-
[
https://issues.apache.org/jira/browse/FLINK-4155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389028#comment-15389028
]
Tzu-Li (Gordon) Tai commented on FLINK-4155:
Solving this together with FLINK-
[
https://issues.apache.org/jira/browse/FLINK-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-4023:
--
Assignee: Tzu-Li (Gordon) Tai
> Move Kafka consumer partition discovery from co
[
https://issues.apache.org/jira/browse/FLINK-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4023:
---
Fix Version/s: 1.2.0
> Move Kafka consumer partition discovery from constructor to ope
[
https://issues.apache.org/jira/browse/FLINK-4155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-4155:
--
Assignee: Tzu-Li (Gordon) Tai
> Get Kafka producer partition info in open metho
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389003#comment-15389003
]
Jark Wu edited comment on FLINK-4252 at 7/22/16 6:35 AM:
-
I debug
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389003#comment-15389003
]
Jark Wu commented on FLINK-4252:
I debug it and find that we use {Class.getCanonicalName}
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388967#comment-15388967
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2260
Hi @chadnickbok,
I've gave the new config a test on AWS EC2 instances with appropriate IAM
roles attached, and it works as expected and nicely. I think the changes are
good to merge once the rem
GitHub user gallenvara opened a pull request:
https://github.com/apache/flink/pull/2282
Support order by with offset and fetch.
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes ta
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge updated FLINK-4252:
-
Description:
I'm trying the table apis.
I got some errors like this
My code is in the attachments
Renkai Ge created FLINK-4252:
Summary: Table program cannot be compiled
Key: FLINK-4252
URL: https://issues.apache.org/jira/browse/FLINK-4252
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-4252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge updated FLINK-4252:
-
Attachment: TestMain.scala
> Table program cannot be compiled
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388780#comment-15388780
]
Jark Wu edited comment on FLINK-4250 at 7/22/16 2:55 AM:
-
I think
[
https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388780#comment-15388780
]
Jark Wu commented on FLINK-4250:
I think the second exception is similar to the first, bec
[
https://issues.apache.org/jira/browse/FLINK-3940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388752#comment-15388752
]
GaoLun commented on FLINK-3940:
---
Hello, i would like to work on this issue. :)
> Add suppor
[
https://issues.apache.org/jira/browse/FLINK-4175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388545#comment-15388545
]
Felix Neutatz commented on FLINK-4175:
--
I started a design document here:
https://do
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2271
Also, the documentation (list of all exposed metrics) was not updated.
---
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 d
[
https://issues.apache.org/jira/browse/FLINK-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-4202:
-
Documentation was not properly updated.
> Add JM metric which shows the restart duration
> --
[
https://issues.apache.org/jira/browse/FLINK-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388507#comment-15388507
]
ASF GitHub Bot commented on FLINK-4202:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387967#comment-15387967
]
Chesnay Schepler edited comment on FLINK-4245 at 7/21/16 9:52 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-4245:
Component/s: Metrics
> Metric naming improvements
> --
>
>
GitHub user PhilippGrulich opened a pull request:
https://github.com/apache/flink/pull/2281
RMQ Sink: Possibility to customize queue config [FLINK-4251]
This patch adds the possibilty for the user of the RabbitMQ
Streaming Sink to customize the queue which is used.
This adop
[
https://issues.apache.org/jira/browse/FLINK-4251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388395#comment-15388395
]
ASF GitHub Bot commented on FLINK-4251:
---
GitHub user PhilippGrulich opened a pull re
Philipp Grulich created FLINK-4251:
--
Summary: Add possiblity for the RMQ Streaming Sink to customize
the queue
Key: FLINK-4251
URL: https://issues.apache.org/jira/browse/FLINK-4251
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388348#comment-15388348
]
ASF GitHub Bot commented on FLINK-3779:
---
Github user soniclavier commented on the is
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2051
One more question, is it possible to configure the JobManager Actor path
that the client connects to, it looks like it default to
`akka://flink/user/jobmanager`.
In that way I can create a m
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2051
Sorry, the compilation error was because the Tuple2 was scala.Tuple2 not
flink Tuple2. Changing to `org.apache.flink.api.java.tuple.Tuple2` fixed the
issue.
---
If your project is set up for it
[
https://issues.apache.org/jira/browse/FLINK-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388178#comment-15388178
]
ASF GitHub Bot commented on FLINK-3779:
---
Github user soniclavier commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388165#comment-15388165
]
Timo Walther commented on FLINK-4250:
-
I think the problem of your first exception is
[
https://issues.apache.org/jira/browse/FLINK-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388116#comment-15388116
]
ASF GitHub Bot commented on FLINK-3779:
---
Github user soniclavier commented on the is
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2051
Thanks Ufuk & Stephen for the reply,
I tried the serializers suggested by you
```
val typeHint = new TypeHint[Tuple2[Long,String]](){}
val serializer = TypeInformation.of(typeH
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388102#comment-15388102
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on the iss
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2275
Adding some more cotext to the implementation details. which is based on
the design proposal
(https://docs.google.com/document/d/1-GQB6uVOyoaXGwtqwqLV8BHDxWiMO2WnVzBoJ8oPaAs/edit?usp=sharing)
[
https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4250:
-
Priority: Critical (was: Major)
> Cannot select other than first column from Table
>
[
https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4250:
-
Summary: Cannot select other than first column from Table (was: Cannot
select column from CsvTabl
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2051
A simpler way to get the serializer may be
```java
TypeInformation.of(new TypeHint>(){}).createSerializer(null);
```
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-4250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388074#comment-15388074
]
Till Rohrmann commented on FLINK-4250:
--
The problem seems to be more general than the
Till Rohrmann created FLINK-4250:
Summary: Cannot select column from CsvTableSource
Key: FLINK-4250
URL: https://issues.apache.org/jira/browse/FLINK-4250
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388069#comment-15388069
]
ASF GitHub Bot commented on FLINK-3779:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388058#comment-15388058
]
ASF GitHub Bot commented on FLINK-3779:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2051
Regarding local vs. cluster mode: that's on purpose, but we can certainly
change that behaviour. For now, you would have to run in cluster mode.
Regarding the serializer: assuming that it is a F
[
https://issues.apache.org/jira/browse/FLINK-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388043#comment-15388043
]
ASF GitHub Bot commented on FLINK-3779:
---
Github user soniclavier commented on the is
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2051
Never mind, I was hitting with wrong key, it works now! Cheers.
---
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 doe
[
https://issues.apache.org/jira/browse/FLINK-4243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387982#comment-15387982
]
Chesnay Schepler commented on FLINK-4243:
-
I'm not really against this, but i woul
[
https://issues.apache.org/jira/browse/FLINK-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387978#comment-15387978
]
ASF GitHub Bot commented on FLINK-4202:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2271
The Javadoc for the `RestartingTimeGauge` is not consistent with the
implementation.
The Javadocs say "The time between the RESTARTING and RUNNING".
The implementation says either
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387967#comment-15387967
]
Chesnay Schepler commented on FLINK-4245:
-
1. As long as we don't have unique oper
[
https://issues.apache.org/jira/browse/FLINK-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387961#comment-15387961
]
Josh Forman-Gornall commented on FLINK-4190:
Thanks! Oh nice, this looks like
[
https://issues.apache.org/jira/browse/FLINK-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387930#comment-15387930
]
ASF GitHub Bot commented on FLINK-3779:
---
Github user soniclavier commented on the is
Github user soniclavier commented on the issue:
https://github.com/apache/flink/pull/2051
Hi,
Continuing the discussion from the mailing list, I was able to go past the
NettyConfig problem once I ran Flink in cluster mode ( I would still like to
know if there is a way to run
Till Rohrmann created FLINK-4249:
Summary: CsvTableSource does not support reading SqlTimeTypeInfo
types
Key: FLINK-4249
URL: https://issues.apache.org/jira/browse/FLINK-4249
Project: Flink
Till Rohrmann created FLINK-4248:
Summary: CsvTableSource does not support reading SqlTimeTypeInfo
types
Key: FLINK-4248
URL: https://issues.apache.org/jira/browse/FLINK-4248
Project: Flink
Till Rohrmann created FLINK-4247:
Summary: CsvTableSource.getDataSet() expects Java
ExecutionEnvironment
Key: FLINK-4247
URL: https://issues.apache.org/jira/browse/FLINK-4247
Project: Flink
Github user fpompermaier commented on the issue:
https://github.com/apache/flink/pull/1989
Don't worry @twalthr, it will be nice to have it in the 1.1 but I
understand that it's not a priority :)
Thanks a lot for the update!
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387913#comment-15387913
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user fpompermaier commented on the i
[
https://issues.apache.org/jira/browse/FLINK-4244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387907#comment-15387907
]
ASF GitHub Bot commented on FLINK-4244:
---
GitHub user wuchong opened a pull request:
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2280
[FLINK-4244] [docs] Field names for union operator do not have to be equal
We just merged FLINK-2985 , but not update the document.
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/FLINK-4244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu reassigned FLINK-4244:
--
Assignee: Jark Wu
> Field names for union operator do not have to be equal
> --
[
https://issues.apache.org/jira/browse/FLINK-3901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387892#comment-15387892
]
ASF GitHub Bot commented on FLINK-3901:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/1989
@fpompermaier I started working on this, but I can not guarantee that it
will be part of the release.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2257
Hi @tillrohrmann! Your changes look good. I would say this is good to merge
once we have fixed the issue with the `YarnFlinkResourceManagerTest` on Travis.
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-4246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387867#comment-15387867
]
Stephan Ewen commented on FLINK-4246:
-
+1, I like this idea
> Allow Specifying Multip
[
https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387865#comment-15387865
]
ASF GitHub Bot commented on FLINK-4192:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2226
Will merge this, leaving the config as is.
---
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 featu
[
https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387859#comment-15387859
]
ASF GitHub Bot commented on FLINK-4152:
---
Github user mxm commented on the issue:
Aljoscha Krettek created FLINK-4246:
---
Summary: Allow Specifying Multiple Metrics Reporters
Key: FLINK-4246
URL: https://issues.apache.org/jira/browse/FLINK-4246
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387848#comment-15387848
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387851#comment-15387851
]
Jark Wu commented on FLINK-4244:
Yes, we just merged [FLINK-2985] , but not update the doc
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387849#comment-15387849
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2279#discussion_r71722866
--- Diff:
flink-core/src/test/java/org/apache/flink/metrics/reporter/JMXReporterTest.java
---
@@ -88,7 +88,7 @@ public void testPortConflictHandling() th
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2279
Looks good, will merge 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 a
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2276
I think as it is, it is fine.
Let's extend the option for HA in a separate issue. We could have:
- high-availability: *none* (what is currently *standalone recovery*)
- high-av
[
https://issues.apache.org/jira/browse/FLINK-4240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387824#comment-15387824
]
Jark Wu commented on FLINK-4240:
It's not a bug I think as we cannot select a column not i
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387820#comment-15387820
]
ASF GitHub Bot commented on FLINK-4229:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2279#discussion_r71720105
--- Diff:
flink-core/src/test/java/org/apache/flink/metrics/reporter/JMXReporterTest.java
---
@@ -88,7 +88,7 @@ public void testPortConflictHandling() th
[
https://issues.apache.org/jira/browse/FLINK-4229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387809#comment-15387809
]
ASF GitHub Bot commented on FLINK-4229:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2279
[FLINK-4229] Only start JMX server when port is specified
The JMX reporter now only starts an extra server if a port (or port range)
was specified. Otherwise, it will just have the default local JM
[
https://issues.apache.org/jira/browse/FLINK-4201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387800#comment-15387800
]
ASF GitHub Bot commented on FLINK-4201:
---
Github user StephanEwen commented on the is
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2276
Thanks for taking a look, Stephan.
Regarding your question: *Would we interfere with such a setup when
removing checkpoints on "suspend" in "standalone" mode?*:
Yes, we would interfere,
[
https://issues.apache.org/jira/browse/FLINK-4201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387789#comment-15387789
]
ASF GitHub Bot commented on FLINK-4201:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387767#comment-15387767
]
ASF GitHub Bot commented on FLINK-4190:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387772#comment-15387772
]
Stephan Ewen edited comment on FLINK-4245 at 7/21/16 2:26 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387772#comment-15387772
]
Stephan Ewen commented on FLINK-4245:
-
An added benefit of that would be that, regardl
Stephan Ewen created FLINK-4245:
---
Summary: Metric naming improvements
Key: FLINK-4245
URL: https://issues.apache.org/jira/browse/FLINK-4245
Project: Flink
Issue Type: Improvement
Re
[
https://issues.apache.org/jira/browse/FLINK-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387768#comment-15387768
]
ASF GitHub Bot commented on FLINK-4202:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2271
---
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-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4202.
Resolution: Done
Added via 5dd85e2867a639e10891209dd59be0136a19ecfa
> Add JM metric which shows the
[
https://issues.apache.org/jira/browse/FLINK-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387754#comment-15387754
]
ASF GitHub Bot commented on FLINK-4202:
---
Github user tillrohrmann commented on the i
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2269
Very good work!
I know we discussed before whether to check for inactivity in a different
thread or in `invoke()`. There's actually a third option that I'm showcasing in
the PR I did agains
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2256
Thank you for your review. I've addressed your comment and now parent
directories are deleted if empty, resulting in an empty storage folder after
regular cleanup. If there are no objections, I would lik
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2271
Thanks for the review @uce. 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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/19dae21b00cfbf68ee64af80672d25974a3cd346#commitcomment-18339788
Let's leave the remainder as it is for now, at least as long as we do not
have the name collisions fully resolved. I am filing
[
https://issues.apache.org/jira/browse/FLINK-4150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387753#comment-15387753
]
ASF GitHub Bot commented on FLINK-4150:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15387744#comment-15387744
]
ASF GitHub Bot commented on FLINK-4150:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2256#discussion_r71711908
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobManagerHARecoveryTest.java
---
@@ -243,6 +256,268 @@ public void testJobRecoveryWhen
Till Rohrmann created FLINK-4244:
Summary: Field names for union operator do not have to be equal
Key: FLINK-4244
URL: https://issues.apache.org/jira/browse/FLINK-4244
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-3962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-3962.
-
Resolution: Fixed
> JMXReporter doesn't properly register/deregister metrics
> ---
Stephan Ewen created FLINK-4243:
---
Summary: Change "Scope" to "Namespace" for Metrics
Key: FLINK-4243
URL: https://issues.apache.org/jira/browse/FLINK-4243
Project: Flink
Issue Type: Improvement
1 - 100 of 159 matches
Mail list logo
