Till Rohrmann created FLINK-6768:
Summary: Quadratic/Inefficient field lookup in
PojoSerializer#ensureCompatibility
Key: FLINK-6768
URL: https://issues.apache.org/jira/browse/FLINK-6768
Project: Flink
Matt created FLINK-6767:
---
Summary: Cannot load user class on local environment
Key: FLINK-6767
URL: https://issues.apache.org/jira/browse/FLINK-6767
Project: Flink
Issue Type: Bug
Components:
Stefan Richter created FLINK-6766:
-
Summary: Update documentation with async backends and incremental
checkpoints
Key: FLINK-6766
URL: https://issues.apache.org/jira/browse/FLINK-6766
Project: Flink
Till Rohrmann created FLINK-6765:
Summary: PojoSerializer returns wrong ConvertDeserializer when
migration is required
Key: FLINK-6765
URL: https://issues.apache.org/jira/browse/FLINK-6765
Project: Fl
Hi Robert,
+1 to release:
Check items have been checked, as follows: (flink-table)
1.Check that the JAVA and SCALA logical plans are consistent.
2.Check that the SQL and Table API logical plans are consistent.
3.Check that UDF, UDTF, and UDAF are working properly in group-windows and
over-window
Hi,
officially, we currently do not want to support rescaling from (incremental)
checkpoints, but only from savepoints. For this reason, I would not consider
this a blocking issue.
Unofficially, I think we are not too far away from supporting this, but there
is a question mark behind the effi
Till Rohrmann created FLINK-6764:
Summary: Deduplicate stateless TypeSerializers when serializing
composite TypeSerializers
Key: FLINK-6764
URL: https://issues.apache.org/jira/browse/FLINK-6764
Projec
Till Rohrmann created FLINK-6763:
Summary: Inefficient PojoSerializerConfigSnapshot serialization
format
Key: FLINK-6763
URL: https://issues.apache.org/jira/browse/FLINK-6763
Project: Flink
Hi,
I have found an issue with rescaling incremental checkpoints:
https://issues.apache.org/jira/browse/FLINK-6762
I am not sure if this is regarded as a blocker, it depends on our
assumptions about externalized checkpoints.
What do you think?
Cheers,
Gyula
Robert Metzger ezt írta (időpont: 2
Gyula Fora created FLINK-6762:
-
Summary: Cannot rescale externalized incremental checkpoints
Key: FLINK-6762
URL: https://issues.apache.org/jira/browse/FLINK-6762
Project: Flink
Issue Type: Bug
+1 to release:
- Tested building job against staging repository
- tested YARN session start and container recovery on YARN
- Validated HA on YARN (per job and session mode)
- Incremental checkpointing with rocksdb works
- FsStatebackend with async snapshots works
- Flink builds from source on Lin
Stefan Richter created FLINK-6761:
-
Summary: Limitation for maximum state size per key in RocksDB
backend
Key: FLINK-6761
URL: https://issues.apache.org/jira/browse/FLINK-6761
Project: Flink
sunjincheng created FLINK-6760:
--
Summary: Fix OverWindowTest alias test error
Key: FLINK-6760
URL: https://issues.apache.org/jira/browse/FLINK-6760
Project: Flink
Issue Type: Sub-task
+1
* Builds from source
* start/stop scripts work
* logs don't show anything suspicious on startup/shutdown
* ran some example jobs
* ran jobs on yarn with exactly-once & RocksDB
o canceling with savepoint/resuming from savepoint
o without/with rescaling
* SideOutputs work
* Metr
Normally, I’m the first one to suggest removing everything that is not
absolutely necessary in order to have a clean code base. On this issue, though,
I think we should support restoring from old Savepoints as far back as possible
if it does not make the code completely unmaintainable. Some user
Chesnay Schepler created FLINK-6759:
---
Summary: storm-examples cannot be built without cached dependencies
Key: FLINK-6759
URL: https://issues.apache.org/jira/browse/FLINK-6759
Project: Flink
Chesnay Schepler created FLINK-6758:
---
Summary: Loaded configuration values are logged twice
Key: FLINK-6758
URL: https://issues.apache.org/jira/browse/FLINK-6758
Project: Flink
Issue Type:
Till Rohrmann created FLINK-6757:
Summary: Investigate Apache Atlas integration
Key: FLINK-6757
URL: https://issues.apache.org/jira/browse/FLINK-6757
Project: Flink
Issue Type: Wish
Andrea Spina created FLINK-6756:
---
Summary: Provide RichAsyncFunction to Scala API suite
Key: FLINK-6756
URL: https://issues.apache.org/jira/browse/FLINK-6756
Project: Flink
Issue Type: Improvem
Gyula Fora created FLINK-6755:
-
Summary: Allow triggering Checkpoints through command line client
Key: FLINK-6755
URL: https://issues.apache.org/jira/browse/FLINK-6755
Project: Flink
Issue Type:
Gyula Fora created FLINK-6754:
-
Summary: Savepoints don't respect client timeout config
Key: FLINK-6754
URL: https://issues.apache.org/jira/browse/FLINK-6754
Project: Flink
Issue Type: Bug
21 matches
Mail list logo
