flinkbot commented on issue #7834: [FLINK-11715][table-planner-blink] Add
optimize program to organize optimization phases
URL: https://github.com/apache/flink/pull/7834#issuecomment-467315881
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the com
godfreyhe opened a new pull request #7834: [FLINK-11715][table-planner-blink]
Add optimize program to organize optimization phases
URL: https://github.com/apache/flink/pull/7834
## What is the purpose of the change
This commit adds optimize program to organize optimization phases.
[
https://issues.apache.org/jira/browse/FLINK-11715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11715:
---
Labels: pull-request-available (was: )
> Add optimize program to organize optimization phas
Myasuka commented on issue #7832: [FLINK-11748]Optimize savepoint: Remove the
task states and KeyedState into increments.
URL: https://github.com/apache/flink/pull/7832#issuecomment-467311487
@Mr-Nineteen Thanks for your idea. However, I think it would be unnecessary
to introduce `Savepoin
[
https://issues.apache.org/jira/browse/FLINK-11091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11091:
Affects Version/s: 1.9.0
> Clear the use of deprecated methods of KeyedStream in table operators
>
[
https://issues.apache.org/jira/browse/FLINK-10875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777616#comment-16777616
]
sunjincheng commented on FLINK-10875:
-
Did not find a better way.
close JIRA first.
[
https://issues.apache.org/jira/browse/FLINK-10875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-10875.
---
Resolution: Won't Fix
Release Note:
Did not find a better way.
close JIRA first
Will
> Add
wuchong commented on a change in pull request #7817:
[FLINK-11702][table-planner-blink] Introduce a new table type system:
InternalType
URL: https://github.com/apache/flink/pull/7817#discussion_r260119864
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache
wuchong commented on a change in pull request #7817:
[FLINK-11702][table-planner-blink] Introduce a new table type system:
InternalType
URL: https://github.com/apache/flink/pull/7817#discussion_r260134823
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache
wuchong commented on a change in pull request #7817:
[FLINK-11702][table-planner-blink] Introduce a new table type system:
InternalType
URL: https://github.com/apache/flink/pull/7817#discussion_r260129503
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache
wuchong commented on a change in pull request #7817:
[FLINK-11702][table-planner-blink] Introduce a new table type system:
InternalType
URL: https://github.com/apache/flink/pull/7817#discussion_r260132981
##
File path:
flink-table/flink-table-planner-blink/src/test/java/org/apache
sunhaibotb commented on a change in pull request #7797: [FLINK-11379] Fix
OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD
URL: https://github.com/apache/flink/pull/7797#discussion_r260120081
##
File path: flink-core/src/main/java/org/apache/flink/util/
sunjincheng121 commented on a change in pull request #7797: [FLINK-11379] Fix
OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD
URL: https://github.com/apache/flink/pull/7797#discussion_r260119340
##
File path: flink-core/src/main/java/org/apache/flink/u
sunjincheng121 commented on a change in pull request #7797: [FLINK-11379] Fix
OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD
URL: https://github.com/apache/flink/pull/7797#discussion_r260119340
##
File path: flink-core/src/main/java/org/apache/flink/u
sunjincheng121 commented on a change in pull request #7797: [FLINK-11379] Fix
OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD
URL: https://github.com/apache/flink/pull/7797#discussion_r260116294
##
File path: flink-core/src/main/java/org/apache/flink/u
[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777549#comment-16777549
]
zhijiang commented on FLINK-6227:
-
The initial motivation of this task is to give a hint/
sunjincheng121 commented on a change in pull request #7797: [FLINK-11379] Fix
OutOfMemoryError caused by Files.readAllBytes() when TM loads a large size TDD
URL: https://github.com/apache/flink/pull/7797#discussion_r260116294
##
File path: flink-core/src/main/java/org/apache/flink/u
TisonKun created FLINK-11749:
Summary: Returns the stored leadership on
ZooKeeperLeaderRetrievalService stated
Key: FLINK-11749
URL: https://issues.apache.org/jira/browse/FLINK-11749
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun updated FLINK-11749:
-
Summary: Returns the stored leadership info on
ZooKeeperLeaderRetrievalService started (was: Returns th
[
https://issues.apache.org/jira/browse/FLINK-11748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11748:
---
Labels: pull-request-available (was: )
> Optimize savepoint: Remove the task states and Key
flinkbot commented on issue #7832: [FLINK-11748]Optimize savepoint: Remove the
task states and KeyedState into increments.
URL: https://github.com/apache/flink/pull/7832#issuecomment-467276873
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the com
Mr-Nineteen opened a new pull request #7832: [FLINK-11748]Optimize savepoint:
Remove the task states and KeyedState into increments.
URL: https://github.com/apache/flink/pull/7832
The optimized savepoint (v3) comes from the blink branch.
After verification, I want to merge into the main
Mr.Nineteen created FLINK-11748:
---
Summary: Optimize savepoint: Remove the task states and KeyedState
into increments.
Key: FLINK-11748
URL: https://issues.apache.org/jira/browse/FLINK-11748
Project: Fli
tzulitai commented on issue #7818: [FLINK-11740] [core] Clarify
CompositeTypeSerializerSnapshot class signature
URL: https://github.com/apache/flink/pull/7818#issuecomment-467272592
Thanks for the review @igalshilman! I'll proceed to merge this PR.
-
tzulitai commented on a change in pull request #7818: [FLINK-11740] [core]
Clarify CompositeTypeSerializerSnapshot class signature
URL: https://github.com/apache/flink/pull/7818#discussion_r260106820
##
File path:
flink-scala/src/main/java/org/apache/flink/api/scala/typeutils/Tuple
[
https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777512#comment-16777512
]
Yadong Xie commented on FLINK-10705:
Hi [~StephanEwen] [~wolli] [~rmetzger]
Thanks
[
https://issues.apache.org/jira/browse/FLINK-11733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777503#comment-16777503
]
vinoyang commented on FLINK-11733:
--
Hi [~fhueske] The access modifier about map method
[
https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-10867:
Assignee: (was: vinoyang)
> Add a DataSet-based CacheOperator to reuse results between jobs
>
[
https://issues.apache.org/jira/browse/FLINK-11737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777496#comment-16777496
]
vinoyang commented on FLINK-11737:
--
[~StephanEwen] updated. Constructing
{{org.apache.
tzulitai commented on issue #7726: [FLINK-10342] Filter restored partitions
with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#issuecomment-467265871
@fengli one comment about addressing reviews:
Unless necessary, I suggest to only push follow-up commits to addr
[
https://issues.apache.org/jira/browse/FLINK-11737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11737:
-
Summary: Support org.apache.hadoop.mapreduce.lib.output.MultipleOutputs
output (was: Support MultipleOu
tzulitai commented on a change in pull request #7726: [FLINK-10342] Filter
restored partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#discussion_r260100624
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink
[
https://issues.apache.org/jira/browse/FLINK-11737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11737:
-
Description: This issue is to improve Flink's compatibility with Hadoop.
Currently, for the old version
tzulitai commented on a change in pull request #7726: [FLINK-10342] Filter
restored partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#discussion_r260099148
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink
vthinkxie edited a comment on issue #7086: [FLINK-10858] Create Angular
Scaffold in Flink Dashboard
URL: https://github.com/apache/flink/pull/7086#issuecomment-467259258
@rmetzger
thanks for your review, I will submit another pr including all feature and
commits later
vthinkxie edited a comment on issue #7086: [FLINK-10858] Create Angular
Scaffold in Flink Dashboard
URL: https://github.com/apache/flink/pull/7086#issuecomment-467259258
@rmetzger
thanks for your review!
I will submit another pr including all feature and commits later
--
vthinkxie commented on issue #7086: [FLINK-10858] Create Angular Scaffold in
Flink Dashboard
URL: https://github.com/apache/flink/pull/7086#issuecomment-467259258
@rmetzger
thanks for your review, I will submit another pr including all feature and
commits
-
[
https://issues.apache.org/jira/browse/FLINK-11747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samir Desai updated FLINK-11747:
Description:
In the Elasticsearch6 connector, the
[RestClientFactory|https://github.com/apache/fl
[
https://issues.apache.org/jira/browse/FLINK-11747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samir Desai updated FLINK-11747:
Issue Type: Improvement (was: Wish)
> Elasticsearch 6 connector - Expose RestHighLevelClient to a
[
https://issues.apache.org/jira/browse/FLINK-11747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samir Desai updated FLINK-11747:
Summary: Elasticsearch 6 connector - Expose RestHighLevelClient to allow
for custom sniffing (was
Samir Desai created FLINK-11747:
---
Summary: Elasticsearch6 - Expose RestHighLevelClient to allow for
custom sniffing
Key: FLINK-11747
URL: https://issues.apache.org/jira/browse/FLINK-11747
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-7243.
Resolution: Implemented
Fix Version/s: 1.9.0
Implemented for 1.9.0 with d015ce7a3b86a529f4db
fengli commented on a change in pull request #7726: [FLINK-10342] Filter
restored partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#discussion_r260052216
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/s
glaksh100 commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r260050222
##
File path:
flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/str
fhueske closed pull request #6873: [hotfix] Add Review Progress section to PR
description template.
URL: https://github.com/apache/flink/pull/6873
This is an automated message from the Apache Git Service.
To respond to the m
asfgit closed pull request #6483: [FLINK-7243][flink-formats] Add parquet input
format
URL: https://github.com/apache/flink/pull/6483
This is an automated message from the Apache Git Service.
To respond to the message, pleas
fengli commented on a change in pull request #7726: [FLINK-10342] Filter
restored partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#discussion_r260021890
##
File path:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/s
Xeli commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added
PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r260012933
##
File path:
flink-connectors/flink-connector-pubsub/src/main/ja
rmetzger commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r260006793
##
File path:
flink-connectors/flink-connector-pubsub/src/mai
fhueske commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input
format
URL: https://github.com/apache/flink/pull/6483#issuecomment-467169678
Thanks for the update @HuangZhenQiu.
I'll do some final minor changes and will merge the PR.
Thanks for your patience and endura
rmetzger commented on issue #7086: [FLINK-10858] Create Angular Scaffold in
Flink Dashboard
URL: https://github.com/apache/flink/pull/7086#issuecomment-467163863
@zentol This change adds the following dependencies
```
@angular-devkit/build-angular 0.10.7 : MIT License
@angular/ani
Xeli commented on a change in pull request #6594: [FLINK-9311] [pubsub] Added
PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r259971965
##
File path:
flink-connectors/flink-connector-pubsub/src/main/ja
rmetzger commented on issue #7086: [FLINK-10858] Create Angular Scaffold in
Flink Dashboard
URL: https://github.com/apache/flink/pull/7086#issuecomment-467135622
Overall, the new UI looks very nice. I'm very excited about this change :)
> Support GPU calculations
> -
[
https://issues.apache.org/jira/browse/FLINK-10867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777121#comment-16777121
]
Stephan Ewen edited comment on FLINK-10867 at 2/25/19 5:35 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-11737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777115#comment-16777115
]
Stephan Ewen commented on FLINK-11737:
--
What exactly is this feature proposal? Coul
[
https://issues.apache.org/jira/browse/FLINK-11199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-11199:
Assignee: Jiangjie Qin
> Support interactive programming in Flink
> -
[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777098#comment-16777098
]
Aleksandr Salatich commented on FLINK-6227:
---
Yes, it's really pretty hard to un
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777070#comment-16777070
]
Dawid Wysakowicz commented on FLINK-11654:
--
Just thinking out loud... I am not
tzulitai commented on a change in pull request #7726: [FLINK-10342] Filter
restored partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#discussion_r259889775
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink
tzulitai commented on a change in pull request #7726: [FLINK-10342] Filter
restored partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#discussion_r259889775
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink
flinkbot edited a comment on issue #7726: [FLINK-10342] Filter restored
partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#issuecomment-464515662
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
tzulitai commented on a change in pull request #7726: [FLINK-10342] Filter
restored partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#discussion_r259889775
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink
tzulitai commented on issue #7726: [FLINK-10342] Filter restored partitions
with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#issuecomment-467078148
@flinkbot approve quality
This is an automated me
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777053#comment-16777053
]
Aljoscha Krettek commented on FLINK-11654:
--
We could use the {{client.id}} sett
TisonKun commented on a change in pull request #7809: [FLINK-11710][tests]
Refactor SimpleSlotProvider to TestingLogicalSlo…
URL: https://github.com/apache/flink/pull/7809#discussion_r259903358
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/Al
StefanRRichter commented on a change in pull request #7813: [FLINK-10712]
Support to restore state when using RestartPipelinedRegionStrategy
URL: https://github.com/apache/flink/pull/7813#discussion_r259902872
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/execu
flinkbot commented on issue #7831: [FLINK-9685] Adding support
hostname-substitution for security.kerberos login.principal
URL: https://github.com/apache/flink/pull/7831#issuecomment-467074455
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the co
Salatich opened a new pull request #7831: [FLINK-9685] Adding support
hostname-substitution for security.kerberos login.principal
URL: https://github.com/apache/flink/pull/7831
## What is the purpose of the change
Flink should support hostname-substitution for
security.kerb
flinkbot edited a comment on issue #7794: [FLINK-9685] Adding support
hostname-substitution for security.kerberos login.principal
URL: https://github.com/apache/flink/pull/7794#issuecomment-466014768
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help
Salatich closed pull request #7794: [FLINK-9685] Adding support
hostname-substitution for security.kerberos login.principal
URL: https://github.com/apache/flink/pull/7794
This is an automated message from the Apache Git Serv
flinkbot edited a comment on issue #7809: [FLINK-11710][tests] Refactor
SimpleSlotProvider to TestingLogicalSlo…
URL: https://github.com/apache/flink/pull/7809#issuecomment-466376137
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
TisonKun commented on a change in pull request #7809: [FLINK-11710][tests]
Refactor SimpleSlotProvider to TestingLogicalSlo…
URL: https://github.com/apache/flink/pull/7809#discussion_r259897603
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/Al
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777038#comment-16777038
]
Aljoscha Krettek commented on FLINK-11654:
--
On the second point, something like
tzulitai commented on a change in pull request #7726: [FLINK-10342] Filter
restored partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#discussion_r259891347
##
File path:
flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink
tzulitai commented on a change in pull request #7726: [FLINK-10342] Filter
restored partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#discussion_r259889775
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink
tzulitai commented on a change in pull request #7726: [FLINK-10342] Filter
restored partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#discussion_r259890790
##
File path:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink
[
https://issues.apache.org/jira/browse/FLINK-11335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777023#comment-16777023
]
Dawid Wysakowicz commented on FLINK-11335:
--
Are you sure that no offsets are co
tillrohrmann commented on a change in pull request #7809: [FLINK-11710][tests]
Refactor SimpleSlotProvider to TestingLogicalSlo…
URL: https://github.com/apache/flink/pull/7809#discussion_r259879291
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpoo
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777001#comment-16777001
]
Aljoscha Krettek commented on FLINK-11654:
--
I don't have a solution yet. Is the
flinkbot commented on issue #7830: [hotfix] Reduce and simplify code for column
creation in RocksDB backend
URL: https://github.com/apache/flink/pull/7830#issuecomment-467051279
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to re
azagrebin commented on issue #7830: [hotfix] Reduce and simplify code for
column creation in RocksDB backend
URL: https://github.com/apache/flink/pull/7830#issuecomment-467050990
cc @StefanRRichter, @carp84
This is an automa
azagrebin opened a new pull request #7830: [hotfix] Reduce and simplify code
for column creation in RocksDB backend
URL: https://github.com/apache/flink/pull/7830
## What is the purpose of the change
This PR is a simple refactoring of some RocksDB state backend code.
## Brief
dawidwys removed a comment on issue #7726: [FLINK-10342] Filter restored
partitions with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#issuecomment-467048535
@flinkbot disapprove architecture
This is
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16776983#comment-16776983
]
Aljoscha Krettek commented on FLINK-11654:
--
I think we need another fix for thi
dawidwys commented on issue #7726: [FLINK-10342] Filter restored partitions
with discovered partitions b…
URL: https://github.com/apache/flink/pull/7726#issuecomment-467048535
@flinkbot disapprove architecture
This is an auto
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-11654:
Assignee: (was: Aljoscha Krettek)
> Multiple transactional KafkaProducers wri
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-11654:
Assignee: Aljoscha Krettek
> Multiple transactional KafkaProducers writing to sam
1 - 100 of 271 matches
Mail list logo
