[
https://issues.apache.org/jira/browse/FLINK-27836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642013#comment-17642013
]
Nico Kruber commented on FLINK-27836:
-
Unfortunately, it's not that simple because F
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
[
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) whe
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: Flink
[
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
[e962c6964929d9943a3884bf8f
[
https://issues.apache.org/jira/browse/FLINK-25306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628811#comment-17628811
]
Nico Kruber commented on FLINK-25306:
-
one more:
https://dev.azure.com/apache-flink
[
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
[2306e448bfa8ca78e2bf13e34d2838939bce31e1|https://github.
[
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
[d0c6075be47e3d277a418d9fdefe513eeeb0c0f2|https://github.
[
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
[614fc2a5fd301789f7daa1282a5b500bf8d67d4b|https://github.
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
[
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
> finegrained_resource_management/SortMer
[
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)
> Javadocs
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
Is
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
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 Type:
[
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
> -
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
Proj
[
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 en
[
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
>
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 T
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
[
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 05791e5
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 Fea
[
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 n
[
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 ne
[
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)
Ass
[
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:
- a47f38e7b3e7fe0e1bf372d97852da
[
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 9c25c54a73578b24b15e9c52e2874
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: Bu
[
https://issues.apache.org/jira/browse/FLINK-20255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17524261#comment-17524261
]
Nico Kruber commented on FLINK-20255:
-
The following example (which was simplified f
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: Bug
[
https://issues.apache.org/jira/browse/FLINK-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17474622#comment-17474622
]
Nico Kruber commented on FLINK-5129:
No, blob.storage.directory has to be a local pat
[
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: e9dba5e
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 Type:
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: Flin
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
Pr
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
[
https://issues.apache.org/jira/browse/FLINK-24783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439496#comment-17439496
]
Nico Kruber commented on FLINK-24783:
-
FYI: I'm actually planning to upstream a coup
[
https://issues.apache.org/jira/browse/FLINK-24769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17438706#comment-17438706
]
Nico Kruber commented on FLINK-24769:
-
Actually, it seems like this is the same with
[
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
>
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
[
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
>
[
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 metho
[
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 bbb051ac458e1555f76f396f9424337d2
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
[
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 bfcd25a
[
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
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: Flin
[
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 fd65b11
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
Co
[
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:
- bd4a088fd3aa23b13eea5e75307b26
[
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
{{TransformationSinkProvider}}
[
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 r
[
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 flink-trai
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
[
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 st
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: Impro
[
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
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 Feat
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
[
https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405135#comment-17405135
]
Nico Kruber commented on FLINK-22826:
-
While I see what [~lzljs3620320] mentioned as
[
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 casting
[
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 comput
[
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 informative
[
https://issues.apache.org/jira/browse/FLINK-20427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402158#comment-17402158
]
Nico Kruber commented on FLINK-20427:
-
[~trohrmann] it may be cleaner to remove this
[
https://issues.apache.org/jira/browse/FLINK-22826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402117#comment-17402117
]
Nico Kruber commented on FLINK-22826:
-
[~lzljs3620320] Why did you re-open this tick
[
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 upse
[
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 in
[
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 u
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
[
https://issues.apache.org/jira/browse/FLINK-21336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400022#comment-17400022
]
Nico Kruber commented on FLINK-21336:
-
Looks like the document linked in FLINK-7588
[
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 config
[
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
al
[
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
w
[
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
> ---
[
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
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
[
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 fro
[
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
> -
[
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 fo
[
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 e
[
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 Scala
[
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 exer
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: B
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 T
[
https://issues.apache.org/jira/browse/FLINK-23667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394725#comment-17394725
]
Nico Kruber commented on FLINK-23667:
-
The same actually also applies to the new {{C
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 Ty
[
https://issues.apache.org/jira/browse/FLINK-23495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394161#comment-17394161
]
Nico Kruber commented on FLINK-23495:
-
[~airblader] or [~arvid] do you think, there
[
https://issues.apache.org/jira/browse/FLINK-23495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17394015#comment-17394015
]
Nico Kruber commented on FLINK-23495:
-
Looks ok to me as well since you wouldn't los
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-16556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17393744#comment-17393744
]
Nico Kruber commented on FLINK-16556:
-
Looks about right...luckily, the source isn't
[
https://issues.apache.org/jira/browse/FLINK-23495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17393734#comment-17393734
]
Nico Kruber commented on FLINK-23495:
-
Messages are only acknowledged once the check
[
https://issues.apache.org/jira/browse/FLINK-22452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17393242#comment-17393242
]
Nico Kruber commented on FLINK-22452:
-
Hmm...sorry, I overread this part.
For discov
[
https://issues.apache.org/jira/browse/FLINK-22452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17393068#comment-17393068
]
Nico Kruber commented on FLINK-22452:
-
I think, for this property in particular, we
[
https://issues.apache.org/jira/browse/FLINK-22452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392905#comment-17392905
]
Nico Kruber commented on FLINK-22452:
-
Thanks for taking care of this. Looking at th
[
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
> -
[
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 implement
[
https://issues.apache.org/jira/browse/FLINK-23495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392198#comment-17392198
]
Nico Kruber commented on FLINK-23495:
-
If you [look through the
code|https://github
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-22405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392072#comment-17392072
]
Nico Kruber commented on FLINK-22405:
-
I think, it is...
(I see no need of maintaini
1 - 100 of 1422 matches
Mail list logo
