[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=16142277#comment-16142277 ] Shuyi Chen commented on FLINK-7491: --- Thanks for reviewing the PR. [~jark] I think Multiset and Array

[jira] [Comment Edited] (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=16142277#comment-16142277 ] Shuyi Chen edited comment on FLINK-7491 at 8/25/17 10:15 PM: - Thanks for

[jira] [Created] (FLINK-7525) Add config option to disable Cancel functionality on UI

Ted Yu created FLINK-7525: - Summary: Add config option to disable Cancel functionality on UI Key: FLINK-7525 URL: https://issues.apache.org/jira/browse/FLINK-7525 Project: Flink Issue Type:

[jira] [Updated] (FLINK-7525) Add config option to disable Cancel functionality on UI

[ https://issues.apache.org/jira/browse/FLINK-7525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-7525: -- Description: In this email thread

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

Github user tedyu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r135366122 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -421,6 +437,15 @@ private void

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

Github user tedyu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r135366609 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -526,18 +551,32 @@ private boolean

[GitHub] flink pull request #4296: [FLINK-7147] [cep] Support greedy quantifier in CE...

Github user tedyu commented on a diff in the pull request: https://github.com/apache/flink/pull/4296#discussion_r135367240 --- Diff: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java --- @@ -526,18 +551,32 @@ private boolean

[jira] [Commented] (FLINK-7147) Support greedy quantifier in CEP

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

[jira] [Commented] (FLINK-7511) Remove dead code after dropping backward compatibility with <=1.2

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

[GitHub] flink pull request #4587: [FLINK-7511] [cep] Remove dead code after dropping...

GitHub user dawidwys opened a pull request: https://github.com/apache/flink/pull/4587 [FLINK-7511] [cep] Remove dead code after dropping backward compatibi… …lity with <=1.2 *Thank you very much for contributing to Apache Flink - we are happy that you want to help

[jira] [Created] (FLINK-7512) avoid unnecessary buffer copies during network serialization

Nico Kruber created FLINK-7512: -- Summary: avoid unnecessary buffer copies during network serialization Key: FLINK-7512 URL: https://issues.apache.org/jira/browse/FLINK-7512 Project: Flink

[GitHub] flink pull request #4577: Add user context and bind together state fields in...

Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4577#discussion_r135202467 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java --- @@ -304,4 +287,33 @@

[GitHub] flink pull request #4586: [FLINK-7502] [metrics] Improve PrometheusReporter

GitHub user mbode opened a pull request: https://github.com/apache/flink/pull/4586 [FLINK-7502] [metrics] Improve PrometheusReporter ## What is the purpose of the change *This pull request addresses several issues that came up when testing PrometheusReporter in a YARN

[jira] [Commented] (FLINK-7502) PrometheusReporter improvements

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

[GitHub] flink issue #4586: [FLINK-7502] [metrics] Improve PrometheusReporter

Github user mbode commented on the issue: https://github.com/apache/flink/pull/4586 [Green Travis](https://travis-ci.org/mbode/flink/builds/268258386) --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

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

Nico Kruber created FLINK-7514: -- Summary: fix BackPressureStatsTrackerITCase releasing buffers twice Key: FLINK-7514 URL: https://issues.apache.org/jira/browse/FLINK-7514 Project: Flink Issue

[jira] [Commented] (FLINK-7206) Implementation of DataView to support state access for UDAGG

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

[GitHub] flink issue #4355: [FLINK-7206] [table] Implementation of DataView to suppor...

Github user kaibozhou commented on the issue: https://github.com/apache/flink/pull/4355 Thanks @fhueske for the suggestion. All comments addressed. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project

[jira] [Commented] (FLINK-7502) PrometheusReporter improvements

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

[jira] [Updated] (FLINK-7427) integrate PartitionRequestProtocol into NettyProtocol

[ https://issues.apache.org/jira/browse/FLINK-7427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7427: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-7512 > integrate

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

[ https://issues.apache.org/jira/browse/FLINK-7411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7411: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-7512 > minor performance improvements

[jira] [Updated] (FLINK-7512) avoid unnecessary buffer copies during network serialization

[ https://issues.apache.org/jira/browse/FLINK-7512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7512: --- Description: Currently, we have our own {{Buffer}} class backed by a {{MemorySegment}} and whenever

[jira] [Updated] (FLINK-7412) optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly

[ https://issues.apache.org/jira/browse/FLINK-7412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7412: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-7512 > optimise

[GitHub] flink issue #4569: [FLINK-7040] [REST] Add basics for REST communication

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4569 One last change I'd like to apply before merging is to let the user provide the target address and target port to the method `sendRequest` instead of to the `RestClientEndpoint` constructor.

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[jira] [Created] (FLINK-7511) Remove dead code after dropping backward compatibility with <=1.2

Dawid Wysakowicz created FLINK-7511: --- Summary: Remove dead code after dropping backward compatibility with <=1.2 Key: FLINK-7511 URL: https://issues.apache.org/jira/browse/FLINK-7511 Project: Flink

[jira] [Updated] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7499: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7512 > double buffer release in

[jira] [Updated] (FLINK-7428) avoid one additional buffer copy when receiving messages

[ https://issues.apache.org/jira/browse/FLINK-7428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7428: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-7512 > avoid one additional buffer

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

Nico Kruber created FLINK-7513: -- Summary: remove TestBufferFactory#MOCK_BUFFER Key: FLINK-7513 URL: https://issues.apache.org/jira/browse/FLINK-7513 Project: Flink Issue Type: Sub-task

[GitHub] flink issue #4569: [FLINK-7040] [REST] Add basics for REST communication

Github user kl0u commented on the issue: https://github.com/apache/flink/pull/4569 Thanks a lot @tillrohrmann ! This is a pretty useful API addition. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does

[jira] [Commented] (FLINK-7040) Flip-6 client-cluster communication

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

[jira] [Assigned] (FLINK-3431) Add retrying logic for RocksDB snapshots

[ https://issues.apache.org/jira/browse/FLINK-3431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-3431: - Assignee: Shuyi Chen > Add retrying logic for RocksDB snapshots >

[jira] [Commented] (FLINK-3431) Add retrying logic for RocksDB snapshots

[ https://issues.apache.org/jira/browse/FLINK-3431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16142536#comment-16142536 ] Shuyi Chen commented on FLINK-3431: --- Anyone looking at this issue? I can take a look otherwise. > Add

[jira] [Commented] (FLINK-7410) Add getName method to UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16142604#comment-16142604 ] Hequn Cheng commented on FLINK-7410: hi [~jark] , thanks for your advice. {toString} may be used to

[jira] [Comment Edited] (FLINK-7410) Add getName method to UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16142604#comment-16142604 ] Hequn Cheng edited comment on FLINK-7410 at 8/26/17 4:04 AM: - hi [~jark] ,

[jira] [Created] (FLINK-7517) let NettyBufferPool extend PooledByteBufAllocator

Nico Kruber created FLINK-7517: -- Summary: let NettyBufferPool extend PooledByteBufAllocator Key: FLINK-7517 URL: https://issues.apache.org/jira/browse/FLINK-7517 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-7513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7513: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7315 > remove TestBufferFactory#MOCK_BUFFER >

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

[ https://issues.apache.org/jira/browse/FLINK-7513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7513: --- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7512) > remove

[jira] [Updated] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7499: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7315 > double buffer release in

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

[ https://issues.apache.org/jira/browse/FLINK-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7514: --- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7512) > fix

[jira] [Updated] (FLINK-7428) avoid one additional buffer copy when receiving messages

[ https://issues.apache.org/jira/browse/FLINK-7428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7428: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7315 > avoid one additional buffer copy when

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

[ https://issues.apache.org/jira/browse/FLINK-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7514: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7315 > fix BackPressureStatsTrackerITCase

[jira] [Updated] (FLINK-7517) let NettyBufferPool extend PooledByteBufAllocator

[ https://issues.apache.org/jira/browse/FLINK-7517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7517: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7315 > let NettyBufferPool extend

[jira] [Created] (FLINK-7521) Remove the 10MB limit from the current REST implementation.

Kostas Kloudas created FLINK-7521: - Summary: Remove the 10MB limit from the current REST implementation. Key: FLINK-7521 URL: https://issues.apache.org/jira/browse/FLINK-7521 Project: Flink

[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=16141546#comment-16141546 ] ASF GitHub Bot commented on FLINK-7514: --- GitHub user NicoK opened a pull request:

[GitHub] flink pull request #4593: [FLINK-7516][memory] do not allow copies into a re...

GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4593 [FLINK-7516][memory] do not allow copies into a read-only ByteBuffer ## What is the purpose of the change `HybridMemorySegment#get(int, ByteBuffer, int)` allows writing into a read-only

[jira] [Commented] (FLINK-7517) let NettyBufferPool extend PooledByteBufAllocator

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

[jira] [Created] (FLINK-7518) pass our own buffer instances to netty

Nico Kruber created FLINK-7518: -- Summary: pass our own buffer instances to netty Key: FLINK-7518 URL: https://issues.apache.org/jira/browse/FLINK-7518 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-7519) Enrich ClientRestException with HttpResponseStatus

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

[jira] [Updated] (FLINK-7427) integrate PartitionRequestProtocol into NettyProtocol

[ https://issues.apache.org/jira/browse/FLINK-7427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7427: --- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7512) > integrate

[jira] [Updated] (FLINK-7428) avoid one additional buffer copy when receiving messages

[ https://issues.apache.org/jira/browse/FLINK-7428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7428: --- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7512) > avoid one additional buffer

[jira] [Updated] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7499: --- Priority: Blocker (was: Major) > double buffer release in SpillableSubpartitionView >

[jira] [Updated] (FLINK-7499) double buffer release in SpillableSubpartitionView

[ https://issues.apache.org/jira/browse/FLINK-7499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7499: --- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7512) > double buffer release in

[jira] [Updated] (FLINK-7516) HybridMemorySegment: do not allow copies into a read-only ByteBuffer

[ https://issues.apache.org/jira/browse/FLINK-7516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7516: --- Summary: HybridMemorySegment: do not allow copies into a read-only ByteBuffer (was: MemorySegment:

[jira] [Updated] (FLINK-7450) Bounded generic POJO field is identified as Object by TypeExtractor

[ https://issues.apache.org/jira/browse/FLINK-7450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7450: Affects Version/s: 1.4.0 > Bounded generic POJO field is identified as Object by

[GitHub] flink pull request #4591: [FLINK-7514][tests] fix BackPressureStatsTrackerIT...

GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4591 [FLINK-7514][tests] fix BackPressureStatsTrackerITCase releasing buffers twice ## What is the purpose of the change `BackPressureStatsTrackerITCase#testBackPressuredProducer()` is releasing

[GitHub] flink pull request #4592: [FLINK-7515][network] allow actual 0-length conten...

GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4592 [FLINK-7515][network] allow actual 0-length content in NettyMessage#allocateBuffer() ## What is the purpose of the change Previously, length "0" meant "unknown content length" but there are

[jira] [Commented] (FLINK-7515) allow actual 0-length content in NettyMessage#allocateBuffer()

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

[jira] [Commented] (FLINK-7516) HybridMemorySegment: do not allow copies into a read-only ByteBuffer

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

[jira] [Updated] (FLINK-7517) let NettyBufferPool extend PooledByteBufAllocator

[ https://issues.apache.org/jira/browse/FLINK-7517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7517: --- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7512) > let NettyBufferPool extend

[jira] [Updated] (FLINK-7516) MemorySegment: do not allow copies into a read-only ByteBuffer

[ https://issues.apache.org/jira/browse/FLINK-7516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7516: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7315 > MemorySegment: do not allow copies into

[jira] [Updated] (FLINK-7515) allow actual 0-length content in NettyMessage#allocateBuffer()

[ https://issues.apache.org/jira/browse/FLINK-7515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7515: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7315 > allow actual 0-length content in

[jira] [Updated] (FLINK-7520) let our Buffer class extend from netty's buffer class

[ https://issues.apache.org/jira/browse/FLINK-7520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7520: --- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7512) > let our Buffer class extend

[jira] [Updated] (FLINK-7515) allow actual 0-length content in NettyMessage#allocateBuffer()

[ https://issues.apache.org/jira/browse/FLINK-7515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7515: --- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7512) > allow actual 0-length

[jira] [Updated] (FLINK-7516) MemorySegment: do not allow copies into a read-only ByteBuffer

[ https://issues.apache.org/jira/browse/FLINK-7516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7516: --- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7512) > MemorySegment: do not allow

[jira] [Created] (FLINK-7522) Add termination future to ClusterEntrypoint

Till Rohrmann created FLINK-7522: Summary: Add termination future to ClusterEntrypoint Key: FLINK-7522 URL: https://issues.apache.org/jira/browse/FLINK-7522 Project: Flink Issue Type:

[jira] [Commented] (FLINK-7522) Add termination future to ClusterEntrypoint

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

[GitHub] flink pull request #4590: [FLINK-7513][tests] remove TestBufferFactory#MOCK_...

GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4590 [FLINK-7513][tests] remove TestBufferFactory#MOCK_BUFFER ## What is the purpose of the change The static `TestBufferFactory#MOCK_BUFFER` buffer did not allow proper reference counting and we

[jira] [Commented] (FLINK-7429) Add restore from 1.2 / 1.3 migration tests for FlinkKinesisConsumer

[ https://issues.apache.org/jira/browse/FLINK-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16141548#comment-16141548 ] Aljoscha Krettek commented on FLINK-7429: - Implemented on master in

[GitHub] flink issue #4565: [FLINK-7429] [kinesis] Add migration test coverage for Fl...

Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4565 I merged this on master, waiting for tests to pass on release-1.3. 😃 Could you please close this PR? --- If your project is set up for it, you can reply to this email and have your

[jira] [Commented] (FLINK-7429) Add restore from 1.2 / 1.3 migration tests for FlinkKinesisConsumer

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

[jira] [Updated] (FLINK-7516) HybridMemorySegment: do not allow copies into a read-only ByteBuffer

[ https://issues.apache.org/jira/browse/FLINK-7516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7516: --- Description: {{HybridMemorySegment#get(int, ByteBuffer, int)}} allows writing into a read-only

[jira] [Assigned] (FLINK-4831) Implement a slf4j metric reporter

[ https://issues.apache.org/jira/browse/FLINK-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sumit Sarin reassigned FLINK-4831: -- Assignee: (was: Sumit Sarin) > Implement a slf4j metric reporter >

[jira] [Created] (FLINK-7523) test instability in LocalStreamEnvironmentITCase#testRunIsolatedJob

Nico Kruber created FLINK-7523: -- Summary: test instability in LocalStreamEnvironmentITCase#testRunIsolatedJob Key: FLINK-7523 URL: https://issues.apache.org/jira/browse/FLINK-7523 Project: Flink

[jira] [Updated] (FLINK-7523) test instability in LocalStreamEnvironmentITCase#testRunIsolatedJob

[ https://issues.apache.org/jira/browse/FLINK-7523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7523: --- Labels: flip-6 test-stability (was: ) > test instability in

[jira] [Created] (FLINK-7515) allow actual 0-length content in NettyMessage#allocateBuffer()

Nico Kruber created FLINK-7515: -- Summary: allow actual 0-length content in NettyMessage#allocateBuffer() Key: FLINK-7515 URL: https://issues.apache.org/jira/browse/FLINK-7515 Project: Flink

[jira] [Created] (FLINK-7519) Enrich ClientRestException with HttpResponseStatus

Till Rohrmann created FLINK-7519: Summary: Enrich ClientRestException with HttpResponseStatus Key: FLINK-7519 URL: https://issues.apache.org/jira/browse/FLINK-7519 Project: Flink Issue Type:

[GitHub] flink pull request #4588: [FLINK-7519] Add HttpResponseStatus to RestClientE...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4588 [FLINK-7519] Add HttpResponseStatus to RestClientException ## What is the purpose of the change Enrich the RestClientException with the HttpResponseStatus in case of failures.

[jira] [Created] (FLINK-7520) let our Buffer class extend from netty's buffer class

Nico Kruber created FLINK-7520: -- Summary: let our Buffer class extend from netty's buffer class Key: FLINK-7520 URL: https://issues.apache.org/jira/browse/FLINK-7520 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-7411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7411: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7315 > minor performance improvements in

[jira] [Updated] (FLINK-7518) pass our own buffer instances to netty

[ https://issues.apache.org/jira/browse/FLINK-7518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7518: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7315 > pass our own buffer instances to netty

[jira] [Updated] (FLINK-7518) pass our own buffer instances to netty

[ https://issues.apache.org/jira/browse/FLINK-7518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7518: --- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7512) > pass our own buffer

[jira] [Updated] (FLINK-7520) let our Buffer class extend from netty's buffer class

[ https://issues.apache.org/jira/browse/FLINK-7520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7520: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7315 > let our Buffer class extend from

[jira] [Closed] (FLINK-7512) avoid unnecessary buffer copies during network serialization

[ https://issues.apache.org/jira/browse/FLINK-7512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-7512. -- Resolution: Duplicate > avoid unnecessary buffer copies during network serialization >

[jira] [Updated] (FLINK-7521) Remove the 10MB limit from the current REST implementation.

[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-7521: -- Description: In the current {{AbstractRestServer}} we impose an upper bound of 10MB in the

[GitHub] flink pull request #4589: [FLINK-7522] Add termination future to ClusterEntr...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4589 [FLINK-7522] Add termination future to ClusterEntrypoint ## What is the purpose of the change The termination future is completed when the `ClusterEntrypoint` shuts down. This

[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=16141543#comment-16141543 ] ASF GitHub Bot commented on FLINK-7513: --- GitHub user NicoK opened a pull request:

[jira] [Created] (FLINK-7516) MemorySegment: do not allow copies into a read-only ByteBuffer

Nico Kruber created FLINK-7516: -- Summary: MemorySegment: do not allow copies into a read-only ByteBuffer Key: FLINK-7516 URL: https://issues.apache.org/jira/browse/FLINK-7516 Project: Flink

[jira] [Updated] (FLINK-7312) activate checkstyle for flink/core/memory/*

[ https://issues.apache.org/jira/browse/FLINK-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7312: --- Issue Type: Sub-task (was: Improvement) Parent: FLINK-7315 > activate checkstyle for

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

[ https://issues.apache.org/jira/browse/FLINK-7411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7411: --- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7512) > minor performance

[jira] [Updated] (FLINK-7427) integrate PartitionRequestProtocol into NettyProtocol

[ https://issues.apache.org/jira/browse/FLINK-7427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7427: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7315 > integrate PartitionRequestProtocol into

[jira] [Updated] (FLINK-7412) optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly

[ https://issues.apache.org/jira/browse/FLINK-7412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7412: --- Issue Type: Bug (was: Sub-task) Parent: (was: FLINK-7512) > optimise

[jira] [Updated] (FLINK-7412) optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly

[ https://issues.apache.org/jira/browse/FLINK-7412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-7412: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-7315 > optimise

[GitHub] flink pull request #4594: [FLINK-7517][network] let NettyBufferPool extend P...

GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4594 [FLINK-7517][network] let NettyBufferPool extend PooledByteBufAllocator ## What is the purpose of the change `NettyBufferPool` wraps `PooledByteBufAllocator` but due to this, any allocated

[jira] [Updated] (FLINK-7510) Move "flink-connector-twitter & flink-connector-wikiedits" to bahir-flink

[ https://issues.apache.org/jira/browse/FLINK-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7510: Description: * flink-connectors *flink-connectors/flink-connector-twitter* &

[jira] [Updated] (FLINK-7510) Move "flink-connector-twitter & flink-connector-wikiedits" to bahir-flink

[ https://issues.apache.org/jira/browse/FLINK-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7510: Description: * flink-connectors *flink-connectors/flink-connector-twitter* & *

[jira] [Created] (FLINK-7510) Move "flink-connector-twitter & flink-connector-wikiedits" to bahir-flink

Hai Zhou created FLINK-7510: --- Summary: Move "flink-connector-twitter & flink-connector-wikiedits" to bahir-flink Key: FLINK-7510 URL: https://issues.apache.org/jira/browse/FLINK-7510 Project: Flink

[GitHub] flink pull request #4585: [FLINK-7491] add MultiSetTypeInfo; add built-in Co...

GitHub user suez1224 opened a pull request: https://github.com/apache/flink/pull/4585 [FLINK-7491] add MultiSetTypeInfo; add built-in Collect Aggregate Function for Flink SQL. *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve

  1   2   >