[jira] [Commented] (FLINK-27836) RocksDBMapState iteration may stop too early for var-length prefixes

2022-12-01 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17642013#comment-17642013 ] Nico Kruber commented on FLINK-27836: - Unfortunately, it's not that simple because Flink doesn't

[jira] [Created] (FLINK-30072) Cannot assign instance of SerializedLambda to field KeyGroupStreamPartitioner.keySelector

2022-11-17 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-30072: --- Summary: Cannot assign instance of SerializedLambda to field KeyGroupStreamPartitioner.keySelector Key: FLINK-30072 URL: https://issues.apache.org/jira/browse/FLINK-30072

[jira] [Updated] (FLINK-30045) FromClasspathEntryClassInformationProvider too eager to verify MainClass

2022-11-16 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-30045: Description: {{FromClasspathEntryClassInformationProvider}} is attempting to verify (eagerly)

[jira] [Created] (FLINK-30045) FromClasspathEntryClassInformationProvider too eager to verify MainClass

2022-11-16 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-30045: --- Summary: FromClasspathEntryClassInformationProvider too eager to verify MainClass Key: FLINK-30045 URL: https://issues.apache.org/jira/browse/FLINK-30045 Project:

[jira] [Closed] (FLINK-15633) Javadocs cannot be built on Java 11

2022-11-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-15633. --- Fix Version/s: 1.17.0 Resolution: Fixed Should be fixed now with

[jira] [Commented] (FLINK-25306) Flink CLI end-to-end test timeout on azure

2022-11-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628811#comment-17628811 ] Nico Kruber commented on FLINK-25306: - one more:

[jira] [Closed] (FLINK-29865) Allow configuring the JDK in build-nightly-dist.yml

2022-11-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-29865. --- Resolution: Fixed Fixed on {{master}} via

[jira] [Closed] (FLINK-29867) Update maven-enforcer-plugin to 3.1.0

2022-11-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-29867. --- Resolution: Fixed fixed in {{master}} via

[jira] [Closed] (FLINK-29868) Dependency convergence error for org.osgi:org.osgi.core:jar

2022-11-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-29868. --- Resolution: Fixed fixed in {{master}} via

[jira] [Created] (FLINK-29884) Flaky test failure in finegrained_resource_management/SortMergeResultPartitionTest.testRelease

2022-11-04 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-29884: --- Summary: Flaky test failure in finegrained_resource_management/SortMergeResultPartitionTest.testRelease Key: FLINK-29884 URL: https://issues.apache.org/jira/browse/FLINK-29884

[jira] [Updated] (FLINK-29884) Flaky test failure in finegrained_resource_management/SortMergeResultPartitionTest.testRelease

2022-11-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-29884: Labels: test-stability (was: ) > Flaky test failure in >

[jira] [Updated] (FLINK-15633) Javadocs cannot be built on Java 11

2022-11-03 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-15633: Labels: pull-request-available (was: auto-deprioritized-minor pull-request-available) >

[jira] [Created] (FLINK-29868) Dependency convergence error for org.osgi:org.osgi.core:jar

2022-11-03 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-29868: --- Summary: Dependency convergence error for org.osgi:org.osgi.core:jar Key: FLINK-29868 URL: https://issues.apache.org/jira/browse/FLINK-29868 Project: Flink

[jira] [Created] (FLINK-29867) Update maven-enforcer-plugin to 3.1.0

2022-11-03 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-29867: --- Summary: Update maven-enforcer-plugin to 3.1.0 Key: FLINK-29867 URL: https://issues.apache.org/jira/browse/FLINK-29867 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29865) Allow configuring the JDK in build-nightly-dist.yml

2022-11-03 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-29865: --- Summary: Allow configuring the JDK in build-nightly-dist.yml Key: FLINK-29865 URL: https://issues.apache.org/jira/browse/FLINK-29865 Project: Flink Issue

[jira] [Assigned] (FLINK-15633) Javadocs cannot be built on Java 11

2022-11-03 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-15633: --- Assignee: Nico Kruber > Javadocs cannot be built on Java 11 >

[jira] [Created] (FLINK-29643) Possible NPE in ApplicationDispatcherBootstrap with failedJob submission and no HA

2022-10-14 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-29643: --- Summary: Possible NPE in ApplicationDispatcherBootstrap with failedJob submission and no HA Key: FLINK-29643 URL: https://issues.apache.org/jira/browse/FLINK-29643

[jira] [Updated] (FLINK-29208) Logs and stdout endpoints not mentioned in Docs or OpenAPI spec

2022-09-06 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-29208: Summary: Logs and stdout endpoints not mentioned in Docs or OpenAPI spec (was: Logs and stdout

[jira] [Updated] (FLINK-29208) Logs and stdout endpoints not mentioned on OpenAPI spec

2022-09-06 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-29208: Affects Version/s: 1.16.0 > Logs and stdout endpoints not mentioned on OpenAPI spec >

[jira] [Created] (FLINK-29208) Logs and stdout endpoints not mentioned on OpenAPI spec

2022-09-06 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-29208: --- Summary: Logs and stdout endpoints not mentioned on OpenAPI spec Key: FLINK-29208 URL: https://issues.apache.org/jira/browse/FLINK-29208 Project: Flink Issue

[jira] [Created] (FLINK-27836) RocksDBMapState iteration may stop too early for var-length prefixes

2022-05-30 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-27836: --- Summary: RocksDBMapState iteration may stop too early for var-length prefixes Key: FLINK-27836 URL: https://issues.apache.org/jira/browse/FLINK-27836 Project: Flink

[jira] [Closed] (FLINK-27353) Update training exercises to use Flink 1.15

2022-04-28 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-27353. --- Fix Version/s: 1.15.0 (was: 1.15.1) Resolution: Fixed fixed in

[jira] [Created] (FLINK-27353) Update training exercises to use Flink 1.15

2022-04-22 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-27353: --- Summary: Update training exercises to use Flink 1.15 Key: FLINK-27353 URL: https://issues.apache.org/jira/browse/FLINK-27353 Project: Flink Issue Type: New

[jira] [Assigned] (FLINK-24144) Improve DataGenerator to prevent excessive creation of new Random objects

2022-04-22 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-24144: --- Assignee: (was: Nico Kruber) > Improve DataGenerator to prevent excessive creation of

[jira] [Updated] (FLINK-24144) Improve DataGenerator to prevent excessive creation of new Random objects

2022-04-22 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-24144: Priority: Not a Priority (was: Major) > Improve DataGenerator to prevent excessive creation of

[jira] [Resolved] (FLINK-26382) Add Chinese documents for flink-training exercises

2022-04-22 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-26382. - Fix Version/s: 1.15.0 1.14.5 (was: 1.14.3)

[jira] [Closed] (FLINK-27322) Add license headers and spotless checks for them

2022-04-21 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-27322. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed on master via: -

[jira] [Resolved] (FLINK-25313) Enable flink runtime web

2022-04-20 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-25313. - Fix Version/s: 1.15.0 Resolution: Fixed fixed in master via

[jira] [Created] (FLINK-27322) Add license headers and spotless checks for them

2022-04-20 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-27322: --- Summary: Add license headers and spotless checks for them Key: FLINK-27322 URL: https://issues.apache.org/jira/browse/FLINK-27322 Project: Flink Issue Type:

[jira] [Commented] (FLINK-20255) Nested decorrelate failed

2022-04-19 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524261#comment-17524261 ] Nico Kruber commented on FLINK-20255: - The following example (which was simplified from a more

[jira] [Created] (FLINK-26852) RocksDBMapState#clear not forwarding exceptions

2022-03-24 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-26852: --- Summary: RocksDBMapState#clear not forwarding exceptions Key: FLINK-26852 URL: https://issues.apache.org/jira/browse/FLINK-26852 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5129) make the BlobServer use a distributed file system

2022-01-12 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474622#comment-17474622 ] Nico Kruber commented on FLINK-5129: No, blob.storage.directory has to be a local path. I also

[jira] [Closed] (FLINK-25362) Incorrect dependencies in Table Confluent/Avro docs

2022-01-11 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-25362. --- Fix Version/s: 1.15.0 1.13.6 Resolution: Fixed Fixed in * master:

[jira] [Created] (FLINK-25362) Incorrect dependencies in Table Confluent/Avro docs

2021-12-17 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-25362: --- Summary: Incorrect dependencies in Table Confluent/Avro docs Key: FLINK-25362 URL: https://issues.apache.org/jira/browse/FLINK-25362 Project: Flink Issue

[jira] [Created] (FLINK-25027) Allow GC of a finished job's JobMaster before the slot timeout is reached

2021-11-23 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-25027: --- Summary: Allow GC of a finished job's JobMaster before the slot timeout is reached Key: FLINK-25027 URL: https://issues.apache.org/jira/browse/FLINK-25027 Project:

[jira] [Created] (FLINK-25023) ClassLoader leak on JM/TM through indirectly-started Hadoop threads out of user code

2021-11-23 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-25023: --- Summary: ClassLoader leak on JM/TM through indirectly-started Hadoop threads out of user code Key: FLINK-25023 URL: https://issues.apache.org/jira/browse/FLINK-25023

[jira] [Created] (FLINK-25022) ClassLoader leak with ThreadLocals on the JM when submitting a job through the REST API

2021-11-23 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-25022: --- Summary: ClassLoader leak with ThreadLocals on the JM when submitting a job through the REST API Key: FLINK-25022 URL: https://issues.apache.org/jira/browse/FLINK-25022

[jira] [Commented] (FLINK-24783) Improve monitoring experience and usability of state backend

2021-11-05 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439496#comment-17439496 ] Nico Kruber commented on FLINK-24783: - FYI: I'm actually planning to upstream a couple of options

[jira] [Commented] (FLINK-24769) FlameGraphs in 1.14 do not aggregate subtasks' stack traces anymore

2021-11-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438706#comment-17438706 ] Nico Kruber commented on FLINK-24769: - Actually, it seems like this is the same with Flink 1.13.3,

[jira] [Updated] (FLINK-24769) FlameGraphs in 1.14 do not aggregate subtasks' stack traces anymore

2021-11-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-24769: Affects Version/s: 1.13.3 > FlameGraphs in 1.14 do not aggregate subtasks' stack traces anymore >

[jira] [Created] (FLINK-24769) FlameGraphs in 1.14 do not aggregate subtasks' stack traces anymore

2021-11-04 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-24769: --- Summary: FlameGraphs in 1.14 do not aggregate subtasks' stack traces anymore Key: FLINK-24769 URL: https://issues.apache.org/jira/browse/FLINK-24769 Project: Flink

[jira] [Resolved] (FLINK-21336) Activate bloom filter in RocksDB State Backend via Flink configuration

2021-10-19 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-21336. - Resolution: Duplicate > Activate bloom filter in RocksDB State Backend via Flink configuration

[jira] [Assigned] (FLINK-24432) RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method

2021-10-05 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-24432: --- Assignee: Victor Xu > RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator

[jira] [Closed] (FLINK-23653) improve training exercises and tests so they are better examples

2021-10-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-23653. --- Fix Version/s: 1.13.3 Resolution: Fixed Fixed on master via

[jira] [Created] (FLINK-24411) Add docs navigation for release notes

2021-09-30 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-24411: --- Summary: Add docs navigation for release notes Key: FLINK-24411 URL: https://issues.apache.org/jira/browse/FLINK-24411 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-24118) enable TaxiFareGenerator to produce a bounded stream

2021-09-03 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-24118. --- Fix Version/s: 1.13.3 1.14.0 Resolution: Fixed Fixed on master via

[jira] [Updated] (FLINK-23886) An exception is thrown out when recover job timers from checkpoint file

2021-09-03 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-23886: Affects Version/s: 1.10.0 1.11.3 > An exception is thrown out when recover

[jira] [Created] (FLINK-24144) Improve DataGenerator to prevent excessive creation of new Random objects

2021-09-03 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-24144: --- Summary: Improve DataGenerator to prevent excessive creation of new Random objects Key: FLINK-24144 URL: https://issues.apache.org/jira/browse/FLINK-24144 Project:

[jira] [Closed] (FLINK-23926) change TaxiRide data model to have a single timestamp

2021-09-03 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-23926. --- Fix Version/s: 1.13.3 1.14.0 Resolution: Fixed Fixed on master via

[jira] [Created] (FLINK-24115) Outdated SQL Temporal Join Example

2021-09-01 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-24115: --- Summary: Outdated SQL Temporal Join Example Key: FLINK-24115 URL: https://issues.apache.org/jira/browse/FLINK-24115 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-23670) Add Scala formatting checks to training exercises

2021-09-01 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-23670. --- Fix Version/s: 1.14.0 Resolution: Fixed Fixed on master via: -

[jira] [Updated] (FLINK-23895) Upsert materializer is not inserted for all sink providers

2021-08-31 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-23895: Description: The new {{SinkUpsertMaterializer}} is not inserted for

[jira] [Closed] (FLINK-24022) Scala checks not running in flink-training CI

2021-08-30 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-24022. --- Resolution: Fixed Fixed on master via 65cde7910e5bff6283eef7ea536fde3ea5d4c9d4 > Scala checks not

[jira] [Updated] (FLINK-24022) Scala checks not running in flink-training CI

2021-08-27 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-24022: Summary: Scala checks not running in flink-training CI (was: Re-Enable Scala checks in

[jira] [Created] (FLINK-24022) Re-Enable Scala checks in flink-training CI

2021-08-27 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-24022: --- Summary: Re-Enable Scala checks in flink-training CI Key: FLINK-24022 URL: https://issues.apache.org/jira/browse/FLINK-24022 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-24016) Restore 1.12 SQL docs page on state retention/TTL

2021-08-27 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-24016: Summary: Restore 1.12 SQL docs page on state retention/TTL (was: Restore 1.12 SQL docs page on

[jira] [Created] (FLINK-24016) Restore 1.12 SQL docs page on state retention

2021-08-27 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-24016: --- Summary: Restore 1.12 SQL docs page on state retention Key: FLINK-24016 URL: https://issues.apache.org/jira/browse/FLINK-24016 Project: Flink Issue Type:

[jira] [Updated] (FLINK-24008) Support state cleanup based on unique keys

2021-08-26 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-24008: Description: In a join of two tables where we join on unique columns, e.g. from primary keys, we

[jira] [Created] (FLINK-24008) Support state cleanup based on unique keys

2021-08-26 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-24008: --- Summary: Support state cleanup based on unique keys Key: FLINK-24008 URL: https://issues.apache.org/jira/browse/FLINK-24008 Project: Flink Issue Type: New

[jira] [Created] (FLINK-23993) Describe eventually-consistency of materializing upserts

2021-08-26 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-23993: --- Summary: Describe eventually-consistency of materializing upserts Key: FLINK-23993 URL: https://issues.apache.org/jira/browse/FLINK-23993 Project: Flink Issue

[jira] [Commented] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

2021-08-26 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405135#comment-17405135 ] Nico Kruber commented on FLINK-22826: - While I see what [~lzljs3620320] mentioned as very important

[jira] [Updated] (FLINK-21566) Improve error message for "Unsupported casting"

2021-08-23 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-21566: Labels: stale-major usability (was: stale-major) > Improve error message for "Unsupported

[jira] [Updated] (FLINK-21563) Support using computed columns when defining new computed columns

2021-08-23 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-21563: Labels: auto-deprioritized-major usability (was: auto-deprioritized-major) > Support using

[jira] [Updated] (FLINK-21562) Add more informative message on CSV parsing errors

2021-08-23 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-21562: Labels: auto-deprioritized-major usability (was: auto-deprioritized-major) > Add more

[jira] [Commented] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

2021-08-20 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402158#comment-17402158 ] Nico Kruber commented on FLINK-20427: - [~trohrmann] it may be cleaner to remove this along with the

[jira] [Commented] (FLINK-22826) flink sql1.13.1 causes data loss based on change log stream data join

2021-08-20 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402117#comment-17402117 ] Nico Kruber commented on FLINK-22826: - [~lzljs3620320] Why did you re-open this ticket? Isn't it

[jira] [Updated] (FLINK-23054) Correct upsert optimization by upsert keys

2021-08-20 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-23054: Parent: FLINK-20374 Issue Type: Sub-task (was: Bug) > Correct upsert optimization by

[jira] [Updated] (FLINK-22901) Introduce getChangeLogUpsertKeys in FlinkRelMetadataQuery

2021-08-20 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-22901: Parent: FLINK-20374 Issue Type: Sub-task (was: Bug) > Introduce getChangeLogUpsertKeys

[jira] [Updated] (FLINK-22899) ValuesUpsertSinkFunction needs to use global upsert

2021-08-20 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-22899: Parent: FLINK-20374 Issue Type: Sub-task (was: Bug) > ValuesUpsertSinkFunction needs to

[jira] [Created] (FLINK-23839) Unclear severity of Kafka transaction recommit warning in logs

2021-08-17 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-23839: --- Summary: Unclear severity of Kafka transaction recommit warning in logs Key: FLINK-23839 URL: https://issues.apache.org/jira/browse/FLINK-23839 Project: Flink

[jira] [Commented] (FLINK-21336) Activate bloom filter in RocksDB State Backend via Flink configuration

2021-08-16 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400022#comment-17400022 ] Nico Kruber commented on FLINK-21336: - Looks like the document linked in FLINK-7588 is a good source

[jira] [Updated] (FLINK-23812) Support configuration of the RocksDB info logging via configuration

2021-08-16 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-23812: Summary: Support configuration of the RocksDB info logging via configuration (was: Support

[jira] [Closed] (FLINK-23812) Support configuration of the RocksDB logging via configuration

2021-08-16 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-23812. --- Fix Version/s: 1.14.0 Release Note: With RocksDB bumped to 6.20.3 (FLINK-14482), you can now

[jira] [Closed] (FLINK-12141) Allow @TypeInfo annotation on POJO field declarations

2021-08-16 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-12141. --- Fix Version/s: 1.14.0 Release Note: @TypeInfo annotations can now also be used on POJO fields

[jira] [Assigned] (FLINK-12141) Allow @TypeInfo annotation on POJO field declarations

2021-08-16 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-12141: --- Assignee: Nico Kruber > Allow @TypeInfo annotation on POJO field declarations >

[jira] [Updated] (FLINK-23812) Support configuration of the RocksDB logging via configuration

2021-08-16 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-23812: Description: Since FLINK-14482 has been merged now, we should also allow users to configure more

[jira] [Created] (FLINK-23812) Support configuration of the RocksDB logging via configuration

2021-08-16 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-23812: --- Summary: Support configuration of the RocksDB logging via configuration Key: FLINK-23812 URL: https://issues.apache.org/jira/browse/FLINK-23812 Project: Flink

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

2021-08-13 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-15747. --- Fix Version/s: (was: 1.14.0) Resolution: Duplicate > Enable setting RocksDB log level

[jira] [Updated] (FLINK-20911) Support configuration of RocksDB log level

2021-08-13 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-20911: Fix Version/s: 1.13.0 > Support configuration of RocksDB log level >

[jira] [Assigned] (FLINK-23667) Fix training exercises IDE setup description for Scala

2021-08-10 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-23667: --- Assignee: Nico Kruber (was: Nico Kruber) > Fix training exercises IDE setup description

[jira] [Assigned] (FLINK-23669) Avoid using Scala >= 2.12.8 in Flink Training exercises

2021-08-10 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-23669: --- Assignee: Nico Kruber (was: Nico Kruber) > Avoid using Scala >= 2.12.8 in Flink Training

[jira] [Closed] (FLINK-23669) Avoid using Scala >= 2.12.8 in Flink Training exercises

2021-08-06 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-23669. --- Resolution: Fixed Merged on master via 1704fd959122aa197b48803441338c1fb0470091 > Avoid using

[jira] [Closed] (FLINK-23667) Fix training exercises IDE setup description for Scala

2021-08-06 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-23667. --- Resolution: Fixed Merged on master via 08f5bf4d93d241f58d67148dc3e054a2325b64a0 > Fix training

[jira] [Created] (FLINK-23670) Add Scala formatting checks to training exercises

2021-08-06 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-23670: --- Summary: Add Scala formatting checks to training exercises Key: FLINK-23670 URL: https://issues.apache.org/jira/browse/FLINK-23670 Project: Flink Issue Type:

[jira] [Created] (FLINK-23669) Avoid using Scala >= 2.12.8 in Flink Training exercises

2021-08-06 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-23669: --- Summary: Avoid using Scala >= 2.12.8 in Flink Training exercises Key: FLINK-23669 URL: https://issues.apache.org/jira/browse/FLINK-23669 Project: Flink Issue

[jira] [Commented] (FLINK-23667) Fix training exercises IDE setup description for Scala

2021-08-06 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17394725#comment-17394725 ] Nico Kruber commented on FLINK-23667: - The same actually also applies to the new {{CONTRIBUTING.md}}

[jira] [Created] (FLINK-23667) Fix training exercises IDE setup description for Scala

2021-08-06 Thread Nico Kruber (Jira)
Nico Kruber created FLINK-23667: --- Summary: Fix training exercises IDE setup description for Scala Key: FLINK-23667 URL: https://issues.apache.org/jira/browse/FLINK-23667 Project: Flink Issue

[jira] [Commented] (FLINK-23495) [GCP PubSub] Make checkpoint optional for preview/staging mode

2021-08-05 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17394161#comment-17394161 ] Nico Kruber commented on FLINK-23495: - [~airblader] or [~arvid] do you think, there would be any

[jira] [Commented] (FLINK-23495) [GCP PubSub] Make checkpoint optional for preview/staging mode

2021-08-05 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17394015#comment-17394015 ] Nico Kruber commented on FLINK-23495: - Looks ok to me as well since you wouldn't lose anything if

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

2021-08-05 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-16556: --- Assignee: Liebing Yu > TopSpeedWindowing should implement checkpointing for its source >

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

2021-08-05 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393744#comment-17393744 ] Nico Kruber commented on FLINK-16556: - Looks about right...luckily, the source isn't declared as a

[jira] [Commented] (FLINK-23495) [GCP PubSub] Make checkpoint optional for preview/staging mode

2021-08-05 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393734#comment-17393734 ] Nico Kruber commented on FLINK-23495: - Messages are only acknowledged once the checkpoint is

[jira] [Commented] (FLINK-22452) Support specifying custom transactional.id prefix in FlinkKafkaProducer

2021-08-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393242#comment-17393242 ] Nico Kruber commented on FLINK-22452: - Hmm...sorry, I overread this part. For discoverability

[jira] [Commented] (FLINK-22452) Support specifying custom transactional.id prefix in FlinkKafkaProducer

2021-08-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393068#comment-17393068 ] Nico Kruber commented on FLINK-22452: - I think, for this property in particular, we should also

[jira] [Commented] (FLINK-22452) Support specifying custom transactional.id prefix in FlinkKafkaProducer

2021-08-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392905#comment-17392905 ] Nico Kruber commented on FLINK-22452: - Thanks for taking care of this. Looking at the commits,

[jira] [Assigned] (FLINK-22405) Support fixed-lengh chars in the LeadLag built-in function

2021-08-03 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber reassigned FLINK-22405: --- Assignee: liwei li > Support fixed-lengh chars in the LeadLag built-in function >

[jira] [Issue Comment Deleted] (FLINK-22405) Support fixed-lengh chars in the LeadLag built-in function

2021-08-03 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-22405: Comment: was deleted (was: I think, it is... (I see no need of maintaining a specialized

[jira] [Commented] (FLINK-23495) [GCP PubSub] Make checkpoint optional for preview/staging mode

2021-08-03 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392198#comment-17392198 ] Nico Kruber commented on FLINK-23495: - If you [look through the

[jira] [Updated] (FLINK-23501) [GCP PubSub] add table source API for GCP PubSub

2021-08-03 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-23501: Issue Type: New Feature (was: Improvement) > [GCP PubSub] add table source API for GCP PubSub >

[jira] [Commented] (FLINK-22405) Support fixed-lengh chars in the LeadLag built-in function

2021-08-03 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392072#comment-17392072 ] Nico Kruber commented on FLINK-22405: - I think, it is... (I see no need of maintaining a specialized

  1   2   3   4   5   6   7   8   9   10   >