[jira] [Updated] (FLINK-10701) Move modern kafka connector module into connector profile

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10701: --- Labels: pull-request-available (was: ) > Move modern kafka connector module into connector

[jira] [Commented] (FLINK-10701) Move modern kafka connector module into connector profile

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1272#comment-1272 ] ASF GitHub Bot commented on FLINK-10701: yanghua opened a new pull request #6954: [FLINK-10701]

[GitHub] yanghua opened a new pull request #6954: [FLINK-10701] Move modern kafka connector module into connector profile

2018-10-27 Thread GitBox
yanghua opened a new pull request #6954: [FLINK-10701] Move modern kafka connector module into connector profile URL: https://github.com/apache/flink/pull/6954 ## What is the purpose of the change *This pull request moves modern kafka connector module into connector profile*

[jira] [Commented] (FLINK-10558) Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1203#comment-1203 ] ASF GitHub Bot commented on FLINK-10558: TisonKun edited a comment on issue #6953: [FLINK-10558]

[jira] [Commented] (FLINK-10558) Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1202#comment-1202 ] ASF GitHub Bot commented on FLINK-10558: TisonKun commented on issue #6953: [FLINK-10558]

[GitHub] TisonKun edited a comment on issue #6953: [FLINK-10558] [yarn-test] Port YARNHighAvailabilityITCase to new code…

2018-10-27 Thread GitBox
TisonKun edited a comment on issue #6953: [FLINK-10558] [yarn-test] Port YARNHighAvailabilityITCase to new code… URL: https://github.com/apache/flink/pull/6953#issuecomment-433648252 The main process I think this test should have is, 1. start the session 2. submit a somehow

[GitHub] TisonKun commented on issue #6953: [FLINK-10558] [yarn-test] Port YARNHighAvailabilityITCase to new code…

2018-10-27 Thread GitBox
TisonKun commented on issue #6953: [FLINK-10558] [yarn-test] Port YARNHighAvailabilityITCase to new code… URL: https://github.com/apache/flink/pull/6953#issuecomment-433648252 The main process I think this test should have is, 1. start the session 2. submit a somehow blocking job 3.

[jira] [Updated] (FLINK-10558) Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10558: --- Labels: pull-request-available (was: ) > Port YARNHighAvailabilityITCase and

[jira] [Commented] (FLINK-10558) Port YARNHighAvailabilityITCase and YARNSessionCapacitySchedulerITCase to new code base

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

[GitHub] TisonKun opened a new pull request #6953: [FLINK-10558] [yarn-test] Port YARNHighAvailabilityITCase to new code…

2018-10-27 Thread GitBox
TisonKun opened a new pull request #6953: [FLINK-10558] [yarn-test] Port YARNHighAvailabilityITCase to new code… URL: https://github.com/apache/flink/pull/6953 … base ## What is the purpose of the change ## Brief change log ## Verifying this change *(Please

[GitHub] xueyumusic opened a new pull request #6952: [hotfix][cep] fix typos in cep quantifier

2018-10-27 Thread GitBox
xueyumusic opened a new pull request #6952: [hotfix][cep] fix typos in cep quantifier URL: https://github.com/apache/flink/pull/6952 This PR is a hotfix for typos in cep quantifier's combinations and consecutive's exception msg.

[jira] [Assigned] (FLINK-10114) Support Orc for StreamingFileSink

2018-10-27 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10114: Assignee: vinoyang (was: lihongli) > Support Orc for StreamingFileSink >

[jira] [Updated] (FLINK-10693) Fix Scala EitherSerializer duplication

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10693: --- Labels: pull-request-available (was: ) > Fix Scala EitherSerializer duplication >

[jira] [Commented] (FLINK-10693) Fix Scala EitherSerializer duplication

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

[GitHub] StephanEwen opened a new pull request #6951: [FLINK-10693] [Scala API] Fix incorrect duplication in EitherSerializer

2018-10-27 Thread GitBox
StephanEwen opened a new pull request #6951: [FLINK-10693] [Scala API] Fix incorrect duplication in EitherSerializer URL: https://github.com/apache/flink/pull/6951 ## What is the purpose of the change / Brief change log Fixes the duplication of the Scala `EitherSerialzer` that never

[jira] [Assigned] (FLINK-10114) Support Orc for StreamingFileSink

2018-10-27 Thread zhangminglei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangminglei reassigned FLINK-10114: Assignee: lihongli (was: vinoyang) > Support Orc for StreamingFileSink >

[jira] [Commented] (FLINK-10692) Harden Confluent schema E2E test

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1042#comment-1042 ] ASF GitHub Bot commented on FLINK-10692: tillrohrmann closed pull request #6940: [FLINK-10692]

[jira] [Closed] (FLINK-10692) Harden Confluent schema E2E test

2018-10-27 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10692. - Resolution: Fixed Fixed via 1.7.0:

[GitHub] tillrohrmann commented on issue #6941: [BP-1.6][FLINK-10692] Harden Confluent schema registry E2E test

2018-10-27 Thread GitBox
tillrohrmann commented on issue #6941: [BP-1.6][FLINK-10692] Harden Confluent schema registry E2E test URL: https://github.com/apache/flink/pull/6941#issuecomment-433612794 Thanks for the review @zentol. Failing test case is unrelated.

[GitHub] tillrohrmann closed pull request #6941: [BP-1.6][FLINK-10692] Harden Confluent schema registry E2E test

2018-10-27 Thread GitBox
tillrohrmann closed pull request #6941: [BP-1.6][FLINK-10692] Harden Confluent schema registry E2E test URL: https://github.com/apache/flink/pull/6941 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

[GitHub] tillrohrmann commented on issue #6940: [FLINK-10692] Harden Confluent schema registry E2E test

2018-10-27 Thread GitBox
tillrohrmann commented on issue #6940: [FLINK-10692] Harden Confluent schema registry E2E test URL: https://github.com/apache/flink/pull/6940#issuecomment-433612753 Thanks for the review @zentol This is an automated message

[GitHub] tillrohrmann closed pull request #6940: [FLINK-10692] Harden Confluent schema registry E2E test

2018-10-27 Thread GitBox
tillrohrmann closed pull request #6940: [FLINK-10692] Harden Confluent schema registry E2E test URL: https://github.com/apache/flink/pull/6940 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

[jira] [Commented] (FLINK-10692) Harden Confluent schema E2E test

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1041#comment-1041 ] ASF GitHub Bot commented on FLINK-10692: tillrohrmann commented on issue #6940: [FLINK-10692]

[jira] [Commented] (FLINK-10600) Provide End-to-end test cases for modern Kafka connectors

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16665997#comment-16665997 ] ASF GitHub Bot commented on FLINK-10600: yanghua commented on issue #6924: [FLINK-10600] Provide

[GitHub] yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

2018-10-27 Thread GitBox
yanghua commented on issue #6924: [FLINK-10600] Provide End-to-end test cases for modern Kafka connectors URL: https://github.com/apache/flink/pull/6924#issuecomment-433603466 @pnowojski I solved the test problem and it is now ready to be reviewed again.

[jira] [Commented] (FLINK-10668) Streaming File Sink E2E test fails because not all legitimate exceptions are excluded

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16665976#comment-16665976 ] ASF GitHub Bot commented on FLINK-10668: hequn8128 opened a new pull request #6950:

[jira] [Updated] (FLINK-10668) Streaming File Sink E2E test fails because not all legitimate exceptions are excluded

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10668: --- Labels: pull-request-available (was: ) > Streaming File Sink E2E test fails because not

[GitHub] hequn8128 opened a new pull request #6950: [FLINK-10668][e2e] Streaming File Sink E2E test fails because not all legitimate exceptions are excluded

2018-10-27 Thread GitBox
hequn8128 opened a new pull request #6950: [FLINK-10668][e2e] Streaming File Sink E2E test fails because not all legitimate exceptions are excluded URL: https://github.com/apache/flink/pull/6950 ## What is the purpose of the change Streaming File Sink E2E test fails because not

[jira] [Comment Edited] (FLINK-5601) Window operator does not checkpoint watermarks

2018-10-27 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16665975#comment-16665975 ] Jiayi Liao edited comment on FLINK-5601 at 10/27/18 7:46 AM: -

[jira] [Commented] (FLINK-5601) Window operator does not checkpoint watermarks

2018-10-27 Thread Jiayi Liao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16665975#comment-16665975 ] Jiayi Liao commented on FLINK-5601: --- [~aljoscha][~kkl0u] Here is my idea: In

[jira] [Commented] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16665968#comment-16665968 ] ASF GitHub Bot commented on FLINK-10676: hequn8128 opened a new pull request #6949:

[jira] [Updated] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API

2018-10-27 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10676: --- Labels: pull-request-available (was: ) > Add 'as' method for OverWindowWithOrderBy in Java

[GitHub] hequn8128 opened a new pull request #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy

2018-10-27 Thread GitBox
hequn8128 opened a new pull request #6949: [FLINK-10676][table] Add 'as' method for OverWindowWithOrderBy URL: https://github.com/apache/flink/pull/6949 ## What is the purpose of the change The preceding clause of OVER Window in the traditional database is optional. The default