[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=16183603#comment-16183603 ] 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_r141517953 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7661) Add credit field in PartitionRequest message

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

[GitHub] flink issue #4698: [FLINK-7661][network] Add credit field in PartitionReques...

Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/4698 @NicoK , it already passed travis tests this time. ---

[jira] [Updated] (FLINK-7686) Add Flink Forward Berlin 2017 conference slides to the flink website

[ https://issues.apache.org/jira/browse/FLINK-7686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-7686: -- Labels: (was: comm) > Add Flink Forward Berlin 2017 conference slides to the flink website >

[jira] [Updated] (FLINK-7686) Add Flink Forward Berlin 2017 conference slides to the flink website

[ https://issues.apache.org/jira/browse/FLINK-7686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-7686: -- Labels: comm (was: site) > Add Flink Forward Berlin 2017 conference slides to the flink

[jira] [Updated] (FLINK-7686) Add Flink Forward Berlin 2017 conference slides to the flink website

[ https://issues.apache.org/jira/browse/FLINK-7686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-7686: -- Component/s: Project Website > Add Flink Forward Berlin 2017 conference slides to the flink

[jira] [Updated] (FLINK-7686) Add Flink Forward Berlin 2017 conference slides to the flink website

[ https://issues.apache.org/jira/browse/FLINK-7686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 updated FLINK-7686: -- Labels: site (was: ) > Add Flink Forward Berlin 2017 conference slides to the flink website >

[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=16183532#comment-16183532 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 commented on a diff in the pull

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

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141507401 --- 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=16183530#comment-16183530 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 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=16183531#comment-16183531 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 commented on a diff in the pull

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

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141507197 --- 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 suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141507177 --- Diff: flink-core/src/main/java/org/apache/flink/api/java/typeutils/MultisetTypeInfo.java --- @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183465#comment-16183465 ] Kent Murra commented on FLINK-7657: --- As an aside, my testing indicates that the "DATE/TIME/TIMESTAMP"

[jira] [Closed] (FLINK-7635) Support sideOutput in ProcessWindowFunciton

[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-7635. --- Resolution: Done > Support sideOutput in ProcessWindowFunciton > ---

[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=16183444#comment-16183444 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 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=16183445#comment-16183445 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 commented on a diff in the pull

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

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141494189 --- 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 suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141494139 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/CollectAggFunction.scala --- @@ -0,0 +1,158 @@ +/*

[jira] [Commented] (FLINK-7724) add extra metrics to MetricStoreTest.setupStore

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

[jira] [Commented] (FLINK-6703) Document how to take a savepoint on YARN

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

[GitHub] flink issue #4739: [FLINK-7724][REST][Tests][Metrics] add extra metrics to M...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4739 cc @tillrohrmann @zentol ---

[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=16183426#comment-16183426 ] ASF GitHub Bot commented on FLINK-7650: --- Github user bowenli86 commented on a diff in the pull

[GitHub] flink issue #4721: [FLINK-6703][savepoint/doc] Document how to take a savepo...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4721 cc @zentol ---

[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_r141492673 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobMessageParameters.java --- @@ -0,0 +1,42 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-7724) add extra metrics to MetricStoreTest.setupStore

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

[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=16183415#comment-16183415 ] ASF GitHub Bot commented on FLINK-7649: --- Github user asfgit closed the pull request at:

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

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

[GitHub] flink pull request #4739: [FLINK-7724][REST][Tests][Metrics] add extra metri...

GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/4739 [FLINK-7724][REST][Tests][Metrics] add extra metrics to MetricStoreTest.setupStore ## What is the purpose of the change This is a pre-requisite for FLINK-7694 I'm porting

[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=16183413#comment-16183413 ] ASF GitHub Bot commented on FLINK-7650: --- Github user asfgit closed the pull request at:

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

[ https://issues.apache.org/jira/browse/FLINK-7649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7649. -- Resolution: Fixed Fixed via adeab64ea0abdc892e51c6f630aa56dabf7e2c98 > Port JobStoppingHandler

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-7650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7650. -- Resolution: Fixed Fixed via 8ea4db1a8b368b4e00dd310c0d07405fd2142b34 > Port

[jira] [Closed] (FLINK-7723) DispatcherTest instable

[ https://issues.apache.org/jira/browse/FLINK-7723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7723. Resolution: Fixed Fixed via 4debc6033cc2099b763d7fef86829b9f6734d91a > DispatcherTest instable >

[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=16183381#comment-16183381 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 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=16183380#comment-16183380 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 commented on a diff in the pull

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

Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141485942 --- 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 suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4585#discussion_r141485981 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala --- @@ -1414,8 +1414,29 @@ object

[jira] [Created] (FLINK-7724) add extra metrics to MetricStoreTest.setupStore

Bowen Li created FLINK-7724: --- Summary: add extra metrics to MetricStoreTest.setupStore Key: FLINK-7724 URL: https://issues.apache.org/jira/browse/FLINK-7724 Project: Flink Issue Type: Test

[jira] [Closed] (FLINK-7722) MiniCluster does not appear to honor Log4j settings

[ https://issues.apache.org/jira/browse/FLINK-7722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Elias Levy closed FLINK-7722. - Resolution: Not A Problem > MiniCluster does not appear to honor Log4j settings >

[jira] [Commented] (FLINK-7722) MiniCluster does not appear to honor Log4j settings

[ https://issues.apache.org/jira/browse/FLINK-7722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183336#comment-16183336 ] Elias Levy commented on FLINK-7722: --- Aye. I figured out the issue was that I needed to call

[jira] [Created] (FLINK-7723) DispatcherTest instable

Till Rohrmann created FLINK-7723: Summary: DispatcherTest instable Key: FLINK-7723 URL: https://issues.apache.org/jira/browse/FLINK-7723 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-6949) Add ability to ship custom resource files to YARN cluster

[ https://issues.apache.org/jira/browse/FLINK-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183304#comment-16183304 ] Mikhail Pryakhin commented on FLINK-6949: - I propose to add a --yarnship-files CLI option that

[jira] [Assigned] (FLINK-6949) Add ability to ship custom resource files to YARN cluster

[ https://issues.apache.org/jira/browse/FLINK-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Pryakhin reassigned FLINK-6949: --- Assignee: Mikhail Pryakhin > Add ability to ship custom resource files to YARN

[jira] [Commented] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183241#comment-16183241 ] Kent Murra commented on FLINK-7657: --- Thanks for the information Timo. My approach was to add an apply

[jira] [Commented] (FLINK-7722) MiniCluster does not appear to honor Log4j settings

[ https://issues.apache.org/jira/browse/FLINK-7722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183221#comment-16183221 ] Ufuk Celebi commented on FLINK-7722: I think this is the output of the client that is actually

[jira] [Created] (FLINK-7722) MiniCluster does not appear to honor Log4j settings

Elias Levy created FLINK-7722: - Summary: MiniCluster does not appear to honor Log4j settings Key: FLINK-7722 URL: https://issues.apache.org/jira/browse/FLINK-7722 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7720) Centralize creation of backends and state related resources

[ https://issues.apache.org/jira/browse/FLINK-7720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183151#comment-16183151 ] Bowen Li commented on FLINK-7720: - +1 > Centralize creation of backends and state related resources >

[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=16183148#comment-16183148 ] ASF GitHub Bot commented on FLINK-7491: --- Github user suez1224 commented on a diff in the pull

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

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

[jira] [Assigned] (FLINK-6950) Add ability to specify single jar files to be shipped to YARN

[ https://issues.apache.org/jira/browse/FLINK-6950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mikhail Pryakhin reassigned FLINK-6950: --- Assignee: Mikhail Pryakhin > Add ability to specify single jar files to be shipped

[jira] [Commented] (FLINK-6950) Add ability to specify single jar files to be shipped to YARN

[ https://issues.apache.org/jira/browse/FLINK-6950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183104#comment-16183104 ] Robert Metzger commented on FLINK-6950: --- Yes, please go ahead! > Add ability to specify single jar

[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=16183016#comment-16183016 ] ASF GitHub Bot commented on FLINK-7650: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels

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

[GitHub] flink issue #4697: [FLINK-7650] [flip6] Port JobCancellationHandler to new R...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/4697 +1 from my side. ---

[GitHub] flink pull request #4738: [FLINK-7721] [DataStream] Only emit new min waterm...

GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/4738 [FLINK-7721] [DataStream] Only emit new min watermark iff it was aggregated from watermark-aligned inputs ## What is the purpose of the change Prior to this PR, in the calculation of 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=16183011#comment-16183011 ] 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_r141425581 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobMessageParameters.java --- @@ -0,0 +1,42 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-5944) Flink should support reading Snappy Files

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

[GitHub] flink pull request #4683: [FLINK-5944] Support reading of Snappy files

Github user mlipkovich commented on a diff in the pull request: https://github.com/apache/flink/pull/4683#discussion_r141424281 --- Diff: flink-core/pom.xml --- @@ -52,6 +52,12 @@ under the License. flink-shaded-asm +

[jira] [Created] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels

Tzu-Li (Gordon) Tai created FLINK-7721: -- Summary: StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels Key: FLINK-7721 URL:

[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! One more ask: can you please add comments to both the class and the code explaining that concurrent modification will fail the iteration? ---

[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=16182944#comment-16182944 ] ASF GitHub Bot commented on FLINK-7683: --- Github user bowenli86 commented on the issue:

[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=16182930#comment-16182930 ] 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=16182929#comment-16182929 ] 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_r141409228 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobMessageParameters.java --- @@ -0,0 +1,42 @@ +/* + * Licensed to

[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_r141409233 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobMessageParameters.java --- @@ -0,0 +1,42 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r141406439 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/PermanentBlobCache.java --- @@ -0,0 +1,429 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r141406045 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java --- @@ -389,95 +413,332 @@ public File getFile(JobID jobId, BlobKey

[jira] [Commented] (FLINK-7068) change BlobService sub-classes for permanent and transient BLOBs

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

[GitHub] flink pull request #4358: [FLINK-7068][blob] change BlobService sub-classes ...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4358#discussion_r141405909 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java --- @@ -174,7 +176,6 @@ public ServerSocket createSocket(int port)

[jira] [Commented] (FLINK-7411) minor performance improvements in NettyMessage

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

[GitHub] flink issue #4517: [FLINK-7411][network] minor performance improvements in N...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4517 Thanks for your contribution @NicoK and the review @pnowojski. Changes look good to me. Will wait for Travis and then merge this PR. ---

[jira] [Commented] (FLINK-7514) fix BackPressureStatsTrackerITCase releasing buffers twice

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

[GitHub] flink issue #4591: [FLINK-7514][tests] fix BackPressureStatsTrackerITCase re...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4591 Thanks for your contribution @NicoK and the reviews @pnowojski and @zentol. Changes look good. If Travis passes, then I'll merge the PR. ---

[jira] [Commented] (FLINK-7513) remove TestBufferFactory#MOCK_BUFFER

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

[GitHub] flink issue #4590: [FLINK-7513][tests] remove TestBufferFactory#MOCK_BUFFER

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4590 Thanks for your contribution @NicoK and the review @pnowojski. Merging this PR. ---

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider

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

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4735#discussion_r141400676 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java --- @@ -211,10 +210,15 @@ public void

[jira] [Commented] (FLINK-7487) test instability in ClassLoaderITCase (no resources available)

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

[GitHub] flink issue #4571: [FLINK-7487][tests] fix ClassLoaderITCase#testDisposeSave...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4571 Thanks for your contribution @NicoK. Merging this PR. ---

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4735#discussion_r141398906 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -87,6 +88,12 @@ /**

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider

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

[jira] [Commented] (FLINK-7695) Port JobConfigHandler to new REST endpoint

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

[GitHub] flink pull request #4737: [FLINK-7695] [flip6] Add JobConfigHandler for new ...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4737 [FLINK-7695] [flip6] Add JobConfigHandler for new RestServerEndpoint ## What is the purpose of the change Add `JobConfigHandler` for the new `RestServerEndpoint`. ## Verifying

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

Github user wuchong commented on the issue: https://github.com/apache/flink/pull/4710 Looks good to me. +1 ---

[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=16182840#comment-16182840 ] ASF GitHub Bot commented on FLINK-7446: --- Github user wuchong commented on the issue:

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141396863 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,283 @@ +/* + * Licensed

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

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

[jira] [Commented] (FLINK-7667) Add serializable AccessExecutionGraph implementation

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

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

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

[GitHub] flink issue #4727: [FLINK-7667] [flip6] Use ArchivedExecutionGraph as serial...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4727 Thanks for the review @zentol. Rebasing this commit and waiting on Travis. ---

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141396295 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,283 @@ +/* + * Licensed

[jira] [Commented] (FLINK-7406) Implement Netty receiver incoming pipeline for credit-based

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

[GitHub] flink pull request #4509: [FLINK-7406][network] Implement Netty receiver inc...

Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4509#discussion_r141396023 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedClientHandler.java --- @@ -0,0 +1,283 @@ +/* + * Licensed

[jira] [Assigned] (FLINK-7717) Port TaskManagerMetricsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-7717: --- Assignee: Bowen Li > Port TaskManagerMetricsHandler to new REST endpoint >

[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=16182827#comment-16182827 ] ASF GitHub Bot commented on FLINK-7649: --- Github user tillrohrmann commented on the issue:

  1   2   3   4   5   >