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

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602656#comment-16602656 ] vinoyang commented on FLINK-10114: -- [~mingleizhang] OK, I will try to implement this fe

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

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10114: Assignee: vinoyang > Support Orc for StreamingFileSink > - > >

[GitHub] TisonKun commented on issue #6643: [FLINK-10275] StreamTask support object reuse

TisonKun commented on issue #6643: [FLINK-10275] StreamTask support object reuse URL: https://github.com/apache/flink/pull/6643#issuecomment-418236948 This pull request would affect reusing of object from network, according to [FLIP-21](https://cwiki.apache.org/confluence/pages/viewpage.act

[jira] [Commented] (FLINK-10275) StreamTask support object reuse

[ https://issues.apache.org/jira/browse/FLINK-10275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602588#comment-16602588 ] ASF GitHub Bot commented on FLINK-10275: TisonKun commented on issue #6643: [FLI

[jira] [Commented] (FLINK-8500) Get the timestamp of the Kafka message from kafka consumer(Kafka010Fetcher)

[ https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602584#comment-16602584 ] ASF GitHub Bot commented on FLINK-8500: --- alexeyt820 commented on issue #6105: [FLIN

[GitHub] alexeyt820 commented on issue #6105: [FLINK-8500] Get the timestamp of the Kafka message from kafka consumer

alexeyt820 commented on issue #6105: [FLINK-8500] Get the timestamp of the Kafka message from kafka consumer URL: https://github.com/apache/flink/pull/6105#issuecomment-418235101 FYI, I have added deserialize with “Record” parameter to my PR

[jira] [Updated] (FLINK-9824) Support IPv6 literal

[ https://issues.apache.org/jira/browse/FLINK-9824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-9824: -- Description: Currently we use colon as separator when parsing host and port. We should support the usage of IP

[jira] [Comment Edited] (FLINK-9735) Potential resource leak in RocksDBStateBackend#getDbOptions

[ https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16559975#comment-16559975 ] Ted Yu edited comment on FLINK-9735 at 9/4/18 3:27 AM: --- Thanks, Vin

[jira] [Commented] (FLINK-10125) Unclosed ByteArrayDataOutputView in RocksDBMapState

[ https://issues.apache.org/jira/browse/FLINK-10125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602577#comment-16602577 ] Ted Yu commented on FLINK-10125: bq. we keep it under try/with/resources +1 > Unclose

[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602548#comment-16602548 ] ASF GitHub Bot commented on FLINK-10261: hequn8128 commented on a change in pull

[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602550#comment-16602550 ] ASF GitHub Bot commented on FLINK-10261: hequn8128 commented on a change in pull

[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602549#comment-16602549 ] ASF GitHub Bot commented on FLINK-10261: hequn8128 commented on a change in pull

[GitHub] hequn8128 commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by

hequn8128 commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by URL: https://github.com/apache/flink/pull/6648#discussion_r214773263 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCas

[GitHub] hequn8128 commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by

hequn8128 commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by URL: https://github.com/apache/flink/pull/6648#discussion_r214773258 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/sql/validation/I

[GitHub] hequn8128 commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by

hequn8128 commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by URL: https://github.com/apache/flink/pull/6648#discussion_r214773269 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SqlITCas

[jira] [Created] (FLINK-10279) Better clarification for status

Thomas Weise created FLINK-10279: Summary: Better clarification for status Key: FLINK-10279 URL: https://issues.apache.org/jira/browse/FLINK-10279 Project: Flink Issue Type: Task Co

[jira] [Closed] (FLINK-10278) Flink in YARN cluster uses wrong path when looking for Kerberos Keytab

[ https://issues.apache.org/jira/browse/FLINK-10278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben La Monica closed FLINK-10278. - Resolution: Fixed It appears that this was fixed as part of FLINK-10013. Closing. > Flink in YA

[jira] [Commented] (FLINK-10050) Support 'allowedLateness' in CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-10050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602400#comment-16602400 ] ASF GitHub Bot commented on FLINK-10050: EugeneYushin commented on issue #6646:

[jira] [Updated] (FLINK-10278) Flink in YARN cluster uses wrong path when looking for Kerberos Keytab

[ https://issues.apache.org/jira/browse/FLINK-10278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben La Monica updated FLINK-10278: -- Fix Version/s: 1.5.3 > Flink in YARN cluster uses wrong path when looking for Kerberos Keytab

[GitHub] EugeneYushin commented on issue #6646: [FLINK-10050] Support allowedLateness in CoGroupedStreams

EugeneYushin commented on issue #6646: [FLINK-10050] Support allowedLateness in CoGroupedStreams URL: https://github.com/apache/flink/pull/6646#issuecomment-418175648 @aljoscha @tillrohrmann guys, please can you take a glance on it? -

[jira] [Commented] (FLINK-10278) Flink in YARN cluster uses wrong path when looking for Kerberos Keytab

[ https://issues.apache.org/jira/browse/FLINK-10278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602387#comment-16602387 ] Ben La Monica commented on FLINK-10278: --- It appears to already be fixed in 1.5.3.

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602386#comment-16602386 ] ASF GitHub Bot commented on FLINK-5315: --- walterddr commented on a change in pull re

[GitHub] walterddr commented on a change in pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream

walterddr commented on a change in pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream URL: https://github.com/apache/flink/pull/6521#discussion_r214744230 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flin

[jira] [Created] (FLINK-10278) Flink in YARN cluster uses wrong path when looking for Kerberos Keytab

Ben La Monica created FLINK-10278: - Summary: Flink in YARN cluster uses wrong path when looking for Kerberos Keytab Key: FLINK-10278 URL: https://issues.apache.org/jira/browse/FLINK-10278 Project: Fli

[jira] [Commented] (FLINK-10206) Add hbase sink connector

[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602287#comment-16602287 ] Shimin Yang commented on FLINK-10206: - [~hequn8128] Thanks for your advice, I have a

[jira] [Commented] (FLINK-5029) Implement KvState SSL

[ https://issues.apache.org/jira/browse/FLINK-5029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602170#comment-16602170 ] ASF GitHub Bot commented on FLINK-5029: --- StephanEwen commented on issue #6626: [FLI

[GitHub] StephanEwen commented on issue #6626: [FLINK-5029] [QueryableState] SSL Support

StephanEwen commented on issue #6626: [FLINK-5029] [QueryableState] SSL Support URL: https://github.com/apache/flink/pull/6626#issuecomment-418114906 Thanks for this big contribution! I have a few questions of the overall approach: - How does this work with repeated queries/lookups

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602163#comment-16602163 ] ASF GitHub Bot commented on FLINK-5315: --- hequn8128 commented on a change in pull re

[GitHub] hequn8128 commented on a change in pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream

hequn8128 commented on a change in pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream URL: https://github.com/apache/flink/pull/6521#discussion_r214681480 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flin

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602161#comment-16602161 ] ASF GitHub Bot commented on FLINK-5315: --- hequn8128 commented on a change in pull re

[GitHub] hequn8128 commented on a change in pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream

hequn8128 commented on a change in pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream URL: https://github.com/apache/flink/pull/6521#discussion_r214681480 ## File path: flink-libraries/flink-table/src/main/scala/org/apache/flin

[jira] [Updated] (FLINK-10150) Inconsistent number of "Records received" / "Records sent"

[ https://issues.apache.org/jira/browse/FLINK-10150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10150: - Fix Version/s: (was: 1.4.3) > Inconsistent number of "Records received" / "Records s

[jira] [Commented] (FLINK-10150) Inconsistent number of "Records received" / "Records sent"

[ https://issues.apache.org/jira/browse/FLINK-10150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602147#comment-16602147 ] ASF GitHub Bot commented on FLINK-10150: zentol opened a new pull request #6655:

[jira] [Commented] (FLINK-10150) Inconsistent number of "Records received" / "Records sent"

[ https://issues.apache.org/jira/browse/FLINK-10150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602146#comment-16602146 ] ASF GitHub Bot commented on FLINK-10150: zentol opened a new pull request #6654:

[GitHub] zentol opened a new pull request #6655: [1.6][FLINK-10150][metrics] Fix OperatorMetricGroup creation for Batch

zentol opened a new pull request #6655: [1.6][FLINK-10150][metrics] Fix OperatorMetricGroup creation for Batch URL: https://github.com/apache/flink/pull/6655 Back-port of #6599 for 1.6. This is an automated message from the A

[GitHub] zentol opened a new pull request #6654: [1.5][FLINK-10150][metrics] Fix OperatorMetricGroup creation for Batch

zentol opened a new pull request #6654: [1.5][FLINK-10150][metrics] Fix OperatorMetricGroup creation for Batch URL: https://github.com/apache/flink/pull/6654 Back-port of #6599 for 1.5. This is an automated message from the A

[jira] [Commented] (FLINK-10150) Inconsistent number of "Records received" / "Records sent"

[ https://issues.apache.org/jira/browse/FLINK-10150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602142#comment-16602142 ] ASF GitHub Bot commented on FLINK-10150: zentol closed pull request #6599: [FLIN

[GitHub] zentol closed pull request #6599: [FLINK-10150][metrics] Fix OperatorMetricGroup creation for Batch

zentol closed pull request #6599: [FLINK-10150][metrics] Fix OperatorMetricGroup creation for Batch URL: https://github.com/apache/flink/pull/6599 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: A

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602115#comment-16602115 ] ASF GitHub Bot commented on FLINK-5315: --- hequn8128 commented on a change in pull re

[GitHub] hequn8128 commented on a change in pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream

hequn8128 commented on a change in pull request #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream URL: https://github.com/apache/flink/pull/6521#discussion_r214677464 ## File path: docs/dev/table/tableApi.md ## @@ -381,6 +381,36 @

[GitHub] lamber-ken commented on issue #6647: [hotfix][docs] Fix error html tag in batch index documentatition

lamber-ken commented on issue #6647: [hotfix][docs] Fix error html tag in batch index documentatition URL: https://github.com/apache/flink/pull/6647#issuecomment-418098609 cc @zentol This is an automated message from the Apac

[GitHub] TisonKun commented on issue #6644: [hotfix] check correct parameter

TisonKun commented on issue #6644: [hotfix] check correct parameter URL: https://github.com/apache/flink/pull/6644#issuecomment-418095159 cc @tillrohrmann @twalthr This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-10115) Content-length limit is also applied to FileUploads

[ https://issues.apache.org/jira/browse/FLINK-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602062#comment-16602062 ] ASF GitHub Bot commented on FLINK-10115: zentol closed pull request #6650: [1.6]

[jira] [Commented] (FLINK-10115) Content-length limit is also applied to FileUploads

[ https://issues.apache.org/jira/browse/FLINK-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16602063#comment-16602063 ] ASF GitHub Bot commented on FLINK-10115: zentol closed pull request #6651: [1.5]

[GitHub] zentol closed pull request #6651: [1.5][FLINK-10115][rest] Ignore content-length limit for FileUploads

zentol closed pull request #6651: [1.5][FLINK-10115][rest] Ignore content-length limit for FileUploads URL: https://github.com/apache/flink/pull/6651 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance

[jira] [Closed] (FLINK-10115) Content-length limit is also applied to FileUploads

[ https://issues.apache.org/jira/browse/FLINK-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10115. Resolution: Fixed 1.5: 2dbed9bfa96c645e4d7a4e8166a76f78880f48d1 1.6: 994b18518fb1534f6a624

[GitHub] zentol closed pull request #6650: [1.6][FLINK-10115][rest] Ignore content-length limit for FileUploads

zentol closed pull request #6650: [1.6][FLINK-10115][rest] Ignore content-length limit for FileUploads URL: https://github.com/apache/flink/pull/6650 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance

[GitHub] lamber-ken removed a comment on issue #6647: [hotfix][docs] Fix error html tag in batch index documentatition

lamber-ken removed a comment on issue #6647: [hotfix][docs] Fix error html tag in batch index documentatition URL: https://github.com/apache/flink/pull/6647#issuecomment-418009418 @dawidwys hi, cc This is an automated message

[GitHub] zentol commented on issue #6625: [hotfix][docs] Fix some error about the example of stateful source function in state documentatition

zentol commented on issue #6625: [hotfix][docs] Fix some error about the example of stateful source function in state documentatition URL: https://github.com/apache/flink/pull/6625#issuecomment-418061827 It doesn't make any sense to add up offsets. I can see how the current example is flaw

[jira] [Commented] (FLINK-8914) CEP's greedy() modifier doesn't work

[ https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601943#comment-16601943 ] aitozi commented on FLINK-8914: --- Hi,[~alpinegizmo] & [~GuoLJ] Now It can be solved like th

[GitHub] zentol opened a new pull request #6653: [FLINK-10235][kafka] Explicitly cast custom partitioner classes

zentol opened a new pull request #6653: [FLINK-10235][kafka] Explicitly cast custom partitioner classes URL: https://github.com/apache/flink/pull/6653 This PR fixes a jdk9 incompatibility regarding generics. The method compilation fails on java 9 since the CONNECTOR_SINK_PARTITIONER_VALUE_

[jira] [Updated] (FLINK-10235) KafkaTableSourceSinkFactoryBase#getFlinkKafkaPartitioner does not compile with Java 9

[ https://issues.apache.org/jira/browse/FLINK-10235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10235: --- Labels: pull-request-available (was: ) > KafkaTableSourceSinkFactoryBase#getFlinkKafkaParti

[jira] [Commented] (FLINK-10235) KafkaTableSourceSinkFactoryBase#getFlinkKafkaPartitioner does not compile with Java 9

[ https://issues.apache.org/jira/browse/FLINK-10235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601940#comment-16601940 ] ASF GitHub Bot commented on FLINK-10235: zentol opened a new pull request #6653:

[jira] [Updated] (FLINK-10234) Lambda usage in FutureUtils is ambigouos with Java 9

[ https://issues.apache.org/jira/browse/FLINK-10234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10234: --- Labels: pull-request-available (was: ) > Lambda usage in FutureUtils is ambigouos with Java

[jira] [Commented] (FLINK-10234) Lambda usage in FutureUtils is ambigouos with Java 9

[ https://issues.apache.org/jira/browse/FLINK-10234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601935#comment-16601935 ] ASF GitHub Bot commented on FLINK-10234: zentol opened a new pull request #6652:

[GitHub] zentol opened a new pull request #6652: [FLINK-10234][runtime] Fix ambiguous lambda usage

zentol opened a new pull request #6652: [FLINK-10234][runtime] Fix ambiguous lambda usage URL: https://github.com/apache/flink/pull/6652 ## What is the purpose of the change This PR fixes a jdk9 incompatibility caused by lambdas. The problem is that the compiler cannot determine whe

[jira] [Commented] (FLINK-10115) Content-length limit is also applied to FileUploads

[ https://issues.apache.org/jira/browse/FLINK-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601930#comment-16601930 ] Chesnay Schepler commented on FLINK-10115: -- master: b01aff35ec133b028c390341ca2

[jira] [Updated] (FLINK-10115) Content-length limit is also applied to FileUploads

[ https://issues.apache.org/jira/browse/FLINK-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10115: - Affects Version/s: 1.7.0 1.5.1 > Content-length limit is also app

[jira] [Updated] (FLINK-10115) Content-length limit is also applied to FileUploads

[ https://issues.apache.org/jira/browse/FLINK-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10115: - Fix Version/s: 1.5.4 1.7.0 > Content-length limit is also applied to

[jira] [Closed] (FLINK-10186) Use ThreadLocalRandom in BufferSpiller constructor

[ https://issues.apache.org/jira/browse/FLINK-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10186. Resolution: Fixed Fix Version/s: 1.7.0 master: d216dc9803750050e8c9d369ad468c512511

[jira] [Updated] (FLINK-10186) Use ThreadLocalRandom in BufferSpiller constructor

[ https://issues.apache.org/jira/browse/FLINK-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10186: - Issue Type: Improvement (was: Bug) > Use ThreadLocalRandom in BufferSpiller constructor

[jira] [Assigned] (FLINK-10186) Use ThreadLocalRandom in BufferSpiller constructor

[ https://issues.apache.org/jira/browse/FLINK-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-10186: Assignee: Hiroaki Yoshida > Use ThreadLocalRandom in BufferSpiller constructor >

[jira] [Updated] (FLINK-10186) Use ThreadLocalRandom in BufferSpiller constructor

[ https://issues.apache.org/jira/browse/FLINK-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10186: - Affects Version/s: 1.7.0 > Use ThreadLocalRandom in BufferSpiller constructor >

[jira] [Updated] (FLINK-10186) se ThreadLocalRandom in BufferSpiller constructor

[ https://issues.apache.org/jira/browse/FLINK-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10186: - Summary: se ThreadLocalRandom in BufferSpiller constructor (was: FindBugs warnings: Ran

[jira] [Updated] (FLINK-10186) Use ThreadLocalRandom in BufferSpiller constructor

[ https://issues.apache.org/jira/browse/FLINK-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10186: - Summary: Use ThreadLocalRandom in BufferSpiller constructor (was: se ThreadLocalRandom

[GitHub] zentol closed pull request #6591: [FLINK-10186] Fix FindBugs warnings: Random object created and used o…

zentol closed pull request #6591: [FLINK-10186] Fix FindBugs warnings: Random object created and used o… URL: https://github.com/apache/flink/pull/6591 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenanc

[jira] [Commented] (FLINK-10186) FindBugs warnings: Random object created and used only once

[ https://issues.apache.org/jira/browse/FLINK-10186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601903#comment-16601903 ] ASF GitHub Bot commented on FLINK-10186: zentol closed pull request #6591: [FLIN

[GitHub] zentol commented on a change in pull request #6599: [FLINK-10150][metrics] Fix OperatorMetricGroup creation for Batch

zentol commented on a change in pull request #6599: [FLINK-10150][metrics] Fix OperatorMetricGroup creation for Batch URL: https://github.com/apache/flink/pull/6599#discussion_r214614670 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskMetricGro

[jira] [Commented] (FLINK-10150) Inconsistent number of "Records received" / "Records sent"

[ https://issues.apache.org/jira/browse/FLINK-10150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601901#comment-16601901 ] ASF GitHub Bot commented on FLINK-10150: zentol commented on a change in pull re

[jira] [Closed] (FLINK-7551) Add VERSION to the REST urls.

[ https://issues.apache.org/jira/browse/FLINK-7551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7551. --- Resolution: Fixed master: 14ae6e5df54d0855e414270c5c107839d0ee1c76 > Add VERSION to the REST

[GitHub] zentol closed pull request #6602: [FLINK-7551][rest] Add versioning to REST API

zentol closed pull request #6602: [FLINK-7551][rest] Add versioning to REST API URL: https://github.com/apache/flink/pull/6602 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign

[jira] [Commented] (FLINK-7551) Add VERSION to the REST urls.

[ https://issues.apache.org/jira/browse/FLINK-7551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601892#comment-16601892 ] ASF GitHub Bot commented on FLINK-7551: --- zentol closed pull request #6602: [FLINK-

[GitHub] zentol opened a new pull request #6651: [1.5][FLINK-10115][rest] Ignore content-length limit for FileUploads

zentol opened a new pull request #6651: [1.5][FLINK-10115][rest] Ignore content-length limit for FileUploads URL: https://github.com/apache/flink/pull/6651 Back-port of #6595 for 1.5 . This is an automated message from the A

[jira] [Commented] (FLINK-10115) Content-length limit is also applied to FileUploads

[ https://issues.apache.org/jira/browse/FLINK-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601890#comment-16601890 ] ASF GitHub Bot commented on FLINK-10115: zentol opened a new pull request #6651:

[GitHub] zentol opened a new pull request #6650: [1.6][FLINK-10115][rest] Ignore content-length limit for FileUploads

zentol opened a new pull request #6650: [1.6][FLINK-10115][rest] Ignore content-length limit for FileUploads URL: https://github.com/apache/flink/pull/6650 Back-port of #6595 for 1.6 . This is an automated message from the A

[jira] [Commented] (FLINK-10115) Content-length limit is also applied to FileUploads

[ https://issues.apache.org/jira/browse/FLINK-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601878#comment-16601878 ] ASF GitHub Bot commented on FLINK-10115: zentol opened a new pull request #6650:

[jira] [Commented] (FLINK-10115) Content-length limit is also applied to FileUploads

[ https://issues.apache.org/jira/browse/FLINK-10115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601875#comment-16601875 ] ASF GitHub Bot commented on FLINK-10115: zentol closed pull request #6595: [FLIN

[GitHub] zentol closed pull request #6595: [FLINK-10115][rest] Ignore content-length limit for file uploads

zentol closed pull request #6595: [FLINK-10115][rest] Ignore content-length limit for file uploads URL: https://github.com/apache/flink/pull/6595 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: A

[GitHub] zentol closed pull request #6645: [hotfix] Update deprecated parameters in WebOptions

zentol closed pull request #6645: [hotfix] Update deprecated parameters in WebOptions URL: https://github.com/apache/flink/pull/6645 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a f

[jira] [Commented] (FLINK-10256) Port legacy jobmanager test to FILP-6

[ https://issues.apache.org/jira/browse/FLINK-10256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16601838#comment-16601838 ] 陈梓立 commented on FLINK-10256: - Hi guys, I met a problem when porting JM failover case to FLI

[GitHub] maqingxiang opened a new pull request #6649: [hotfix][flink-connector-filesystem] modify typo in BucketingSink

maqingxiang opened a new pull request #6649: [hotfix][flink-connector-filesystem] modify typo in BucketingSink URL: https://github.com/apache/flink/pull/6649 ## What is the purpose of the change Modify the annotation in the BucketingSink.java of setPartSuffix() -