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

2017-08-25 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142604#comment-16142604 ] Hequn Cheng edited comment on FLINK-7410 at 8/26/17 4:04 AM: -

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

2017-08-25 Thread Hequn Cheng (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142604#comment-16142604 ] Hequn Cheng commented on FLINK-7410: hi [~jark] , thanks for your advice. {toString} m

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

2017-08-25 Thread Shuyi Chen (JIRA)
[ 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

2017-08-25 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142536#comment-16142536 ] Shuyi Chen commented on FLINK-3431: --- Anyone looking at this issue? I can take a look oth

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

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142374#comment-16142374 ] ASF GitHub Bot commented on FLINK-7147: --- Github user tedyu commented on a diff in th

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

2017-08-25 Thread tedyu
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 isPatternOption

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

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142367#comment-16142367 ] ASF GitHub Bot commented on FLINK-7147: --- Github user tedyu commented on a diff in th

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

2017-08-25 Thread tedyu
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 isPatternOption

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

2017-08-25 Thread tedyu
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 addStopStateToLoopi

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

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142361#comment-16142361 ] ASF GitHub Bot commented on FLINK-7147: --- Github user tedyu commented on a diff in th

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

2017-08-25 Thread Ted Yu (JIRA)
[ 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 http://search-hadoop.com/m/Flink/VkLeQlf0QOnc7YA?subj=Security+Control+of+run

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

2017-08-25 Thread Ted Yu (JIRA)
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: Improveme

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

2017-08-25 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142277#comment-16142277 ] Shuyi Chen edited comment on FLINK-7491 at 8/25/17 10:15 PM: -

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

2017-08-25 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142277#comment-16142277 ] Shuyi Chen commented on FLINK-7491: --- Thanks for reviewing the PR. [~jark] I think Multi

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

2017-08-25 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142007#comment-16142007 ] Bowen Li commented on FLINK-7512: - Hi [~NicoK], I'm seeing the follow errors in our jobma

[jira] [Commented] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141974#comment-16141974 ] ASF GitHub Bot commented on FLINK-7357: --- Github user walterddr commented on a diff i

[GitHub] flink pull request #4521: [FLINK-7357] [table] Created extended rules for Wi...

2017-08-25 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/4521#discussion_r135321169 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/sql/GroupWindowTest.scala --- @@ -143,4 +143,36 @@ class GroupWindo

[jira] [Created] (FLINK-7524) Task "xxx" did not react to cancelling signal, but is stuck in method

2017-08-25 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7524: --- Summary: Task "xxx" did not react to cancelling signal, but is stuck in method Key: FLINK-7524 URL: https://issues.apache.org/jira/browse/FLINK-7524 Project: Flink Is

[jira] [Updated] (FLINK-7510) Move some connectors to Apache Bahir

2017-08-25 Thread Hai Zhou (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou updated FLINK-7510: Description: Hi Flink community: Flink is really a great stream processing framework, provides a number of

issues@flink.apache.org

2017-08-25 Thread Jacob Park (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141856#comment-16141856 ] Jacob Park commented on FLINK-7465: --- [~sunzhenya] When you say you want to process the r

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

2017-08-25 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-7521: -- Priority: Blocker (was: Major) > Remove the 10MB limit from the current REST implementation. >

[jira] [Commented] (FLINK-7378) Create a fix size (non rebalancing) buffer pool type for the floating buffers

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141727#comment-16141727 ] ASF GitHub Bot commented on FLINK-7378: --- Github user NicoK commented on the issue:

[GitHub] flink issue #4485: [FLINK-7378][core]Create a fix size (non rebalancing) buf...

2017-08-25 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4485 Reviewed 9 of 13 files at r2. Review status: all files reviewed at latest revision, 7 unresolved discussions, some commit checks failed. --- *[a discussion](ht

[GitHub] flink issue #3511: [Flink-5734] code generation for normalizedkey sorter

2017-08-25 Thread ggevay
Github user ggevay commented on the issue: https://github.com/apache/flink/pull/3511 Hi @heytitle, What is the status here? I will be on vacation next week, so I would have some time to work on this. Should I work on finishing this, or are you also working on it? I would like

[jira] [Commented] (FLINK-7129) Dynamically changing patterns

2017-08-25 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141659#comment-16141659 ] Dawid Wysakowicz commented on FLINK-7129: - I meant that if I have some keyed state

[jira] [Comment Edited] (FLINK-7129) Dynamically changing patterns

2017-08-25 Thread Dawid Wysakowicz (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141659#comment-16141659 ] Dawid Wysakowicz edited comment on FLINK-7129 at 8/25/17 2:02 PM: --

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

2017-08-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141611#comment-16141611 ] Till Rohrmann commented on FLINK-7523: -- The problem is that we don't wait until the {

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

2017-08-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7523: Assignee: Till Rohrmann > test instability in LocalStreamEnvironmentITCase#testRunIsolatedJ

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

2017-08-25 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7523: - Priority: Critical (was: Major) > test instability in LocalStreamEnvironmentITCase#testRunIsolate

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

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141608#comment-16141608 ] ASF GitHub Bot commented on FLINK-7428: --- Github user NicoK commented on the issue:

[GitHub] flink issue #4529: [FLINK-7428][network] avoid buffer copies when receiving ...

2017-08-25 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4529 Thanks, @greghogan - I put most of them under FLINK-7315 now (at least the ones which are loosely related). Regarding the PR itself, I still need to investigate whether the previous issues wen

[GitHub] flink pull request #4521: [FLINK-7357] [table] Created extended rules for Wi...

2017-08-25 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4521#discussion_r135254243 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/sql/GroupWindowTest.scala --- @@ -143,4 +143,36 @@ class GroupWindowT

[jira] [Commented] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141605#comment-16141605 ] ASF GitHub Bot commented on FLINK-7357: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #4521: [FLINK-7357] [table] Created extended rules for Wi...

2017-08-25 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4521#discussion_r135256246 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/FlinkRuleSets.scala --- @@ -147,7 +147,8 @@ object FlinkRuleSets {

[jira] [Commented] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141603#comment-16141603 ] ASF GitHub Bot commented on FLINK-7357: --- Github user twalthr commented on a diff in

[jira] [Commented] (FLINK-7357) HOP_START() HOP_END() does not work when using HAVING clause with GROUP BY HOP window

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141604#comment-16141604 ] ASF GitHub Bot commented on FLINK-7357: --- Github user twalthr commented on a diff in

[GitHub] flink pull request #4521: [FLINK-7357] [table] Created extended rules for Wi...

2017-08-25 Thread twalthr
Github user twalthr commented on a diff in the pull request: https://github.com/apache/flink/pull/4521#discussion_r135255639 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/OverWindowITCase.scala --- @@ -836,6 +836,52 @@ class OverWin

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

2017-08-25 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7429. --- Resolution: Fixed > Add restore from 1.2 / 1.3 migration tests for FlinkKinesisConsumer >

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

2017-08-25 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141597#comment-16141597 ] Aljoscha Krettek commented on FLINK-7429: - Implemented on release-1.3 in 8dc5fd031

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 LocalStreamEnvironmentITCase#testRunIsola

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

2017-08-25 Thread Nico Kruber (JIRA)
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] [Commented] (FLINK-7517) let NettyBufferPool extend PooledByteBufAllocator

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

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

2017-08-25 Thread NicoK
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 bu

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

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

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

2017-08-25 Thread NicoK
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 `Byte

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

2017-08-25 Thread Sumit Sarin (JIRA)
[ 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] [Updated] (FLINK-7516) HybridMemorySegment: do not allow copies into a read-only ByteBuffer

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 {{ByteB

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

2017-08-25 Thread NicoK
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 c

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

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

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

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

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

2017-08-25 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141548#comment-16141548 ] Aljoscha Krettek commented on FLINK-7429: - Implemented on master in c384e52e647da4

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

2017-08-25 Thread aljoscha
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 repl

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

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141546#comment-16141546 ] ASF GitHub Bot commented on FLINK-7514: --- GitHub user NicoK opened a pull request:

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

2017-08-25 Thread NicoK
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

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

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141543#comment-16141543 ] ASF GitHub Bot commented on FLINK-7513: --- GitHub user NicoK opened a pull request:

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

2017-08-25 Thread NicoK
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] [Updated] (FLINK-7450) Bounded generic POJO field is identified as Object by TypeExtractor

2017-08-25 Thread Aljoscha Krettek (JIRA)
[ 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 TypeExtract

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

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141530#comment-16141530 ] ASF GitHub Bot commented on FLINK-7522: --- GitHub user tillrohrmann opened a pull requ

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

2017-08-25 Thread tillrohrmann
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 allo

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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: do

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

2017-08-25 Thread Till Rohrmann (JIRA)
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: Improve

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

2017-08-25 Thread Kostas Kloudas (JIRA)
[ 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 stat

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

2017-08-25 Thread Kostas Kloudas (JIRA)
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] [Closed] (FLINK-7512) avoid unnecessary buffer copies during network serialization

2017-08-25 Thread Nico Kruber (JIRA)
[ 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-7520) let our Buffer class extend from netty's buffer class

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 netty's

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 instances

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 PooledByteBuf

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 Po

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 f

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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()

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 NettyMe

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 content

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 c

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 TestBufferFactory#MOCK

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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-7499) double buffer release in SpillableSubpartitionView

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 SpillableSubpar

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 BackPressureStatsTrackerI

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 re

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 relea

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 Spil

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 PartitionRequestPro

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 c

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 NettyMessage.TaskEventRequest#r

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 NettyMessage.TaskEve

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 improvement

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 NettyM

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

2017-08-25 Thread Nico Kruber (JIRA)
[ 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 flink/co

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

2017-08-25 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16141510#comment-16141510 ] ASF GitHub Bot commented on FLINK-7519: --- GitHub user tillrohrmann opened a pull requ

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

2017-08-25 Thread tillrohrmann
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. Thi

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

2017-08-25 Thread Nico Kruber (JIRA)
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: S

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

2017-08-25 Thread Till Rohrmann (JIRA)
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:

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

2017-08-25 Thread Nico Kruber (JIRA)
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] [Created] (FLINK-7517) let NettyBufferPool extend PooledByteBufAllocator

2017-08-25 Thread Nico Kruber (JIRA)
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: Sub-t

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

2017-08-25 Thread Nico Kruber (JIRA)
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 Iss

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

2017-08-25 Thread Nico Kruber (JIRA)
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 Iss

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

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

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

2017-08-25 Thread kl0u
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 no

  1   2   >