tzulitai opened a new pull request #198:
URL: https://github.com/apache/flink-statefun/pull/198
Making sure ASF legal-wise we are good with the new `statefun-java-sdk`
artifact.
Since we are bundling and shading Protobuf, that should be acknowledged in
the NOTICE file and also the BSD
[
https://issues.apache.org/jira/browse/FLINK-21250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278630#comment-17278630
]
jiangjiguang0719 commented on FLINK-21250:
--
I have reproduced this problem，When jobmanager has
XComp commented on a change in pull request #14798:
URL: https://github.com/apache/flink/pull/14798#discussion_r570012364
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java
##
@@ -870,6 +874,78 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-21274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jichao Wang updated FLINK-21274:
Description:
This is a partial configuration of my Flink History service(flink-conf.yaml).
Tzu-Li (Gordon) Tai created FLINK-21276:
---
Summary: flink-statefun/statefun-sdk-java should mention Protobuf
in NOTICE and bundle its license
Key: FLINK-21276
URL:
[
https://issues.apache.org/jira/browse/FLINK-21274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jichao Wang updated FLINK-21274:
Description:
This is a partial configuration of my Flink History service(flink-conf.yaml).
gaoyunhaii commented on a change in pull request #14820:
URL: https://github.com/apache/flink/pull/14820#discussion_r570009052
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/CheckpointableOneInputStreamTask.java
##
@@ -0,0 +1,49 @@
[
https://issues.apache.org/jira/browse/FLINK-21047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-21047:
Assignee: Yangze Guo
> Expose the correct registered/free resources information in
[
https://issues.apache.org/jira/browse/FLINK-21274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jichao Wang updated FLINK-21274:
Description:
This is a partial configuration of my Flink History service(flink-conf.yaml).
flinkbot edited a comment on pull request #14862:
URL: https://github.com/apache/flink/pull/14862#issuecomment-773094565
## CI report:
* f762a60fb9cc869720abebab6f4f081a3c843140 Azure:
flinkbot edited a comment on pull request #14860:
URL: https://github.com/apache/flink/pull/14860#issuecomment-773047949
## CI report:
* 028f91af25c57ac35ed04077b049a428ff089eaa Azure:
flinkbot edited a comment on pull request #14861:
URL: https://github.com/apache/flink/pull/14861#issuecomment-773094467
## CI report:
* 213102836a80edeb968a37566f174b501de36028 Azure:
flinkbot edited a comment on pull request #14820:
URL: https://github.com/apache/flink/pull/14820#issuecomment-770327711
## CI report:
* 48599d7654cbb03fb31bd28f9fc795a103870d81 Azure:
flinkbot edited a comment on pull request #14754:
URL: https://github.com/apache/flink/pull/14754#issuecomment-766965862
## CI report:
* 0fbe576aeefa4712cc9aaeb856cab8afab85668e Azure:
flinkbot edited a comment on pull request #14791:
URL: https://github.com/apache/flink/pull/14791#issuecomment-768926023
## CI report:
* c229b2c09cf62019cc497edb8dd7fc84dc64fc0b Azure:
flinkbot edited a comment on pull request #14766:
URL: https://github.com/apache/flink/pull/14766#issuecomment-767662801
## CI report:
* 570c161221ed5d2a71386fa412fe4a8b24e833c7 Azure:
KarmaGYZ commented on pull request #14860:
URL: https://github.com/apache/flink/pull/14860#issuecomment-773099073
Thanks for the review, @xintongsong . PR updated.
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-21232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias reassigned FLINK-21232:
Assignee: jackwangcs
> Introduce pluggable Hadoop delegation token providers
>
flinkbot commented on pull request #14862:
URL: https://github.com/apache/flink/pull/14862#issuecomment-773094565
## CI report:
* f762a60fb9cc869720abebab6f4f081a3c843140 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #14861:
URL: https://github.com/apache/flink/pull/14861#issuecomment-773094467
## CI report:
* 213102836a80edeb968a37566f174b501de36028 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot edited a comment on pull request #14766:
URL: https://github.com/apache/flink/pull/14766#issuecomment-767662801
## CI report:
* 570c161221ed5d2a71386fa412fe4a8b24e833c7 Azure:
flinkbot edited a comment on pull request #14754:
URL: https://github.com/apache/flink/pull/14754#issuecomment-766965862
## CI report:
* 0fbe576aeefa4712cc9aaeb856cab8afab85668e Azure:
xintongsong commented on a change in pull request #14860:
URL: https://github.com/apache/flink/pull/14860#discussion_r569980985
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
##
@@ -158,6 +159,9 @@
[
https://issues.apache.org/jira/browse/FLINK-21272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278605#comment-17278605
]
Guowei Ma commented on FLINK-21272:
---
One is scale up. The other is scale down. But I am not sure
flinkbot commented on pull request #14862:
URL: https://github.com/apache/flink/pull/14862#issuecomment-773085972
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-21275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo closed FLINK-21275.
Resolution: Duplicate
> DataStreamTests::test_key_by_on_connect_stream Fail
>
flinkbot commented on pull request #14861:
URL: https://github.com/apache/flink/pull/14861#issuecomment-773085076
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
flinkbot edited a comment on pull request #14860:
URL: https://github.com/apache/flink/pull/14860#issuecomment-773047949
## CI report:
* 028f91af25c57ac35ed04077b049a428ff089eaa Azure:
flinkbot edited a comment on pull request #14775:
URL: https://github.com/apache/flink/pull/14775#issuecomment-768234660
## CI report:
* 9cdc750c7db649b3ce4571c0d80fcdd3eb2acfdf Azure:
[
https://issues.apache.org/jira/browse/FLINK-21175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-21175:
--
Affects Version/s: (was: 1.13.0)
> OneInputStreamTaskTest.testWatermarkMetrics:914 expected:<1>
[
https://issues.apache.org/jira/browse/FLINK-21175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-21175:
--
Affects Version/s: 1.11.3
> OneInputStreamTaskTest.testWatermarkMetrics:914 expected:<1> but
>
[
https://issues.apache.org/jira/browse/FLINK-21273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21273:
---
Labels: pull-request-available (was: )
> Remove unused
wuchong commented on a change in pull request #14727:
URL: https://github.com/apache/flink/pull/14727#discussion_r569989010
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java
##
@@ -379,6 +390,33 @@
KarmaGYZ opened a new pull request #14862:
URL: https://github.com/apache/flink/pull/14862
…quirements
## What is the purpose of the change
Remove unused ExecutionVertexSchedulingRequirements.
## Verifying this change
This change is a trivial rework / code
[
https://issues.apache.org/jira/browse/FLINK-21271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-21271:
-
Affects Version/s: (was: 1.12.2)
1.12.1
>
[
https://issues.apache.org/jira/browse/FLINK-21274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Jichao updated FLINK-21274:
Affects Version/s: (was: 1.12.0)
(was: 1.11.0)
> At per-job
[
https://issues.apache.org/jira/browse/FLINK-20908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278599#comment-17278599
]
Guowei Ma commented on FLINK-20908:
---
[
https://issues.apache.org/jira/browse/FLINK-21027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278597#comment-17278597
]
Jark Wu commented on FLINK-21027:
-
Yes. In case of state key value is not serialized, we have to copy
Guowei Ma created FLINK-21275:
-
Summary: DataStreamTests::test_key_by_on_connect_stream Fail
Key: FLINK-21275
URL: https://issues.apache.org/jira/browse/FLINK-21275
Project: Flink
Issue Type:
Wang Jichao created FLINK-21274:
---
Summary: At per-job mode，when the upload speed of the HDFS file
system is slow, the task exits abnormally, and the task archive file upload
fails.
Key: FLINK-21274
URL:
XComp commented on a change in pull request #14798:
URL: https://github.com/apache/flink/pull/14798#discussion_r569986337
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java
##
@@ -522,6 +527,7 @@ protected
[
https://issues.apache.org/jira/browse/FLINK-21273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278592#comment-17278592
]
Zhu Zhu commented on FLINK-21273:
-
Thanks for firing this ticket! [~karmagyz]
I have assigned you the
[
https://issues.apache.org/jira/browse/FLINK-21273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-21273:
---
Assignee: Yangze Guo
> Remove unused ExecutionVertexSchedulingRequirements
>
[
https://issues.apache.org/jira/browse/FLINK-17378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-17378:
--
Affects Version/s: (was: 1.13.0)
1.12.1
>
[
https://issues.apache.org/jira/browse/FLINK-21027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278590#comment-17278590
]
Nicholas Jiang commented on FLINK-21027:
[~jark], is the `isStateKeyValueSerialized()` API only
[
https://issues.apache.org/jira/browse/FLINK-17378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma updated FLINK-17378:
--
Affects Version/s: 1.13.0
>
[
https://issues.apache.org/jira/browse/FLINK-17378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma reopened FLINK-17378:
---
> KafkaProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceCustomOperator
> unstable
>
[
https://issues.apache.org/jira/browse/FLINK-17378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma closed FLINK-17378.
-
Resolution: Duplicate
>
[
https://issues.apache.org/jira/browse/FLINK-21273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278589#comment-17278589
]
Yangze Guo commented on FLINK-21273:
cc [~zhuzh] Could you assign this to me?
> Remove unused
WeiZhong94 commented on a change in pull request #14842:
URL: https://github.com/apache/flink/pull/14842#discussion_r569902739
##
File path:
flink-python/src/main/java/org/apache/flink/client/python/PythonFunctionFactoryImpl.java
##
@@ -0,0 +1,61 @@
+/*
+ * Licensed to the
shouweikun commented on a change in pull request #14727:
URL: https://github.com/apache/flink/pull/14727#discussion_r569984252
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java
##
@@ -379,6 +390,33 @@
[
https://issues.apache.org/jira/browse/FLINK-17378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guowei Ma reopened FLINK-17378:
---
[
https://issues.apache.org/jira/browse/FLINK-21088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21088:
---
Labels: pull-request-available (was: )
> CheckpointCoordinator pass the flag about whether
[
https://issues.apache.org/jira/browse/FLINK-21273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278583#comment-17278583
]
Yangze Guo commented on FLINK-21273:
Also the ExecutionSlotAllocatorTestUtils and
gaoyunhaii opened a new pull request #14861:
URL: https://github.com/apache/flink/pull/14861
## What is the purpose of the change
For checkpoints after tasks finished, if some operators are fully finished,
it would store a special state content in the checkpoint metadata. After
[
https://issues.apache.org/jira/browse/FLINK-21148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278581#comment-17278581
]
Guowei Ma commented on FLINK-21148:
---
[
https://issues.apache.org/jira/browse/FLINK-21175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278579#comment-17278579
]
Kezhu Wang commented on FLINK-21175:
[~maguowei] [~AHeise] [~roman_khachatryan] FLINK-19864 on 1.11
Yangze Guo created FLINK-21273:
--
Summary: Remove unused ExecutionVertexSchedulingRequirements
Key: FLINK-21273
URL: https://issues.apache.org/jira/browse/FLINK-21273
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-21272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278577#comment-17278577
]
Nicholas Jiang commented on FLINK-21272:
[~maguowei], is this issue duplicated with
wuchong commented on a change in pull request #14727:
URL: https://github.com/apache/flink/pull/14727#discussion_r569979293
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java
##
@@ -379,6 +390,33 @@
[
https://issues.apache.org/jira/browse/FLINK-21051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278576#comment-17278576
]
Guowei Ma commented on FLINK-21051:
---
wuchong commented on a change in pull request #14727:
URL: https://github.com/apache/flink/pull/14727#discussion_r569977623
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java
##
@@ -379,6 +390,33 @@
wuchong commented on a change in pull request #14727:
URL: https://github.com/apache/flink/pull/14727#discussion_r569977623
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java
##
@@ -379,6 +390,33 @@
Guowei Ma created FLINK-21272:
-
Summary: Resuming Savepoint (rocks, scale down, rocks timers)
end-to-end test' Fail
Key: FLINK-21272
URL: https://issues.apache.org/jira/browse/FLINK-21272
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-21233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278569#comment-17278569
]
Yuan Mei commented on FLINK-21233:
--
Is this ticket completed? Why it is in "closed" status?
> Race
[
https://issues.apache.org/jira/browse/FLINK-21248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278566#comment-17278566
]
Ceyhan Kasap commented on FLINK-21248:
--
Hi [~trohrmann] ,
As far as I know, savepoints are
shouweikun commented on a change in pull request #14727:
URL: https://github.com/apache/flink/pull/14727#discussion_r569971752
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java
##
@@ -379,6 +390,33 @@
shouweikun commented on a change in pull request #14727:
URL: https://github.com/apache/flink/pull/14727#discussion_r569971058
##
File path: docs/dev/table/connectors/filesystem.md
##
@@ -375,6 +375,35 @@ public class AnalysisCommitPolicy implements
PartitionCommitPolicy {
shouweikun commented on a change in pull request #14727:
URL: https://github.com/apache/flink/pull/14727#discussion_r569971058
##
File path: docs/dev/table/connectors/filesystem.md
##
@@ -375,6 +375,35 @@ public class AnalysisCommitPolicy implements
PartitionCommitPolicy {
curcur edited a comment on pull request #14838:
URL: https://github.com/apache/flink/pull/14838#issuecomment-773054677
1. The StateChangeLog is put under flink-state-backends,
under flink-statebackend-changelog
But this is where/the name I planned to put the WrappedStateBackend.
flinkbot edited a comment on pull request #14859:
URL: https://github.com/apache/flink/pull/14859#issuecomment-773047857
## CI report:
* 31aab909d881e3f2bf60197b1d27048114f082c0 Azure:
flinkbot edited a comment on pull request #14860:
URL: https://github.com/apache/flink/pull/14860#issuecomment-773047949
## CI report:
* 028f91af25c57ac35ed04077b049a428ff089eaa Azure:
flinkbot edited a comment on pull request #14851:
URL: https://github.com/apache/flink/pull/14851#issuecomment-772551657
## CI report:
* 65b50e39e32f6698ba71267b10c6c3c6bd70ea2a Azure:
shouweikun commented on pull request #14727:
URL: https://github.com/apache/flink/pull/14727#issuecomment-773058266
@wuchong Thanks for ur review! I'll take care of the comments later.
This is an automated message from
curcur edited a comment on pull request #14838:
URL: https://github.com/apache/flink/pull/14838#issuecomment-773054677
The StateChangeLog is put under flink-state-backends,
under flink-statebackend-changelog
But this is where/the name I planned to put the WrappedStateBackend.
curcur edited a comment on pull request #14838:
URL: https://github.com/apache/flink/pull/14838#issuecomment-773054677
The StateChangeLog is put under flink-state-backends,
under flink-statebackend-changelog
But this is where/the name I planned to put the WrappedStateBackend.
curcur commented on pull request #14838:
URL: https://github.com/apache/flink/pull/14838#issuecomment-773054677
The StateChangeLog is put under flink-state-backends,
under flink-statebackend-changelog
But this is where/the name I planned to put the WrappedStateBackend. What do
curcur commented on a change in pull request #14838:
URL: https://github.com/apache/flink/pull/14838#discussion_r569963528
##
File path:
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/changelog/StateChangelogClientTest.java
##
@@ -0,0 +1,158
[
https://issues.apache.org/jira/browse/FLINK-21162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278558#comment-17278558
]
WeiNan Zhao commented on FLINK-21162:
-
[~hiscat] I debug your sql and found that col is null is
flinkbot commented on pull request #14860:
URL: https://github.com/apache/flink/pull/14860#issuecomment-773047949
## CI report:
* 028f91af25c57ac35ed04077b049a428ff089eaa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #14859:
URL: https://github.com/apache/flink/pull/14859#issuecomment-773047857
## CI report:
* 31aab909d881e3f2bf60197b1d27048114f082c0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #14860:
URL: https://github.com/apache/flink/pull/14860#issuecomment-773045245
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-21269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-21269:
---
Labels: pull-request-available (was: )
> Introduce runtime interfaces for specifying
KarmaGYZ opened a new pull request #14860:
URL: https://github.com/apache/flink/pull/14860
## What is the purpose of the change
Introduce runtime interfaces for specifying SlotSharingGroup-based resource
requirements and the specified resource requirements will be passed on all the
[
https://issues.apache.org/jira/browse/FLINK-15318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278547#comment-17278547
]
Guowei Ma commented on FLINK-15318:
---
another case
[
https://issues.apache.org/jira/browse/FLINK-21175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278545#comment-17278545
]
Guowei Ma commented on FLINK-21175:
---
[
https://issues.apache.org/jira/browse/FLINK-21270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-21270:
Assignee: Yangze Guo
> Generate the slot request respect to the resource specification
[
https://issues.apache.org/jira/browse/FLINK-21269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-21269:
Assignee: Yangze Guo
> Introduce runtime interfaces for specifying SSG-based resource
flinkbot commented on pull request #14859:
URL: https://github.com/apache/flink/pull/14859#issuecomment-773038275
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. We will use this comment to track the
[
https://issues.apache.org/jira/browse/FLINK-21267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-21267:
Assignee: Yangze Guo
> FLIP-156: Runtime Interfaces for Fine-Grained Resource
HuangXingBo opened a new pull request #14859:
URL: https://github.com/apache/flink/pull/14859
## What is the purpose of the change
*This pull request will make Arrow Coder serialize schema info in every
batch*
## Brief change log
- *make Arrow Coder serialize
[
https://issues.apache.org/jira/browse/FLINK-21264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278540#comment-17278540
]
tonychan edited comment on FLINK-21264 at 2/4/21, 5:19 AM:
---
this is the summit
[
https://issues.apache.org/jira/browse/FLINK-21264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278540#comment-17278540
]
tonychan edited comment on FLINK-21264 at 2/4/21, 5:16 AM:
---
this is the summit
[
https://issues.apache.org/jira/browse/FLINK-21264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278540#comment-17278540
]
tonychan edited comment on FLINK-21264 at 2/4/21, 5:14 AM:
---
this is the summit
[
https://issues.apache.org/jira/browse/FLINK-21264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278540#comment-17278540
]
tonychan commented on FLINK-21264:
--
this is the summit code
./bin/flink run -m yarn-cluster -yjm 2048
[
https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young reassigned FLINK-21236:
--
Assignee: Nicholas Jiang
> Don't explicitly use HeapMemorySegment in raw format serde
>
[
https://issues.apache.org/jira/browse/FLINK-21225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278521#comment-17278521
]
appleyuchi commented on FLINK-21225:
[~twalthr]
My later replies to above link of mailing list is
[
https://issues.apache.org/jira/browse/FLINK-21225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278521#comment-17278521
]
appleyuchi edited comment on FLINK-21225 at 2/4/21, 4:26 AM:
-
[~twalthr]
My
wuchong commented on a change in pull request #14727:
URL: https://github.com/apache/flink/pull/14727#discussion_r569925499
##
File path: docs/dev/table/connectors/filesystem.md
##
@@ -375,6 +375,35 @@ public class AnalysisCommitPolicy implements
PartitionCommitPolicy {
[
https://issues.apache.org/jira/browse/FLINK-21108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278520#comment-17278520
]
Xiaoguang Sun commented on FLINK-21108:
---
Just bring this up again in case notification got missed,
1 - 100 of 485 matches
Mail list logo
