[
https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830875#comment-16830875
]
Zhenqiu Huang commented on FLINK-12342:
---
[~till.rohrmann]
After reading the AMRMAsynclient, I just
[
https://issues.apache.org/jira/browse/FLINK-12260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830862#comment-16830862
]
Hwanju Kim commented on FLINK-12260:
Thanks for the clarification. I thought you meant it without
xuefuz commented on issue #8314: [FLINK-12365][table] Add stats related catalog
APIs
URL: https://github.com/apache/flink/pull/8314#issuecomment-488209732
did a forced push and now it seems good.
This is an automated message
xuefuz removed a comment on issue #8314: [FLINK-12365][table] Add stats related
catalog APIs
URL: https://github.com/apache/flink/pull/8314#issuecomment-488206199
> Hi @xuefuz , can you properly rebase to master? the commit history has
some unrelated commits
What unrelated commits
xuefuz commented on issue #8314: [FLINK-12365][table] Add stats related catalog
APIs
URL: https://github.com/apache/flink/pull/8314#issuecomment-488206199
> Hi @xuefuz , can you properly rebase to master? the commit history has
some unrelated commits
What unrelated commits you saw?
bowenli86 commented on issue #8314: [FLINK-12365][table] Add stats related
catalog APIs
URL: https://github.com/apache/flink/pull/8314#issuecomment-488205589
Hi @xuefuz , can you properly rebase to master? the commit history has some
unrelated commits
piyushnarang commented on issue #8117: [FLINK-12115] [filesystems]: Add support
for AzureFS
URL: https://github.com/apache/flink/pull/8117#issuecomment-488195295
Seems like the missing ingredient was this commit:
[
https://issues.apache.org/jira/browse/FLINK-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Adam Lamar updated FLINK-12375:
---
Description:
When building a custom job container using flink-container, the job can't be
launched
piyushnarang edited a comment on issue #8117: [FLINK-12115] [filesystems]: Add
support for AzureFS
URL: https://github.com/apache/flink/pull/8117#issuecomment-488128359
P.S. @tillrohrmann / @shuai-xu - I was able to test this out on a hadoop
cluster. I had to copy the following jars to my
stevenzwu edited a comment on issue #8315: [FLINK-12368] add subtask index to
FlinkKafkaConsumerBase logging, wh…
URL: https://github.com/apache/flink/pull/8315#issuecomment-488149092
@Myasuka that is good to know. This can be an option. but I am not sure if
we always want to enable
stevenzwu commented on issue #8315: [FLINK-12368] add subtask index to
FlinkKafkaConsumerBase logging, wh…
URL: https://github.com/apache/flink/pull/8315#issuecomment-488149092
@Myasuka that is good to know.enable thread name in each log line can be an
option. but I am not sure if we
[
https://issues.apache.org/jira/browse/FLINK-12379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henrik updated FLINK-12379:
---
Description:
When running one standalone-job w/ parallelism=1 + one taskmanager, you will
shortly get this
xuefuz commented on a change in pull request #8312: [FLINK-12366][table] Clean
up Catalog APIs to make them more consiste…
URL: https://github.com/apache/flink/pull/8312#discussion_r279961356
##
File path:
Henrik created FLINK-12379:
--
Summary: Parallelism in job/GCS/Hadoop: Could not finalize the
pending checkpoint
Key: FLINK-12379
URL: https://issues.apache.org/jira/browse/FLINK-12379
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-12376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henrik updated FLINK-12376:
---
Environment:
FROM flink:1.8.0-scala_2.11
ARG version=0.17
ADD
xuefuz commented on issue #8314: [FLINK-12365][table] Add stats related catalog
APIs
URL: https://github.com/apache/flink/pull/8314#issuecomment-488133623
I updated the PR with the following reworking:
1. Modified CatalogColumnStatistics class to enclose statistical info of all
columns
flinkbot edited a comment on issue #8326: [FLINK-12378][docs] Consolidate
FileSystem Documentation
URL: https://github.com/apache/flink/pull/8326#issuecomment-488131875
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
[
https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830731#comment-16830731
]
Seth Wiesman commented on FLINK-8513:
-
Included as part of
sjwiesman commented on issue #8326: [FLINK-12378][docs] Consolidate FileSystem
Documentation
URL: https://github.com/apache/flink/pull/8326#issuecomment-488131970
@flinkbot attention @fhueske
This is an automated message
flinkbot commented on issue #8326: [FLINK-12378][docs] Consolidate FileSystem
Documentation
URL: https://github.com/apache/flink/pull/8326#issuecomment-488131875
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
sjwiesman opened a new pull request #8326: Flink 12378
URL: https://github.com/apache/flink/pull/8326
## What is the purpose of the change
Currently flink's filesystem documentation is spread across a number of
pages without any clear connection. A non-exhaustive list of
piyushnarang commented on issue #8117: [FLINK-12115] [filesystems]: Add support
for AzureFS
URL: https://github.com/apache/flink/pull/8117#issuecomment-488128359
P.S. @tillrohrmann / @shuai-xu - I was able to test this out on a hadoop
cluster. I had to copy the following jars to my lib
Seth Wiesman created FLINK-12378:
Summary: Consolidate FileSystem Documentation
Key: FLINK-12378
URL: https://issues.apache.org/jira/browse/FLINK-12378
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman reassigned FLINK-8513:
---
Assignee: Seth Wiesman
> Add documentation for connecting to non-AWS S3 endpoints
>
Henrik created FLINK-12377:
--
Summary: Outdated docs (Flink 0.10) for Google Compute Engine
Key: FLINK-12377
URL: https://issues.apache.org/jira/browse/FLINK-12377
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-10249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman reassigned FLINK-10249:
Assignee: Seth Wiesman
> Document hadoop/presto s3 file system configuration forwarding
[
https://issues.apache.org/jira/browse/FLINK-12376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henrik updated FLINK-12376:
---
Description:
I'm trying to use the google cloud storage file system, but it would seem that
the FLINK /
[
https://issues.apache.org/jira/browse/FLINK-12355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830686#comment-16830686
]
Bowen Li commented on FLINK-12355:
--
saw another failure
[
https://issues.apache.org/jira/browse/FLINK-12355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-12355:
-
Affects Version/s: 1.9.0
> KafkaITCase.testTimestamps is unstable
>
[
https://issues.apache.org/jira/browse/FLINK-12355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-12355:
-
Fix Version/s: 1.9.0
> KafkaITCase.testTimestamps is unstable
> --
piyushnarang commented on issue #8117: [FLINK-12115] [filesystems]: Add support
for AzureFS
URL: https://github.com/apache/flink/pull/8117#issuecomment-488112927
@tillrohrmann do you know if there's any special setup required for the
flink e2e tests to run on developer machines? I'm
yanyan300300 commented on issue #8215: [FLINK-8801][yarn/s3] Fix jars
downloading issues due to inconsistent timestamp in S3 Filesystem
URL: https://github.com/apache/flink/pull/8215#issuecomment-488111519
@tillrohrmann @aljoscha Could you kindly review this change? Thanks!
Henrik created FLINK-12376:
--
Summary: GCS runtime exn: Request payload size exceeds the limit
Key: FLINK-12376
URL: https://issues.apache.org/jira/browse/FLINK-12376
Project: Flink
Issue Type: Bug
piyushnarang commented on a change in pull request #8117: [FLINK-12115]
[filesystems]: Add support for AzureFS
URL: https://github.com/apache/flink/pull/8117#discussion_r279896298
##
File path:
Adam Lamar created FLINK-12375:
--
Summary: flink-container job jar does not have read permissions
Key: FLINK-12375
URL: https://issues.apache.org/jira/browse/FLINK-12375
Project: Flink
Issue
yanyan300300 commented on issue #8215: [FLINK-8801][yarn/s3] Fix jars
downloading issues due to inconsistent timestamp in S3 Filesystem
URL: https://github.com/apache/flink/pull/8215#issuecomment-488062731
> Indeed, it looks like this is the better approach. Aside from some minor
details
yanyan300300 edited a comment on issue #8215: [FLINK-8801][yarn/s3] Fix jars
downloading issues due to inconsistent timestamp in S3 Filesystem
URL: https://github.com/apache/flink/pull/8215#issuecomment-488062731
> Indeed, it looks like this is the better approach. Aside from some minor
yanyan300300 commented on a change in pull request #8215: [FLINK-8801][yarn/s3]
Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem
URL: https://github.com/apache/flink/pull/8215#discussion_r279876022
##
File path:
yanyan300300 commented on a change in pull request #8215: [FLINK-8801][yarn/s3]
Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem
URL: https://github.com/apache/flink/pull/8215#discussion_r279873137
##
File path:
yanyan300300 commented on a change in pull request #8215: [FLINK-8801][yarn/s3]
Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem
URL: https://github.com/apache/flink/pull/8215#discussion_r279865426
##
File path:
yanyan300300 commented on a change in pull request #8215: [FLINK-8801][yarn/s3]
Fix jars downloading issues due to inconsistent timestamp in S3 Filesystem
URL: https://github.com/apache/flink/pull/8215#discussion_r279864771
##
File path:
flinkbot commented on issue #8325: [hotfix] [table] Refactor
GenericInMemoryCatalogTest to prepare for moving common tests to CatalogTestBase
URL: https://github.com/apache/flink/pull/8325#issuecomment-488043959
Thanks a lot for your contribution to the Apache Flink project. I'm the
bowenli86 opened a new pull request #8325: [hotfix] [table] Refactor
GenericInMemoryCatalogTest to prepare for moving common tests to CatalogTestBase
URL: https://github.com/apache/flink/pull/8325
## What is the purpose of the change
This PR refactors existing
[
https://issues.apache.org/jira/browse/FLINK-11475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-11475.
Resolution: Won't Fix
created GenericInMemoryCatalog from scratch
> Adapt existing
[
https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830474#comment-16830474
]
Rong Rong commented on FLINK-11921:
---
Thanks for the follow up [~ykt836]. I found the issue and it is
flinkbot commented on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19
URL: https://github.com/apache/flink/pull/8324#issuecomment-488032392
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
[
https://issues.apache.org/jira/browse/FLINK-11921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11921:
---
Labels: pull-request-available (was: )
> Upgrade Calcite dependency to 1.19
>
walterddr opened a new pull request #8324: [FLINK-11921][table] Upgrade to
calcite 1.19
URL: https://github.com/apache/flink/pull/8324
## What is the purpose of the change
This change upgrades apache calcite dependencies to 1.19.0 release.
## Brief change log
-
bowenli86 commented on a change in pull request #8314: [FLINK-12365][table] Add
stats related catalog APIs
URL: https://github.com/apache/flink/pull/8314#discussion_r279839941
##
File path:
zhijiangW commented on issue #7822: [FLINK-11726][network] Refactor the
creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#issuecomment-488025285
I updated the codes for addressing the left comments. @azagrebin
Regarding
zhijiangW commented on a change in pull request #7822: [FLINK-11726][network]
Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#discussion_r279837029
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830423#comment-16830423
]
dalongliu commented on FLINK-11637:
---
Hi, [~klion26] Is anyone doing the work now？
> Translate
zhijiangW commented on a change in pull request #7822: [FLINK-11726][network]
Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#discussion_r279816732
##
File path:
zhijiangW commented on a change in pull request #7822: [FLINK-11726][network]
Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#discussion_r279814078
##
File path:
zhijiangW commented on a change in pull request #7822: [FLINK-11726][network]
Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#discussion_r279814078
##
File path:
flinkbot commented on issue #8323: [BP-1.7][FLINK-12296][StateBackend] Fix
local state directory collision with state loss for chained keyed operators
URL: https://github.com/apache/flink/pull/8323#issuecomment-488000878
Thanks a lot for your contribution to the Apache Flink project. I'm
klion26 opened a new pull request #8323: [BP-1.7][FLINK-12296][StateBackend]
Fix local state directory collision with state loss for chained keyed operators
URL: https://github.com/apache/flink/pull/8323
## What is the purpose of the change
manual cherry-pick #8263 to
klion26 commented on issue #8313:
[FLINK-12184][Coordination]HistoryServerArchieFetcher incompatible with old
version
URL: https://github.com/apache/flink/pull/8313#issuecomment-487998692
@tillrohrmann thanks for the quick review.
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-48798
I opened a issuse before, it describe a scene that containts two steps.
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-48798
I opened a issuse before, it describe a scene that containts two steps.
flinkbot edited a comment on issue #8233: [FLINK-12227] [runtime] introduce
SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#issuecomment-485317615
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to
GJL commented on issue #8233: [FLINK-12227] [runtime] introduce
SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#issuecomment-487985822
@flinkbot approve-until architecture
This is an automated
GJL edited a comment on issue #8233: [FLINK-12227] [runtime] introduce
SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#issuecomment-487985288
Thanks for your contribution to Apache Flink, @shuai-xu! The changes look
overall good, and I have left a few minor
GJL commented on issue #8233: [FLINK-12227] [runtime] introduce
SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#issuecomment-487985288
Thanks for your contribution to Apache Flink @shuai-xu. The changes look
overall good, and I have left a few minor comments.
GJL commented on a change in pull request #8233: [FLINK-12227] [runtime]
introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r279792812
##
File path:
GJL commented on a change in pull request #8233: [FLINK-12227] [runtime]
introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r279786441
##
File path:
GJL commented on a change in pull request #8233: [FLINK-12227] [runtime]
introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r279758565
##
File path:
GJL commented on a change in pull request #8233: [FLINK-12227] [runtime]
introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r279788463
##
File path:
GJL commented on a change in pull request #8233: [FLINK-12227] [runtime]
introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r279633733
##
File path:
GJL commented on a change in pull request #8233: [FLINK-12227] [runtime]
introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r279792342
##
File path:
GJL commented on a change in pull request #8233: [FLINK-12227] [runtime]
introduce SchedulingStrategy interface
URL: https://github.com/apache/flink/pull/8233#discussion_r279787045
##
File path:
lamber-ken commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-48798
I opened a issuse before, it describe a scene that containts two steps.
[
https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830362#comment-16830362
]
Zhenqiu Huang commented on FLINK-12343:
---
[~till.rohrmann]
I agree that we shouldn't define a
Jing Zhang created FLINK-12374:
--
Summary: Support translation from
StreamExecTableSourceScan/BatchExecTableSourceScan to StreamTransformation.
Key: FLINK-12374
URL: https://issues.apache.org/jira/browse/FLINK-12374
lamber-ken commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-487979406
ok，I agree with you
tillrohrmann commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-487977504
It is true that Yarn could try to restart the cluster depending on the
[
https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830343#comment-16830343
]
Till Rohrmann commented on FLINK-12343:
---
I think the {{ResourceManager}} also sets up some local
azagrebin commented on a change in pull request #8320:
[FLINK-12201][network][metrics] Introduce InputGateWithMetrics in Task to
increment numBytesIn metric
URL: https://github.com/apache/flink/pull/8320#discussion_r279770711
##
File path:
azagrebin commented on a change in pull request #8320:
[FLINK-12201][network][metrics] Introduce InputGateWithMetrics in Task to
increment numBytesIn metric
URL: https://github.com/apache/flink/pull/8320#discussion_r279764419
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-12343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830330#comment-16830330
]
Zhenqiu Huang commented on FLINK-12343:
---
[~till.rohrmann][~rmetzger]
I think we can set the
HuangZhenQiu commented on issue #8303: [FLINK-12343]add file replication config
for yarn configuration
URL: https://github.com/apache/flink/pull/8303#issuecomment-487964624
@rmetzger @tillrohrmann
I think we can set the hdfs.replication in YarnConfiguration of
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-487951795
I have a question that if use `System.exit` to kill the JobManager，the Yarn
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-487951795
I have a question that if use `System.exit` to kill the JobManager，the Yarn
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-487951795
I have a question that if use `System.exit` to kill the JobManager，the
lamber-ken commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-487951795
but, another problem is I can't re-open this issue again
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-487950703
Your solution is fantastic @tillrohrmann!
I known the reason，but I'm
lamber-ken commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-487950703
Your solution is fantastic @tillrohrmann!
I known the reason，but I'm sorry
[
https://issues.apache.org/jira/browse/FLINK-12184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-12184:
-
Assignee: Congxian Qiu(klion26)
> HistoryServerArchiveFetcher isn't compatible with
tillrohrmann commented on a change in pull request #8313:
[FLINK-12184][Coordination]HistoryServerArchieFetcher incompatible with old
version
URL: https://github.com/apache/flink/pull/8313#discussion_r279748455
##
File path:
yanghua commented on issue #8322: [FLINK-12364] Introduce a
CheckpointFailureManager to centralized manage checkpoint failure
URL: https://github.com/apache/flink/pull/8322#issuecomment-487947096
@StefanRRichter This is the second step's PR of the checkpoint failure
process improvement.
[
https://issues.apache.org/jira/browse/FLINK-12364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12364:
---
Labels: pull-request-available (was: )
> Introduce a CheckpointFailureManager to
flinkbot commented on issue #8322: [FLINK-12364] Introduce a
CheckpointFailureManager to centralized manage checkpoint failure
URL: https://github.com/apache/flink/pull/8322#issuecomment-487944247
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help
yanghua opened a new pull request #8322: [FLINK-12364] Introduce a
CheckpointFailureManager to centralized manage checkpoint failure
URL: https://github.com/apache/flink/pull/8322
## What is the purpose of the change
*This pull request introduces a CheckpointFailureManager to
[
https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16830265#comment-16830265
]
Nico Kruber commented on FLINK-10317:
-
I'm actually unsure whether we should set a default now,
It
tillrohrmann commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-487940319
As I've said before, the archiving handlers belong to Flink and if they are
[
https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16725939#comment-16725939
]
Nico Kruber edited comment on FLINK-10317 at 4/30/19 12:51 PM:
---
-Actually
hequn8128 commented on issue #8230: [FLINK-10977][table] Add streaming
non-window FlatAggregate to Table API
URL: https://github.com/apache/flink/pull/8230#issuecomment-487938937
@sunjincheng121 Thank you very much for your continues review and
suggestions. I have addressed all your
flinkbot commented on issue #8321: [FLINK-12351][DataStream] Fix
AsyncWaitOperator to deep copy StreamElement when object reuse is enabled
URL: https://github.com/apache/flink/pull/8321#issuecomment-487935686
Thanks a lot for your contribution to the Apache Flink project. I'm the
[
https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12351:
---
Labels: pull-request-available (was: )
> AsyncWaitOperator should deep copy StreamElement
wuchong opened a new pull request #8321: [FLINK-12351][DataStream] Fix
AsyncWaitOperator to deep copy StreamElement when object reuse is enabled
URL: https://github.com/apache/flink/pull/8321
## What is the purpose of the change
Currently, AsyncWaitOperator directly put
1 - 100 of 289 matches
Mail list logo
