[jira] [Commented] (FLINK-4500) Cassandra sink can lose messages

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241624#comment-16241624 ] ASF GitHub Bot commented on FLINK-4500: --- Github user mcfongtw commented on the issue:

[GitHub] flink issue #4605: [FLINK-4500] [C* Connector] CassandraSinkBase implements ...

2017-11-06 Thread mcfongtw
Github user mcfongtw commented on the issue: https://github.com/apache/flink/pull/4605 Hi, @zentol, since there are some conflicts in this branch and a bit out of date from current master, I will rebase on this branch. However, I need to know if you are planning to review and merge

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241620#comment-16241620 ] ASF GitHub Bot commented on FLINK-7878: --- Github user shuai-xu commented on the issue:

[GitHub] flink issue #4911: [FLINK-7878] [api] make resource type extendible in Resou...

2017-11-06 Thread shuai-xu
Github user shuai-xu commented on the issue: https://github.com/apache/flink/pull/4911 @tillrohrmann, Yes, the Resource is a little too generic and prone to typos. However, the resource are various and closely related to the platform(YARN/MESOS), only a GPUResource and FPGAResource

[jira] [Closed] (FLINK-1317) Add a standalone version of the Flink Plan Visualizer to the Website

2017-11-06 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-1317. - Resolution: Won't Fix > Add a standalone version of the Flink Plan Visualizer to the Website >

[jira] [Closed] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout

2017-11-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-7590. --- Resolution: Won't Fix > Flink failed to flush and close the file system output stream for > checkpointing

[jira] [Comment Edited] (FLINK-7692) Support user-defined variables in Metrics

2017-11-06 Thread Wei-Che Wei (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16235098#comment-16235098 ] Wei-Che Wei edited comment on FLINK-7692 at 11/7/17 5:36 AM: - Hi [~Zentol] I

[jira] [Closed] (FLINK-1166) Add a QA bot to Flink that is testing pull requests

2017-11-06 Thread Hai Zhou UTC+8 (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 closed FLINK-1166. - Resolution: Fixed Assignee: Robert Metzger > Add a QA bot to Flink that is testing pull

[jira] [Comment Edited] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

2017-11-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241455#comment-16241455 ] Tzu-Li (Gordon) Tai edited comment on FLINK-8001 at 11/7/17 4:36 AM: -

[GitHub] flink issue #4826: [FLINK-7608][metric] Refactor latency statistics metric

2017-11-06 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/4826 ping @zentol ---

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241468#comment-16241468 ] ASF GitHub Bot commented on FLINK-7608: --- Github user yew1eb commented on the issue:

[jira] [Commented] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

2017-11-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241466#comment-16241466 ] Tzu-Li (Gordon) Tai commented on FLINK-8001: I don't think 1.3 isn't affected by this though.

[jira] [Comment Edited] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

2017-11-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241466#comment-16241466 ] Tzu-Li (Gordon) Tai edited comment on FLINK-8001 at 11/7/17 4:25 AM: -

[jira] [Comment Edited] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

2017-11-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241455#comment-16241455 ] Tzu-Li (Gordon) Tai edited comment on FLINK-8001 at 11/7/17 4:19 AM: -

[jira] [Commented] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

2017-11-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241455#comment-16241455 ] Tzu-Li (Gordon) Tai commented on FLINK-8001: Seems like we have to check that all the

[jira] [Assigned] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

2017-11-06 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-8001: -- Assignee: Tzu-Li (Gordon) Tai > Mark Kafka Consumer as idle if it doesn't have

[jira] [Commented] (FLINK-7856) Port JobVertexBackPressureHandler to REST endpoint

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241412#comment-16241412 ] ASF GitHub Bot commented on FLINK-7856: --- Github user zjureel commented on the issue:

[GitHub] flink issue #4893: [FLINK-7856][flip6] Port JobVertexBackPressureHandler to ...

2017-11-06 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4893 @tillrohrmann Thank you for you suggestions, and I think move these things to the `JobMaster` would be good. I think this issue could be fixed as follows: 1. Add `CompletableFuture

[jira] [Commented] (FLINK-7999) Variable Join Window Boundaries

2017-11-06 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241303#comment-16241303 ] Xingcan Cui commented on FLINK-7999: Hi [~sjwiesman], thanks for opening this. Could you give some

[GitHub] flink pull request #4964: [hotfix][docs] Add type for numLateRecordsDropped ...

2017-11-06 Thread yew1eb
GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/4964 [hotfix][docs] Add type for numLateRecordsDropped metric in documentation This "numLateRecordsDropped" metric missing type described in the document:

[jira] [Updated] (FLINK-7475) support update() in ListState

2017-11-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7475: Affects Version/s: 1.4.0 > support update() in ListState > - > >

[jira] [Commented] (FLINK-7475) support update() in ListState

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16241262#comment-16241262 ] ASF GitHub Bot commented on FLINK-7475: --- GitHub user bowenli86 opened a pull request:

[GitHub] flink pull request #4963: [FLINK-7475] [core][state backend] support update(...

2017-11-06 Thread bowenli86
GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/4963 [FLINK-7475] [core][state backend] support update() in ListState ## What is the purpose of the change If users want to update the list, they have to do two steps: ```java

[jira] [Updated] (FLINK-7475) support update() in ListState

2017-11-06 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-7475: Component/s: State Backends, Checkpointing > support update() in ListState > -

[GitHub] flink issue #4960: Update version to 1.5-SNAPSHOT

2017-11-06 Thread yew1eb
Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/4960 :clap: ---

[jira] [Created] (FLINK-8003) Support Calcite's ROW value constructor in Flink SQL

2017-11-06 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8003: - Summary: Support Calcite's ROW value constructor in Flink SQL Key: FLINK-8003 URL: https://issues.apache.org/jira/browse/FLINK-8003 Project: Flink Issue Type: New

[GitHub] flink pull request #4962: [FLINK-8002] [table] Fix join window boundary for ...

2017-11-06 Thread fhueske
GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/4962 [FLINK-8002] [table] Fix join window boundary for LESS_THAN and GREATER_THAN predicates. ## What is the purpose of the change Fix the computation of join window boundaries for LESS_THAN

[jira] [Commented] (FLINK-8002) Incorrect join window boundaries for LESS_THAN and GREATER_THAN predicates

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240842#comment-16240842 ] ASF GitHub Bot commented on FLINK-8002: --- GitHub user fhueske opened a pull request:

[jira] [Created] (FLINK-8002) Incorrect join window boundaries for LESS_THAN and GREATER_THAN predicates

2017-11-06 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8002: Summary: Incorrect join window boundaries for LESS_THAN and GREATER_THAN predicates Key: FLINK-8002 URL: https://issues.apache.org/jira/browse/FLINK-8002 Project:

[GitHub] flink issue #4960: Update version to 1.5-SNAPSHOT

2017-11-06 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4960 👍 ---

[jira] [Commented] (FLINK-4228) YARN artifact upload does not work with S3AFileSystem

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240749#comment-16240749 ] ASF GitHub Bot commented on FLINK-4228: --- Github user NicoK commented on the issue:

[GitHub] flink issue #4939: [FLINK-4228][yarn/s3a] fix yarn resource upload s3a defau...

2017-11-06 Thread NicoK
Github user NicoK commented on the issue: https://github.com/apache/flink/pull/4939 I addresses the PR comments in my latest commit but I will also have to adapt the S3 test to not use our S3 implementation and instead the one in the Hadoop version YARN uses. Stay tuned ;) ---

[jira] [Commented] (FLINK-7973) Fix service shading relocation for S3 file systems

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

[GitHub] flink pull request #4961: [FLINK-7973] fix shading and relocating Hhadoop fo...

2017-11-06 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/4961 [FLINK-7973] fix shading and relocating Hhadoop for the S3 filesystems ## What is the purpose of the change The current shading of the `flink-s3-fs-hadoop` and `flink-s3-fs-presto` projects

[GitHub] flink pull request #4960: Update version to 1.5-SNAPSHOT

2017-11-06 Thread aljoscha
GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/4960 Update version to 1.5-SNAPSHOT You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink update-1.5 Alternatively you can review and

[jira] [Commented] (FLINK-6022) Improve support for Avro GenericRecord

2017-11-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240735#comment-16240735 ] Stephan Ewen commented on FLINK-6022: - With the merged pull request, Avro Specific Records now

[jira] [Closed] (FLINK-7997) Avro should be always in the user code

2017-11-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-7997. --- > Avro should be always in the user code > -- > >

[jira] [Resolved] (FLINK-7997) Avro should be always in the user code

2017-11-06 Thread Stephan Ewen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-7997. - Resolution: Fixed Fixed in c85f15ead50e9961e284eef50e5dc569560db022 > Avro should be always in

[jira] [Created] (FLINK-8001) Mark Kafka Consumer as idle if it doesn't have partitions

2017-11-06 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-8001: --- Summary: Mark Kafka Consumer as idle if it doesn't have partitions Key: FLINK-8001 URL: https://issues.apache.org/jira/browse/FLINK-8001 Project: Flink

[GitHub] flink pull request #4959: private scope is changed to public to resolve acce...

2017-11-06 Thread vetriselvan1187
GitHub user vetriselvan1187 opened a pull request: https://github.com/apache/flink/pull/4959 private scope is changed to public to resolve access exception *Thank you very much for contributing to Apache Flink - we are happy that you want to help us improve Flink. To help the

[jira] [Commented] (FLINK-8000) Sort REST handler URLs in RestServerEndpoint

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240558#comment-16240558 ] ASF GitHub Bot commented on FLINK-8000: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #4958: [FLINK-8000] Sort Rest handler URLS in RestServerE...

2017-11-06 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4958 [FLINK-8000] Sort Rest handler URLS in RestServerEndpoint ## What is the purpose of the change Introduce special `RestHandlerUrlComparator` to sort REST URLs such that URLs with

[jira] [Created] (FLINK-8000) Sort REST handler URLs in RestServerEndpoint

2017-11-06 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8000: Summary: Sort REST handler URLs in RestServerEndpoint Key: FLINK-8000 URL: https://issues.apache.org/jira/browse/FLINK-8000 Project: Flink Issue Type:

[jira] [Created] (FLINK-7999) Variable Join Window Boundaries

2017-11-06 Thread Seth Wiesman (JIRA)
Seth Wiesman created FLINK-7999: --- Summary: Variable Join Window Boundaries Key: FLINK-7999 URL: https://issues.apache.org/jira/browse/FLINK-7999 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-7773) Test instability in UtilsTest#testYarnFlinkResourceManagerJobManagerLostLeadership

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240485#comment-16240485 ] ASF GitHub Bot commented on FLINK-7773: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #4957: [FLINK-7773] [tests] Move all mocking before testi...

2017-11-06 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4957 [FLINK-7773] [tests] Move all mocking before testing code in UtilsTest to avoid unfinished stubbing ## What is the purpose of the change Move all mocking code before the actual

[jira] [Commented] (FLINK-7986) Introduce FilterSetOpTransposeRule to Flink

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240466#comment-16240466 ] ASF GitHub Bot commented on FLINK-7986: --- GitHub user Xpray opened a pull request:

[jira] [Commented] (FLINK-7963) Add ability to call trigger savepoint on flink cluster shutdown

2017-11-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240467#comment-16240467 ] Aljoscha Krettek commented on FLINK-7963: - Let me think about that for a bit but we should

[GitHub] flink pull request #4956: [FLINK-7986][TableAPI & SQL] Introduce FilterSetOp...

2017-11-06 Thread Xpray
GitHub user Xpray opened a pull request: https://github.com/apache/flink/pull/4956 [FLINK-7986][TableAPI & SQL] Introduce FilterSetOpTransposeRule to Flink ## What is the purpose of the change Introduce FilterSetOpTransposeRule to Flink ## Brief

[jira] [Updated] (FLINK-7949) AsyncWaitOperator is not restarting when queue is full

2017-11-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7949: Priority: Critical (was: Major) > AsyncWaitOperator is not restarting when queue is full >

[jira] [Commented] (FLINK-6022) Improve support for Avro GenericRecord

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240443#comment-16240443 ] ASF GitHub Bot commented on FLINK-6022: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #4943: [FLINK-6022] [avro] Use Avro to serialize Avro in flight ...

2017-11-06 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4943 👍 Btw, now users have to manually depend on `flink-avro` in their projects where before they didn't necessarily have to, right? If yes, we should also put it in the release notes.

[jira] [Commented] (FLINK-6022) Improve support for Avro GenericRecord

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240442#comment-16240442 ] ASF GitHub Bot commented on FLINK-6022: --- Github user aljoscha commented on the issue:

[GitHub] flink issue #4943: [FLINK-6022] [avro] Use Avro to serialize Avro in flight ...

2017-11-06 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4943 I would suggest adding that last paragraph in the `release notes` field of FLINK-6022 so we don't forget about this. ---

[jira] [Assigned] (FLINK-6022) Improve support for Avro GenericRecord

2017-11-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-6022: --- Assignee: Stephan Ewen > Improve support for Avro GenericRecord >

[jira] [Updated] (FLINK-6022) Improve support for Avro GenericRecord

2017-11-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6022: Priority: Blocker (was: Major) > Improve support for Avro GenericRecord >

[jira] [Updated] (FLINK-6022) Improve support for Avro GenericRecord

2017-11-06 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6022: Fix Version/s: 1.4.0 > Improve support for Avro GenericRecord >

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

2017-11-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7515. -- Resolution: Fixed Fix Version/s: 1.4.0 Fixed via

[jira] [Resolved] (FLINK-7745) add tests for ensuring NetworkBufferPool overprovisioning behaviour

2017-11-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7745. -- Resolution: Fixed Fix Version/s: 1.4.0 Fixed via

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

2017-11-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7516. -- Resolution: Fixed Fix Version/s: 1.4.0 Fixed via

[jira] [Resolved] (FLINK-7701) IllegalArgumentException in Netty bootstrap with small memory state segment size

2017-11-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7701. -- Resolution: Fixed Fix Version/s: 1.4.0 Fixed via

[GitHub] flink pull request #4733: [FLINK-7701][network] really fix watermark configu...

2017-11-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4733 ---

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

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240431#comment-16240431 ] ASF GitHub Bot commented on FLINK-7515: --- Github user asfgit closed the pull request at:

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

2017-11-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4592 ---

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

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240430#comment-16240430 ] ASF GitHub Bot commented on FLINK-7516: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7745) add tests for ensuring NetworkBufferPool overprovisioning behaviour

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240429#comment-16240429 ] ASF GitHub Bot commented on FLINK-7745: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7701) IllegalArgumentException in Netty bootstrap with small memory state segment size

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240432#comment-16240432 ] ASF GitHub Bot commented on FLINK-7701: --- Github user asfgit closed the pull request at:

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

2017-11-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4593 ---

[GitHub] flink pull request #4758: [FLINK-7745][tests] add tests for ensuring Network...

2017-11-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4758 ---

[GitHub] flink pull request #4911: [FLINK-7878] [api] make resource type extendible i...

2017-11-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4911#discussion_r149098417 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java --- @@ -61,18 +79,17 @@ /** How many state size in

[GitHub] flink pull request #4911: [FLINK-7878] [api] make resource type extendible i...

2017-11-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4911#discussion_r149097234 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/operators/ResourceSpecTest.java --- @@ -0,0 +1,144 @@ +/* + * Licensed to the

[GitHub] flink pull request #4911: [FLINK-7878] [api] make resource type extendible i...

2017-11-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4911#discussion_r149096457 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/operators/ResourceSpecTest.java --- @@ -0,0 +1,144 @@ +/* + * Licensed to the

[GitHub] flink pull request #4911: [FLINK-7878] [api] make resource type extendible i...

2017-11-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4911#discussion_r149096221 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java --- @@ -183,17 +238,81 @@ public int hashCode() {

[GitHub] flink pull request #4911: [FLINK-7878] [api] make resource type extendible i...

2017-11-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4911#discussion_r149096402 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/operators/ResourceSpecTest.java --- @@ -0,0 +1,144 @@ +/* + * Licensed to the

[GitHub] flink pull request #4911: [FLINK-7878] [api] make resource type extendible i...

2017-11-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4911#discussion_r149096804 --- Diff: flink-core/src/test/java/org/apache/flink/api/common/operators/ResourceSpecTest.java --- @@ -0,0 +1,144 @@ +/* + * Licensed to the

[GitHub] flink pull request #4911: [FLINK-7878] [api] make resource type extendible i...

2017-11-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4911#discussion_r149098202 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java --- @@ -183,17 +238,81 @@ public int hashCode() {

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240410#comment-16240410 ] ASF GitHub Bot commented on FLINK-7878: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240412#comment-16240412 ] ASF GitHub Bot commented on FLINK-7878: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240409#comment-16240409 ] ASF GitHub Bot commented on FLINK-7878: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240411#comment-16240411 ] ASF GitHub Bot commented on FLINK-7878: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4911: [FLINK-7878] [api] make resource type extendible i...

2017-11-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4911#discussion_r149096169 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java --- @@ -183,17 +238,81 @@ public int hashCode() {

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240415#comment-16240415 ] ASF GitHub Bot commented on FLINK-7878: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #4911: [FLINK-7878] [api] make resource type extendible i...

2017-11-06 Thread tillrohrmann
Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/4911#discussion_r149096103 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java --- @@ -183,17 +238,81 @@ public int hashCode() {

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240414#comment-16240414 ] ASF GitHub Bot commented on FLINK-7878: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240407#comment-16240407 ] ASF GitHub Bot commented on FLINK-7878: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240408#comment-16240408 ] ASF GitHub Bot commented on FLINK-7878: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240413#comment-16240413 ] ASF GitHub Bot commented on FLINK-7878: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Updated] (FLINK-5513) Remove relocation of internal API classes

2017-11-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5513: Fix Version/s: (was: 1.4.0) 1.5.0 > Remove relocation of internal

[jira] [Commented] (FLINK-7990) Strange behavior when configuring Logback for logging

2017-11-06 Thread Teena K (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240404#comment-16240404 ] Teena K commented on FLINK-7990: I always restart the cluster after updating the jars in the lib folder.

[jira] [Updated] (FLINK-7726) Move marshalling testbases out of legacy namespace

2017-11-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7726: Description: The marshalling test bases currently reside under

[jira] [Updated] (FLINK-7878) Extend the resource type user can define in ResourceSpec

2017-11-06 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7878: - Issue Type: Improvement (was: Bug) > Extend the resource type user can define in ResourceSpec >

[jira] [Commented] (FLINK-7993) Kafka 08 curator shading pattern out-of-sync

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240393#comment-16240393 ] ASF GitHub Bot commented on FLINK-7993: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4953: [FLINK-7993][kafka] Sync curator shading patterns

2017-11-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4953 ---

[jira] [Closed] (FLINK-7993) Kafka 08 curator shading pattern out-of-sync

2017-11-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7993. --- Resolution: Fixed 1.4: 7978a174474fed8a3d8e6eecfdc13bb129745893 > Kafka 08 curator shading

[jira] [Commented] (FLINK-7993) Kafka 08 curator shading pattern out-of-sync

2017-11-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16240385#comment-16240385 ] ASF GitHub Bot commented on FLINK-7993: --- Github user zentol commented on the issue:

[GitHub] flink issue #4953: [FLINK-7993][kafka] Sync curator shading patterns

2017-11-06 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4953 merging. ---

[jira] [Updated] (FLINK-7009) dogstatsd mode in statsd reporter

2017-11-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7009: Fix Version/s: (was: 1.4.0) 1.5.0 > dogstatsd mode in statsd

[jira] [Updated] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

2017-11-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6900: Fix Version/s: (was: 1.3.3) (was: 1.4.0) 1.5.0

[jira] [Updated] (FLINK-6437) Move history server configuration to a separate file

2017-11-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6437: Fix Version/s: (was: 1.4.0) 1.5.0 > Move history server

[jira] [Updated] (FLINK-7341) Update code snippets in documentation

2017-11-06 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7341: Issue Type: Improvement (was: Sub-task) Parent: (was: FLINK-7242) > Update

  1   2   3   >