[jira] [Commented] (FLINK-7800) Enable window joins without equi-join predicates

2018-09-28 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632815#comment-16632815 ] Xingcan Cui commented on FLINK-7800: As posted in the calcite mailing list before [Question about

[jira] [Commented] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

2018-09-28 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632808#comment-16632808 ] zhijiang commented on FLINK-10462: -- [~pnowojski] [~NicoK] Do you have other concerns or is it necessary

[jira] [Updated] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

2018-09-28 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-10462: - Description: Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will be

[jira] [Updated] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

2018-09-28 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-10462: - Description: Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will be

[jira] [Updated] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

2018-09-28 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-10462: - Description: Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will be

[jira] [Updated] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

2018-09-28 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-10462: - Description: Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will be

[jira] [Commented] (FLINK-10340) Add Cosh math function supported in Table API and SQL

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632805#comment-16632805 ] ASF GitHub Bot commented on FLINK-10340: xccui commented on a change in pull request #6700:

[GitHub] xccui commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL

2018-09-28 Thread GitBox
xccui commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6700#discussion_r221416887 ## File path: docs/dev/table/functions.md ## @@ -1274,6 +1274,17 @@

[jira] [Commented] (FLINK-10340) Add Cosh math function supported in Table API and SQL

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632803#comment-16632803 ] ASF GitHub Bot commented on FLINK-10340: xccui commented on a change in pull request #6700:

[GitHub] xccui commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL

2018-09-28 Thread GitBox
xccui commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6700#discussion_r221416735 ## File path:

[jira] [Commented] (FLINK-10340) Add Cosh math function supported in Table API and SQL

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632801#comment-16632801 ] ASF GitHub Bot commented on FLINK-10340: xccui commented on a change in pull request #6700:

[GitHub] xccui commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL

2018-09-28 Thread GitBox
xccui commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6700#discussion_r221416690 ## File path:

[jira] [Commented] (FLINK-10340) Add Cosh math function supported in Table API and SQL

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632800#comment-16632800 ] ASF GitHub Bot commented on FLINK-10340: xccui commented on a change in pull request #6700:

[GitHub] xccui commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL

2018-09-28 Thread GitBox
xccui commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6700#discussion_r221416652 ## File path:

[jira] [Commented] (FLINK-10340) Add Cosh math function supported in Table API and SQL

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632799#comment-16632799 ] ASF GitHub Bot commented on FLINK-10340: xccui commented on a change in pull request #6700:

[GitHub] xccui commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL

2018-09-28 Thread GitBox
xccui commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6700#discussion_r221416622 ## File path: docs/dev/table/functions.md ## @@ -1274,6 +1274,17 @@

[jira] [Commented] (FLINK-10427) Port JobSubmitTest to new code base

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632776#comment-16632776 ] ASF GitHub Bot commented on FLINK-10427: TisonKun removed a comment on issue #6768:

[jira] [Commented] (FLINK-10406) Port JobManagerTest to new code base

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632774#comment-16632774 ] ASF GitHub Bot commented on FLINK-10406: TisonKun removed a comment on issue #6765:

[jira] [Commented] (FLINK-10427) Port JobSubmitTest to new code base

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632775#comment-16632775 ] ASF GitHub Bot commented on FLINK-10427: TisonKun removed a comment on issue #6768:

[GitHub] TisonKun removed a comment on issue #6768: [FLINK-10427] [tests] Port JobSubmitTest to new code base

2018-09-28 Thread GitBox
TisonKun removed a comment on issue #6768: [FLINK-10427] [tests] Port JobSubmitTest to new code base URL: https://github.com/apache/flink/pull/6768#issuecomment-425414128 Still fails on `ScheduleOrUpdateConsumersTest`, can be reproduced on master, so it is irrelevant.

[GitHub] TisonKun removed a comment on issue #6768: [FLINK-10427] [tests] Port JobSubmitTest to new code base

2018-09-28 Thread GitBox
TisonKun removed a comment on issue #6768: [FLINK-10427] [tests] Port JobSubmitTest to new code base URL: https://github.com/apache/flink/pull/6768#issuecomment-425101906 FYI travis fails on irrelevant test. ```

[GitHub] TisonKun removed a comment on issue #6765: [FLINK-10406] [tests] Port JobManagerTest to new code base

2018-09-28 Thread GitBox
TisonKun removed a comment on issue #6765: [FLINK-10406] [tests] Port JobManagerTest to new code base URL: https://github.com/apache/flink/pull/6765#issuecomment-424804290 FYI, travis fails on `org.apache.flink.queryablestate.network.ClientTest#testSimpleRequests`, which I cannot

[jira] [Updated] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

2018-09-28 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-10462: - Description: Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will be

[jira] [Updated] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

2018-09-28 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-10462: - Description: Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will be

[jira] [Updated] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

2018-09-28 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-10462: - Description: Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will be

[jira] [Updated] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

2018-09-28 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-10462: - Description: Every {{IntermediateResult}} generates a random {{ConnectionIndex}} which will be

[jira] [Created] (FLINK-10462) Remove ConnectionIndex for further sharing tcp connection in credit-based mode

2018-09-28 Thread zhijiang (JIRA)
zhijiang created FLINK-10462: Summary: Remove ConnectionIndex for further sharing tcp connection in credit-based mode Key: FLINK-10462 URL: https://issues.apache.org/jira/browse/FLINK-10462 Project:

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632763#comment-16632763 ] ASF GitHub Bot commented on FLINK-10247: Clark commented on issue #6759:

[GitHub] Clarkkkkk commented on issue #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system

2018-09-28 Thread GitBox
Clark commented on issue #6759: [FLINK-10247][Metrics] Run MetricQueryService in a dedicated actor system URL: https://github.com/apache/flink/pull/6759#issuecomment-425612640 @yanghua Thx! This is an automated message

[GitHub] TisonKun commented on a change in pull request #6751: [FLINK-10403] Port JobManagerHAProcessFailureBatchRecoveryITCase to new code base

2018-09-28 Thread GitBox
TisonKun commented on a change in pull request #6751: [FLINK-10403] Port JobManagerHAProcessFailureBatchRecoveryITCase to new code base URL: https://github.com/apache/flink/pull/6751#discussion_r221413841 ## File path:

[jira] [Commented] (FLINK-10403) Port JobManagerHAProcessFailureBatchRecoveryITCase to new code base

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632754#comment-16632754 ] ASF GitHub Bot commented on FLINK-10403: TisonKun commented on a change in pull request #6751:

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632738#comment-16632738 ] ASF GitHub Bot commented on FLINK-10461: klion26 commented on issue #6777: [FLINK-10461] [State

[GitHub] klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

2018-09-28 Thread GitBox
klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#issuecomment-425609212 cc @StefanRRichter I use 5 threads for downloading files, because I think 5 is enough for

[jira] [Commented] (FLINK-5542) YARN client incorrectly uses local YARN config to check vcore capacity

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632737#comment-16632737 ] ASF GitHub Bot commented on FLINK-5542: --- leanken commented on issue #6775: [FLINK-5542] use

[GitHub] leanken commented on issue #6775: [FLINK-5542] use YarnCluster vcores setting to do MaxVCore validation

2018-09-28 Thread GitBox
leanken commented on issue #6775: [FLINK-5542] use YarnCluster vcores setting to do MaxVCore validation URL: https://github.com/apache/flink/pull/6775#issuecomment-425609144 cc @rehevkor5 @tillrohrmann This is an automated

[jira] [Updated] (FLINK-10461) Speed up download file procedure when restore

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10461: --- Labels: pull-request-available (was: ) > Speed up download file procedure when restore >

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632735#comment-16632735 ] ASF GitHub Bot commented on FLINK-10461: klion26 opened a new pull request #6777: [FLINK-10461]

[GitHub] klion26 opened a new pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

2018-09-28 Thread GitBox
klion26 opened a new pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777 ## What is the purpose of the change This PR speed up the download files when restore from DFS using

[jira] [Created] (FLINK-10461) Speed up download file procedure when restore

2018-09-28 Thread Congxian Qiu (JIRA)
Congxian Qiu created FLINK-10461: Summary: Speed up download file procedure when restore Key: FLINK-10461 URL: https://issues.apache.org/jira/browse/FLINK-10461 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-10461) Speed up download file procedure when restore

2018-09-28 Thread Congxian Qiu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu reassigned FLINK-10461: Assignee: Congxian Qiu > Speed up download file procedure when restore >

[jira] [Commented] (FLINK-10152) Add reverse supported in TableAPI and SQL

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632724#comment-16632724 ] ASF GitHub Bot commented on FLINK-10152: yanghua commented on a change in pull request #6773:

[jira] [Commented] (FLINK-10152) Add reverse supported in TableAPI and SQL

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632726#comment-16632726 ] ASF GitHub Bot commented on FLINK-10152: yanghua commented on a change in pull request #6773:

[jira] [Commented] (FLINK-10152) Add reverse supported in TableAPI and SQL

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632725#comment-16632725 ] ASF GitHub Bot commented on FLINK-10152: yanghua commented on a change in pull request #6773:

[GitHub] yanghua commented on a change in pull request #6773: [FLINK-10152] [table] Add reverse function in Table API and SQL

2018-09-28 Thread GitBox
yanghua commented on a change in pull request #6773: [FLINK-10152] [table] Add reverse function in Table API and SQL URL: https://github.com/apache/flink/pull/6773#discussion_r221411819 ## File path: docs/dev/table/functions.md ## @@ -2963,6 +2985,17 @@

[GitHub] yanghua commented on a change in pull request #6773: [FLINK-10152] [table] Add reverse function in Table API and SQL

2018-09-28 Thread GitBox
yanghua commented on a change in pull request #6773: [FLINK-10152] [table] Add reverse function in Table API and SQL URL: https://github.com/apache/flink/pull/6773#discussion_r221411780 ## File path: docs/dev/table/functions.md ## @@ -2460,6 +2460,17 @@ REPLACE(string1,

[GitHub] yanghua commented on a change in pull request #6773: [FLINK-10152] [table] Add reverse function in Table API and SQL

2018-09-28 Thread GitBox
yanghua commented on a change in pull request #6773: [FLINK-10152] [table] Add reverse function in Table API and SQL URL: https://github.com/apache/flink/pull/6773#discussion_r221411814 ## File path: docs/dev/table/functions.md ## @@ -2712,6 +2723,17 @@

[jira] [Updated] (FLINK-10152) Add reverse supported in TableAPI and SQL

2018-09-28 Thread Guibo Pan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guibo Pan updated FLINK-10152: -- Component/s: Table API & SQL > Add reverse supported in TableAPI and SQL >

[jira] [Updated] (FLINK-10152) Add reverse supported in TableAPI and SQL

2018-09-28 Thread Guibo Pan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guibo Pan updated FLINK-10152: -- Labels: pull-request-available (was: ) > Add reverse supported in TableAPI and SQL >

[jira] [Commented] (FLINK-7525) Add config option to disable Cancel functionality on UI

2018-09-28 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632688#comment-16632688 ] vinoyang commented on FLINK-7525: - hi [~till.rohrmann] yes, you are right. I mean, do we still need to

[jira] [Commented] (FLINK-9587) ContinuousFileMonitoringFunction crashes on short living files

2018-09-28 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632656#comment-16632656 ] Bowen Li commented on FLINK-9587: - Set a FilePathFilter in FileInputFormat and just ignore any temporary

[jira] [Commented] (FLINK-9953) Active Kubernetes integration

2018-09-28 Thread JIN SUN (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632653#comment-16632653 ] JIN SUN commented on FLINK-9953: [~till.rohrmann], is there anyone working on this? i would like to

[jira] [Commented] (FLINK-9955) Kubernetes ClusterDescriptor

2018-09-28 Thread JIN SUN (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632652#comment-16632652 ] JIN SUN commented on FLINK-9955: [~till.rohrmann], is there anyone working on this? i would like to

[jira] [Updated] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

2018-09-28 Thread JIN SUN (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN updated FLINK-10205: Description: Today DataSource Task pull InputSplits from JobManager to achieve better performance,

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632583#comment-16632583 ] ASF GitHub Bot commented on FLINK-10205: isunjin commented on issue #6684: [FLINK-10205]

[GitHub] isunjin commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

2018-09-28 Thread GitBox
isunjin commented on issue #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#issuecomment-425576301 @fhueske @StephanEwen could you help to have a look?

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632580#comment-16632580 ] ASF GitHub Bot commented on FLINK-10205: isunjin commented on a change in pull request #6684:

[GitHub] isunjin commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

2018-09-28 Thread GitBox
isunjin commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#discussion_r221389763 ## File path:

[jira] [Commented] (FLINK-10148) flink cancel withSavepoint does not seem to use akka properties from flink-conf.yaml with Flink 1.6.0 as with flink 1.4.x

2018-09-28 Thread David Haglund (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632578#comment-16632578 ] David Haglund commented on FLINK-10148: --- This issue seems to be fixed in 1.6.1 and with

[jira] [Commented] (FLINK-10388) RestClientTest sometimes fails with AssertionError

2018-09-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632560#comment-16632560 ] Ted Yu commented on FLINK-10388: I don't see 'Network unreachable' error in FLINK-4052 > RestClientTest

[jira] [Updated] (FLINK-9048) LocalFlinkMiniClusterITCase#testLocalFlinkMiniClusterWithMultipleTaskManagers sometimes fails

2018-09-28 Thread Ted Yu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9048: -- Description: As of commit e0bc37bef69f5376d03214578e9b95816add661b, I got the following : {code}

[jira] [Closed] (FLINK-10311) HA end-to-end/Jepsen tests for standby Dispatchers

2018-09-28 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-10311. Resolution: Fixed Fixed via abc6453ccde474b07c41fd405565db22ff1b00c0 > HA end-to-end/Jepsen tests for

[jira] [Commented] (FLINK-10311) HA end-to-end/Jepsen tests for standby Dispatchers

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632263#comment-16632263 ] ASF GitHub Bot commented on FLINK-10311: asfgit closed pull request #6712: [FLINK-10311][tests]

[jira] [Updated] (FLINK-10311) HA end-to-end/Jepsen tests for standby Dispatchers

2018-09-28 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10311: - Fix Version/s: (was: 1.6.2) > HA end-to-end/Jepsen tests for standby Dispatchers >

[jira] [Created] (FLINK-10460) DataDog reporter JsonMappingException

2018-09-28 Thread Elias Levy (JIRA)
Elias Levy created FLINK-10460: -- Summary: DataDog reporter JsonMappingException Key: FLINK-10460 URL: https://issues.apache.org/jira/browse/FLINK-10460 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-09-28 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632167#comment-16632167 ] Nico Kruber commented on FLINK-10419: - Hi [~Xeli], I don't think, your Exception is related - the

[jira] [Updated] (FLINK-10459) Flink cluster does not work properly in kubernetes

2018-09-28 Thread Georgii Gobozov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Georgii Gobozov updated FLINK-10459: Component/s: (was: Configuration) (was: Cluster Management) >

[jira] [Commented] (FLINK-10419) ClassNotFoundException while deserializing user exceptions from checkpointing

2018-09-28 Thread Richard Deurwaarder (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632161#comment-16632161 ] Richard Deurwaarder commented on FLINK-10419: - I have actually run into a very similar

[jira] [Updated] (FLINK-10459) Flink cluster does not work properly in kubernetes

2018-09-28 Thread Georgii Gobozov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Georgii Gobozov updated FLINK-10459: Description: Trying to run flink 1.6.1/1.5.4 cluster in Kubernetes, using default

[jira] [Updated] (FLINK-10459) Flink cluster does not work properly in kubernetes

2018-09-28 Thread Georgii Gobozov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Georgii Gobozov updated FLINK-10459: Attachment: image-2018-09-28-10-30-27-649.png > Flink cluster does not work properly in

[jira] [Updated] (FLINK-10459) Flink cluster does not work properly in kubernetes

2018-09-28 Thread Georgii Gobozov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Georgii Gobozov updated FLINK-10459: Attachment: jobmanger.log > Flink cluster does not work properly in kubernetes >

[jira] [Updated] (FLINK-10459) Flink cluster does not work properly in kubernetes

2018-09-28 Thread Georgii Gobozov (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Georgii Gobozov updated FLINK-10459: Attachment: taskmanager.log > Flink cluster does not work properly in kubernetes >

[jira] [Created] (FLINK-10459) Flink cluster does not work properly in kubernetes

2018-09-28 Thread Georgii Gobozov (JIRA)
Georgii Gobozov created FLINK-10459: --- Summary: Flink cluster does not work properly in kubernetes Key: FLINK-10459 URL: https://issues.apache.org/jira/browse/FLINK-10459 Project: Flink

[jira] [Resolved] (FLINK-10065) InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

2018-09-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10065. --- Resolution: Fixed Fix Version/s: 1.7.0 Fixed via

[jira] [Commented] (FLINK-10065) InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632110#comment-16632110 ] ASF GitHub Bot commented on FLINK-10065: tillrohrmann closed pull request #6498: [FLINK-10065]

[GitHub] tillrohrmann closed pull request #6498: [FLINK-10065] InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

2018-09-28 Thread GitBox
tillrohrmann closed pull request #6498: [FLINK-10065] InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream URL: https://github.com/apache/flink/pull/6498 This is a PR merged from a forked repository. As GitHub hides

[jira] [Commented] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632104#comment-16632104 ] ASF GitHub Bot commented on FLINK-10291: yanghua commented on issue #6733: [FLINK-10291]

[GitHub] yanghua commented on issue #6733: [FLINK-10291] Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

2018-09-28 Thread GitBox
yanghua commented on issue #6733: [FLINK-10291] Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/6733#issuecomment-425493849 @tillrohrmann I have refactored and rebased this PR. I found the original

[jira] [Updated] (FLINK-8803) Mini Cluster Shutdown with HA unstable, causing test failures

2018-09-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8803: - Fix Version/s: (was: 1.7.0) > Mini Cluster Shutdown with HA unstable, causing test failures

[jira] [Commented] (FLINK-8803) Mini Cluster Shutdown with HA unstable, causing test failures

2018-09-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632095#comment-16632095 ] Till Rohrmann commented on FLINK-8803: -- Yes, I agree, we won't do this for 1.7.0 since we hopefully

[jira] [Commented] (FLINK-8035) Unable to submit job when HA is enabled

2018-09-28 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632090#comment-16632090 ] Till Rohrmann commented on FLINK-8035: -- The {{jobmanager.log}} would be a good start. > Unable to

[jira] [Commented] (FLINK-10126) There should be a Scala DataSource

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632048#comment-16632048 ] ASF GitHub Bot commented on FLINK-10126: yanghua commented on issue #6738: [FLINK-10126] There

[GitHub] yanghua commented on issue #6738: [FLINK-10126] There should be a Scala DataSource

2018-09-28 Thread GitBox
yanghua commented on issue #6738: [FLINK-10126] There should be a Scala DataSource URL: https://github.com/apache/flink/pull/6738#issuecomment-425481174 @tillrohrmann and @pnowojski any suggestion? This is an automated

[jira] [Commented] (FLINK-10398) Add Tanh math function supported in Table API and SQL

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632044#comment-16632044 ] ASF GitHub Bot commented on FLINK-10398: yanghua commented on issue #6736: [FLINK-10398][table]

[GitHub] yanghua commented on issue #6736: [FLINK-10398][table] Add Tanh math function supported in Table API and SQL

2018-09-28 Thread GitBox
yanghua commented on issue #6736: [FLINK-10398][table] Add Tanh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6736#issuecomment-425480397 also updated this PR's documentation This is

[jira] [Commented] (FLINK-10384) Add Sinh math function supported in Table API and SQL

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632030#comment-16632030 ] ASF GitHub Bot commented on FLINK-10384: yanghua commented on issue #6730: [FLINK-10384][table]

[GitHub] yanghua commented on issue #6730: [FLINK-10384][table] Add Sinh math function supported in Table API and SQL

2018-09-28 Thread GitBox
yanghua commented on issue #6730: [FLINK-10384][table] Add Sinh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6730#issuecomment-425478395 also updated the documentation. This is an

[jira] [Commented] (FLINK-10340) Add Cosh math function supported in Table API and SQL

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16632019#comment-16632019 ] ASF GitHub Bot commented on FLINK-10340: yanghua commented on a change in pull request #6700:

[GitHub] yanghua commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL

2018-09-28 Thread GitBox
yanghua commented on a change in pull request #6700: [FLINK-10340][table] Add Cosh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6700#discussion_r221296090 ## File path: docs/dev/table/functions.md ## @@ -1274,6 +1274,17 @@

[jira] [Commented] (FLINK-10311) HA end-to-end/Jepsen tests for standby Dispatchers

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631982#comment-16631982 ] ASF GitHub Bot commented on FLINK-10311: GJL commented on issue #6712: [FLINK-10311][tests] HA

[GitHub] GJL commented on issue #6712: [FLINK-10311][tests] HA end-to-end/Jepsen tests for standby Dispatchers

2018-09-28 Thread GitBox
GJL commented on issue #6712: [FLINK-10311][tests] HA end-to-end/Jepsen tests for standby Dispatchers URL: https://github.com/apache/flink/pull/6712#issuecomment-425466833 Merging This is an automated message from the Apache

[jira] [Updated] (FLINK-10311) HA end-to-end/Jepsen tests for standby Dispatchers

2018-09-28 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-10311: - Fix Version/s: (was: 1.5.5) > HA end-to-end/Jepsen tests for standby Dispatchers >

[jira] [Commented] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631965#comment-16631965 ] ASF GitHub Bot commented on FLINK-10291: tillrohrmann commented on issue #6733: [FLINK-10291]

[jira] [Commented] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631963#comment-16631963 ] ASF GitHub Bot commented on FLINK-10291: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631964#comment-16631964 ] ASF GitHub Bot commented on FLINK-10291: tillrohrmann commented on a change in pull request

[GitHub] tillrohrmann commented on issue #6733: [FLINK-10291] Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

2018-09-28 Thread GitBox
tillrohrmann commented on issue #6733: [FLINK-10291] Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/6733#issuecomment-425462347 Please also rebase onto the latest master if possible.

[jira] [Commented] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631959#comment-16631959 ] ASF GitHub Bot commented on FLINK-10291: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631961#comment-16631961 ] ASF GitHub Bot commented on FLINK-10291: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631957#comment-16631957 ] ASF GitHub Bot commented on FLINK-10291: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631960#comment-16631960 ] ASF GitHub Bot commented on FLINK-10291: tillrohrmann commented on a change in pull request

[jira] [Commented] (FLINK-10291) Generate JobGraph with fixed/configurable JobID in StandaloneJobClusterEntrypoint

2018-09-28 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16631962#comment-16631962 ] ASF GitHub Bot commented on FLINK-10291: tillrohrmann commented on a change in pull request

  1   2   3   >