[
https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou reopened FLINK-9373:
---
> Always call RocksIterator.status() to check the internal error of RocksDB
>
[
https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476972#comment-16476972
]
Timo Walther commented on FLINK-9091:
-
[~yew1eb] can we close this issue or do you still get this
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/6001#discussion_r188529928
--- Diff: docs/dev/stream/operators/windows.md ---
@@ -797,7 +797,7 @@ DataStream input = ...;
input
.keyBy()
- .timeWindow()
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476984#comment-16476984
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477009#comment-16477009
]
ASF GitHub Bot commented on FLINK-9182:
---
Github user sihuazhou commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477008#comment-16477008
]
ASF GitHub Bot commented on FLINK-9337:
---
Github user StephanEwen commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6019
I wonder can you introduce a `HeapState` which scoped to `key group` to
support timer service. This way timer service is backed by keyed state backend,
which looks like a beautiful things.
---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5995
I would actually keep the package name for now. It makes sense, because the
connection to the registry is avro-specific at the moment...
---
[
https://issues.apache.org/jira/browse/FLINK-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-9376:
---
Description:
Currently, users have access to upgrade state serializers on the restore
[
https://issues.apache.org/jira/browse/FLINK-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-9376:
---
Description:
Currently, users have access to upgrade state serializers on the restore
[
https://issues.apache.org/jira/browse/FLINK-9341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477191#comment-16477191
]
Sergey Nuyanzin commented on FLINK-9341:
issue created FLINK-9378
will be able to do it in the
[
https://issues.apache.org/jira/browse/FLINK-9299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476927#comment-16476927
]
ASF GitHub Bot commented on FLINK-9299:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6001
cc @tzulitai @fhueske
---
[
https://issues.apache.org/jira/browse/FLINK-9325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476945#comment-16476945
]
ASF GitHub Bot commented on FLINK-9325:
---
Github user sihuazhou commented on the issue:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/5982
@StephanEwen I guess this PR is already for an another look now...
---
[
https://issues.apache.org/jira/browse/FLINK-8428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476998#comment-16476998
]
ASF GitHub Bot commented on FLINK-8428:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5327#discussion_r188532278
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRel.scala
---
@@ -53,4 +53,8 @@ trait
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6010
merging.
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6005
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-9354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477097#comment-16477097
]
ASF GitHub Bot commented on FLINK-9354:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6008#discussion_r188550129
--- Diff: flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh ---
@@ -33,8 +33,8 @@ else
NUM_SLOTS=$NEW_DOP
fi
Tzu-Li (Gordon) Tai created FLINK-9376:
--
Summary: Allow upgrading to incompatible state serializers (state
schema evolution)
Key: FLINK-9376
URL: https://issues.apache.org/jira/browse/FLINK-9376
[
https://issues.apache.org/jira/browse/FLINK-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476909#comment-16476909
]
ASF GitHub Bot commented on FLINK-8659:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476905#comment-16476905
]
ASF GitHub Bot commented on FLINK-8659:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476908#comment-16476908
]
ASF GitHub Bot commented on FLINK-8659:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476930#comment-16476930
]
ASF GitHub Bot commented on FLINK-9292:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5970
cc @tzulitai
---
[
https://issues.apache.org/jira/browse/FLINK-8428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476994#comment-16476994
]
ASF GitHub Bot commented on FLINK-8428:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476992#comment-16476992
]
ASF GitHub Bot commented on FLINK-8428:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5327#discussion_r188531785
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -176,14 +179,34 @@ class
[
https://issues.apache.org/jira/browse/FLINK-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477040#comment-16477040
]
Chesnay Schepler commented on FLINK-9360:
-
I will push a hotfix to reduce the sleep to 30 seconds.
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5928#discussion_r188548955
--- Diff: docs/ops/state/checkpoints.md ---
@@ -35,60 +35,62 @@ the same semantics as a failure-free execution.
See [Checkpointing]({{ site.baseurl
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5928#discussion_r188548729
--- Diff: docs/_includes/generated/checkpointing_configuration.html ---
@@ -40,7 +40,7 @@
state.checkpoints.dir
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5928#discussion_r188549219
--- Diff: docs/ops/state/checkpoints.md ---
@@ -35,60 +35,62 @@ the same semantics as a failure-free execution.
See [Checkpointing]({{ site.baseurl
[
https://issues.apache.org/jira/browse/FLINK-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-9377:
---
Description:
When writing meta information of a state in savepoints, we currently
Tzu-Li (Gordon) Tai created FLINK-9377:
--
Summary: Remove writing serializers as part of the checkpoint meta
information
Key: FLINK-9377
URL: https://issues.apache.org/jira/browse/FLINK-9377
[
https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477194#comment-16477194
]
Tzu-Li (Gordon) Tai commented on FLINK-6944:
I'll change this to be a subtask of FLINK-9376,
[
https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6944:
---
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-9376
> Introduce
[
https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6944:
---
Priority: Blocker (was: Major)
> Introduce DefaultTypeSerializerConfigSnapshot as a
[
https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9373:
--
Description: Currently, when using RocksIterator we only use the
_iterator.isValid()_ to check whether
[
https://issues.apache.org/jira/browse/FLINK-9374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Franz Thoma updated FLINK-9374:
---
Description:
The {{FlinkKinesisProducer}} just accepts records and forwards it to a
GitHub user fmthoma opened a pull request:
https://github.com/apache/flink/pull/6021
[FLINK-9374] [kinesis] Enable FlinkKinesisProducer Backpressuring
## What is the purpose of the change
The `FlinkKinesisProducer` just accepts records and forwards it to a
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6022
merging.
---
Stefan Richter created FLINK-9375:
-
Summary: Introduce AbortCheckpoint message from JM to TMs
Key: FLINK-9375
URL: https://issues.apache.org/jira/browse/FLINK-9375
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-8918:
--
Description:
In general, stream join is one of the most performance cost task. For every
record from
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477127#comment-16477127
]
Fabian Hueske commented on FLINK-8866:
--
Regarding (3), originally, {{TableSink}} was designed to be
[
https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9373:
--
Summary: Fix potential data losing for RocksDBBackend (was: Always call
RocksIterator.status() to
[
https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477171#comment-16477171
]
ASF GitHub Bot commented on FLINK-9303:
---
Github user EAlexRojas commented on a diff in the pull
Github user EAlexRojas commented on a diff in the pull request:
https://github.com/apache/flink/pull/5991#discussion_r188564095
--- Diff:
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer08.java
---
@@ -221,7
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6001#discussion_r188530473
--- Diff: docs/dev/stream/operators/windows.md ---
@@ -797,7 +797,7 @@ DataStream input = ...;
input
.keyBy()
- .timeWindow()
+
[
https://issues.apache.org/jira/browse/FLINK-9375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9375:
---
Assignee: vinoyang
> Introduce AbortCheckpoint message from JM to TMs
>
Sergey Nuyanzin created FLINK-9378:
--
Summary: Improve TableException message with TypeName usage
Key: FLINK-9378
URL: https://issues.apache.org/jira/browse/FLINK-9378
Project: Flink
Issue
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5955#discussion_r188511081
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
---
@@ -0,0 +1,418 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476906#comment-16476906
]
ASF GitHub Bot commented on FLINK-8659:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5955#discussion_r188512949
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
---
@@ -0,0 +1,418 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476910#comment-16476910
]
ASF GitHub Bot commented on FLINK-8659:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8659?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476907#comment-16476907
]
ASF GitHub Bot commented on FLINK-8659:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5955#discussion_r188512862
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
---
@@ -0,0 +1,418 @@
+/*
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5955#discussion_r188512804
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
---
@@ -0,0 +1,418 @@
+/*
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5955#discussion_r188511280
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
---
@@ -0,0 +1,418 @@
+/*
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5955#discussion_r188511258
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/utils/StatefulJobWBroadcastStateMigrationITCase.java
---
@@ -0,0 +1,418 @@
+/*
Sihua Zhou created FLINK-9373:
-
Summary: Always call RocksIterator.status() to check the internal
error of RocksDB
Key: FLINK-9373
URL: https://issues.apache.org/jira/browse/FLINK-9373
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16476989#comment-16476989
]
ASF GitHub Bot commented on FLINK-9373:
---
GitHub user sihuazhou opened a pull request:
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5327#discussion_r188531694
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamJoin.scala
---
@@ -60,6 +60,9 @@ class
[
https://issues.apache.org/jira/browse/FLINK-9283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477017#comment-16477017
]
ASF GitHub Bot commented on FLINK-9283:
---
GitHub user yuqi1129 opened a pull request:
Github user sihuazhou commented on the issue:
https://github.com/apache/flink/pull/6020
cc @StefanRRichter
---
[
https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477035#comment-16477035
]
ASF GitHub Bot commented on FLINK-9373:
---
Github user sihuazhou commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477066#comment-16477066
]
Fabian Hueske commented on FLINK-9341:
--
Thanks for investigating the issue [~kgeis] and [~Sergey
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5964#discussion_r188546038
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -470,6 +488,9
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5964#discussion_r188545921
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -381,6 +393,9
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5964#discussion_r188545761
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -381,6 +393,9
[
https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou updated FLINK-9373:
--
Fix Version/s: 1.5.0
> Fix potential data losing for RocksDBBackend
>
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6008
nice catch @tzulitai, will rework this into a run_test method that takes a
description and command to execute.
---
Franz Thoma created FLINK-9374:
--
Summary: Flink Kinesis Producer does not backpressure
Key: FLINK-9374
URL: https://issues.apache.org/jira/browse/FLINK-9374
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-9354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477003#comment-16477003
]
ASF GitHub Bot commented on FLINK-9354:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6009
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-9357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477022#comment-16477022
]
ASF GitHub Bot commented on FLINK-9357:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477043#comment-16477043
]
ASF GitHub Bot commented on FLINK-9333:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5989
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477074#comment-16477074
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5946
merging.
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5964#discussion_r188546432
--- Diff:
flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477070#comment-16477070
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5964#discussion_r188545817
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -410,6 +425,9
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477069#comment-16477069
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5964#discussion_r188545721
--- Diff:
flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java
---
@@ -258,6 +259,17
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477072#comment-16477072
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477073#comment-16477073
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477071#comment-16477071
]
ASF GitHub Bot commented on FLINK-8655:
---
Github user zentol commented on a diff in the pull request:
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6008#discussion_r188548653
--- Diff: flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh ---
@@ -33,8 +33,8 @@ else
NUM_SLOTS=$NEW_DOP
fi
[
https://issues.apache.org/jira/browse/FLINK-9354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477086#comment-16477086
]
ASF GitHub Bot commented on FLINK-9354:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sihua Zhou closed FLINK-9373.
-
Resolution: Invalid
> Always call RocksIterator.status() to check the internal error of RocksDB
>
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/6020
[FLINK-9373][state] Always call RocksIterator.status() to check the
internal error of RocksDB
## What is the purpose of the change
Currently, when using RocksIterator we only use the
[
https://issues.apache.org/jira/browse/FLINK-9359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477037#comment-16477037
]
ASF GitHub Bot commented on FLINK-9359:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477038#comment-16477038
]
ASF GitHub Bot commented on FLINK-9176:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477075#comment-16477075
]
ASF GitHub Bot commented on FLINK-9285:
---
Github user zentol commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6001
@StephanEwen fixed based on your suggestion
---
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5961
Thanks for the update @snuyanzin. I'll try to have a look at the changes in
the next days.
Best, Fabian
---
[
https://issues.apache.org/jira/browse/FLINK-766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16477115#comment-16477115
]
Flavio Pompermaier commented on FLINK-766:
--
+1 for this feature!
> Web interface progress
[
https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-6944:
---
Description:
FLINK-9377 proposes to remove writing serializers as part of checkpoint
1 - 100 of 282 matches
Mail list logo
