Hi Joao,
I noticed the FLIP currently contains the following 2 methods about type
serializer:
(1) TypeSerializer createInputSerializer();
(2) TypeSerializer createSerializer(TypeInformation inType);
Is the method (2) still needed now?
Best,
Lijie
João Boto 于2023年5月19日周五 16:53写道：
> Updated
Michał Fijołek created FLINK-32160:
--
Summary: CompactOperator cannot continue from checkpoint because
of java.util.NoSuchElementException
Key: FLINK-32160
URL: https://issues.apache.org/jira/browse/FLINK-32160
+1 (binding)
- Verified checksums and signatures
- Verified that no binary exist in the source archive
- Build the source with Maven
- Verified that README doesn't have unexpected contents
- Verified that the commit ID on Flink UI matches with the tag
- Run a job with SQL client that reads from a
+1 (non-binding)
- Verified signature
- Verified hashes
- Build form source with mac
- Verify that the source archives do not contain any binaries
- Run streaming and batch job in sql-client successfully.
Thank you for driving this release candidate.
On Tue, 23 May 2023 at 1:51 PM, Qingsheng Ren
+1(non-binding)
- reviewed Jira release notes
- built from source
- verified signatures
- verified hashes
- verified that no binary exist in the source archive
- run streaming job in sql-client successfully
Best,
Hang
Samrat Deb 于2023年5月23日周二 16:23写道：
> +1 (non-binding)
>
> - Verified signatur
Hi guys,
I want to bring up a discussion about adding support of User
Defined AsyncTableFunction in Flink.
Currently, async table function are special functions for table source
to perform
async lookup. However, it's worth to support the user defined async
table function.
Because, in this way,
Niceee. Thanks for managing the release, Gyula!
-Max
On Wed, May 17, 2023 at 8:25 PM Márton Balassi wrote:
>
> Thanks, awesome! :-)
>
> On Wed, May 17, 2023 at 2:24 PM Gyula Fóra wrote:
>>
>> The Apache Flink community is very happy to announce the release of Apache
>> Flink Kubernetes Operato
Weijie Guo created FLINK-32161:
--
Summary: Migrate and remove some legacy ExternalResource
Key: FLINK-32161
URL: https://issues.apache.org/jira/browse/FLINK-32161
Project: Flink
Issue Type: Techn
Just catch an user case report from Giannis Polyzos for this usage:
https://lists.apache.org/thread/qljwd40v5ntz6733cwcdr8s4z97b343b
Aitozi 于2023年5月23日周二 17:45写道：
>
> Hi guys,
> I want to bring up a discussion about adding support of User
> Defined AsyncTableFunction in Flink.
> Currently, a
Chesnay Schepler created FLINK-32162:
Summary: Misleading log message due to missing null check
Key: FLINK-32162
URL: https://issues.apache.org/jira/browse/FLINK-32162
Project: Flink
Issu
melin created FLINK-32163:
-
Summary: Support the same application run multiple jobs in HA mode
Key: FLINK-32163
URL: https://issues.apache.org/jira/browse/FLINK-32163
Project: Flink
Issue Type: New F
Gyula Fora created FLINK-32164:
--
Summary: LifecycleState count metrics are not reported correctly
by namespace
Key: FLINK-32164
URL: https://issues.apache.org/jira/browse/FLINK-32164
Project: Flink
Chesnay Schepler created FLINK-32165:
Summary: Improve observability ofd fine-grained resource management
Key: FLINK-32165
URL: https://issues.apache.org/jira/browse/FLINK-32165
Project: Flink
Chesnay Schepler created FLINK-32166:
Summary: Show unassigned/total TM resources in web ui
Key: FLINK-32166
URL: https://issues.apache.org/jira/browse/FLINK-32166
Project: Flink
Issue Ty
Chesnay Schepler created FLINK-32167:
Summary: Log dynamic slot creation on task manager
Key: FLINK-32167
URL: https://issues.apache.org/jira/browse/FLINK-32167
Project: Flink
Issue Type:
Chesnay Schepler created FLINK-32168:
Summary: Log required/available resources in RM
Key: FLINK-32168
URL: https://issues.apache.org/jira/browse/FLINK-32168
Project: Flink
Issue Type: Su
Chesnay Schepler created FLINK-32169:
Summary: Show allocated slots on TM page
Key: FLINK-32169
URL: https://issues.apache.org/jira/browse/FLINK-32169
Project: Flink
Issue Type: Sub-task
Hi,
Thanks for the proposal. However, are you sure that the OperatorCoordinator
is the right place to place such logic? What would happen if there are two
(or more) operator coordinators with conflicting desired checkpoint trigger
behaviour? If one source is processing a backlog and the other is a
Hi,
I vaguely remember someone implementing a mechanism to deal with it. I
think at least at some point (it might have changed since I looked at it),
it was solving the problem via canceling the checkpoint in the scenario
that you described. However I can not remember from the top of my head
neith
Dear Flink Dev team,
It's about a while since I am dealing with an issue that can't figure out
myself. I spent quite a lot of time trying to solve the problem myself, but
I feel stuck.
I explained the problem statement and the issue here:
https://stackoverflow.com/questions/76308686/how-to-figure
Hi Piotr,
Thanks for the comments. Let me try to understand your concerns and
hopefully address the concerns.
>> What would happen if there are two (or more) operator coordinators with
conflicting desired checkpoint trigger behaviour
With the proposed change, there won't exist any "*conflicting*
Maximilian Michels created FLINK-32170:
--
Summary: Continue metric collection on intermittant job restarts
Key: FLINK-32170
URL: https://issues.apache.org/jira/browse/FLINK-32170
Project: Flink
Xingcan Cui created FLINK-32171:
---
Summary: Add PostStart hook to flink k8s operator helm
Key: FLINK-32171
URL: https://issues.apache.org/jira/browse/FLINK-32171
Project: Flink
Issue Type: New F
xulongfeng created FLINK-32172:
--
Summary: KafkaExample can not run with args
Key: FLINK-32172
URL: https://issues.apache.org/jira/browse/FLINK-32172
Project: Flink
Issue Type: Bug
Comp
Hi Yunfeng, Hi Dong
Thanks for the informative discussion! It is a rational requirement to set
different checkpoint intervals for different sources in a hybridSource. The
tiny downside of this proposal, at least for me, is that I have to
understand the upper-bound definition of the interval and th
Prabhu Joseph created FLINK-32173:
-
Summary: Flink Job Metrics returns stale values in the first
request after an update in the values
Key: FLINK-32173
URL: https://issues.apache.org/jira/browse/FLINK-32173
26 matches
Mail list logo
