[jira] [Commented] (FLINK-7076) Implement container release to support dynamic scaling

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

[GitHub] flink pull request #4729: [FLINK-7076] [ResourceManager] implement YARN stop...

GitHub user suez1224 opened a pull request: https://github.com/apache/flink/pull/4729 [FLINK-7076] [ResourceManager] implement YARN stopWorker logic ## What is the purpose of the change *Implement stopWorker logic for YarnResourceManager* ## Brief change log

[jira] [Commented] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist

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

[GitHub] flink issue #4709: [FLINK-7675] [metrics] LatestCompletedCheckpointExternalP...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4709 +1 ---

[GitHub] flink pull request #4697: [FLINK-7650] [flip6] Port JobCancellationHandler t...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4697#discussion_r141242109 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobPathParameter.java --- @@ -0,0 +1,45 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181958#comment-16181958 ] ASF GitHub Bot commented on FLINK-7650: --- Github user bowenli86 commented on a diff in the pull

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181959#comment-16181959 ] ASF GitHub Bot commented on FLINK-7650: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink pull request #4697: [FLINK-7650] [flip6] Port JobCancellationHandler t...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4697#discussion_r141241750 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/JobNotFoundException.java --- @@ -0,0 +1,34 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181960#comment-16181960 ] ASF GitHub Bot commented on FLINK-7650: --- Github user bowenli86 commented on a diff in the pull

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181961#comment-16181961 ] ASF GitHub Bot commented on FLINK-7650: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink pull request #4697: [FLINK-7650] [flip6] Port JobCancellationHandler t...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4697#discussion_r141241787 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/JobNotFoundException.java --- @@ -0,0 +1,34 @@ +/* + * Licensed to the

[GitHub] flink pull request #4697: [FLINK-7650] [flip6] Port JobCancellationHandler t...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4697#discussion_r141241955 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobCancellationHeaders.java --- @@ -0,0 +1,68 @@ +/* + * Licensed to

[jira] [Updated] (FLINK-7642) Upgrade maven surefire plugin to 2.19.1

[ https://issues.apache.org/jira/browse/FLINK-7642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7642: -- Description: Surefire 2.19 release introduced more useful test filters which would let us run a subset of the

[jira] [Commented] (FLINK-7694) Port JobMetricsHandler to new REST handler

[ https://issues.apache.org/jira/browse/FLINK-7694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181953#comment-16181953 ] Bowen Li commented on FLINK-7694: - [~till.rohrmann] Hi Till, I have done some research on how to

[GitHub] flink issue #4704: [hotfix] [docs] Update function name in DataStream API

Github user phiradet commented on the issue: https://github.com/apache/flink/pull/4704 Thanks ---

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181847#comment-16181847 ] Xingcan Cui commented on FLINK-7548: Thanks for the explanation, [~fhueske]. I was too paranoid about

[jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181812#comment-16181812 ] Raymond Tay commented on FLINK-7669: Checked but its still occurring, i'll investigate this a little

[jira] [Commented] (FLINK-7549) CEP - Pattern not discovered if source streaming is very fast

[ https://issues.apache.org/jira/browse/FLINK-7549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181718#comment-16181718 ] Paolo Rendano commented on FLINK-7549: -- mentioned in > CEP - Pattern not discovered if source

[jira] [Comment Edited] (FLINK-7606) CEP operator leaks state

[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181713#comment-16181713 ] Paolo Rendano edited comment on FLINK-7606 at 9/26/17 10:59 PM: Hi

[jira] [Comment Edited] (FLINK-7606) CEP operator leaks state

[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16176654#comment-16176654 ] Paolo Rendano edited comment on FLINK-7606 at 9/26/17 10:59 PM: Hi

[jira] [Commented] (FLINK-7606) CEP operator leaks state

[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181713#comment-16181713 ] Paolo Rendano commented on FLINK-7606: -- Hi [~kkl0u], 1) sure I have to set and I was not setting it

[jira] [Updated] (FLINK-7606) CEP operator leaks state

[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Rendano updated FLINK-7606: - Attachment: Schermata 2017-09-27 alle 00.35.53.png > CEP operator leaks state >

[jira] [Commented] (FLINK-7648) Port TaskManagersHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181315#comment-16181315 ] Bowen Li commented on FLINK-7648: - [~till.rohrmann] Hi Till, I built Flink from source, copied

[jira] [Commented] (FLINK-7670) typo in docs runtime section

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

[jira] [Commented] (FLINK-7670) typo in docs runtime section

[ https://issues.apache.org/jira/browse/FLINK-7670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181264#comment-16181264 ] ASF GitHub Bot commented on FLINK-7670: --- Github user keweishang closed the pull request at:

[GitHub] flink pull request #4706: [FLINK-7670][doc] fix typo in docs runtime section

Github user keweishang closed the pull request at: https://github.com/apache/flink/pull/4706 ---

[GitHub] flink issue #4706: [FLINK-7670][doc] fix typo in docs runtime section

Github user keweishang commented on the issue: https://github.com/apache/flink/pull/4706 @tzulitai thanks for merging the fix! ---

[jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

[ https://issues.apache.org/jira/browse/FLINK-7683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181245#comment-16181245 ] ASF GitHub Bot commented on FLINK-7683: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink issue #4722: [FLINK-7683] Iterate over keys in KeyedStateBackend

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4722 LGTM ---

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181234#comment-16181234 ] Fabian Hueske commented on FLINK-7548: -- I think there might be a misunderstanding of the

[jira] [Commented] (FLINK-7683) Add method to iterate over all of the existing keys in a statebackend

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

[GitHub] flink pull request #4722: [FLINK-7683] Iterate over keys in KeyedStateBacken...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/4722#discussion_r141136758 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -1946,4

[jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

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

[GitHub] flink issue #4710: [FLINK-7446] [table] Change DefinedRowtimeAttribute to wo...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4710 Thanks for the review @twalthr. I've updated the PR. @haohui: This PR preserves the current logic that time attributes are exposed as `TIMESTAMP`. I agree that support for time

[jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181204#comment-16181204 ] ASF GitHub Bot commented on FLINK-7446: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #4710: [FLINK-7446] [table] Change DefinedRowtimeAttribut...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4710#discussion_r141130569 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/table/TableSourceTest.scala --- @@ -121,19 +161,81 @@ class

[jira] [Created] (FLINK-7696) Add projection push-down support for TableSources with time attributes

Fabian Hueske created FLINK-7696: Summary: Add projection push-down support for TableSources with time attributes Key: FLINK-7696 URL: https://issues.apache.org/jira/browse/FLINK-7696 Project: Flink

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

[ https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181183#comment-16181183 ] ASF GitHub Bot commented on FLINK-7668: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141123168 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterGateway.java --- @@ -227,5 +229,19 @@ void failSlot(final ResourceID

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141125073 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java --- @@ -38,5 +44,36 @@ * @param timeout for this

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

[ https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181182#comment-16181182 ] ASF GitHub Bot commented on FLINK-7668: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7668) Add AccessExecutionGraph refresh interval to ExecutionGraphHolder

[ https://issues.apache.org/jira/browse/FLINK-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181181#comment-16181181 ] ASF GitHub Bot commented on FLINK-7668: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4728: [FLINK-7668] Add ExecutionGraphCache for Execution...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4728#discussion_r141122442 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebRuntimeMonitor.java --- @@ -228,55 +245,55 @@ public WebRuntimeMonitor(

[jira] [Commented] (FLINK-7446) Support to define an existing field as the rowtime field for TableSource

[ https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181172#comment-16181172 ] ASF GitHub Bot commented on FLINK-7446: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #4710: [FLINK-7446] [table] Change DefinedRowtimeAttribut...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4710#discussion_r141124496 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/logical/PushProjectIntoTableSourceScanRule.scala --- @@ -33,6 +32,9

[jira] [Commented] (FLINK-7649) Port JobStoppingHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181158#comment-16181158 ] ASF GitHub Bot commented on FLINK-7649: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4700: [FLINK-7649] [flip6] Extend JobTerminationHandler ...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4700#discussion_r141121095 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobTerminationMessageParameters.java --- @@ -26,9 +26,10 @@ * * A

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181151#comment-16181151 ] ASF GitHub Bot commented on FLINK-7650: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4697: [FLINK-7650] [flip6] Port JobCancellationHandler t...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4697#discussion_r141120508 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobCancellationHeaders.java --- @@ -0,0 +1,68 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-7663) Allow AbstractRestHandler to handle bad requests

[ https://issues.apache.org/jira/browse/FLINK-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181143#comment-16181143 ] ASF GitHub Bot commented on FLINK-7663: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7663) Allow AbstractRestHandler to handle bad requests

[ https://issues.apache.org/jira/browse/FLINK-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181145#comment-16181145 ] ASF GitHub Bot commented on FLINK-7663: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7663) Allow AbstractRestHandler to handle bad requests

[ https://issues.apache.org/jira/browse/FLINK-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181144#comment-16181144 ] ASF GitHub Bot commented on FLINK-7663: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4699: [FLINK-7663] [flip6] Return BAD_REQUEST if Handler...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4699#discussion_r141119299 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestEndpointITCase.java --- @@ -237,8 +300,8 @@ public TestParameters

[GitHub] flink pull request #4699: [FLINK-7663] [flip6] Return BAD_REQUEST if Handler...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4699#discussion_r141118884 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestEndpointITCase.java --- @@ -86,46 +98,97 @@ public void testEndpoints() throws

[GitHub] flink pull request #4699: [FLINK-7663] [flip6] Return BAD_REQUEST if Handler...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4699#discussion_r141119740 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/RestEndpointITCase.java --- @@ -162,8 +225,8 @@ public void testEndpoints() throws

[jira] [Commented] (FLINK-7663) Allow AbstractRestHandler to handle bad requests

[ https://issues.apache.org/jira/browse/FLINK-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181122#comment-16181122 ] ASF GitHub Bot commented on FLINK-7663: --- Github user zentol commented on a diff in the pull request:

[GitHub] flink pull request #4699: [FLINK-7663] [flip6] Return BAD_REQUEST if Handler...

Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4699#discussion_r141115054 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractRestHandler.java --- @@ -117,11 +117,26 @@ protected void

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181117#comment-16181117 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181113#comment-16181113 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181110#comment-16181110 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181114#comment-16181114 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181116#comment-16181116 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181101#comment-16181101 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181112#comment-16181112 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181105#comment-16181105 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181115#comment-16181115 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181109#comment-16181109 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181103#comment-16181103 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181108#comment-16181108 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181100#comment-16181100 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141100624 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181098#comment-16181098 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181107#comment-16181107 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1618#comment-1618 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141103652 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141095159 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141096324 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141104254 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141106084 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181102#comment-16181102 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181099#comment-16181099 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181104#comment-16181104 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181106#comment-16181106 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on a diff in the pull

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141093589 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r14367 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -1414,8 +1414,29 @@ object

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141096269 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141105482 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141096297 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141097263 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141102418 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141099803 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141093104 --- Diff: docs/dev/table/sql.md --- @@ -746,6 +746,7 @@ The SQL runtime is built on top of Flink's DataSet and DataStream APIs. Internal |

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r14022 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -1414,8 +1414,29 @@ object

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141113194 --- Diff: docs/dev/table/sql.md --- @@ -2107,6 +2108,17 @@ VAR_SAMP(value) Returns the sample variance (square of the sample standard

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141097303 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141097202 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141112340 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -1414,8 +1414,29 @@ object

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181093#comment-16181093 ] ASF GitHub Bot commented on FLINK-7650: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181092#comment-16181092 ] ASF GitHub Bot commented on FLINK-7650: --- Github user zentol commented on a diff in the pull request:

[jira] [Commented] (FLINK-7650) Port JobCancellationHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16181095#comment-16181095 ] ASF GitHub Bot commented on FLINK-7650: --- Github user zentol commented on a diff in the pull request:

  1   2   3   >