zentol merged pull request #8259: [FLINK-12325][metrics] Fix bug in statsd
exporter when using negative values
URL: https://github.com/apache/flink/pull/8259
This is an automated message from the Apache Git Service.
To respo
sunjincheng121 commented on issue #8377: [FLINK-12455][python] Move the
packaging of pyflink to flink-dist
URL: https://github.com/apache/flink/pull/8377#issuecomment-490767978
@flinkbot approve all
Merging
This is an auto
[
https://issues.apache.org/jira/browse/FLINK-12363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836141#comment-16836141
]
vinoyang commented on FLINK-12363:
--
OK, [~Zentol] Can you tell the plan how to process
zentol commented on a change in pull request #8377: [FLINK-12455][python] Move
the packaging of pyflink to flink-dist
URL: https://github.com/apache/flink/pull/8377#discussion_r282357816
##
File path: flink-dist/pom.xml
##
@@ -588,6 +588,31 @@ under the License.
[
https://issues.apache.org/jira/browse/FLINK-12363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836136#comment-16836136
]
Chesnay Schepler commented on FLINK-12363:
--
everything in that package is not l
flinkbot commented on issue #8379: [FLINK-12457][table-planner-blink] Remove
char support in blink
URL: https://github.com/apache/flink/pull/8379#issuecomment-490766764
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
[
https://issues.apache.org/jira/browse/FLINK-12457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12457:
---
Labels: pull-request-available (was: )
> Remove char support in blink
> ---
JingsongLi opened a new pull request #8379: [FLINK-12457][table-planner-blink]
Remove char support in blink
URL: https://github.com/apache/flink/pull/8379
## What is the purpose of the change
Sql types don't support java char. CharType(InternalType) in blink and
CharType of the new
Jingsong Lee created FLINK-12457:
Summary: Remove char support in blink
Key: FLINK-12457
URL: https://issues.apache.org/jira/browse/FLINK-12457
Project: Flink
Issue Type: Improvement
wuchong commented on a change in pull request #8360:
[FLINK-12393][table-common] Add the user-facing classes of the new type system
URL: https://github.com/apache/flink/pull/8360#discussion_r282355354
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table
JingsongLi commented on issue #8378: [FLINK-12453][table-planner-blink]
Simplify constructor of AggsHandlerCodeGenerator
URL: https://github.com/apache/flink/pull/8378#issuecomment-490764350
LGTM if travis green
This is an au
[
https://issues.apache.org/jira/browse/FLINK-12363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836129#comment-16836129
]
vinoyang commented on FLINK-12363:
--
What do you think? [~Zentol] [~till.rohrmann]
> Re
wuchong commented on a change in pull request #8360:
[FLINK-12393][table-common] Add the user-facing classes of the new type system
URL: https://github.com/apache/flink/pull/8360#discussion_r282354267
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table
[
https://issues.apache.org/jira/browse/FLINK-12455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836126#comment-16836126
]
sunjincheng commented on FLINK-12455:
-
Thanks, [~dian.fu] this issue can be done in
[
https://issues.apache.org/jira/browse/FLINK-12456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836120#comment-16836120
]
sunjincheng commented on FLINK-12456:
-
Thanks for mention this issue. [~lzljs3620320
wuchong opened a new pull request #8378: [FLINK-12453][table-planner-blink]
Simplify constructor of AggsHandlerCodeGenerator
URL: https://github.com/apache/flink/pull/8378
## What is the purpose of the change
Currently, the constructor of `AggsHandlerCodeGenerator` contains sever
[
https://issues.apache.org/jira/browse/FLINK-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12453:
---
Labels: pull-request-available (was: )
> StreamExecGlobalGroupAggregate construct wrong arg
flinkbot commented on issue #8378: [FLINK-12453][table-planner-blink] Simplify
constructor of AggsHandlerCodeGenerator
URL: https://github.com/apache/flink/pull/8378#issuecomment-490759827
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the communi
[
https://issues.apache.org/jira/browse/FLINK-12456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-12456:
Component/s: API / Python
> Wrong CharType convertion in type_utils.py
> -
twalthr commented on a change in pull request #8360:
[FLINK-12393][table-common] Add the user-facing classes of the new type system
URL: https://github.com/apache/flink/pull/8360#discussion_r282348005
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table
twalthr commented on a change in pull request #8360:
[FLINK-12393][table-common] Add the user-facing classes of the new type system
URL: https://github.com/apache/flink/pull/8360#discussion_r282347857
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table
twalthr commented on a change in pull request #8360:
[FLINK-12393][table-common] Add the user-facing classes of the new type system
URL: https://github.com/apache/flink/pull/8360#discussion_r282347087
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table
[
https://issues.apache.org/jira/browse/FLINK-9410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangminglei reassigned FLINK-9410:
---
Assignee: zhangminglei (was: lihongli)
> Replace NMClient with NMClientAsync in YarnResourc
Jingsong Lee created FLINK-12456:
Summary: Wrong CharType convertion in type_utils.py
Key: FLINK-12456
URL: https://issues.apache.org/jira/browse/FLINK-12456
Project: Flink
Issue Type: Bug
wuchong commented on issue #8376: [FLINK-12392] [table-planner-blink] Port
FlinkRelMetadataQuery into Java to avoid compiling error with Scala 2.12
URL: https://github.com/apache/flink/pull/8376#issuecomment-490752948
Thanks for digging into this.
LGTM.
Will merge after travi
flinkbot commented on issue #8377: [FLINK-12455][python] Move the packaging of
pyflink to flink-dist
URL: https://github.com/apache/flink/pull/8377#issuecomment-490752300
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review yo
[
https://issues.apache.org/jira/browse/FLINK-12455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12455:
---
Labels: pull-request-available (was: )
> Move the packaging of pyflink to flink-dist
>
dianfu opened a new pull request #8377: [FLINK-12455][python] Move the
packaging of pyflink to flink-dist
URL: https://github.com/apache/flink/pull/8377
## What is the purpose of the change
*This pull request moves the packaging of pyflink to flink-dist for the
following reasons: *
[
https://issues.apache.org/jira/browse/FLINK-12455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-12455:
Summary: Move the packaging of pyflink to flink-dist (was: Move the
package of pyflink to flink-dist)
>
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282339745
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282339745
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282337775
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282339745
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282337926
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282337926
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282337775
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
HuangZhenQiu commented on issue #8303: [FLINK-12343]add file replication config
for yarn configuration
URL: https://github.com/apache/flink/pull/8303#issuecomment-490741884
@xintongsong @tillrohrmann @rmetzger
Thanks for the informative comments. The verified the solution end to end.
Dian Fu created FLINK-12455:
---
Summary: Move the package of pyflink to flink-dist
Key: FLINK-12455
URL: https://issues.apache.org/jira/browse/FLINK-12455
Project: Flink
Issue Type: Sub-task
wuchong commented on a change in pull request #8360:
[FLINK-12393][table-common] Add the user-facing classes of the new type system
URL: https://github.com/apache/flink/pull/8360#discussion_r282335432
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table
wuchong commented on a change in pull request #8360:
[FLINK-12393][table-common] Add the user-facing classes of the new type system
URL: https://github.com/apache/flink/pull/8360#discussion_r282334560
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table
wuchong commented on a change in pull request #8360:
[FLINK-12393][table-common] Add the user-facing classes of the new type system
URL: https://github.com/apache/flink/pull/8360#discussion_r282334300
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table
chunweilei commented on a change in pull request #8266: [FLINK-9904]Allow users
to control MaxDirectMemorySize
URL: https://github.com/apache/flink/pull/8266#discussion_r282333076
##
File path: flink-dist/src/main/flink-bin/bin/config.sh
##
@@ -429,6 +430,11 @@ if [ -z "${
eaglewatcherwb edited a comment on issue #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#issuecomment-490734729
Hi, @GJL @tillrohrmann , I have updated the PR based on the latest master.
Would you mind to begin anot
eaglewatcherwb edited a comment on issue #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#issuecomment-490734729
Hi, @GJL @tillrohrmann , I have updated the PR based on the latest master.
Would you mind to begin anot
[
https://issues.apache.org/jira/browse/FLINK-12454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-12454:
Labels: (was: Python)
> Add custom check options for lint-python.sh
> --
[
https://issues.apache.org/jira/browse/FLINK-12454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-12454:
Labels: Python (was: )
> Add custom check options for lint-python.sh
> --
[
https://issues.apache.org/jira/browse/FLINK-12454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-12454:
Description: At present, int-python.sh has Python compatibility checks and
code style checks. By d
sunjincheng created FLINK-12454:
---
Summary: Add custom check options for lint-python.sh
Key: FLINK-12454
URL: https://issues.apache.org/jira/browse/FLINK-12454
Project: Flink
Issue Type: Sub-tas
eaglewatcherwb commented on issue #8309: [FLINK-12229] [runtime] Implement
LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#issuecomment-490734729
Hi, @GJL @tillrohrmann , I have updated the PR based on the latest master.
Would you mind to begin another rou
eaglewatcherwb edited a comment on issue #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#issuecomment-490734729
Hi, @GJL @tillrohrmann , I have updated the PR based on the latest master.
Would you mind to begin anot
godfreyhe opened a new pull request #8376: [FLINK-12392] [table-planner-blink]
Port FlinkRelMetadataQuery into Java to avoid compiling error with Scala 2.12
URL: https://github.com/apache/flink/pull/8376
## What is the purpose of the change
*Port FlinkRelMetadataQuery into Java t
[
https://issues.apache.org/jira/browse/FLINK-12392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12392:
---
Labels: pull-request-available (was: )
> FlinkRelMetadataQuery does not compile with Scala
flinkbot commented on issue #8376: [FLINK-12392] [table-planner-blink] Port
FlinkRelMetadataQuery into Java to avoid compiling error with Scala 2.12
URL: https://github.com/apache/flink/pull/8376#issuecomment-490732935
Thanks a lot for your contribution to the Apache Flink project. I'm the
[
https://issues.apache.org/jira/browse/FLINK-12392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he reassigned FLINK-12392:
--
Assignee: godfrey he
> FlinkRelMetadataQuery does not compile with Scala 2.12
> -
wenhuitang commented on issue #7805: [FLINK-11697] Add readMapReduceTextFile
API for HadoopInputs.
URL: https://github.com/apache/flink/pull/7805#issuecomment-490729884
Open another PR（https://github.com/apache/flink/pull/8375） due to this pr
from unknown repository. So close this one.
--
flinkbot commented on issue #8375: [FLINK-11697] Add readMapReduceTextFile API
for HadoopInputs.
URL: https://github.com/apache/flink/pull/8375#issuecomment-490729901
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your p
wenhuitang closed pull request #7805: [FLINK-11697] Add readMapReduceTextFile
API for HadoopInputs.
URL: https://github.com/apache/flink/pull/7805
This is an automated message from the Apache Git Service.
To respond to the m
wenhuitang opened a new pull request #8375: [FLINK-11697] Add
readMapReduceTextFile API for HadoopInputs.
URL: https://github.com/apache/flink/pull/8375
## What is the purpose of the change
This pull request Add readMapReduceTextFile API for HadoopInputs.
https://issues.apache.or
[
https://issues.apache.org/jira/browse/FLINK-12453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-12453:
-
Description:
In generateAggsHandler:
val generator = new AggsHandlerCodeGenerator(
CodeGene
wenhuitang closed pull request #7810: [FLINK-11698] Add readMapRedTextFile API
for HadoopInputs.
URL: https://github.com/apache/flink/pull/7810
This is an automated message from the Apache Git Service.
To respond to the mess
wenhuitang commented on issue #7810: [FLINK-11698] Add readMapRedTextFile API
for HadoopInputs.
URL: https://github.com/apache/flink/pull/7810#issuecomment-490729368
Open another PR（https://github.com/apache/flink/pull/8374） due to this pr
from unknown repository. So close this one.
Jingsong Lee created FLINK-12453:
Summary: StreamExecGlobalGroupAggregate construct wrong args for
AggsHandlerCodeGenerator
Key: FLINK-12453
URL: https://issues.apache.org/jira/browse/FLINK-12453
Proj
flinkbot commented on issue #8374: [FLINK-11698] Add readMapRedTextFile API for
HadoopInputs.
URL: https://github.com/apache/flink/pull/8374#issuecomment-490729202
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
wenhuitang opened a new pull request #8374: [FLINK-11698] Add
readMapRedTextFile API for HadoopInputs.
URL: https://github.com/apache/flink/pull/8374
## What is the purpose of the change
This pull request Add readMapRedTextFile API for HadoopInputs.
https://issues.apache.org/jira
xuefuz commented on a change in pull request #8353: [FLINK-12233][hive] Support
table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282322682
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
[
https://issues.apache.org/jira/browse/FLINK-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-12375:
Assignee: Yun Tang
> flink-container job jar does not have read permissions
> ---
xuefuz commented on a change in pull request #8353: [FLINK-12233][hive] Support
table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282321982
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
xuefuz commented on a change in pull request #8353: [FLINK-12233][hive] Support
table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282322716
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
xuefuz commented on a change in pull request #8353: [FLINK-12233][hive] Support
table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282322682
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
tianchen92 commented on a change in pull request #8266: [FLINK-9904]Allow users
to control MaxDirectMemorySize
URL: https://github.com/apache/flink/pull/8266#discussion_r282321092
##
File path: flink-dist/src/main/flink-bin/bin/config.sh
##
@@ -429,6 +430,11 @@ if [ -z "${
xuefuz commented on a change in pull request #8353: [FLINK-12233][hive] Support
table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282320563
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
xuefuz commented on a change in pull request #8353: [FLINK-12233][hive] Support
table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282320535
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
[
https://issues.apache.org/jira/browse/FLINK-12437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836032#comment-16836032
]
Abdul Qadeer commented on FLINK-12437:
--
[~rmetzger] I don't expect a fix to be made
sunhaibotb edited a comment on issue #8124: [FLINK-11877] Implement the runtime
handling of the InputSelectable interface
URL: https://github.com/apache/flink/pull/8124#issuecomment-490388025
@pnowojski , the code has been updated and it relies on the latest version
of [PR-7959](https://gi
walterddr commented on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19
URL: https://github.com/apache/flink/pull/8324#issuecomment-490712462
@wuchong can you also help take a look at the upgrade? Thanks
This is an au
walterddr commented on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19
URL: https://github.com/apache/flink/pull/8324#issuecomment-490712398
@flinkbot attention @wuchong
This is an automated message from the Apa
[
https://issues.apache.org/jira/browse/FLINK-12392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836018#comment-16836018
]
Jark Wu commented on FLINK-12392:
-
Sure [~twalthr], we will figure it out today.
> Flin
xuefuz commented on issue #8353: [FLINK-12233][hive] Support table related
operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#issuecomment-490709606
> @xuefuz @lirui-apache thanks for your review! The build failure is
unrelated (python api issue). If there's no more c
bowenli86 commented on issue #8353: [FLINK-12233][hive] Support table related
operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#issuecomment-490695098
Rebased to latest master to resolve conflicts. Will wait for a green build
before proceeding
--
[
https://issues.apache.org/jira/browse/FLINK-12417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-12417.
Resolution: Fixed
merged in 1.9.0: c954780c9fb2c0cc5b3730caff7e99bacbd534ba
> Unify ReadableCatalog and R
asfgit closed pull request #8365: [FLINK-12417][table] Unify ReadableCatalog
and ReadableWritableCatalog interfaces to Catalog interface
URL: https://github.com/apache/flink/pull/8365
This is an automated message from the Ap
bowenli86 commented on issue #8353: [FLINK-12233][hive] Support table related
operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#issuecomment-490692748
@xuefuz @lirui-apache thanks for your review! The build failure is unrelated
(python api issue). If there's no more
bowenli86 commented on issue #8365: [FLINK-12417][table] Unify ReadableCatalog
and ReadableWritableCatalog interfaces to Catalog interface
URL: https://github.com/apache/flink/pull/8365#issuecomment-490692552
@xuefuz thanks for your review! ReadableCatalog.java is already deleted.
M
xuefuz commented on issue #8365: [FLINK-12417][table] Unify ReadableCatalog and
ReadableWritableCatalog interfaces to Catalog interface
URL: https://github.com/apache/flink/pull/8365#issuecomment-490680574
Yes. Let's delete ReadableCatalog.java and the PR is good to go. Thanks.
---
xuefuz commented on issue #8353: [FLINK-12233][hive] Support table related
operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#issuecomment-490680873
ok. sounds good. thanks.
This is an automated message
bowenli86 edited a comment on issue #8353: [FLINK-12233][hive] Support table
related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#issuecomment-490654662
> Thanks for refactoring the code. It looks much cleaner now.
>
> However, I still noticed there are st
bowenli86 commented on issue #8353: [FLINK-12233][hive] Support table related
operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#issuecomment-490654662
> Thanks for refactoring the code. It looks much cleaner now.
>
> However, I still noticed there are still a l
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282251157
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282251084
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
Bowen Li created FLINK-12452:
Summary: alterTable() should ensure existing base table and the
new one are of the same type
Key: FLINK-12452
URL: https://issues.apache.org/jira/browse/FLINK-12452
Project:
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282244476
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282239896
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
bowenli86 commented on a change in pull request #8353: [FLINK-12233][hive]
Support table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282238893
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
bowenli86 commented on issue #8365: [FLINK-12417][table] Unify ReadableCatalog
and ReadableWritableCatalog interfaces to Catalog interface
URL: https://github.com/apache/flink/pull/8365#issuecomment-490639242
> Changes look good to me. However, I wonder if we should get ride of
ReadableCat
StefanRRichter commented on a change in pull request #8361:
[FLINK-12434][network] Replace listeners with CompletableFuture in InputGates
URL: https://github.com/apache/flink/pull/8361#discussion_r282212329
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/util/Set
StefanRRichter commented on a change in pull request #8361:
[FLINK-12434][network] Replace listeners with CompletableFuture in InputGates
URL: https://github.com/apache/flink/pull/8361#discussion_r282213460
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/netwo
xuefuz commented on a change in pull request #8353: [FLINK-12233][hive] Support
table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282206462
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
xuefuz commented on a change in pull request #8353: [FLINK-12233][hive] Support
table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282205173
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
xuefuz commented on a change in pull request #8353: [FLINK-12233][hive] Support
table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282203125
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
xuefuz commented on a change in pull request #8353: [FLINK-12233][hive] Support
table related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#discussion_r282205441
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
1 - 100 of 296 matches
Mail list logo
