[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

2020-04-29 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096144#comment-17096144 ] Nico Kruber commented on FLINK-16850: - The first commit needs to go into the Apache git, only after

[jira] [Closed] (FLINK-17432) Rename Tutorials to Training

2020-04-28 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17432. --- Resolution: Fixed merged to {{master}} via c955eb3 > Rename Tutorials to Training >

[jira] [Closed] (FLINK-17316) Have HourlyTips solutions use TumblingEventTimeWindows.of

2020-04-22 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17316. --- Fix Version/s: 1.11.0 1.10.1 Resolution: Fixed Merged to flink-training:

[jira] [Closed] (FLINK-17279) Use gradle build scans for training exercises

2020-04-21 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17279. --- Resolution: Fixed merged into flink-training: * {{master}}: 679eba0 * release-1.10: 3de0d22 >

[jira] [Closed] (FLINK-17278) Add Travis to the training exercises

2020-04-21 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17278. --- Resolution: Fixed merged into flink-training: * {{master}}: 122d56c * release-1.10: 122d56c >

[jira] [Closed] (FLINK-17277) Apply IntelliJ recommendations to training exercises

2020-04-21 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17277. --- Resolution: Fixed merged into flink-training: * {{master}}: b7bc718 * release-1.10: b7bc718 >

[jira] [Closed] (FLINK-17275) Add core training exercises

2020-04-21 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17275. --- Resolution: Fixed merged into flink-training: * {{master}}: a3071ca * release-1.10: a3071ca >

[jira] [Closed] (FLINK-17276) Add checkstyle to training exercises

2020-04-21 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17276. --- Resolution: Fixed merged into flink-training: * {{master}}: 6f9ddff * release-1.10: 6f9ddff >

[jira] [Commented] (FLINK-17287) Disable merge commit button

2020-04-21 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088485#comment-17088485 ] Nico Kruber commented on FLINK-17287: - - merged to flink-training {{master}} via

[jira] [Created] (FLINK-17293) Port training exercises data sets to a generator

2020-04-21 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-17293: --- Summary: Port training exercises data sets to a generator Key: FLINK-17293 URL: https://issues.apache.org/jira/browse/FLINK-17293 Project: Flink Issue Type:

[jira] [Commented] (FLINK-17279) Use gradle build scans for training exercises

2020-04-20 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17087996#comment-17087996 ] Nico Kruber commented on FLINK-17279: - Both have been newly added - not sure whether "Documentation

[jira] [Commented] (FLINK-17278) Add Travis to the training exercises

2020-04-20 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17087918#comment-17087918 ] Nico Kruber commented on FLINK-17278: - I think, the requirements are a bit different here, but if we

[jira] [Created] (FLINK-17279) Use gradle build scans

2020-04-20 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-17279: --- Summary: Use gradle build scans Key: FLINK-17279 URL: https://issues.apache.org/jira/browse/FLINK-17279 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17278) Add Travis to the training exercises

2020-04-20 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-17278: --- Summary: Add Travis to the training exercises Key: FLINK-17278 URL: https://issues.apache.org/jira/browse/FLINK-17278 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-17276) Add checkstyle to training exercises

2020-04-20 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-17276: Affects Version/s: (was: 1.11.0) (was: 1.10.0) > Add checkstyle to

[jira] [Updated] (FLINK-17275) Add core training exercises

2020-04-20 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-17275: Affects Version/s: (was: 1.11.0) > Add core training exercises > ---

[jira] [Created] (FLINK-17277) Apply IntelliJ recommendations to training exercises

2020-04-20 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-17277: --- Summary: Apply IntelliJ recommendations to training exercises Key: FLINK-17277 URL: https://issues.apache.org/jira/browse/FLINK-17277 Project: Flink Issue

[jira] [Created] (FLINK-17276) Add checkstyle to training exercises

2020-04-20 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-17276: --- Summary: Add checkstyle to training exercises Key: FLINK-17276 URL: https://issues.apache.org/jira/browse/FLINK-17276 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17275) Add core training exercises

2020-04-20 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-17275: --- Summary: Add core training exercises Key: FLINK-17275 URL: https://issues.apache.org/jira/browse/FLINK-17275 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

2020-04-15 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-16662: Priority: Blocker (was: Major) > Blink Planner failed to generate JobGraph for POJO DataStream

[jira] [Closed] (FLINK-17171) Blink planner fails to compile Table program with POJO source

2020-04-15 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17171. --- Resolution: Duplicate > Blink planner fails to compile Table program with POJO source >

[jira] [Created] (FLINK-17171) Blink planner fails to compile Table program with POJO source

2020-04-15 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-17171: --- Summary: Blink planner fails to compile Table program with POJO source Key: FLINK-17171 URL: https://issues.apache.org/jira/browse/FLINK-17171 Project: Flink

[jira] [Commented] (FLINK-17143) Blog feed.xml should only contain excerpts, not full contents

2020-04-14 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083547#comment-17083547 ] Nico Kruber commented on FLINK-17143: - I wasn't aware of such use case. I mainly use feeds in

[jira] [Created] (FLINK-17143) Blog feed.xml should only contain excerpts, not full contents

2020-04-14 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-17143: --- Summary: Blog feed.xml should only contain excerpts, not full contents Key: FLINK-17143 URL: https://issues.apache.org/jira/browse/FLINK-17143 Project: Flink

[jira] [Closed] (FLINK-17056) JMH main() methods call unrelated benchmarks

2020-04-09 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17056. --- Resolution: Fixed merged to master via

[jira] [Created] (FLINK-17057) Add OpenSSL micro-benchmarks

2020-04-08 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-17057: --- Summary: Add OpenSSL micro-benchmarks Key: FLINK-17057 URL: https://issues.apache.org/jira/browse/FLINK-17057 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-17056) JMH main() methods call unrelated benchmarks

2020-04-08 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-17056: Description: Each benchmark class is accompanied by an according {{public static main (String[]

[jira] [Created] (FLINK-17056) JMH main() methods call unrelated benchmarks

2020-04-08 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-17056: --- Summary: JMH main() methods call unrelated benchmarks Key: FLINK-17056 URL: https://issues.apache.org/jira/browse/FLINK-17056 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-16890) Add AvroGeneric benchmark

2020-04-02 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-16890. --- Fix Version/s: 1.11.0 Resolution: Fixed fixed via

[jira] [Updated] (FLINK-16890) Add AvroGeneric benchmark

2020-03-31 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-16890: Labels: pull-request-available (was: ) > Add AvroGeneric benchmark > - >

[jira] [Created] (FLINK-16890) Add AvroGeneric benchmark

2020-03-31 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-16890: --- Summary: Add AvroGeneric benchmark Key: FLINK-16890 URL: https://issues.apache.org/jira/browse/FLINK-16890 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-12577) Flink uses Kryo serializer if given a SpecificRecord type

2020-03-31 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071970#comment-17071970 ] Nico Kruber commented on FLINK-12577: - Actually, I'm not sure the description above matched when I

[jira] [Updated] (FLINK-12577) Flink uses Kryo serializer if given a SpecificRecord type

2020-03-31 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-12577: Affects Version/s: 1.10.0 > Flink uses Kryo serializer if given a SpecificRecord type >

[jira] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

2020-03-31 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071770#comment-17071770 ] Nico Kruber commented on FLINK-16850: - I would actually support at least creating (light-weight)

[jira] [Created] (FLINK-16729) Offer an out-of-the-box Set serializer

2020-03-23 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-16729: --- Summary: Offer an out-of-the-box Set serializer Key: FLINK-16729 URL: https://issues.apache.org/jira/browse/FLINK-16729 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-16460) Add Serialization benchmark for Protobuf

2020-03-23 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-16460. --- Fix Version/s: 1.11.0 Resolution: Fixed merged to flink-benchmarks as

[jira] [Resolved] (FLINK-16459) Add Serialization benchmark for Apache Thrift

2020-03-23 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-16459. - Fix Version/s: 1.11.0 Resolution: Fixed merged to flink-benchmarks as

[jira] [Closed] (FLINK-16459) Add Serialization benchmark for Apache Thrift

2020-03-23 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-16459. --- > Add Serialization benchmark for Apache Thrift > - > >

[jira] [Commented] (FLINK-16468) BlobClient rapid retrieval retries on failure opens too many sockets

2020-03-23 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17064685#comment-17064685 ] Nico Kruber commented on FLINK-16468: - Actually, [~gjy] had a good point bringing in the task's

[jira] [Created] (FLINK-16664) Unable to set DataStreamSource parallelism to default (-1)

2020-03-18 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-16664: --- Summary: Unable to set DataStreamSource parallelism to default (-1) Key: FLINK-16664 URL: https://issues.apache.org/jira/browse/FLINK-16664 Project: Flink

[jira] [Resolved] (FLINK-11774) Unstable hashCode causes IllegalArgumentException in HeapPriorityQueueSet

2020-03-17 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-11774. - Fix Version/s: (was: 1.10.1) (was: 1.9.3)

[jira] [Commented] (FLINK-6764) Deduplicate stateless TypeSerializers when serializing composite TypeSerializers

2020-03-16 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060376#comment-17060376 ] Nico Kruber commented on FLINK-6764: [~tzulitai] any updates? > Deduplicate stateless

[jira] [Commented] (FLINK-6763) Inefficient PojoSerializerConfigSnapshot serialization format

2020-03-16 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17060374#comment-17060374 ] Nico Kruber commented on FLINK-6763: [~tzulitai] given that you had a PR for this a while back and it

[jira] [Updated] (FLINK-16468) BlobClient rapid retrieval retries on failure opens too many sockets

2020-03-13 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-16468: Affects Version/s: 1.8.3 1.10.0 > BlobClient rapid retrieval retries on

[jira] [Commented] (FLINK-16576) State inconsistency on restore with memory state backends

2020-03-13 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058566#comment-17058566 ] Nico Kruber commented on FLINK-16576: - Both actually: {{MemoryStateBackend}} as well as

[jira] [Commented] (FLINK-10742) Let Netty use Flink's buffers directly in credit-based mode

2020-03-13 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058497#comment-17058497 ] Nico Kruber commented on FLINK-10742: - [~zjwang] I'm not sure, but since the reported memory usage

[jira] [Updated] (FLINK-11774) Unstable hashCode causes IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11774: Component/s: API / DataStream > Unstable hashCode causes IllegalArgumentException in

[jira] [Updated] (FLINK-16555) Preflight check for known unstable hashCodes.

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-16555: Component/s: API / Type Serialization System > Preflight check for known unstable hashCodes. >

[jira] [Updated] (FLINK-11774) Unstable hashCode causes IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11774: Priority: Major (was: Blocker) > Unstable hashCode causes IllegalArgumentException in

[jira] [Updated] (FLINK-11774) Unstable hashCode causes IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11774: Component/s: (was: Runtime / State Backends) API / Type Serialization System

[jira] [Commented] (FLINK-11774) Unstable hashCode causes IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058262#comment-17058262 ] Nico Kruber commented on FLINK-11774: - Since the original post was using this object as its key:

[jira] [Updated] (FLINK-11774) Unstable hashCode causes IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11774: Summary: Unstable hashCode causes IllegalArgumentException in HeapPriorityQueueSet (was:

[jira] [Issue Comment Deleted] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11774: Comment: was deleted (was: I narrowed it down to the state access inside {{DeltaTrigger}}:

[jira] [Issue Comment Deleted] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11774: Comment: was deleted (was: There are actually two bugs here: * enums not being viable sources

[jira] [Issue Comment Deleted] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11774: Comment: was deleted (was: I actually occasionally also see this with the {{TopSpeedWindowing}}

[jira] [Comment Edited] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058254#comment-17058254 ] Nico Kruber edited comment on FLINK-11774 at 3/12/20, 9:39 PM: --- Ok, after

[jira] [Created] (FLINK-16576) State inconsistency on restore with memory state backends

2020-03-12 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-16576: --- Summary: State inconsistency on restore with memory state backends Key: FLINK-16576 URL: https://issues.apache.org/jira/browse/FLINK-16576 Project: Flink

[jira] [Commented] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17058254#comment-17058254 ] Nico Kruber commented on FLINK-11774: - Ok, after looking at the OP's code and the other occasions, I

[jira] [Commented] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057809#comment-17057809 ] Nico Kruber commented on FLINK-11774: - I narrowed it down to the state access inside

[jira] [Updated] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11774: Affects Version/s: 1.9.2 1.10.0 > IllegalArgumentException in

[jira] [Comment Edited] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057748#comment-17057748 ] Nico Kruber edited comment on FLINK-11774 at 3/12/20, 9:32 AM: --- There are

[jira] [Commented] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057748#comment-17057748 ] Nico Kruber commented on FLINK-11774: - There are actually two bugs here: * enums not being viable

[jira] [Assigned] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-11774: --- Assignee: (was: Nico Kruber) > IllegalArgumentException in HeapPriorityQueueSet >

[jira] [Assigned] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

2020-03-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-11774: --- Assignee: Nico Kruber > IllegalArgumentException in HeapPriorityQueueSet >

[jira] [Created] (FLINK-16556) TopSpeedWindowing should implement checkpointing for its source

2020-03-11 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-16556: --- Summary: TopSpeedWindowing should implement checkpointing for its source Key: FLINK-16556 URL: https://issues.apache.org/jira/browse/FLINK-16556 Project: Flink

[jira] [Commented] (FLINK-16550) HadoopS3* tests fail with NullPointerException exceptions

2020-03-11 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057449#comment-17057449 ] Nico Kruber commented on FLINK-16550: - This actually also showed up in an end-to-end Flink cluster

[jira] [Commented] (FLINK-11774) IllegalArgumentException in HeapPriorityQueueSet

2020-03-11 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17057377#comment-17057377 ] Nico Kruber commented on FLINK-11774: - I actually occasionally also see this with the

[jira] [Commented] (FLINK-16468) BlobClient rapid retrieval retries on failure opens too many sockets

2020-03-11 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056755#comment-17056755 ] Nico Kruber commented on FLINK-16468: - Hi [~longtimer], I verified in the code that the sockets

[jira] [Created] (FLINK-16461) Multiple Bindings with SLF4J

2020-03-06 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-16461: --- Summary: Multiple Bindings with SLF4J Key: FLINK-16461 URL: https://issues.apache.org/jira/browse/FLINK-16461 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-16460) Add Serialization benchmark for Protobuf

2020-03-06 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-16460: Labels: pull-request-available (was: ) > Add Serialization benchmark for Protobuf >

[jira] [Updated] (FLINK-16459) Add Serialization benchmark for Apache Thrift

2020-03-06 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-16459: Labels: pull-request-available (was: ) > Add Serialization benchmark for Apache Thrift >

[jira] [Created] (FLINK-16460) Add Serialization benchmark for Protobuf

2020-03-06 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-16460: --- Summary: Add Serialization benchmark for Protobuf Key: FLINK-16460 URL: https://issues.apache.org/jira/browse/FLINK-16460 Project: Flink Issue Type: New

[jira] [Created] (FLINK-16459) Add Serialization benchmark for Apache Thrift

2020-03-06 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-16459: --- Summary: Add Serialization benchmark for Apache Thrift Key: FLINK-16459 URL: https://issues.apache.org/jira/browse/FLINK-16459 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-15747) Enable setting RocksDB log level from configuration

2020-03-03 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050200#comment-17050200 ] Nico Kruber commented on FLINK-15747: - actually, [~liyu], I think, once

[jira] [Commented] (FLINK-15747) Enable setting RocksDB log level from configuration

2020-02-27 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17046395#comment-17046395 ] Nico Kruber commented on FLINK-15747: - Yes, for those scenarios, it may make sense to simplify

[jira] [Created] (FLINK-16301) Annoying "Cannot find FunctionDefinition" messages with SQL for f_proctime or =

2020-02-27 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-16301: --- Summary: Annoying "Cannot find FunctionDefinition" messages with SQL for f_proctime or = Key: FLINK-16301 URL: https://issues.apache.org/jira/browse/FLINK-16301

[jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException"

2020-02-25 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17045220#comment-17045220 ] Nico Kruber commented on FLINK-8093: Sorry [~bdine] for not seeing your message. I assigned this

[jira] [Assigned] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException"

2020-02-25 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-8093: -- Assignee: Bastien DINE > flink job fail because of kafka producer create fail of >

[jira] [Commented] (FLINK-16282) Wrong exception using DESCRIBE SQL command

2020-02-25 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17045216#comment-17045216 ] Nico Kruber commented on FLINK-16282: - Yes, this ticket is about the error message from trying to

[jira] [Created] (FLINK-16282) Wrong exception using DESCRIBE SQL command

2020-02-25 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-16282: --- Summary: Wrong exception using DESCRIBE SQL command Key: FLINK-16282 URL: https://issues.apache.org/jira/browse/FLINK-16282 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-16009) Native support for the Variable-length and Zig-zag Variable-length integers

2020-02-24 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043640#comment-17043640 ] Nico Kruber commented on FLINK-16009: - FYI: [~rgrebennikov] presented his take on this in a

[jira] [Comment Edited] (FLINK-13793) Build different language docs in parallel

2020-02-13 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036109#comment-17036109 ] Nico Kruber edited comment on FLINK-13793 at 2/13/20 10:21 AM: --- Fixed in

[jira] [Closed] (FLINK-13793) Build different language docs in parallel

2020-02-13 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-13793. --- > Build different language docs in parallel > - > >

[jira] [Resolved] (FLINK-13793) Build different language docs in parallel

2020-02-13 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-13793. - Fix Version/s: 1.11.0 Resolution: Fixed Fixed in master via

[jira] [Resolved] (FLINK-10971) Dependency convergence issue when building flink-s3-fs-presto

2020-02-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-10971. - Resolution: Workaround I actually just ran into this as well and also noticed that the created

[jira] [Updated] (FLINK-15010) Temp directories flink-netty-shuffle-* are not cleaned up

2020-02-06 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-15010: Issue Type: Bug (was: Improvement) > Temp directories flink-netty-shuffle-* are not cleaned up >

[jira] [Resolved] (FLINK-15863) Fix docs stating that savepoints are relocatable

2020-02-05 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-15863. - Fix Version/s: 1.9.3 1.8.4 Resolution: Fixed Fixed via: * master:

[jira] [Commented] (FLINK-15903) Make REST port configurable in end to end test scripts

2020-02-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029905#comment-17029905 ] Nico Kruber commented on FLINK-15903: - A random port may fail every so often, a fixed port is

[jira] [Commented] (FLINK-15863) Fix docs stating that savepoints are relocatable

2020-02-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029711#comment-17029711 ] Nico Kruber commented on FLINK-15863: - sure, I can do it, then please create a PR [~bdine] and I'll

[jira] [Assigned] (FLINK-15863) Fix docs stating that savepoints are relocatable

2020-02-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-15863: --- Assignee: Bastien DINE > Fix docs stating that savepoints are relocatable >

[jira] [Comment Edited] (FLINK-15863) Fix docs stating that savepoints are relocatable

2020-02-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029675#comment-17029675 ] Nico Kruber edited comment on FLINK-15863 at 2/4/20 9:24 AM: - What do you

[jira] [Commented] (FLINK-15863) Fix docs stating that savepoints are relocatable

2020-02-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17029675#comment-17029675 ] Nico Kruber commented on FLINK-15863: - What do you think about this? (I could also create a small PR

[jira] [Created] (FLINK-15863) Fix docs stating that savepoints are relocatable

2020-02-03 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-15863: --- Summary: Fix docs stating that savepoints are relocatable Key: FLINK-15863 URL: https://issues.apache.org/jira/browse/FLINK-15863 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-15814) Log warning when StreamingFileSink is used with bulk output formats and an ambiguous S3 scheme

2020-01-30 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-15814: --- Assignee: Seth Wiesman > Log warning when StreamingFileSink is used with bulk output

[jira] [Created] (FLINK-15753) Show non-numeric metrics in Web UI

2020-01-24 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-15753: --- Summary: Show non-numeric metrics in Web UI Key: FLINK-15753 URL: https://issues.apache.org/jira/browse/FLINK-15753 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15752) Backpressure stats sometimes broken in WebUI

2020-01-24 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-15752: --- Summary: Backpressure stats sometimes broken in WebUI Key: FLINK-15752 URL: https://issues.apache.org/jira/browse/FLINK-15752 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-15603) Show checkpoint start delay in checkpoint statistics

2020-01-24 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022973#comment-17022973 ] Nico Kruber commented on FLINK-15603: - nice new visualization (y) > Show checkpoint start delay in

[jira] [Commented] (FLINK-15747) Enable setting RocksDB log level from configuration

2020-01-24 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022958#comment-17022958 ] Nico Kruber commented on FLINK-15747: - I'm not so sure about making this configurable as the use

[jira] [Commented] (FLINK-15068) Disable RocksDB's local LOG by default

2020-01-24 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17022957#comment-17022957 ] Nico Kruber commented on FLINK-15068: - Thanks for adding the release note, this is probably good to

[jira] [Updated] (FLINK-15298) Wrong dependencies in the DataStream API tutorial (the wiki-edits example)

2020-01-20 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-15298: Summary: Wrong dependencies in the DataStream API tutorial (the wiki-edits example) (was: Wrong

<    1   2   3   4   5   6   7   8   9   10   >