[
https://issues.apache.org/jira/browse/FLINK-13158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882766#comment-16882766
]
vinoyang commented on FLINK-13158:
--
[~till.rohrmann] WDYT about this issue?
> Remove W
flinkbot commented on issue #9078: [FLINK-13186] Remove
dispatcherRetrievalService and dispatcherLeaderRetriever from RestClusterClient
URL: https://github.com/apache/flink/pull/9078#issuecomment-510395226
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
[
https://issues.apache.org/jira/browse/FLINK-13186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882764#comment-16882764
]
vinoyang commented on FLINK-13186:
--
Thanks [~till.rohrmann] Have opened a PR.
> Remove
[
https://issues.apache.org/jira/browse/FLINK-13186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13186:
---
Labels: pull-request-available (was: )
> Remove dispatcherRetrievalService and dispatcherLe
yanghua opened a new pull request #9078: [FLINK-13186] Remove
dispatcherRetrievalService and dispatcherLeaderRetriever from RestClusterClient
URL: https://github.com/apache/flink/pull/9078
## What is the purpose of the change
*This pull request remove dispatcherRetrievalService and
[
https://issues.apache.org/jira/browse/FLINK-11792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882759#comment-16882759
]
Jiangjie Qin commented on FLINK-11792:
--
[~knaufk] This is a little surprising. By d
flinkbot commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build to
Travis
URL: https://github.com/apache/flink/pull/8911#issuecomment-510392806
CI report for commit be72c6a2ba0a41a1a4819917d2cba5d58b0c6dc8: FAILURE
[Build](https://travis-ci.com/flink-ci/flink/builds/118705989)
StephanEwen commented on issue #9069: [FLINK-12297] Fixes
StackOverflowException of ClosureCleaner when cle…
URL: https://github.com/apache/flink/pull/9069#issuecomment-510391660
This PR needs a proper description before being picked up for reviewing.
--
tillrohrmann commented on issue #9043: [FLINK-13165] Complete slot requests in
request order
URL: https://github.com/apache/flink/pull/9043#issuecomment-510391603
Thanks for the review @StephanEwen. Rebasing and then merging this PR.
[
https://issues.apache.org/jira/browse/FLINK-13186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882755#comment-16882755
]
Till Rohrmann commented on FLINK-13186:
---
You are right [~yanghua]. The {{dispatche
[
https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-13184:
--
Issue Type: Improvement (was: Bug)
> Support launching task executors with multi-thread on YA
[
https://issues.apache.org/jira/browse/FLINK-13208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young updated FLINK-13208:
---
Summary: Update Notice file for upgrading calcite to 1.20 (was: Add Notice
file for upgrading calci
[
https://issues.apache.org/jira/browse/FLINK-13202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882751#comment-16882751
]
Till Rohrmann commented on FLINK-13202:
---
Thanks for reporting this issue [~ykt836]
[
https://issues.apache.org/jira/browse/FLINK-13202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-13202:
--
Labels: test-stability (was: )
> Unstable StandaloneResourceManagerTest
> ---
Kurt Young created FLINK-13208:
--
Summary: Add Notice file for upgrading calcite to 1.20
Key: FLINK-13208
URL: https://issues.apache.org/jira/browse/FLINK-13208
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-13202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-13202:
--
Priority: Critical (was: Major)
> Unstable StandaloneResourceManagerTest
> --
Xu Yang created FLINK-13207:
---
Summary: Add the algorithm of Fast Fourier Transformation(FFT)
Key: FLINK-13207
URL: https://issues.apache.org/jira/browse/FLINK-13207
Project: Flink
Issue Type: Sub-t
KurtYoung commented on issue #9056: [FLINK-13185] [sql-parser][table-planner]
Bump Calcite dependency to 1.20.0 in sql parser & flink planner
URL: https://github.com/apache/flink/pull/9056#issuecomment-510388355
> Hi guys, I think this PR changes Flink's dependencies. Whenever we change
de
[
https://issues.apache.org/jira/browse/FLINK-11768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882750#comment-16882750
]
yelun commented on FLINK-11768:
---
Hi [~tzulitai],can you give me more about this issue?than
flinkbot commented on issue #9074: [FLINK-13198] Introduce TimeInterval in
configuration package
URL: https://github.com/apache/flink/pull/9074#issuecomment-510387654
CI report for commit df6685a3394eeea7a6013f2a9f6c1b6bfeac87e5: FAILURE
[Build](https://travis-ci.com/flink-ci/flink/builds/
[
https://issues.apache.org/jira/browse/FLINK-11768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882744#comment-16882744
]
vinoyang commented on FLINK-11768:
--
Hi [~guanghui] this issue is hard to fix. Maybe [~t
zjuwangg created FLINK-13206:
Summary: modify 'use database' syntax in SQL CLI to be consistant
with standard sql
Key: FLINK-13206
URL: https://issues.apache.org/jira/browse/FLINK-13206
Project: Flink
tillrohrmann commented on issue #9056: [FLINK-13185]
[sql-parser][table-planner] Bump Calcite dependency to 1.20.0 in sql parser &
flink planner
URL: https://github.com/apache/flink/pull/9056#issuecomment-510384672
Hi guys, I think this PR changes Flink's dependencies. Whenever we change
[
https://issues.apache.org/jira/browse/FLINK-11768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882735#comment-16882735
]
yelun commented on FLINK-11768:
---
Hi，[~yanghua]，I wang to working this issue,can you explai
wangyang0918 commented on issue #8303: [FLINK-12343] [flink-yarn] add file
replication config for yarn configuration
URL: https://github.com/apache/flink/pull/8303#issuecomment-510381735
Hi @HuangZhenQiu
After investigation, i got the following conclusions.
1. The the default val
[
https://issues.apache.org/jira/browse/FLINK-13185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-13185.
--
Resolution: Implemented
Fix Version/s: 1.9.0
merged in 1.9.0: aad73766d450352b0baaf1b72bb7eb209
KurtYoung closed pull request #9056: [FLINK-13185] [sql-parser][table-planner]
Bump Calcite dependency to 1.20.0 in sql parser & flink planner
URL: https://github.com/apache/flink/pull/9056
This is an automated message from
TsReaper commented on issue #9074: [FLINK-13198] Introduce TimeInterval in
configuration package
URL: https://github.com/apache/flink/pull/9074#issuecomment-510380097
Thanks @twalthr for the comment. I think
`org.apache.flink.api.common.time.Time` has a different functionality compared
to
KurtYoung commented on issue #9056: [FLINK-13185] [sql-parser][table-planner]
Bump Calcite dependency to 1.20.0 in sql parser & flink planner
URL: https://github.com/apache/flink/pull/9056#issuecomment-510379752
Seem we have some irrelevant fails:
https://travis-ci.org/KurtYoung/flink/jo
[
https://issues.apache.org/jira/browse/FLINK-13198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng updated FLINK-13198:
Description: Similar with MemorySize in the configuration package, we also
need to introduce a Tim
tillrohrmann edited a comment on issue #9059: [FLINK-13141][network] Remove
getBufferSize method from BufferPoolFactory
URL: https://github.com/apache/flink/pull/9059#issuecomment-510376994
Before merging please make sure that Travis passes for the commit you are
merging @pnowojski. We jus
wuchong commented on issue #9074: [FLINK-13198] Introduce TimeInterval in
configuration package
URL: https://github.com/apache/flink/pull/9074#issuecomment-510377525
Thanks @TsReaper for the quick updating.
This is an automat
tillrohrmann commented on issue #9059: [FLINK-13141][network] Remove
getBufferSize method from BufferPoolFactory
URL: https://github.com/apache/flink/pull/9059#issuecomment-510376994
Before merging please make sure that Travis passes @pnowojski. We just broke
the master another time due to
wuchong commented on issue #9075: [FLINK-10245][hbase] Add an upsert table
sink factory for HBase
URL: https://github.com/apache/flink/pull/9075#issuecomment-510377192
@JingsongLi @carp84 comments are addressed. Sorry for commits squashed.
---
gaoyunhaii commented on issue #8556: [FLINK-12171][Network] Do not limit the
network buffer memory by heap size on the TM side
URL: https://github.com/apache/flink/pull/8556#issuecomment-510372551
Very thanks @NicoK for the review and sorry for missing the tests. I will
address the comment
wuchong commented on a change in pull request #9075: [FLINK-10245][hbase] Add
an upsert table sink factory for HBase
URL: https://github.com/apache/flink/pull/9075#discussion_r302406031
##
File path:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTab
flinkbot commented on issue #9075: [FLINK-10245][hbase] Add an upsert table
sink factory for HBase
URL: https://github.com/apache/flink/pull/9075#issuecomment-510371864
CI report for commit 4536c6466c74447b306212df544d04e543315997: FAILURE
[Build](https://travis-ci.com/flink-ci/flink/buil
JingsongLi commented on a change in pull request #9075: [FLINK-10245][hbase]
Add an upsert table sink factory for HBase
URL: https://github.com/apache/flink/pull/9075#discussion_r302405476
##
File path:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBase
Alex created FLINK-13205:
Summary: Checkpoints/savepoints injection has loose ordering
properties when a stop-with-savepoint is triggered
Key: FLINK-13205
URL: https://issues.apache.org/jira/browse/FLINK-13205
[
https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin closed FLINK-13204.
Resolution: Duplicate
I was looking at an outdated code base and the issue has been fixed in relea
[
https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated FLINK-13204:
-
Affects Version/s: (was: 1.8.0)
> The subscribedPartitionStates should be thread safe.
> ---
[
https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated FLINK-13204:
-
Fix Version/s: (was: 1.9.0)
> The subscribedPartitionStates should be thread safe.
> ---
[
https://issues.apache.org/jira/browse/FLINK-12998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882711#comment-16882711
]
Piotr Nowojski edited comment on FLINK-12998 at 7/11/19 7:41 AM:
-
wuchong commented on a change in pull request #9075: [FLINK-10245][hbase] Add
an upsert table sink factory for HBase
URL: https://github.com/apache/flink/pull/9075#discussion_r302403176
##
File path:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseWri
flinkbot commented on issue #9076: [FLINK-13200][Table SQL / Planner] Improve
the generated code for if statements
URL: https://github.com/apache/flink/pull/9076#issuecomment-510369615
CI report for commit ebbcb02c1f435e5c983e5815b2ca48720afb86fe: FAILURE
[Build](https://travis-ci.com/flin
[
https://issues.apache.org/jira/browse/FLINK-12998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882711#comment-16882711
]
Piotr Nowojski commented on FLINK-12998:
Just for the record, the documentation
[
https://issues.apache.org/jira/browse/FLINK-11956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-11956:
---
Priority: Critical (was: Blocker)
> Remove shading from filesystems build
> ---
carp84 commented on a change in pull request #9075: [FLINK-10245][hbase] Add
an upsert table sink factory for HBase
URL: https://github.com/apache/flink/pull/9075#discussion_r302396500
##
File path:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseWrit
carp84 commented on a change in pull request #9075: [FLINK-10245][hbase] Add
an upsert table sink factory for HBase
URL: https://github.com/apache/flink/pull/9075#discussion_r302377044
##
File path:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseOpti
carp84 commented on a change in pull request #9075: [FLINK-10245][hbase] Add
an upsert table sink factory for HBase
URL: https://github.com/apache/flink/pull/9075#discussion_r302379783
##
File path:
flink-connectors/flink-hbase/src/main/java/org/apache/flink/addons/hbase/HBaseTabl
[
https://issues.apache.org/jira/browse/FLINK-11956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882708#comment-16882708
]
Piotr Nowojski commented on FLINK-11956:
I've discussed this with [~StephanEwen]
[
https://issues.apache.org/jira/browse/FLINK-12939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882705#comment-16882705
]
yelun commented on FLINK-12939:
---
Hi,[~xujiang],do you still working on this issue?
> Tran
[
https://issues.apache.org/jira/browse/FLINK-13141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-13141.
Resolution: Resolved
Fixed in b6563e385263beb556ce19855ca6dfdbb7f6c853
> Remove getBufferSize method fro
[
https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-13204:
--
Assignee: Jiangjie Qin (was: Piotr Nowojski)
> The subscribedPartitionStates should
[
https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-13204:
--
Assignee: Piotr Nowojski
> The subscribedPartitionStates should be thread safe.
> ---
[
https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated FLINK-13204:
-
Fix Version/s: 1.9.0
> The subscribedPartitionStates should be thread safe.
> --
[
https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882701#comment-16882701
]
Piotr Nowojski edited comment on FLINK-12852 at 7/11/19 7:28 AM:
-
flinkbot commented on issue #9049: [FLINK-13176][SQL CLI] remember current
catalog and database in SQL CLI SessionContext
URL: https://github.com/apache/flink/pull/9049#issuecomment-510365136
CI report for commit aa354f24b53407035750303e78e1fb9d95b37673: SUCCESS
[Build](https://travis-ci.c
pnowojski merged pull request #9059: [FLINK-13141][network] Remove
getBufferSize method from BufferPoolFactory
URL: https://github.com/apache/flink/pull/9059
This is an automated message from the Apache Git Service.
To respo
JingsongLi commented on a change in pull request #8920: [FLINK-13024][table]
integrate FunctionCatalog with CatalogManager
URL: https://github.com/apache/flink/pull/8920#discussion_r302397775
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/
JingsongLi commented on a change in pull request #8920: [FLINK-13024][table]
integrate FunctionCatalog with CatalogManager
URL: https://github.com/apache/flink/pull/8920#discussion_r302397113
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/r
[
https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-12852.
--
Resolution: Fixed
Release Note: To avoid a potential deadlock, this adds a timeout (defau
JingsongLi commented on a change in pull request #8920: [FLINK-13024][table]
integrate FunctionCatalog with CatalogManager
URL: https://github.com/apache/flink/pull/8920#discussion_r302397256
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalo
JingsongLi commented on a change in pull request #8920: [FLINK-13024][table]
integrate FunctionCatalog with CatalogManager
URL: https://github.com/apache/flink/pull/8920#discussion_r302391899
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/f
JingsongLi commented on a change in pull request #8920: [FLINK-13024][table]
integrate FunctionCatalog with CatalogManager
URL: https://github.com/apache/flink/pull/8920#discussion_r302391575
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/f
Jiangjie Qin created FLINK-13204:
Summary: The subscribedPartitionStates should be thread safe.
Key: FLINK-13204
URL: https://issues.apache.org/jira/browse/FLINK-13204
Project: Flink
Issue Ty
twalthr commented on a change in pull request #8294:
[FLINK-12348][table-planner-blink]Use TableConfig in api module to replace
TableConfig in blink-planner module.
URL: https://github.com/apache/flink/pull/8294#discussion_r302395152
##
File path:
flink-table/flink-table-api-java/
twalthr commented on a change in pull request #8294:
[FLINK-12348][table-planner-blink]Use TableConfig in api module to replace
TableConfig in blink-planner module.
URL: https://github.com/apache/flink/pull/8294#discussion_r302393576
##
File path:
flink-table/flink-table-planner-b
TsReaper commented on a change in pull request #9029: [FLINK-13118][jdbc]
Introduce JDBC table factory and bridge JDBC table source with streaming table
source
URL: https://github.com/apache/flink/pull/9029#discussion_r302394858
##
File path:
flink-connectors/flink-jdbc/src/main/j
Piotr Nowojski created FLINK-13203:
--
Summary: [proper fix] Deadlock occurs when requiring exclusive
buffer for RemoteInputChannel
Key: FLINK-13203
URL: https://issues.apache.org/jira/browse/FLINK-13203
flinkbot commented on issue #9054: [FLINK-13183][Table]Add a PrintTableSink
URL: https://github.com/apache/flink/pull/9054#issuecomment-510358821
CI report for commit 67460681c852751f60d49993567aae5d9e4f319f: FAILURE
[Build](https://travis-ci.com/flink-ci/flink/builds/118704853)
--
[
https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-12852:
---
Summary: [hotfix timeout] Deadlock occurs when requiring exclusive buffer
for RemoteInputCha
[
https://issues.apache.org/jira/browse/FLINK-13201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882697#comment-16882697
]
Jingsong Lee commented on FLINK-13201:
--
Looks like there is not output row... The s
flinkbot commented on issue #8859: [FLINK-12905][table-planner] Enable querying
CatalogViews in legacy planner
URL: https://github.com/apache/flink/pull/8859#issuecomment-510358759
CI report for commit c2adafa7ee87b18ba6af0b5f518251150a8da386: FAILURE
[Build](https://travis-ci.com/flink-ci
twalthr commented on issue #8844: [FLINK-12951][table-planner] Add logic to
bridge DDL to table source(…
URL: https://github.com/apache/flink/pull/8844#issuecomment-510358524
Yes, this was also my intention in my previous comment. `sqlUpdate()` can
run multiple statements (DDL and DML) and
[
https://issues.apache.org/jira/browse/FLINK-12858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882692#comment-16882692
]
yelun commented on FLINK-12858:
---
Hi,[~1u0],can you give more description about this issue,
wuchong commented on issue #9074: [FLINK-13198] Introduce TimeLength in
configuration package
URL: https://github.com/apache/flink/pull/9074#issuecomment-510358202
Thanks @TsReaper .
LGTM.
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-12858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yelun reassigned FLINK-12858:
-
Assignee: (was: yelun)
> Potentially not properly working Flink job in case of stop-with-savepoint
klion26 commented on a change in pull request #9064: [FLINK-13188][Runtime /
State Backends][Test] Fix annotation type error in MockTtlStateTest
URL: https://github.com/apache/flink/pull/9064#discussion_r302390170
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/
601 - 679 of 679 matches
Mail list logo
