[GitHub] yanghua commented on issue #7026: [FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion

2018-11-30 Thread GitBox
yanghua commented on issue #7026: [FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion URL: https://github.com/apache/flink/pull/7026#issuecomment-443232126 cc @tillrohrmann This is an automated message

[jira] [Commented] (FLINK-10798) Add the version number of Flink 1.7 to MigrationVersion

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704874#comment-16704874 ] ASF GitHub Bot commented on FLINK-10798: yanghua commented on issue #7026: [FLINK-10798] Add the

[jira] [Commented] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

2018-11-30 Thread Arnaud Linz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705012#comment-16705012 ] Arnaud Linz commented on FLINK-10832: - I've corrected my corrupted maven cache, now the run is fine.

[jira] [Closed] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

2018-11-30 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-10597. Resolution: Fixed Fixed via: d985eff3f5fb9d481e8c5cf46c31b9ae2b3e131e > Enable UDFs

[jira] [Commented] (FLINK-8739) Optimize runtime support for distinct filter

2018-11-30 Thread Rong Rong (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704949#comment-16704949 ] Rong Rong commented on FLINK-8739: -- No I haven't started. please feel free to assign to yourself. >

[jira] [Commented] (FLINK-10930) Refactor checkpoint directory layout

2018-11-30 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704844#comment-16704844 ] Stephan Ewen commented on FLINK-10930: -- Concerning the cleanup of lingering "chk-xxx" directories:

[GitHub] pnowojski opened a new pull request #7207: [hotfix][docs] Fix typo in StreamTableSoureFactory

2018-11-30 Thread GitBox
pnowojski opened a new pull request #7207: [hotfix][docs] Fix typo in StreamTableSoureFactory URL: https://github.com/apache/flink/pull/7207 This is a simple documentation fix This is an automated message from the Apache Git

[GitHub] xueyumusic commented on issue #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common

2018-11-30 Thread GitBox
xueyumusic commented on issue #7059: [FLINK-10689][table] Port UDFs in Table API extension points to flink-table-common URL: https://github.com/apache/flink/pull/7059#issuecomment-443277678 Thank you very much for review , @twalthr , These are very useful suggestions of maintaining good

[GitHub] pnowojski closed pull request #7207: [hotfix][docs] Fix typo in StreamTableSoureFactory

2018-11-30 Thread GitBox
pnowojski closed pull request #7207: [hotfix][docs] Fix typo in StreamTableSoureFactory URL: https://github.com/apache/flink/pull/7207 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 is a

[jira] [Closed] (FLINK-11031) How to consume the Hive data in Flink using Scala

2018-11-30 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-11031. - Resolution: Invalid Fix Version/s: (was: 1.6.2) Hi [~Preethi@C], please post

[jira] [Commented] (FLINK-10689) Port UDFs in Table API extension points to flink-table-common

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705050#comment-16705050 ] ASF GitHub Bot commented on FLINK-10689: xueyumusic commented on issue #7059:

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

2018-11-30 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705067#comment-16705067 ] TisonKun commented on FLINK-10558: -- Hi [~till.rohrmann], I think this jira and FLINK-10665 are the

[GitHub] dawidwys closed pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

2018-11-30 Thread GitBox
dawidwys closed pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189 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-10597) Enable UDFs support in MATCH_RECOGNIZE

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704880#comment-16704880 ] ASF GitHub Bot commented on FLINK-10597: dawidwys closed pull request #7189:

[jira] [Commented] (FLINK-11044) RegisterTableSink docs incorrect

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705361#comment-16705361 ] ASF GitHub Bot commented on FLINK-11044: kgorman opened a new pull request #7208: FLINK-11044

[jira] [Created] (FLINK-11044) RegisterTableSink docs incorrect

2018-11-30 Thread Kenny Gorman (JIRA)
Kenny Gorman created FLINK-11044: Summary: RegisterTableSink docs incorrect Key: FLINK-11044 URL: https://issues.apache.org/jira/browse/FLINK-11044 Project: Flink Issue Type: Bug

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

2018-11-30 Thread Truong Duc Kien (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705572#comment-16705572 ] Truong Duc Kien commented on FLINK-10114: - Maybe we can let the ORC's writer write to a path on

[GitHub] Clarkkkkk commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

2018-11-30 Thread GitBox
Clark commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#discussion_r238051554 ## File path:

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705621#comment-16705621 ] ASF GitHub Bot commented on FLINK-6756: --- Clark commented on a change in pull request #7168:

[jira] [Commented] (FLINK-10640) Enable Slot Resource Profile for Resource Management

2018-11-30 Thread TisonKun (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705598#comment-16705598 ] TisonKun commented on FLINK-10640: -- About the "TM Management" section, currently yarn session mode

[GitHub] Clarkkkkk commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

2018-11-30 Thread GitBox
Clark commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#discussion_r238051723 ## File path:

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705624#comment-16705624 ] ASF GitHub Bot commented on FLINK-6756: --- Clark commented on a change in pull request #7168:

[jira] [Commented] (FLINK-9740) Support group windows over intervals of months

2018-11-30 Thread xuqianjin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16705634#comment-16705634 ] xuqianjin commented on FLINK-9740: -- hi [~liurenjie1024] [~twalthr] I want to try to solve it > Support

[jira] [Commented] (FLINK-10977) Add UnBounded FlatAggregate operator to streaming Table API

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

[GitHub] hequn8128 opened a new pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API

2018-11-30 Thread GitBox
hequn8128 opened a new pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API URL: https://github.com/apache/flink/pull/7209 ## What is the purpose of the change This pull request adds UnBounded FlatAggregate operator to

[jira] [Updated] (FLINK-10977) Add UnBounded FlatAggregate operator to streaming Table API

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10977: --- Labels: pull-request-available (was: ) > Add UnBounded FlatAggregate operator to streaming

[GitHub] kgorman opened a new pull request #7208: FLINK-11044 connect docs fix for registerTableSink

2018-11-30 Thread GitBox
kgorman opened a new pull request #7208: FLINK-11044 connect docs fix for registerTableSink URL: https://github.com/apache/flink/pull/7208 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than

[jira] [Updated] (FLINK-11044) RegisterTableSink docs incorrect

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11044: --- Labels: pull-request-available (was: ) > RegisterTableSink docs incorrect >

[jira] [Commented] (FLINK-11035) Notify data available to network stack immediately after finishing BufferBuilder

2018-11-30 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704380#comment-16704380 ] zhijiang commented on FLINK-11035: -- [~pnowojski], I am not sure whether it is worth improving this

[GitHub] dawidwys opened a new pull request #7200: [FLINK-11017][table] Throw exception if constant with YEAR TO MONTH resolution was used for group windows

2018-11-30 Thread GitBox
dawidwys opened a new pull request #7200: [FLINK-11017][table] Throw exception if constant with YEAR TO MONTH resolution was used for group windows URL: https://github.com/apache/flink/pull/7200 ## What is the purpose of the change * Checking if a proper resolution was used for

[jira] [Created] (FLINK-11037) Introduce another greedy mechanism for distributing floating buffers

2018-11-30 Thread zhijiang (JIRA)
zhijiang created FLINK-11037: Summary: Introduce another greedy mechanism for distributing floating buffers Key: FLINK-11037 URL: https://issues.apache.org/jira/browse/FLINK-11037 Project: Flink

[jira] [Updated] (FLINK-11038) Rewrite Kafka at-least-once it cases

2018-11-30 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-11038: --- Description: Currently they are using {{NetworkFailuresProxy}} which is unstable both for

[jira] [Created] (FLINK-11038) Rewrite Kafka at-least-once it cases

2018-11-30 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-11038: -- Summary: Rewrite Kafka at-least-once it cases Key: FLINK-11038 URL: https://issues.apache.org/jira/browse/FLINK-11038 Project: Flink Issue Type: Bug

[GitHub] dianfu opened a new pull request #7201: [FLINK-7208] [table] Optimize Min/MaxAggFunctionWithRetract with DataView

2018-11-30 Thread GitBox
dianfu opened a new pull request #7201: [FLINK-7208] [table] Optimize Min/MaxAggFunctionWithRetract with DataView URL: https://github.com/apache/flink/pull/7201 ## What is the purpose of the change *This pull request optimizes the performance of Min/MaxAggFunctionWithRetract with

[jira] [Updated] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7208: -- Labels: pull-request-available (was: ) > Refactor build-in agg(MaxWithRetractAccumulator and

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

2018-11-30 Thread GitBox
azagrebin 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-443148880 Thanks for addressing the comment. One more thing, I think we do not actually need

[jira] [Assigned] (FLINK-10149) Fink Mesos allocates extra port when not configured to do so.

2018-11-30 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-10149: Assignee: Gary Yao (was: Rune Skou Larsen) > Fink Mesos allocates extra port when not

[jira] [Commented] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704446#comment-16704446 ] ASF GitHub Bot commented on FLINK-7208: --- dianfu opened a new pull request #7201: [FLINK-7208]

[jira] [Updated] (FLINK-11034) Provide "rewriting config” to file system factory

2018-11-30 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-11034: Fix Version/s: 1.8.0 > Provide "rewriting config” to file system factory >

[jira] [Updated] (FLINK-11034) Provide "rewriting config” to file system factory

2018-11-30 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-11034: Component/s: filesystem-connector FileSystem > Provide "rewriting

[jira] [Commented] (FLINK-11011) Elasticsearch 6 sink end-to-end test unstable

2018-11-30 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704499#comment-16704499 ] Andrey Zagrebin commented on FLINK-11011: - I would suspect that the job is being stopped and

[jira] [Comment Edited] (FLINK-11011) Elasticsearch 6 sink end-to-end test unstable

2018-11-30 Thread Andrey Zagrebin (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704499#comment-16704499 ] Andrey Zagrebin edited comment on FLINK-11011 at 11/30/18 9:53 AM: --- I

[jira] [Commented] (FLINK-10884) Flink on yarn TM container will be killed by nodemanager because of the exceeded physical memory.

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704526#comment-16704526 ] ASF GitHub Bot commented on FLINK-10884: wg1026688210 commented on a change in pull request

[GitHub] wg1026688210 commented on a change in pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory

2018-11-30 Thread GitBox
wg1026688210 commented on a change in pull request #7185: [FLINK-10884] [yarn/mesos] adjust container memory param to set a safe margin from offheap memory URL: https://github.com/apache/flink/pull/7185#discussion_r237810314 ## File path:

[jira] [Commented] (FLINK-10776) Update migration tests for Flink 1.7

2018-11-30 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704533#comment-16704533 ] Till Rohrmann commented on FLINK-10776: --- Since Flink 1.7.0 has now been released, I think it would

[jira] [Created] (FLINK-11039) LogicalExchange and HashPartitioner realization

2018-11-30 Thread ambition (JIRA)
ambition created FLINK-11039: Summary: LogicalExchange and HashPartitioner realization Key: FLINK-11039 URL: https://issues.apache.org/jira/browse/FLINK-11039 Project: Flink Issue Type:

[jira] [Commented] (FLINK-10832) StreamExecutionEnvironment.execute() does not return when all sources end

2018-11-30 Thread Arnaud Linz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704554#comment-16704554 ] Arnaud Linz commented on FLINK-10832: - Okay, I've just tested with the new 1.7.0. All I did is to

[jira] [Closed] (FLINK-10838) Rewrite Kafka tests that fail Kafka brokers

2018-11-30 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10838. -- Resolution: Won't Fix Fix Version/s: (was: 1.8.0) After further investigation, we

[jira] [Assigned] (FLINK-7208) Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView

2018-11-30 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-7208: -- Assignee: Dian Fu > Refactor build-in agg(MaxWithRetractAccumulator and > MinWithRetractAccumulator)

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

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

[jira] [Commented] (FLINK-10986) Jepsen: Deploy Kafka Broker on DB Nodes

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

[GitHub] GJL commented on a change in pull request #7173: [FLINK-10986][tests] Implement DB to setup Apache Kafka

2018-11-30 Thread GitBox
GJL commented on a change in pull request #7173: [FLINK-10986][tests] Implement DB to setup Apache Kafka URL: https://github.com/apache/flink/pull/7173#discussion_r237807172 ## File path: flink-jepsen/docker/test-specs/standalone-session-kafka.edn ## @@ -0,0 +1,23 @@ +;;

[jira] [Commented] (FLINK-10986) Jepsen: Deploy Kafka Broker on DB Nodes

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

[GitHub] GJL commented on a change in pull request #7173: [FLINK-10986][tests] Implement DB to setup Apache Kafka

2018-11-30 Thread GitBox
GJL commented on a change in pull request #7173: [FLINK-10986][tests] Implement DB to setup Apache Kafka URL: https://github.com/apache/flink/pull/7173#discussion_r237807197 ## File path: flink-jepsen/docker/test-specs/mesos-session.edn ## @@ -0,0 +1,19 @@ +;; Licensed to

[GitHub] ambition119 opened a new pull request #7202: LogicalExchange and HashPartitioner realization

2018-11-30 Thread GitBox
ambition119 opened a new pull request #7202: LogicalExchange and HashPartitioner realization URL: https://github.com/apache/flink/pull/7202 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than

[jira] [Commented] (FLINK-8601) Introduce ElasticBloomFilter for Approximate calculation and other situations of performance optimization

2018-11-30 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704388#comment-16704388 ] vinoyang commented on FLINK-8601: - [~sihuazhou] What is the status of this issue? Are you still

[jira] [Updated] (FLINK-11017) Time interval for window aggregations in SQL is wrongly translated if specified with YEAR_MONTH resolution

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11017: --- Labels: pull-request-available (was: ) > Time interval for window aggregations in SQL is

[jira] [Commented] (FLINK-10597) Enable UDFs support in MATCH_RECOGNIZE

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704405#comment-16704405 ] ASF GitHub Bot commented on FLINK-10597: dawidwys commented on a change in pull request #7189:

[jira] [Assigned] (FLINK-11035) Notify data available to network stack immediately after finishing BufferBuilder

2018-11-30 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-11035: Assignee: zhijiang > Notify data available to network stack immediately after finishing >

[GitHub] dawidwys commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE

2018-11-30 Thread GitBox
dawidwys commented on a change in pull request #7189: [FLINK-10597][table] Enabled UDFs support in MATCH_RECOGNIZE URL: https://github.com/apache/flink/pull/7189#discussion_r237778606 ## File path:

[jira] [Commented] (FLINK-10865) Implement Flink's own Aliyun OSS filesystem

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704407#comment-16704407 ] ASF GitHub Bot commented on FLINK-10865: wujinhu commented on issue #7123: [FLINK-10865] Add

[GitHub] wujinhu commented on issue #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies

2018-11-30 Thread GitBox
wujinhu commented on issue #7123: [FLINK-10865] Add Aliyun OSS file systems without Hadoop dependencies URL: https://github.com/apache/flink/pull/7123#issuecomment-443130876 @StefanRRichter Please help to merge this PR, so that I can move on :)

[jira] [Closed] (FLINK-10837) Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked on deleteTestTopic?

2018-11-30 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10837. -- Resolution: Cannot Reproduce Fix Version/s: 1.7.0 I haven't seen Kafka 2.0 test

[jira] [Commented] (FLINK-11017) Time interval for window aggregations in SQL is wrongly translated if specified with YEAR_MONTH resolution

2018-11-30 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704398#comment-16704398 ] Dawid Wysakowicz commented on FLINK-11017: -- Hi [~x1q1j1] thank you for your interest in

[jira] [Updated] (FLINK-11036) Streaming classloader end-to-end test does not work on source releases

2018-11-30 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11036: - Affects Version/s: 1.7.0 > Streaming classloader end-to-end test does not work on source

[jira] [Closed] (FLINK-10993) Bring bloomfilter as a public API

2018-11-30 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang closed FLINK-10993. Resolution: Duplicate > Bring bloomfilter as a public API > - > >

[jira] [Created] (FLINK-11036) Streaming classloader end-to-end test does not work on source releases

2018-11-30 Thread Timo Walther (JIRA)
Timo Walther created FLINK-11036: Summary: Streaming classloader end-to-end test does not work on source releases Key: FLINK-11036 URL: https://issues.apache.org/jira/browse/FLINK-11036 Project:

[jira] [Commented] (FLINK-11017) Time interval for window aggregations in SQL is wrongly translated if specified with YEAR_MONTH resolution

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704396#comment-16704396 ] ASF GitHub Bot commented on FLINK-11017: dawidwys opened a new pull request #7200:

[jira] [Closed] (FLINK-10629) FlinkKafkaProducerITCase.testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify failed on Travis

2018-11-30 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10629. -- Resolution: Cannot Reproduce I haven't seen Kafka 2.0 test failure since upgrading Kafka to

[jira] [Closed] (FLINK-10629) FlinkKafkaProducerITCase.testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify failed on Travis

2018-11-30 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10629. -- Resolution: Cannot Reproduce Fix Version/s: (was: 1.8.0) 1.7.0

[jira] [Reopened] (FLINK-10629) FlinkKafkaProducerITCase.testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify failed on Travis

2018-11-30 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reopened FLINK-10629: > FlinkKafkaProducerITCase.testFlinkKafkaProducerFailTransactionCoordinatorBeforeNotify >

[jira] [Commented] (FLINK-10945) Avoid resource deadlocks for finite stream jobs when resources are limited

2018-11-30 Thread Zhu Zhu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704415#comment-16704415 ] Zhu Zhu commented on FLINK-10945: - Thanks [~azagrebin] for your attention.  I will post the design later

[jira] [Closed] (FLINK-10874) Kafka 2.0 connector testMigrateFromAtLeastOnceToExactlyOnce failure

2018-11-30 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-10874. -- Resolution: Cannot Reproduce Fix Version/s: 1.7.0 I haven't seen Kafka 2.0 test

[jira] [Updated] (FLINK-11036) Streaming classloader end-to-end test does not work on source releases

2018-11-30 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11036: - Description: A Flink distribution that has been built from a source release has no git commit

[jira] [Commented] (FLINK-10149) Fink Mesos allocates extra port when not configured to do so.

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704570#comment-16704570 ] ASF GitHub Bot commented on FLINK-10149: GJL opened a new pull request #7203:

[GitHub] GJL opened a new pull request #7203: [FLINK-10149[mesos] Don't allocate extra mesos port for TM unless configured to do so

2018-11-30 Thread GitBox
GJL opened a new pull request #7203: [FLINK-10149[mesos] Don't allocate extra mesos port for TM unless configured to do so URL: https://github.com/apache/flink/pull/7203 ## What is the purpose of the change *Make sure Flink only allocates the necessary mesos ports. This PR is based

[jira] [Assigned] (FLINK-10147) numBytesOut metric lagging behind

2018-11-30 Thread boshu Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10147: --- Assignee: boshu Zheng > numBytesOut metric lagging behind >

[GitHub] twalthr commented on a change in pull request #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors

2018-11-30 Thread GitBox
twalthr commented on a change in pull request #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors URL: https://github.com/apache/flink/pull/7182#discussion_r237827433 ## File path: flink-connectors/flink-connector-kafka-base/pom.xml

[jira] [Commented] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

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

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704603#comment-16704603 ] ASF GitHub Bot commented on FLINK-6756: --- dawidwys commented on a change in pull request #7168:

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704597#comment-16704597 ] ASF GitHub Bot commented on FLINK-6756: --- dawidwys commented on a change in pull request #7168:

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704604#comment-16704604 ] ASF GitHub Bot commented on FLINK-6756: --- dawidwys commented on a change in pull request #7168:

[GitHub] yanghua commented on a change in pull request #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors

2018-11-30 Thread GitBox
yanghua commented on a change in pull request #7182: [FLINK-11015] Remove deprecated methods and classes about table from all the Kafka connectors URL: https://github.com/apache/flink/pull/7182#discussion_r237829660 ## File path: flink-connectors/flink-connector-kafka-base/pom.xml

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704602#comment-16704602 ] ASF GitHub Bot commented on FLINK-6756: --- dawidwys commented on a change in pull request #7168:

[jira] [Commented] (FLINK-11015) Remove deprecated methods and classes about table from all the Kafka connectors

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

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704601#comment-16704601 ] ASF GitHub Bot commented on FLINK-6756: --- dawidwys commented on a change in pull request #7168:

[jira] [Commented] (FLINK-6756) Provide RichAsyncFunction to Scala API suite

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704600#comment-16704600 ] ASF GitHub Bot commented on FLINK-6756: --- dawidwys commented on a change in pull request #7168:

[jira] [Assigned] (FLINK-11039) LogicalExchange and HashPartitioner realization

2018-11-30 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11039: Assignee: (was: vinoyang) > LogicalExchange and HashPartitioner realization >

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

2018-11-30 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-443188022 @azagrebin thank for your reply, I have a question about this, will JM failover lead to two

[GitHub] asfgit closed pull request #7194: [hotfix][doc] fix missing comma in cep sql

2018-11-30 Thread GitBox
asfgit closed pull request #7194: [hotfix][doc] fix missing comma in cep sql URL: https://github.com/apache/flink/pull/7194 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 is a foreign

[jira] [Commented] (FLINK-10149) Fink Mesos allocates extra port when not configured to do so.

2018-11-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16704573#comment-16704573 ] ASF GitHub Bot commented on FLINK-10149: GJL commented on issue #6557: [FLINK-10149]

[jira] [Assigned] (FLINK-10615) Cancel with savepoint can fail the job

2018-11-30 Thread boshu Zheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-10615: --- Assignee: boshu Zheng > Cancel with savepoint can fail the job >

[GitHub] dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

2018-11-30 Thread GitBox
dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#discussion_r237783551 ## File path:

[GitHub] dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

2018-11-30 Thread GitBox
dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#discussion_r237784643 ## File path:

[GitHub] dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

2018-11-30 Thread GitBox
dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#discussion_r237784773 ## File path:

[GitHub] dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

2018-11-30 Thread GitBox
dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#discussion_r237829048 ## File path:

[GitHub] dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

2018-11-30 Thread GitBox
dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#discussion_r237784333 ## File path:

[GitHub] dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

2018-11-30 Thread GitBox
dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#discussion_r237784432 ## File path:

[GitHub] dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

2018-11-30 Thread GitBox
dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#discussion_r237829126 ## File path:

[GitHub] dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API …

2018-11-30 Thread GitBox
dawidwys commented on a change in pull request #7168: [FLINK-6756][DataStream API] Provide Rich AsyncFunction to Scala API … URL: https://github.com/apache/flink/pull/7168#discussion_r237826877 ## File path:

  1   2   >