[GitHub] StephanEwen opened a new pull request #6728: [FLINK-10383] [s3] (release-1.6) Prevent Hadoop configs on classpath to interfere with S3 configuration

2018-09-20 Thread GitBox
StephanEwen opened a new pull request #6728: [FLINK-10383] [s3] (release-1.6) Prevent Hadoop configs on classpath to interfere with S3 configuration URL: https://github.com/apache/flink/pull/6728 ## What is the purpose of the change The S3 connectors are based on a self-contained

[jira] [Updated] (FLINK-10305) flink-conf.yaml grows continuously

2018-09-20 Thread Dimitrije (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dimitrije updated FLINK-10305: -- Priority: Major (was: Minor) > flink-conf.yaml grows continuously >

[GitHub] StefanRRichter commented on a change in pull request #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif…

2018-09-20 Thread GitBox
StefanRRichter commented on a change in pull request #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif… URL: https://github.com/apache/flink/pull/6723#discussion_r219264649 ## File path:

[jira] [Commented] (FLINK-10377) Remove precondition in TwoPhaseCommitSinkFunction.notifyCheckpointComplete

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

[jira] [Updated] (FLINK-10383) Hadoop configurations on the classpath seep into the S3 file system configs

2018-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10383: --- Labels: pull-request-available (was: ) > Hadoop configurations on the classpath seep into

[jira] [Commented] (FLINK-10383) Hadoop configurations on the classpath seep into the S3 file system configs

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

[jira] [Commented] (FLINK-10380) Check if key is not nul before assign to group in KeyedStream

2018-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622576#comment-16622576 ] ASF GitHub Bot commented on FLINK-10380: satybald commented on issue #6724: [FLINK-10380] Add

[GitHub] StefanRRichter commented on a change in pull request #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif…

2018-09-20 Thread GitBox
StefanRRichter commented on a change in pull request #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif… URL: https://github.com/apache/flink/pull/6723#discussion_r219263435 ## File path:

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-09-20 Thread William Cummings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622536#comment-16622536 ] William Cummings commented on FLINK-10184: -- >[~Jamalarm] [~wcummings] did you find time to test

[GitHub] satybald commented on issue #6724: [FLINK-10380] Add precondition for assignToKeyGroup method

2018-09-20 Thread GitBox
satybald commented on issue #6724: [FLINK-10380] Add precondition for assignToKeyGroup method URL: https://github.com/apache/flink/pull/6724#issuecomment-423304496 @StephanEwen I'm quite new to flink, why would be fine to have precondition check in the same class? Arent' those operators

[jira] [Commented] (FLINK-10375) ExceptionInChainedStubException hides wrapped exception in cause

2018-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622590#comment-16622590 ] ASF GitHub Bot commented on FLINK-10375: Noctune commented on issue #6719: [FLINK-10375] Add

[GitHub] Noctune commented on issue #6719: [FLINK-10375] Add wrapped exception as cause in ExceptionInChainedStubException

2018-09-20 Thread GitBox
Noctune commented on issue #6719: [FLINK-10375] Add wrapped exception as cause in ExceptionInChainedStubException URL: https://github.com/apache/flink/pull/6719#issuecomment-423306534 Seems like the build fails due to log length, but that is obviously not due to this change as no

[GitHub] asfgit closed pull request #6706: [hotfix][doc] Fix curl example in upload jar example

2018-09-20 Thread GitBox
asfgit closed pull request #6706: [hotfix][doc] Fix curl example in upload jar example URL: https://github.com/apache/flink/pull/6706 This is an automated message from the Apache Git Service. To respond to the message,

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

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

[GitHub] GJL commented on a change in pull request #6712: [FLINK-10311][tests] HA end-to-end/Jepsen tests for standby Dispatchers

2018-09-20 Thread GitBox
GJL commented on a change in pull request #6712: [FLINK-10311][tests] HA end-to-end/Jepsen tests for standby Dispatchers URL: https://github.com/apache/flink/pull/6712#discussion_r219282159 ## File path: flink-jepsen/scripts/run-tests.sh ## @@ -36,8 +36,15 @@ do lein

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

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

[jira] [Commented] (FLINK-10358) Flink kinesis connector could throw NPE during getRecords() call

2018-09-20 Thread Ying Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622739#comment-16622739 ] Ying Xu commented on FLINK-10358: - [PR 6708|https://github.com/apache/flink/pull/6708] is merged >

[jira] [Closed] (FLINK-10358) Flink kinesis connector could throw NPE during getRecords() call

2018-09-20 Thread Ying Xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ying Xu closed FLINK-10358. --- Resolution: Fixed > Flink kinesis connector could throw NPE during getRecords() call >

[GitHub] StefanRRichter commented on a change in pull request #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif…

2018-09-20 Thread GitBox
StefanRRichter commented on a change in pull request #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif… URL: https://github.com/apache/flink/pull/6723#discussion_r219263435 ## File path:

[jira] [Commented] (FLINK-10377) Remove precondition in TwoPhaseCommitSinkFunction.notifyCheckpointComplete

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

[jira] [Commented] (FLINK-10377) Remove precondition in TwoPhaseCommitSinkFunction.notifyCheckpointComplete

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

[GitHub] GJL commented on a change in pull request #6712: [FLINK-10311][tests] HA end-to-end/Jepsen tests for standby Dispatchers

2018-09-20 Thread GitBox
GJL commented on a change in pull request #6712: [FLINK-10311][tests] HA end-to-end/Jepsen tests for standby Dispatchers URL: https://github.com/apache/flink/pull/6712#discussion_r219282159 ## File path: flink-jepsen/scripts/run-tests.sh ## @@ -36,8 +36,15 @@ do lein

[jira] [Commented] (FLINK-8851) SQL Client fails if same file is used as default and env configuration

2018-09-20 Thread xuqianjin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623073#comment-16623073 ] xuqianjin commented on FLINK-8851: -- [~fhueske] [~twalthr] Hello, I want to try to recreate and fix this

[jira] [Comment Edited] (FLINK-8851) SQL Client fails if same file is used as default and env configuration

2018-09-20 Thread xuqianjin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623073#comment-16623073 ] xuqianjin edited comment on FLINK-8851 at 9/21/18 5:09 AM: --- [~fhueske]

[jira] [Updated] (FLINK-10386) Remove legacy class TaskExecutionStateListener

2018-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10386: --- Labels: pull-request-available (was: ) > Remove legacy class TaskExecutionStateListener >

[jira] [Commented] (FLINK-10386) Remove legacy class TaskExecutionStateListener

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

[GitHub] TisonKun opened a new pull request #6729: [FLINK-10386] [taskmanager] Remove legacy class TaskExecutionStateListener

2018-09-20 Thread GitBox
TisonKun opened a new pull request #6729: [FLINK-10386] [taskmanager] Remove legacy class TaskExecutionStateListener URL: https://github.com/apache/flink/pull/6729 ## What is the purpose of the change After a discussion

[jira] [Created] (FLINK-10386) Remove legacy class TaskExecutionStateListener

2018-09-20 Thread JIRA
陈梓立 created FLINK-10386: --- Summary: Remove legacy class TaskExecutionStateListener Key: FLINK-10386 URL: https://issues.apache.org/jira/browse/FLINK-10386 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10385) Implement a waitUntilCondition utils

2018-09-20 Thread JIRA
陈梓立 created FLINK-10385: --- Summary: Implement a waitUntilCondition utils Key: FLINK-10385 URL: https://issues.apache.org/jira/browse/FLINK-10385 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-10385) Implement a waitUntilCondition utils

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10385: Description: Recently when I refine some tests, I notice that it is a common requirement to wait until a

[jira] [Updated] (FLINK-10385) Implement a waitUntilCondition utils

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10385: Attachment: example.java > Implement a waitUntilCondition utils > > >

[GitHub] xccui commented on a change in pull request #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL

2018-09-20 Thread GitBox
xccui commented on a change in pull request #6448: [FLINK-9990] [table] Add regexp_extract supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6448#discussion_r219375972 ## File path: docs/dev/table/functions.md ## @@ -2448,6 +2448,18 @@

[jira] [Commented] (FLINK-9990) Add regexp_extract supported in TableAPI and SQL

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

[GitHub] xccui commented on issue #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

2018-09-20 Thread GitBox
xccui commented on issue #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576#issuecomment-423406252 Hi @Guibo-Pan, I wonder if you could rebase your code to resolve these conflicts. Thanks, Xingcan

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

2018-09-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623034#comment-16623034 ] ASF GitHub Bot commented on FLINK-10145: xccui commented on issue #6576: [FLINK-10145][table]

[GitHub] Clarkkkkk commented on issue #6676: [FLINK-10247][Metrics] Run MetricQueryService in separate thread pool

2018-09-20 Thread GitBox
Clark commented on issue #6676: [FLINK-10247][Metrics] Run MetricQueryService in separate thread pool URL: https://github.com/apache/flink/pull/6676#issuecomment-423392372 Hi @tillrohrmann, I have investigated on this after you comment on Jira. Thank you for sharing your idea and it

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

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

[jira] [Commented] (FLINK-10256) Port legacy jobmanager test to FILP-6

2018-09-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622760#comment-16622760 ] Till Rohrmann commented on FLINK-10256: --- At the moment the {{JobMaster}} failover is not super

[jira] [Assigned] (FLINK-10379) Can not use Table Functions in Java Table API

2018-09-20 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-10379: --- Assignee: Hequn Cheng > Can not use Table Functions in Java Table API >

[jira] [Commented] (FLINK-10379) Can not use Table Functions in Java Table API

2018-09-20 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622933#comment-16622933 ] Hequn Cheng commented on FLINK-10379: - I would like to look into this problem. > Can not use Table

[jira] [Updated] (FLINK-10302) Mark legacy(non-flip 6) code as Deprecated

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 updated FLINK-10302: Priority: Minor (was: Major) > Mark legacy(non-flip 6) code as Deprecated >

[jira] [Assigned] (FLINK-9854) Allow passing multi-line input to SQL Client CLI

2018-09-20 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9854: --- Assignee: vinoyang > Allow passing multi-line input to SQL Client CLI >

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

2018-09-20 Thread Jason Kania (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622792#comment-16622792 ] Jason Kania commented on FLINK-8035: I would need to know the specific logs you would like to see and

[jira] [Commented] (FLINK-7942) NPE when apply FilterJoinRule

2018-09-20 Thread Mayer Crystal (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622869#comment-16622869 ] Mayer Crystal commented on FLINK-7942: -- I know that this is marked as resolved, but I'm wondering if

[jira] [Updated] (FLINK-10079) Support external sink table in INSERT INTO statement

2018-09-20 Thread Jun Zhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Zhang updated FLINK-10079: -- Summary: Support external sink table in INSERT INTO statement (was: Automatically register sink

[jira] [Commented] (FLINK-10302) Mark legacy(non-flip 6) code as Deprecated

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622966#comment-16622966 ] 陈梓立 commented on FLINK-10302: - So we need not to add such annotations since they are removed within the next

[jira] [Closed] (FLINK-10302) Mark legacy(non-flip 6) code as Deprecated

2018-09-20 Thread JIRA
[ https://issues.apache.org/jira/browse/FLINK-10302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 陈梓立 closed FLINK-10302. --- Resolution: Won't Do > Mark legacy(non-flip 6) code as Deprecated > -- > >

[jira] [Commented] (FLINK-10320) Introduce JobMaster schedule micro-benchmark

2018-09-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622747#comment-16622747 ] Till Rohrmann commented on FLINK-10320: --- I'm also not 100 percent sure that a scheduling benchmark

[jira] [Commented] (FLINK-10302) Mark legacy(non-flip 6) code as Deprecated

2018-09-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622750#comment-16622750 ] Till Rohrmann commented on FLINK-10302: --- Yes this is the goal for the 1.7.0 release. > Mark

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

2018-09-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16622751#comment-16622751 ] Till Rohrmann commented on FLINK-8035: -- In order to better understand your problem, getting access

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

2018-09-20 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-10384: - Description: like FLINK-10340 for adding Cosh math function (was: like FLINK-10340) > Add Sinh math

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

2018-09-20 Thread vinoyang (JIRA)
vinoyang created FLINK-10384: Summary: Add Sinh math function supported in Table API and SQL Key: FLINK-10384 URL: https://issues.apache.org/jira/browse/FLINK-10384 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10369) Enable YARNITCase

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

[jira] [Closed] (FLINK-10355) The order of the column should start from 1.

2018-09-20 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-10355. - Resolution: Implemented Assignee: lihongli Fix Version/s: 1.7.0 Implemented for

[GitHub] tillrohrmann commented on issue #6717: [FLINK-10369][tests] Enable YARNITCase to test per job mode deployment

2018-09-20 Thread GitBox
tillrohrmann commented on issue #6717: [FLINK-10369][tests] Enable YARNITCase to test per job mode deployment URL: https://github.com/apache/flink/pull/6717#issuecomment-423083222 Thanks for the review @TisonKun. I've addressed your comments.

[jira] [Commented] (FLINK-10370) DistributedCache does not work in job cluster mode.

2018-09-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621599#comment-16621599 ] Till Rohrmann commented on FLINK-10370: --- This problem should only arise in the detached job-mode.

[jira] [Commented] (FLINK-10373) CoGroup Window support lateness

2018-09-20 Thread huangzhenhua (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621590#comment-16621590 ] huangzhenhua commented on FLINK-10373: -- Thank you very much, that is just i want,!    Do you know

[GitHub] asfgit closed pull request #6713: [FLINK-10355][table]the order of the columns start from 1

2018-09-20 Thread GitBox
asfgit closed pull request #6713: [FLINK-10355][table]the order of the columns start from 1 URL: https://github.com/apache/flink/pull/6713 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this

[jira] [Commented] (FLINK-10355) The order of the column should start from 1.

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

[GitHub] tillrohrmann commented on a change in pull request #6717: [FLINK-10369][tests] Enable YARNITCase to test per job mode deployment

2018-09-20 Thread GitBox
tillrohrmann commented on a change in pull request #6717: [FLINK-10369][tests] Enable YARNITCase to test per job mode deployment URL: https://github.com/apache/flink/pull/6717#discussion_r219068565 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java

[jira] [Commented] (FLINK-10243) Add option to reduce latency metrics granularity

2018-09-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621602#comment-16621602 ] Till Rohrmann commented on FLINK-10243: --- What about back-porting this fix to {{1.6}} [~Zentol]? It

[jira] [Commented] (FLINK-10369) Enable YARNITCase

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

[GitHub] tillrohrmann commented on a change in pull request #6717: [FLINK-10369][tests] Enable YARNITCase to test per job mode deployment

2018-09-20 Thread GitBox
tillrohrmann commented on a change in pull request #6717: [FLINK-10369][tests] Enable YARNITCase to test per job mode deployment URL: https://github.com/apache/flink/pull/6717#discussion_r219064427 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNITCase.java

[jira] [Commented] (FLINK-10369) Enable YARNITCase

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

[GitHub] tillrohrmann commented on issue #6716: [hotfix] [yarn-test] Clean up inactive test

2018-09-20 Thread GitBox
tillrohrmann commented on issue #6716: [hotfix] [yarn-test] Clean up inactive test URL: https://github.com/apache/flink/pull/6716#issuecomment-423083471 @TisonKun I'm not sure whether we can already remove the `TestingYarnClusterDescriptor` because it is still being used by the

[jira] [Comment Edited] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-09-20 Thread William Cummings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621846#comment-16621846 ] William Cummings edited comment on FLINK-10184 at 9/20/18 11:22 AM:

[jira] [Commented] (FLINK-6522) Add ZooKeeper cleanup logic to ZooKeeperHaServices

2018-09-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621874#comment-16621874 ] Till Rohrmann commented on FLINK-6522: -- Yes I think we still don't clean properly up the ZNodes in

[jira] [Commented] (FLINK-10157) Allow `null` user values in map state with TTL

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

[GitHub] StefanRRichter commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL

2018-09-20 Thread GitBox
StefanRRichter commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL URL: https://github.com/apache/flink/pull/6707#discussion_r219131023 ## File path:

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

2018-09-20 Thread William Cummings (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621846#comment-16621846 ] William Cummings commented on FLINK-10184: -- [~till.rohrmann] Got sick for a couple days,

[jira] [Commented] (FLINK-10157) Allow `null` user values in map state with TTL

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

[GitHub] azagrebin commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL

2018-09-20 Thread GitBox
azagrebin commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL URL: https://github.com/apache/flink/pull/6707#discussion_r219130240 ## File path:

[jira] [Commented] (FLINK-10157) Allow `null` user values in map state with TTL

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

[GitHub] StefanRRichter commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL

2018-09-20 Thread GitBox
StefanRRichter commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL URL: https://github.com/apache/flink/pull/6707#discussion_r219131023 ## File path:

[jira] [Commented] (FLINK-10333) Rethink ZooKeeper based stores (SubmittedJobGraph, MesosWorker, CompletedCheckpoints)

2018-09-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621880#comment-16621880 ] Till Rohrmann commented on FLINK-10333: --- I think this effort is not only about fixing the existing

[jira] [Commented] (FLINK-10373) CoGroup Window support lateness

2018-09-20 Thread huangzhenhua (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621879#comment-16621879 ] huangzhenhua commented on FLINK-10373: -- Thank you very much for your help!  > CoGroup Window

[jira] [Created] (FLINK-10375) ExceptionInChainedStubException hides wrapped exception in cause

2018-09-20 Thread Mike Pedersen (JIRA)
Mike Pedersen created FLINK-10375: - Summary: ExceptionInChainedStubException hides wrapped exception in cause Key: FLINK-10375 URL: https://issues.apache.org/jira/browse/FLINK-10375 Project: Flink

[jira] [Commented] (FLINK-10373) CoGroup Window support lateness

2018-09-20 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621651#comment-16621651 ] Kostas Kloudas commented on FLINK-10373: I will close this issue as duplicate and please keep an

[jira] [Closed] (FLINK-10373) CoGroup Window support lateness

2018-09-20 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-10373. -- Resolution: Duplicate Same as https://issues.apache.org/jira/browse/FLINK-10050 > CoGroup

[GitHub] twalthr commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

2018-09-20 Thread GitBox
twalthr commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r219078553 ## File path:

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

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

[jira] [Commented] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

2018-09-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621667#comment-16621667 ] Till Rohrmann commented on FLINK-9920: -- Another instance:

[GitHub] azagrebin commented on issue #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL

2018-09-20 Thread GitBox
azagrebin commented on issue #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL URL: https://github.com/apache/flink/pull/6707#issuecomment-423095611 Thanks for the review @StefanRRichter, I updated the PR

[GitHub] StefanRRichter commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL

2018-09-20 Thread GitBox
StefanRRichter commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL URL: https://github.com/apache/flink/pull/6707#discussion_r219102134 ## File path:

[jira] [Commented] (FLINK-10157) Allow `null` user values in map state with TTL

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

[GitHub] StefanRRichter commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL

2018-09-20 Thread GitBox
StefanRRichter commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL URL: https://github.com/apache/flink/pull/6707#discussion_r219103133 ## File path:

[jira] [Commented] (FLINK-10373) CoGroup Window support lateness

2018-09-20 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621650#comment-16621650 ] Kostas Kloudas commented on FLINK-10373: It will get merged probably today. > CoGroup Window

[GitHub] twalthr commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins

2018-09-20 Thread GitBox
twalthr commented on a change in pull request #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#discussion_r219080353 ## File path:

[GitHub] StefanRRichter commented on issue #6498: [FLINK-10065] InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream

2018-09-20 Thread GitBox
StefanRRichter commented on issue #6498: [FLINK-10065] InstantiationUtil.deserializeObject(InputStream in, ClassLoader cl, boolean isFailureTolerant) will close the inputStream URL: https://github.com/apache/flink/pull/6498#issuecomment-423114671 @tillrohrmann that is possible, my comment

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

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

[jira] [Updated] (FLINK-10330) Code Compilation failed in local mode

2018-09-20 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-10330: - Fix Version/s: (was: 1.5.4) (was: 1.6.1) > Code Compilation failed

[jira] [Commented] (FLINK-10157) Allow `null` user values in map state with TTL

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

[jira] [Commented] (FLINK-10310) Cassandra Sink - Handling failing requests

2018-09-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16621604#comment-16621604 ] Till Rohrmann commented on FLINK-10310: --- Looks good to me. I think we can proceed with the

[jira] [Updated] (FLINK-9913) Improve output serialization only once in RecordWriter

2018-09-20 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-9913: Affects Version/s: 1.5.0 1.5.1 1.5.2

[jira] [Created] (FLINK-10380) Check if key is not nul before assign to group in KeyedStream

2018-09-20 Thread Sayat Satybaldiyev (JIRA)
Sayat Satybaldiyev created FLINK-10380: -- Summary: Check if key is not nul before assign to group in KeyedStream Key: FLINK-10380 URL: https://issues.apache.org/jira/browse/FLINK-10380 Project:

[jira] [Created] (FLINK-10379) Can not use Table Functions in Java Table API

2018-09-20 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-10379: -- Summary: Can not use Table Functions in Java Table API Key: FLINK-10379 URL: https://issues.apache.org/jira/browse/FLINK-10379 Project: Flink Issue

[GitHub] azagrebin commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL

2018-09-20 Thread GitBox
azagrebin commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL URL: https://github.com/apache/flink/pull/6707#discussion_r219146019 ## File path:

[GitHub] azagrebin commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL

2018-09-20 Thread GitBox
azagrebin commented on a change in pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL URL: https://github.com/apache/flink/pull/6707#discussion_r219146019 ## File path:

[jira] [Commented] (FLINK-9343) Add Async Example with External Rest API call

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

[jira] [Resolved] (FLINK-9343) Add Async Example with External Rest API call

2018-09-20 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9343. -- Resolution: Won't Fix > Add Async Example with External Rest API call >

  1   2   3   >