[jira] [Comment Edited] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963873#comment-15963873 ] mingleizhang edited comment on FLINK-6275 at 4/11/17 7:03 AM: --

[jira] [Commented] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963968#comment-15963968 ] ASF GitHub Bot commented on FLINK-6275: --- GitHub user zhangminglei opened a pull requ

[GitHub] flink pull request #3707: [FLINK-6275] [yarn] Fix unprotected access to reso...

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 fol

[GitHub] flink issue #3707: [FLINK-6275] [yarn] Fix unprotected access to resourceMan...

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 Gi

[jira] [Commented] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964022#comment-15964022 ] ASF GitHub Bot commented on FLINK-6275: --- Github user zhangminglei commented on the i

[jira] [Created] (FLINK-6291) Internal Timer service cannot be "removed"

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

[jira] [Created] (FLINK-6292) Travis: transfer.sh not accepting uploads via http:// anymore

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 Issu

[jira] [Commented] (FLINK-6245) Fix late side output documentation in Window documents.

[ https://issues.apache.org/jira/browse/FLINK-6245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964067#comment-15964067 ] mingleizhang commented on FLINK-6245: - [~kkl0u] Could you please specify information o

[jira] [Comment Edited] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

[ https://issues.apache.org/jira/browse/FLINK-6275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15963873#comment-15963873 ] mingleizhang edited comment on FLINK-6275 at 4/11/17 9:43 AM: --

[jira] [Commented] (FLINK-6292) Travis: transfer.sh not accepting uploads via http:// anymore

[ https://issues.apache.org/jira/browse/FLINK-6292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964092#comment-15964092 ] ASF GitHub Bot commented on FLINK-6292: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #3708: [FLINK-6292] fix transfer.sh upload by using https

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 https://github.

[GitHub] flink issue #3359: [FLINK-5544][streaming] Add InternalTimerService implemen...

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 asynchronou

[jira] [Commented] (FLINK-5544) Implement Internal Timer Service in RocksDB

[ https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964122#comment-15964122 ] ASF GitHub Bot commented on FLINK-5544: --- Github user shixiaogang commented on the is

[jira] [Created] (FLINK-6293) Flakey JobManagerITCase

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: Job-S

[jira] [Created] (FLINK-6294) BucketingSink throws NPE while cancelling job

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 Compo

[jira] [Commented] (FLINK-6293) Flakey JobManagerITCase

[ https://issues.apache.org/jira/browse/FLINK-6293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964138#comment-15964138 ] Nico Kruber commented on FLINK-6293: Same here (with only the {{transfer.sh}} upload c

[jira] [Updated] (FLINK-6293) Flakey JobManagerITCase

[ 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 > ---

[jira] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

[ https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964153#comment-15964153 ] mingleizhang commented on FLINK-6143: - [~tedyu] Hi, Could you please assgin this jira

[jira] [Comment Edited] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

[ https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964153#comment-15964153 ] mingleizhang edited comment on FLINK-6143 at 4/11/17 10:37 AM: -

[jira] [Assigned] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

[ 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 LocalExecutor#endSession

[jira] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

[ https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964188#comment-15964188 ] Chesnay Schepler commented on FLINK-6143: - [~mingleizhang] I've given you contribu

[jira] [Created] (FLINK-6295) use LoadingCache instead of WeakHashMap to lower latency

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

[jira] [Assigned] (FLINK-5901) 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: Tao Wang > DAG can not show properly in IE > --- > >

[jira] [Assigned] (FLINK-5901) 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 > --- > >

[jira] [Assigned] (FLINK-6295) use LoadingCache instead of WeakHashMap to lower latency

[ 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 > -

[jira] [Commented] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964250#comment-15964250 ] Stefano Bortoli commented on FLINK-6250: According to the JIRA issue open to Calci

[GitHub] flink pull request #3709: [FLINK-6295]use LoadingCache instead of WeakHashMa...

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 on

[jira] [Commented] (FLINK-6295) use LoadingCache instead of WeakHashMap to lower latency

[ https://issues.apache.org/jira/browse/FLINK-6295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964253#comment-15964253 ] ASF GitHub Bot commented on FLINK-6295: --- GitHub user WangTaoTheTonic opened a pull r

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

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 @@ +/* + * Licensed

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

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] flink pull request #3700: Backbone implementation for supporting sort. Imple...

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] flink pull request #3700: Backbone implementation for supporting sort. Imple...

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] flink pull request #3700: Backbone implementation for supporting sort. Imple...

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 +1,139

[GitHub] flink pull request #3710: [FLINK-6143] [clients] Fix unprotected access to t...

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

[jira] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

[ https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964524#comment-15964524 ] ASF GitHub Bot commented on FLINK-6143: --- GitHub user zhangminglei opened a pull requ

[jira] [Commented] (FLINK-6143) Unprotected access to this.flink in LocalExecutor#endSession()

[ https://issues.apache.org/jira/browse/FLINK-6143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964530#comment-15964530 ] mingleizhang commented on FLINK-6143: - [~Zentol] Thanks for your help and the pr is re

[jira] [Assigned] (FLINK-6275) Unprotected access to resourceManager in YarnFlinkApplicationMasterRunner#runApplicationMaster

[ 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 > YarnFlinkApplicationMast

[jira] [Created] (FLINK-6296) Retrieving execution plan fails succeeding execution attempt

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 I

[jira] [Updated] (FLINK-6296) Retrieving execution plan fails succeeding execution attempt

[ 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 {{ExecutionEnvi

[jira] [Updated] (FLINK-6296) Retrieving execution plan fails succeeding execution attempt

[ 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 {{ExecutionEnvi

[jira] [Created] (FLINK-6297) CEP timeout does not trigger under certain conditions

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: Flink

[jira] [Created] (FLINK-6298) Local execution is not setting RuntimeContext for RichOutputFormat

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 Project:

[GitHub] flink pull request #3705: [FLINK-6286] Fix the hbase command not found error

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 i

[jira] [Commented] (FLINK-6286) hbase command not found error

[ https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965233#comment-15965233 ] ASF GitHub Bot commented on FLINK-6286: --- Github user lingjinjiang closed the pull re

[jira] [Updated] (FLINK-6286) 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 error

[GitHub] flink pull request #3711: [FLINK-6286] [script] Fix the hbase command not fo...

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.

[jira] [Commented] (FLINK-6286) hbase command not found error

[ https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965283#comment-15965283 ] ASF GitHub Bot commented on FLINK-6286: --- GitHub user lingjinjiang opened a pull requ

[jira] [Commented] (FLINK-6286) hbase command not found error

[ https://issues.apache.org/jira/browse/FLINK-6286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965289#comment-15965289 ] Jinjiang Ling commented on FLINK-6286: -- Hi,[~greghogan], I have attach a patch and op

[GitHub] flink pull request #3700: Backbone implementation for supporting sort. Imple...

Github user rtudoran commented on a diff in the pull request: https://github.com/apache/flink/pull/3700#discussion_r111073880 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedSortProcessFunction.scala --- @@ -0,0 +1,139

[GitHub] flink issue #3604: [FLINK-5998] Un-fat Hadoop from Flink fat jar

Github user haohui commented on the issue: https://github.com/apache/flink/pull/3604 @rmetzger ping...would you mind taking a look? --- 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 featur

[jira] [Commented] (FLINK-5998) Un-fat Hadoop from Flink fat jar

[ https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965467#comment-15965467 ] ASF GitHub Bot commented on FLINK-5998: --- Github user haohui commented on the issue:

[GitHub] flink pull request #3712: [FLINK-6281] Create TableSink for JDBC.

GitHub user haohui opened a pull request: https://github.com/apache/flink/pull/3712 [FLINK-6281] Create TableSink for JDBC. This PR implements the `StreamTableSink` interface for the JDBC connectors so that the streaming SQL APIs can directly interact with them. You can merge this

[jira] [Commented] (FLINK-6281) Create TableSink for JDBC

[ https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15965470#comment-15965470 ] ASF GitHub Bot commented on FLINK-6281: --- GitHub user haohui opened a pull request: