zhijiangW commented on issue #7549: [FLINK-11403][network] Remove
ResultPartitionConsumableNotifier from ResultPartition
URL: https://github.com/apache/flink/pull/7549#issuecomment-474706964
@azagrebin , thanks for reviews! I submitted a separate fixup commit for
addressing the method acce
[
https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11972:
Description:
Since the difference between 1.8.0 and 1.7.x is that 1.8.x does not put the
`hadoop-
[
https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11971:
Description:
When I did the end-to-end test under Mac OS, I found the following two problems:
1.
zhijiangW commented on a change in pull request #7549: [FLINK-11403][network]
Remove ResultPartitionConsumableNotifier from ResultPartition
URL: https://github.com/apache/flink/pull/7549#discussion_r267201040
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/net
[
https://issues.apache.org/jira/browse/FLINK-11970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11970:
Assignee: vinoyang
> TableEnvironment#registerFunction should overwrite if the same name function
[
https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11971:
Description:
When I did the end-to-end test under Mac OS, I found the following two problems:
1.
[
https://issues.apache.org/jira/browse/FLINK-11949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-11949.
--
Resolution: Implemented
Fix Version/s: 1.9.0
fixed in 4bd2db2abf73f233632a0f256ac00c30dba0c6ec
[
https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-11971:
---
Assignee: Hequn Cheng
> Fix `Command: start_kubernetes_if_not_ruunning failed` error
>
[
https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11971:
Summary: Fix `Command: start_kubernetes_if_not_ruunning failed` error
(was: The classpath is miss
[
https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11971:
Attachment: screenshot-1.png
> Fix `Command: start_kubernetes_if_not_ruunning failed` error
>
[
https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11971:
Summary: The classpath is missing the
`flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the e
[
https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11972:
Summary: The classpath is missing the
`flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the e
[
https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11972:
Description:
Since the difference between 1.8.0 and 1.7.x is that 1.8.x does not put the
`hadoop-
[
https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-11972:
---
Assignee: (was: Hequn Cheng)
> The classpath is missing the `flink-shaded-hadoop2-uber-
[
https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11972:
Attachment: (was: image-2019-03-20-14-04-17-933.png)
> The classpath is missing the `flink-sha
[
https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11971:
Description:
When I did the end-to-end test under Mac OS, I found the following two problems:
1.
[
https://issues.apache.org/jira/browse/FLINK-11971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11971:
Summary: Fix `Command: start_kubernetes_if_not_ruunning failed` error
(was: The classpath is miss
KurtYoung merged pull request #8001: [FLINK-11949][table-planner-blink]
Introduce DeclarativeAggregateFunction and AggsHandlerCodeGenerator to blink
planner
URL: https://github.com/apache/flink/pull/8001
This is an automate
[
https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11972:
Attachment: (was: image-2019-03-20-14-01-05-647.png)
> Fix `Command: start_kubernetes_if_not_r
[
https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-11972:
---
Assignee: Hequn Cheng
> Fix `Command: start_kubernetes_if_not_ruunning failed` error
>
[
https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11972:
Description:
When I did the end-to-end test under Mac OS, I found the following two problems:
1.
[
https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11972:
Description:
When I did the end-to-end test under Mac OS, I found the following two problems:
1.
[
https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11972:
Attachment: image-2019-03-20-14-04-17-933.png
> Fix `Command: start_kubernetes_if_not_ruunning fai
[
https://issues.apache.org/jira/browse/FLINK-11972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-11972:
Attachment: (was: image-2019-03-20-14-02-29-636.png)
> Fix `Command: start_kubernetes_if_not_r
sunjincheng created FLINK-11971:
---
Summary: The classpath is missing the
`flink-shaded-hadoop2-uber-2.8.3-1.8.0.jar` JAR during the end-to-end test.
Key: FLINK-11971
URL: https://issues.apache.org/jira/browse/FLINK-1
sunjincheng created FLINK-11972:
---
Summary: Fix `Command: start_kubernetes_if_not_ruunning failed`
error
Key: FLINK-11972
URL: https://issues.apache.org/jira/browse/FLINK-11972
Project: Flink
I
Jeff Zhang created FLINK-11970:
--
Summary: TableEnvironment#registerFunction should overwrite if the
same name function existed.
Key: FLINK-11970
URL: https://issues.apache.org/jira/browse/FLINK-11970
Pr
[
https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16796788#comment-16796788
]
Jiangjie Qin commented on FLINK-11912:
--
[~suez1224] Thanks for bringing this up. Th
TisonKun commented on issue #7971: [FLINK-11897][tests] should wait all
submitTask methods executed,befo…
URL: https://github.com/apache/flink/pull/7971#issuecomment-474678271
@chummyhe89 I think the community is busy with releasing 1.8 and ASF Project
consists of all volunteers. Sorry for
zhijiangW commented on a change in pull request #7549: [FLINK-11403][network]
Remove ResultPartitionConsumableNotifier from ResultPartition
URL: https://github.com/apache/flink/pull/7549#discussion_r267179415
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/net
zhijiangW commented on a change in pull request #7549: [FLINK-11403][network]
Remove ResultPartitionConsumableNotifier from ResultPartition
URL: https://github.com/apache/flink/pull/7549#discussion_r267178927
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streami
Matrix42 commented on issue #8011: [FLINK-11958][on-yarn] fix flink on windows
yarn deploy failed
URL: https://github.com/apache/flink/pull/8011#issuecomment-474674276
before:
URL: https://github.com/apache/flink/pull/8009
--
Matrix42 commented on a change in pull request #8011: [FLINK-11958][on-yarn]
fix flink on windows yarn deploy failed
URL: https://github.com/apache/flink/pull/8011#discussion_r267170561
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
Matrix42 commented on a change in pull request #8011: [FLINK-11958][on-yarn]
fix flink on windows yarn deploy failed
URL: https://github.com/apache/flink/pull/8011#discussion_r267170387
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
chummyhe89 commented on issue #7992: [FLINK-11929][runtime] remove not used
transientBlobCache
URL: https://github.com/apache/flink/pull/7992#issuecomment-474663255
@tillrohrmann can you help me to review this pr? thanks.
Thi
chummyhe89 commented on issue #7971: [FLINK-11897][tests] should wait all
submitTask methods executed,befo…
URL: https://github.com/apache/flink/pull/7971#issuecomment-474662453
Please take a look. @tillrohrmann @zentol
This
[
https://issues.apache.org/jira/browse/FLINK-11960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11960:
---
Component/s: (was: API / Table SQL)
SQL / Planner
> Verify builtin Blink Table
Jingsong Lee created FLINK-11968:
Summary: Fix runtime SingleElementIterator.iterator and remove
table.SingleElementIterator
Key: FLINK-11968
URL: https://issues.apache.org/jira/browse/FLINK-11968
Pro
[
https://issues.apache.org/jira/browse/FLINK-11854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11854:
---
Component/s: (was: API / Table SQL)
SQL / Planner
> Introduce batch physical no
Hequn Cheng created FLINK-11969:
---
Summary: Add end2end stream sql test for unbounded operators
Key: FLINK-11969
URL: https://issues.apache.org/jira/browse/FLINK-11969
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-11946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-11946.
--
Resolution: Implemented
Assignee: Jing Zhang
Fix Version/s: 1.9.0
fixed in 475a88c26a0
[
https://issues.apache.org/jira/browse/FLINK-11946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11946:
---
Component/s: (was: API / Table SQL)
SQL / Planner
> Introduce ExecNode
> --
JingsongLi commented on a change in pull request #8001:
[FLINK-11949][table-planner-blink] Introduce DeclarativeAggregateFunction and
AggsHandlerCodeGenerator to blink planner
URL: https://github.com/apache/flink/pull/8001#discussion_r267166984
##
File path:
flink-table/flink-tabl
[
https://issues.apache.org/jira/browse/FLINK-11712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11712:
---
Component/s: (was: API / Table SQL)
SQL / Planner
> Add cost model for both bat
[
https://issues.apache.org/jira/browse/FLINK-11822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11822:
---
Component/s: (was: API / Table SQL)
SQL / Planner
> Introduce Flink metadata ha
[
https://issues.apache.org/jira/browse/FLINK-11842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11842:
---
Component/s: (was: API / Table SQL)
SQL / Planner
> Introduce FlinkLogicalMatch
[
https://issues.apache.org/jira/browse/FLINK-11840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11840:
---
Component/s: (was: API / Table SQL)
SQL / Planner
> Introduce FlinkLogicalSnaps
[
https://issues.apache.org/jira/browse/FLINK-11841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11841:
---
Component/s: (was: API / Table SQL)
SQL / Planner
> Introduce FlinkLogicalSemiJ
[
https://issues.apache.org/jira/browse/FLINK-11896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11896:
---
Component/s: (was: API / Table SQL)
SQL / Planner
> Introduce stream physical n
[
https://issues.apache.org/jira/browse/FLINK-11945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11945:
---
Component/s: (was: API / Table SQL)
SQL / Planner
Runtime / Ope
[
https://issues.apache.org/jira/browse/FLINK-11943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11943:
---
Component/s: (was: API / Table SQL)
SQL / Planner
Runtime / Ope
[
https://issues.apache.org/jira/browse/FLINK-11932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11932:
---
Component/s: (was: API / Table SQL)
SQL / Planner
> Add support for generating
[
https://issues.apache.org/jira/browse/FLINK-11944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11944:
---
Component/s: (was: API / Table SQL)
SQL / Planner
Runtime / Ope
[
https://issues.apache.org/jira/browse/FLINK-11966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-11966:
---
Component/s: (was: API / Table SQL)
SQL / Planner
> Add support for generating
[
https://issues.apache.org/jira/browse/FLINK-11946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11946:
---
Labels: pull-request-available (was: )
> Introduce ExecNode
> --
>
>
KurtYoung merged pull request #8010: [FLINK-11946][table-planner-blink]
Introduce ExecNode to blink planner
URL: https://github.com/apache/flink/pull/8010
This is an automated message from the Apache Git Service.
To respond
JingsongLi commented on a change in pull request #8001:
[FLINK-11949][table-planner-blink] Introduce DeclarativeAggregateFunction and
AggsHandlerCodeGenerator to blink planner
URL: https://github.com/apache/flink/pull/8001#discussion_r267165448
##
File path:
flink-table/flink-tabl
[
https://issues.apache.org/jira/browse/FLINK-11848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16796694#comment-16796694
]
frank wang commented on FLINK-11848:
props.setProperty(FlinkKafkaConsumerBase.KEY_PA
klion26 commented on a change in pull request #8008: [FLINK-11963][History
Server]Add time-based cleanup mechanism in history server
URL: https://github.com/apache/flink/pull/8008#discussion_r267163437
##
File path:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonito
JingsongLi commented on a change in pull request #8001:
[FLINK-11949][table-planner-blink] Introduce DeclarativeAggregateFunction and
AggsHandlerCodeGenerator to blink planner
URL: https://github.com/apache/flink/pull/8001#discussion_r267162956
##
File path:
flink-table/flink-tabl
[
https://issues.apache.org/jira/browse/FLINK-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dong reassigned FLINK-7391:
---
Assignee: (was: dong)
> Normalize release entries
> -
>
> Key: F
KurtYoung commented on issue #8010: [FLINK-11946][table-planner-blink]
Introduce ExecNode to blink planner
URL: https://github.com/apache/flink/pull/8010#issuecomment-474653633
LGTM, +1
This is an automated message from the A
JingsongLi commented on issue #8003: [FLINK-11951][table-common] Enhance
UserDefinedFunction interface to allow more user defined types
URL: https://github.com/apache/flink/pull/8003#issuecomment-474653408
> Merging this change to `flink-table-common` would introduce instant legacy
as we a
[
https://issues.apache.org/jira/browse/FLINK-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dong reassigned FLINK-7391:
---
Assignee: dong (was: Neelesh Srinivas Salian)
> Normalize release entries
> -
>
>
yanghua commented on issue #6489: [FLINK-10054] Add
getMaxParallelism/setMaxParallelism API for PythonStreamExecutionEnvironment
URL: https://github.com/apache/flink/pull/6489#issuecomment-474651884
closing this PR...
This is
yanghua closed pull request #6489: [FLINK-10054] Add
getMaxParallelism/setMaxParallelism API for PythonStreamExecutionEnvironment
URL: https://github.com/apache/flink/pull/6489
This is an automated message from the Apache Gi
yanghua commented on issue #6487: [FLINK-10053] Add getParallelism API for
PythonStreamExecutionEnvironment
URL: https://github.com/apache/flink/pull/6487#issuecomment-474651774
Closing this PR cc @zentol
This is an automate
yanghua closed pull request #6487: [FLINK-10053] Add getParallelism API for
PythonStreamExecutionEnvironment
URL: https://github.com/apache/flink/pull/6487
This is an automated message from the Apache Git Service.
To respond
beyond1920 commented on a change in pull request #8010:
[FLINK-11946][table-planner-blink] Introduce ExecNode to blink planner
URL: https://github.com/apache/flink/pull/8010#discussion_r267159417
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/ta
beyond1920 commented on a change in pull request #8010:
[FLINK-11946][table-planner-blink] Introduce ExecNode to blink planner
URL: https://github.com/apache/flink/pull/8010#discussion_r267159307
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/ta
KurtYoung commented on a change in pull request #8010:
[FLINK-11946][table-planner-blink] Introduce ExecNode to blink planner
URL: https://github.com/apache/flink/pull/8010#discussion_r267157093
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/tab
KurtYoung commented on a change in pull request #8010:
[FLINK-11946][table-planner-blink] Introduce ExecNode to blink planner
URL: https://github.com/apache/flink/pull/8010#discussion_r267157193
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/tab
KurtYoung commented on issue #8010: [FLINK-11949][table-planner-blink]
Introduce ExecNode to blink planner
URL: https://github.com/apache/flink/pull/8010#issuecomment-474645882
I think you attached to a wrong jira number
This
flinkbot commented on issue #8013: Minor example typo fix
URL: https://github.com/apache/flink/pull/8013#issuecomment-474627783
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
angoenka opened a new pull request #8013: Minor example typo fix
URL: https://github.com/apache/flink/pull/8013
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid r
[
https://issues.apache.org/jira/browse/FLINK-5182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright resolved FLINK-5182.
-
Resolution: Won't Fix
Closing as unimportant.
> Implement SSL file-shipping
> --
[
https://issues.apache.org/jira/browse/FLINK-3931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright resolved FLINK-3931.
-
Resolution: Fixed
> Implement Transport Encryption (SSL/TLS)
> --
[
https://issues.apache.org/jira/browse/FLINK-5029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright resolved FLINK-5029.
-
Resolution: Won't Fix
> Implement KvState SSL
> -
>
> Key: FL
[
https://issues.apache.org/jira/browse/FLINK-5029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16796554#comment-16796554
]
Eron Wright commented on FLINK-5029:
-
Any objection to resolving this as won't-fix?
[
https://issues.apache.org/jira/browse/FLINK-5029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright updated FLINK-5029:
Labels: (was: pull-request-available)
> Implement KvState SSL
> -
>
>
EronWright commented on issue #6626: [FLINK-5029] [QueryableState] SSL Support
URL: https://github.com/apache/flink/pull/6626#issuecomment-474597145
Closed the PR as "won't fix".
This is an automated message from the Apache Gi
[
https://issues.apache.org/jira/browse/FLINK-5029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright reassigned FLINK-5029:
---
Assignee: (was: Eron Wright )
> Implement KvState SSL
> -
>
>
EronWright closed pull request #6626: [FLINK-5029] [QueryableState] SSL Support
URL: https://github.com/apache/flink/pull/6626
This is an automated message from the Apache Git Service.
To respond to the message, please log on
suez1224 commented on issue #7978: [FLINK-11910] [Yarn] add customizable yarn
application type
URL: https://github.com/apache/flink/pull/7978#issuecomment-474586356
Instead of customize just the version, can we just let user override the
entire application type, which is more flexible?
-
flinkbot edited a comment on issue #7978: [FLINK-11910] [Yarn] add customizable
yarn application type
URL: https://github.com/apache/flink/pull/7978#issuecomment-472607121
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review y
suez1224 commented on issue #7978: [FLINK-11910] [Yarn] add customizable yarn
application type
URL: https://github.com/apache/flink/pull/7978#issuecomment-474584787
@flinkbot approve description
This is an automated message f
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r267077674
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityRoutine.java
##
GJL commented on a change in pull request #7986: [FLINK-10517][rest] Add
stability test
URL: https://github.com/apache/flink/pull/7986#discussion_r267077674
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/compatibility/CompatibilityRoutine.java
##
1 - 100 of 280 matches
Mail list logo
