GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/3710
[FLINK-6143] [clients] Fix unprotected access to this.flink in LocalEâ¦
â¦xecutor#endSession.
Thanks for contributing to Apache Flink. Before you open your pull request,
please take
[
https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964524#comment-15964524
]
ASF GitHub Bot commented on FLINK-6143:
---
GitHub user zhangminglei opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964530#comment-15964530
]
mingleizhang commented on FLINK-6143:
-
[~Zentol] Thanks for your help and the pr is ready now. Could
[
https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-6275:
---
Assignee: mingleizhang
> Unprotected access to resourceManager in
>
Petr Novotnik created FLINK-6296:
Summary: Retrieving execution plan fails succeeding execution
attempt
Key: FLINK-6296
URL: https://issues.apache.org/jira/browse/FLINK-6296
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Petr Novotnik updated FLINK-6296:
-
Description:
Hello,
calling {{ExecutionEnvironment#getExecutionPlan()}} prior to
[
https://issues.apache.org/jira/browse/FLINK-6296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Petr Novotnik updated FLINK-6296:
-
Description:
Hello,
calling {{ExecutionEnvironment#getExecutionPlan()}} prior to
Vijayakumar Palaniappan created FLINK-6297:
--
Summary: CEP timeout does not trigger under certain conditions
Key: FLINK-6297
URL: https://issues.apache.org/jira/browse/FLINK-6297
Project:
Mateusz Zakarczemny created FLINK-6298:
--
Summary: Local execution is not setting RuntimeContext for
RichOutputFormat
Key: FLINK-6298
URL: https://issues.apache.org/jira/browse/FLINK-6298
[
https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15965289#comment-15965289
]
Jinjiang Ling commented on FLINK-6286:
--
Hi,[~greghogan], I have attach a patch and opened a pull
Github user lingjinjiang closed the pull request at:
https://github.com/apache/flink/pull/3705
---
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
[
https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15965233#comment-15965233
]
ASF GitHub Bot commented on FLINK-6286:
---
Github user lingjinjiang closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15965283#comment-15965283
]
ASF GitHub Bot commented on FLINK-6286:
---
GitHub user lingjinjiang opened a pull request:
GitHub user lingjinjiang opened a pull request:
https://github.com/apache/flink/pull/3711
[FLINK-6286] [script] Fix the hbase command not found error
When using flink with the HBASE_CONF_DIR env variable and don't install
hbase, then will get the "hbase command not found" error.
[
https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinjiang Ling updated FLINK-6286:
-
Attachment: FLINK-6286-1.patch
Remove a unnecessary echo command.
> hbase command not found
[
https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963873#comment-15963873
]
mingleizhang edited comment on FLINK-6275 at 4/11/17 7:03 AM:
--
Let me inside
[
https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963968#comment-15963968
]
ASF GitHub Bot commented on FLINK-6275:
---
GitHub user zhangminglei opened a pull request:
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/3707
[FLINK-6275] [yarn] Fix unprotected access to resourceManage in
YarnFlinkApplicationMasterRunner
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the
[
https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15963873#comment-15963873
]
mingleizhang edited comment on FLINK-6275 at 4/11/17 9:43 AM:
--
[~tedyu] Could
[
https://issues.apache.org/jira/browse/FLINK-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964092#comment-15964092
]
ASF GitHub Bot commented on FLINK-6292:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/3708
[FLINK-6292] fix transfer.sh upload by using https
Seems the upload via http is not supported anymore.
You can merge this pull request into a Git repository by running:
$ git pull
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/3707
@rmetzger @greghogan Could you please take some time review my code ? Many
thanks to you both.
---
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-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964022#comment-15964022
]
ASF GitHub Bot commented on FLINK-6275:
---
Github user zhangminglei commented on the issue:
Gyula Fora created FLINK-6291:
-
Summary: Internal Timer service cannot be "removed"
Key: FLINK-6291
URL: https://issues.apache.org/jira/browse/FLINK-6291
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-6292:
--
Summary: Travis: transfer.sh not accepting uploads via http://
anymore
Key: FLINK-6292
URL: https://issues.apache.org/jira/browse/FLINK-6292
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964067#comment-15964067
]
mingleizhang commented on FLINK-6245:
-
[~kkl0u] Could you please specify information of where the
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3359
@vpernin Thanks very much for your attention. The PR is supposed to work on
1.3-SNAPSHOT, but it's not testable now due to some known bugs.
Besides, i want to add support for
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964122#comment-15964122
]
ASF GitHub Bot commented on FLINK-5544:
---
Github user shixiaogang commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tao Wang reassigned FLINK-5901:
---
Assignee: Tao Wang
> DAG can not show properly in IE
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-5901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tao Wang reassigned FLINK-5901:
---
Assignee: (was: Tao Wang)
> DAG can not show properly in IE
> ---
>
Tao Wang created FLINK-6295:
---
Summary: use LoadingCache instead of WeakHashMap to lower latency
Key: FLINK-6295
URL: https://issues.apache.org/jira/browse/FLINK-6295
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tao Wang reassigned FLINK-6295:
---
Assignee: Tao Wang
> use LoadingCache instead of WeakHashMap to lower latency
>
[
https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964250#comment-15964250
]
Stefano Bortoli commented on FLINK-6250:
According to the JIRA issue open to Calcite, there is no
GitHub user WangTaoTheTonic opened a pull request:
https://github.com/apache/flink/pull/3709
[FLINK-6295]use LoadingCache instead of WeakHashMap to lower latency
Now in ExecutionGraphHolder, which is used in many handlers, we use a
WeakHashMap to cache ExecutionGraph(s), which is
[
https://issues.apache.org/jira/browse/FLINK-6295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964253#comment-15964253
]
ASF GitHub Bot commented on FLINK-6295:
---
GitHub user WangTaoTheTonic opened a pull request:
Andrey created FLINK-6294:
-
Summary: BucketingSink throws NPE while cancelling job
Key: FLINK-6294
URL: https://issues.apache.org/jira/browse/FLINK-6294
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964138#comment-15964138
]
Nico Kruber commented on FLINK-6293:
Same here (with only the {{transfer.sh}} upload changed compared
[
https://issues.apache.org/jira/browse/FLINK-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-6293:
---
Component/s: (was: Job-Submission)
JobManager
> Flakey JobManagerITCase
>
[
https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964153#comment-15964153
]
mingleizhang edited comment on FLINK-6143 at 4/11/17 10:37 AM:
---
[~tedyu] Hi,
[
https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-6143:
---
Assignee: mingleizhang
> Unprotected access to this.flink in
[
https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964188#comment-15964188
]
Chesnay Schepler commented on FLINK-6143:
-
[~mingleizhang] I've given you contributor permissions;
Nico Kruber created FLINK-6293:
--
Summary: Flakey JobManagerITCase
Key: FLINK-6293
URL: https://issues.apache.org/jira/browse/FLINK-6293
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15964153#comment-15964153
]
mingleizhang commented on FLINK-6143:
-
[~tedyu] Hi, Could you please assgin this jira to me ? I will
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110900086
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala
---
@@ -0,0 +1,367 @@
+/*
+ *
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110900641
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SortAggFunction.scala
---
@@ -0,0 +1,166 @@
+/*
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110900961
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SortAggFunction.scala
---
@@ -0,0 +1,166 @@
+/*
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110901541
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala
---
@@ -0,0 +1,167 @@
+/*
+
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110902190
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedSortProcessFunction.scala
---
@@ -0,0
48 matches
Mail list logo
