[jira] [Closed] (FLINK-8395) Create (derived) sliced Buffer class

[ https://issues.apache.org/jira/browse/FLINK-8395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-8395. -- Resolution: Fixed Fix Version/s: 1.5.0 Fixed via 665347cf867f0b807fe9d4787b5ef42b0581b510 > Crea

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

[ https://issues.apache.org/jira/browse/FLINK-7520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-7520. -- Resolution: Fixed Fix Version/s: 1.5.0 Fixed via 85bea23ace3133e1b2d239c4ee87270a201b9b6a > let

[jira] [Comment Edited] (FLINK-10317) Configure Metaspace size by default

[ https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16725939#comment-16725939 ] Nico Kruber edited comment on FLINK-10317 at 4/30/19 12:51 PM: ---

[jira] [Commented] (FLINK-10317) Configure Metaspace size by default

[ https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16830265#comment-16830265 ] Nico Kruber commented on FLINK-10317: - I'm actually unsure whether we should set a d

[jira] [Updated] (FLINK-11580) Provide a shaded netty-tcnative

[ https://issues.apache.org/jira/browse/FLINK-11580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-11580: Summary: Provide a shaded netty-tcnative (was: Provide a dynamically-linked netty-tc) > Provide

[jira] [Created] (FLINK-12446) Add documentation how to enable openSSL

Nico Kruber created FLINK-12446: --- Summary: Add documentation how to enable openSSL Key: FLINK-12446 URL: https://issues.apache.org/jira/browse/FLINK-12446 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-11580) Provide a shaded netty-tcnative

[ https://issues.apache.org/jira/browse/FLINK-11580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835587#comment-16835587 ] Nico Kruber commented on FLINK-11580: - Hi [~sunjincheng121], I talked to [~Zentol] a

[jira] [Commented] (FLINK-11580) Provide a shaded netty-tcnative

[ https://issues.apache.org/jira/browse/FLINK-11580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836491#comment-16836491 ] Nico Kruber commented on FLINK-11580: - Small update from my side: I was able to run

[jira] [Commented] (FLINK-9363) Bump Jackson version to 2.9.8

[ https://issues.apache.org/jira/browse/FLINK-9363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838483#comment-16838483 ] Nico Kruber commented on FLINK-9363: Thanks [~aloyszhang] for working on this. For th

[jira] [Commented] (FLINK-11580) Provide a shaded netty-tcnative

[ https://issues.apache.org/jira/browse/FLINK-11580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16838500#comment-16838500 ] Nico Kruber commented on FLINK-11580: - [~sunjincheng121] Sorry for the confusion: I

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

[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16805717#comment-16805717 ] Nico Kruber commented on FLINK-8093: Actually, that's not really a Kafka bug if they

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

[ 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 d

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

[ https://issues.apache.org/jira/browse/FLINK-15068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022957#comment-17022957 ] Nico Kruber commented on FLINK-15068: - Thanks for adding the release note, this is p

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

[ https://issues.apache.org/jira/browse/FLINK-15747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022958#comment-17022958 ] Nico Kruber commented on FLINK-15747: - I'm not so sure about making this configurabl

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

[ https://issues.apache.org/jira/browse/FLINK-15603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17022973#comment-17022973 ] Nico Kruber commented on FLINK-15603: - nice new visualization (y) > Show checkpoint

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

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] [Created] (FLINK-15753) Show non-numeric metrics in Web UI

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] [Assigned] (FLINK-15814) Log warning when StreamingFileSink is used with bulk output formats and an ambiguous S3 scheme

[ 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 format

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

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: Bu

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

[ https://issues.apache.org/jira/browse/FLINK-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029675#comment-17029675 ] Nico Kruber commented on FLINK-15863: - What do you think about this? (I could also c

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

[ https://issues.apache.org/jira/browse/FLINK-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029675#comment-17029675 ] Nico Kruber edited comment on FLINK-15863 at 2/4/20 9:24 AM: -

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

[ https://issues.apache.org/jira/browse/FLINK-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029711#comment-17029711 ] Nico Kruber commented on FLINK-15863: - sure, I can do it, then please create a PR [~

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

[ 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] [Commented] (FLINK-17706) Clarify licensing situation for flink-benchmarks

[ https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126503#comment-17126503 ] Nico Kruber commented on FLINK-17706: - Thanks. It looks like there is a new contrib

[jira] [Comment Edited] (FLINK-17706) Clarify licensing situation for flink-benchmarks

[ https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126503#comment-17126503 ] Nico Kruber edited comment on FLINK-17706 at 6/5/20, 8:01 AM:

[jira] [Closed] (FLINK-17706) Clarify licensing situation for flink-benchmarks

[ https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17706. --- Resolution: Fixed Merged via [dataArtisans/flink-benchmarks:master|https://github.com/dataArtisans/

[jira] [Closed] (FLINK-17705) Add rat license checks for flink-benchmarks

[ https://issues.apache.org/jira/browse/FLINK-17705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17705. --- Resolution: Fixed Merged via [dataArtisans/flink-benchmarks:master|https://github.com/dataArtisans/

[jira] [Closed] (FLINK-17281) Add existing flink-benchmarks code

[ https://issues.apache.org/jira/browse/FLINK-17281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17281. --- Fix Version/s: 1.11.0 Resolution: Fixed Done with https://github.com/apache/flink-benchmarks

[jira] [Assigned] (FLINK-17282) Add CI build for new flink-benchmarks repo

[ https://issues.apache.org/jira/browse/FLINK-17282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-17282: --- Assignee: Nico Kruber > Add CI build for new flink-benchmarks repo > --

[jira] [Commented] (FLINK-17282) Add CI build for new flink-benchmarks repo

[ https://issues.apache.org/jira/browse/FLINK-17282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126600#comment-17126600 ] Nico Kruber commented on FLINK-17282: - The repository already contains a {{.travis.y

[jira] [Commented] (FLINK-17282) Add CI build for new flink-benchmarks repo

[ https://issues.apache.org/jira/browse/FLINK-17282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126637#comment-17126637 ] Nico Kruber commented on FLINK-17282: - thanks - I already forgot what and how we did

[jira] [Closed] (FLINK-17282) Add CI build for new flink-benchmarks repo

[ https://issues.apache.org/jira/browse/FLINK-17282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17282. --- Resolution: Fixed > Add CI build for new flink-benchmarks repo > ---

[jira] [Assigned] (FLINK-18178) flink-training exercises don't build with Eclipse

[ https://issues.apache.org/jira/browse/FLINK-18178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-18178: --- Assignee: Nico Kruber > flink-training exercises don't build with Eclipse > ---

[jira] [Closed] (FLINK-18178) flink-training exercises don't build with Eclipse

[ https://issues.apache.org/jira/browse/FLINK-18178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-18178. --- Fix Version/s: 1.11.0 Resolution: Fixed Fixed in master via 163558d39b > flink-training exer

[jira] [Created] (FLINK-18241) Custom OptionsFactory in user code not working when configured via flink-conf.yaml

Nico Kruber created FLINK-18241: --- Summary: Custom OptionsFactory in user code not working when configured via flink-conf.yaml Key: FLINK-18241 URL: https://issues.apache.org/jira/browse/FLINK-18241 Proj

[jira] [Created] (FLINK-18242) Custom OptionsFactory in user code not working when configured via code

Nico Kruber created FLINK-18242: --- Summary: Custom OptionsFactory in user code not working when configured via code Key: FLINK-18242 URL: https://issues.apache.org/jira/browse/FLINK-18242 Project: Flink

[jira] [Updated] (FLINK-18242) Custom OptionsFactory in user code not working when configured via code

[ https://issues.apache.org/jira/browse/FLINK-18242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-18242: Affects Version/s: 1.11.0 > Custom OptionsFactory in user code not working when configured via cod

[jira] [Commented] (FLINK-18241) Custom OptionsFactory in user code not working when configured via flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-18241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17130572#comment-17130572 ] Nico Kruber commented on FLINK-18241: - I just tried with Flink 1.11-SNAPSHOT and the

[jira] [Updated] (FLINK-18242) Custom OptionsFactory settings seem to have no effect on RocksDB

[ https://issues.apache.org/jira/browse/FLINK-18242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-18242: Summary: Custom OptionsFactory settings seem to have no effect on RocksDB (was: Custom OptionsFac

[jira] [Updated] (FLINK-18242) Custom OptionsFactory settings seem to have no effect on RocksDB

[ https://issues.apache.org/jira/browse/FLINK-18242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-18242: Description:  When I configure a custom {{OptionsFactory}} for RocksDB like this (similarly by sp

[jira] [Commented] (FLINK-18242) Custom OptionsFactory settings seem to have no effect on RocksDB

[ https://issues.apache.org/jira/browse/FLINK-18242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17133134#comment-17133134 ] Nico Kruber commented on FLINK-18242: - Thanks for the analysis - after changing to t

[jira] [Created] (FLINK-18255) Add API annotations to RocksDB user-facing classes

Nico Kruber created FLINK-18255: --- Summary: Add API annotations to RocksDB user-facing classes Key: FLINK-18255 URL: https://issues.apache.org/jira/browse/FLINK-18255 Project: Flink Issue Type:

[jira] [Created] (FLINK-18276) NullPointerException when closing KafkaConsumer

Nico Kruber created FLINK-18276: --- Summary: NullPointerException when closing KafkaConsumer Key: FLINK-18276 URL: https://issues.apache.org/jira/browse/FLINK-18276 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-18276) NullPointerException (and potential leak) when closing KafkaConsumer after exception in reassignPartitions

[ https://issues.apache.org/jira/browse/FLINK-18276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-18276: Summary: NullPointerException (and potential leak) when closing KafkaConsumer after exception in r

[jira] [Created] (FLINK-18955) Add snapshot path to job startup message

Nico Kruber created FLINK-18955: --- Summary: Add snapshot path to job startup message Key: FLINK-18955 URL: https://issues.apache.org/jira/browse/FLINK-18955 Project: Flink Issue Type: Improvemen

[jira] [Updated] (FLINK-18955) Add snapshot path to job startup message

[ https://issues.apache.org/jira/browse/FLINK-18955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-18955: Component/s: Runtime / Checkpointing > Add snapshot path to job startup message >

[jira] [Created] (FLINK-18962) Improve error message if checkpoint directory is not writable

Nico Kruber created FLINK-18962: --- Summary: Improve error message if checkpoint directory is not writable Key: FLINK-18962 URL: https://issues.apache.org/jira/browse/FLINK-18962 Project: Flink

[jira] [Updated] (FLINK-18962) Improve error message if checkpoint directory is not writable

[ https://issues.apache.org/jira/browse/FLINK-18962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-18962: Labels: usability (was: ) > Improve error message if checkpoint directory is not writable > -

[jira] [Updated] (FLINK-18955) Add snapshot path to job startup message

[ https://issues.apache.org/jira/browse/FLINK-18955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-18955: Labels: usability (was: ) > Add snapshot path to job startup message > --

[jira] [Commented] (FLINK-18955) Add snapshot path to job startup message

[ https://issues.apache.org/jira/browse/FLINK-18955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178968#comment-17178968 ] Nico Kruber commented on FLINK-18955: - [~ym] While we are changing this, I probably

[jira] [Commented] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180380#comment-17180380 ] Nico Kruber commented on FLINK-18998: - Maybe also add a line how to enable EventTime

[jira] [Created] (FLINK-19112) No access to metric group in ScalarFunction when optimizing

Nico Kruber created FLINK-19112: --- Summary: No access to metric group in ScalarFunction when optimizing Key: FLINK-19112 URL: https://issues.apache.org/jira/browse/FLINK-19112 Project: Flink Is

[jira] [Updated] (FLINK-19112) No access to metric group in ScalarFunction when optimizing

[ https://issues.apache.org/jira/browse/FLINK-19112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-19112: Description: Under some circumstances, I cannot access {{context.getMetricGroup()}} in a {{Scalar

[jira] [Commented] (FLINK-19112) No access to metric group in ScalarFunction when optimizing

[ https://issues.apache.org/jira/browse/FLINK-19112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188643#comment-17188643 ] Nico Kruber commented on FLINK-19112: - [~twalthr] that seems to work > No access to

[jira] [Commented] (FLINK-19112) No access to metric group in ScalarFunction when optimizing

[ https://issues.apache.org/jira/browse/FLINK-19112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188647#comment-17188647 ] Nico Kruber commented on FLINK-19112: - oh, yes, I basically just need to use a field

[jira] [Commented] (FLINK-19112) No access to metric group in ScalarFunction when optimizing

[ https://issues.apache.org/jira/browse/FLINK-19112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189137#comment-17189137 ] Nico Kruber commented on FLINK-19112: - A mock MetricGroup has the disadvantage that

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

[ 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-17432) Rename Tutorials to Training

[ 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] [Commented] (FLINK-16850) Make flink-benchmark align with different releases of Flink

[ https://issues.apache.org/jira/browse/FLINK-16850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096144#comment-17096144 ] Nico Kruber commented on FLINK-16850: - The first commit needs to go into the Apache

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

[ https://issues.apache.org/jira/browse/FLINK-17057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-17057: Affects Version/s: (was: 1.11.0) > Add OpenSSL micro-benchmarks >

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

[ https://issues.apache.org/jira/browse/FLINK-17057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17057. --- Fix Version/s: 1.11.0 Resolution: Fixed Fixed via b2e2699 > Add OpenSSL micro-benchmarks > -

[jira] [Closed] (FLINK-17244) Update Getting Started / Overview: training and python

[ https://issues.apache.org/jira/browse/FLINK-17244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17244. --- Fix Version/s: 1.11.0 Resolution: Fixed Fixed via 4cb58e7 > Update Getting Started / Overvie

[jira] [Closed] (FLINK-17490) Add Training page to project website

[ https://issues.apache.org/jira/browse/FLINK-17490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17490. --- Resolution: Fixed Fixed via ac0064a > Add Training page to project website > --

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

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] [Closed] (FLINK-17056) JMH main() methods call unrelated benchmarks

[ 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 https://github.com/dataArtisans/flink-benchmarks/commit/b5ac

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

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] [Commented] (FLINK-17143) Blog feed.xml should only contain excerpts, not full contents

[ https://issues.apache.org/jira/browse/FLINK-17143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083547#comment-17083547 ] Nico Kruber commented on FLINK-17143: - I wasn't aware of such use case. I mainly use

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

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] [Updated] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ 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 co

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

[ 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-17275) Add core training exercises

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 C

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

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-17277) Apply IntelliJ recommendations to training exercises

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 Type

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

[ 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] [Updated] (FLINK-17276) Add checkstyle to training exercises

[ 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] [Created] (FLINK-17278) Add Travis to the training exercises

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] [Created] (FLINK-17279) Use gradle build scans

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 Compon

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

[ https://issues.apache.org/jira/browse/FLINK-17278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087918#comment-17087918 ] Nico Kruber commented on FLINK-17278: - I think, the requirements are a bit different

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

[ https://issues.apache.org/jira/browse/FLINK-17279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087996#comment-17087996 ] Nico Kruber commented on FLINK-17279: - Both have been newly added - not sure whether

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

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: Im

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

[ https://issues.apache.org/jira/browse/FLINK-17287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17088485#comment-17088485 ] Nico Kruber commented on FLINK-17287: - - merged to flink-training {{master}} via e4

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

[ 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 > Add

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

[ 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 > Add

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

[ 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 > App

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

[ 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 > Add

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

[ 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 > Use

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

[ https://issues.apache.org/jira/browse/FLINK-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17043640#comment-17043640 ] Nico Kruber commented on FLINK-16009: - FYI: [~rgrebennikov] presented his take on th

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

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-16282) Wrong exception using DESCRIBE SQL command

[ https://issues.apache.org/jira/browse/FLINK-16282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17045216#comment-17045216 ] Nico Kruber commented on FLINK-16282: - Yes, this ticket is about the error message f

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

[ 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 > "javax.man

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

[ https://issues.apache.org/jira/browse/FLINK-8093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17045220#comment-17045220 ] Nico Kruber commented on FLINK-8093: Sorry [~bdine] for not seeing your message. I as

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

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 Project

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

[ https://issues.apache.org/jira/browse/FLINK-15747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17046395#comment-17046395 ] Nico Kruber commented on FLINK-15747: - Yes, for those scenarios, it may make sense t

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

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

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

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 Featur

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

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 F

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

[ 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] [Updated] (FLINK-16460) Add Serialization benchmark for Protobuf

[ 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] [Created] (FLINK-16461) Multiple Bindings with SLF4J

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 Componen

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

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

<    5   6   7   8   9   10   11   12   13   14   >