rmetzger commented on issue #8303: [FLINK-12343]add file replication config for
yarn configuration
URL: https://github.com/apache/flink/pull/8303#issuecomment-490370551
@xintongsong Thanks a lot for taking a look at the PR.
Isn't it a good thing (in this case), that the `copyFromLocalFil
zhijiangW removed a comment on issue #8242: [FLINK-6227][network] Introduce the
DataConsumptionException for downstream task failure
URL: https://github.com/apache/flink/pull/8242#issuecomment-490348518
Yes, I think we are on the same page now.
I would focus on `b, c` in this PR, and
[
https://issues.apache.org/jira/browse/FLINK-12376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835366#comment-16835366
]
Stephan Ewen commented on FLINK-12376:
--
This is actually not a GCS / checkpoint iss
eaglewatcherwb commented on a change in pull request #8290: [FLINK-12070]
[network] Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r281906582
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partit
eaglewatcherwb commented on a change in pull request #8290: [FLINK-12070]
[network] Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r281905867
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partit
eaglewatcherwb commented on a change in pull request #8290: [FLINK-12070]
[network] Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r281906373
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partit
eaglewatcherwb commented on a change in pull request #8290: [FLINK-12070]
[network] Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r281906483
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partit
eaglewatcherwb commented on a change in pull request #8290: [FLINK-12070]
[network] Implement new bounded blocking subpartitions
URL: https://github.com/apache/flink/pull/8290#discussion_r281906191
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partit
[
https://issues.apache.org/jira/browse/FLINK-12379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835361#comment-16835361
]
Stephan Ewen commented on FLINK-12379:
--
This looks like the same issue as FLINK-123
[
https://issues.apache.org/jira/browse/FLINK-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835360#comment-16835360
]
Stephan Ewen commented on FLINK-12381:
--
Flink does not overwrite checkpoints, becau
bowenli86 edited a comment on issue #8340: [FLINK-12395][table] Add more
detailed javadoc for getDescription() and getDetailedDescription() in catalog
object interfaces
URL: https://github.com/apache/flink/pull/8340#issuecomment-490366314
Hi @xuefuz , https://issues.apache.org/jira/browse/
bowenli86 commented on issue #8340: [FLINK-12395][table] Add more detailed
javadoc for getDescription() and getDetailedDescription() in catalog object
interfaces
URL: https://github.com/apache/flink/pull/8340#issuecomment-490366314
Discussed with @twalthr and @dawidwys in
https://issues
[
https://issues.apache.org/jira/browse/FLINK-12425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835354#comment-16835354
]
vinoyang commented on FLINK-12425:
--
OK, it doesn't matter.
> Implement RPCs to allow c
yanghua commented on a change in pull request #8322: [FLINK-12364] Introduce a
CheckpointFailureManager to centralized manage checkpoint failure
URL: https://github.com/apache/flink/pull/8322#discussion_r281928748
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/c
yanghua commented on issue #8322: [FLINK-12364] Introduce a
CheckpointFailureManager to centralized manage checkpoint failure
URL: https://github.com/apache/flink/pull/8322#issuecomment-490365680
@StefanRRichter Really sorry for the late reply, I just took a holiday and
attended QCon confe
yanghua commented on a change in pull request #8322: [FLINK-12364] Introduce a
CheckpointFailureManager to centralized manage checkpoint failure
URL: https://github.com/apache/flink/pull/8322#discussion_r281928748
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/c
yanghua commented on a change in pull request #8322: [FLINK-12364] Introduce a
CheckpointFailureManager to centralized manage checkpoint failure
URL: https://github.com/apache/flink/pull/8322#discussion_r281927266
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/c
[
https://issues.apache.org/jira/browse/FLINK-12440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-12440:
---
Assignee: (was: sunjincheng)
> Add all connector support align Java Table API
> ---
bowenli86 commented on issue #8353: [FLINK-12233][hive] Support table related
operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353#issuecomment-490362402
Thanks @xuefuz . The reason I use util methods is because as the logic
complexity grows, the size of two catalog cla
[
https://issues.apache.org/jira/browse/FLINK-12365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-12365.
--
Resolution: Fixed
merged in 1.9.0: 12d698b6e1c1aef03834963fba8a0974b3729c50
> Add stats related catal
KurtYoung merged pull request #8314: [FLINK-12365][table] Add stats related
catalog APIs
URL: https://github.com/apache/flink/pull/8314
This is an automated message from the Apache Git Service.
To respond to the message, ple
yanghua commented on a change in pull request #8322: [FLINK-12364] Introduce a
CheckpointFailureManager to centralized manage checkpoint failure
URL: https://github.com/apache/flink/pull/8322#discussion_r281923773
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/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_r281922013
##
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_r281922282
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/c
flinkbot commented on issue #8367: [hotfix][doc] typo, remove `one` from `value
of one two...`
URL: https://github.com/apache/flink/pull/8367#issuecomment-490357186
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pul
robstoll opened a new pull request #8367: [hotfix][doc] typo, remove `one` from
`value of one two...`
URL: https://github.com/apache/flink/pull/8367
## What is the purpose of the change
typo
## Brief change log
see changes
## Verifying this change
This change is a
[
https://issues.apache.org/jira/browse/FLINK-12425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned FLINK-12425:
Assignee: Ruidong Li
> Implement RPCs to allow clients release result partitions in a Fli
[
https://issues.apache.org/jira/browse/FLINK-12425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835330#comment-16835330
]
Jiangjie Qin commented on FLINK-12425:
--
[~yanghua] Thanks for being interested in w
[
https://issues.apache.org/jira/browse/FLINK-12379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12379:
---
Component/s: Runtime / Coordination
> Parallelism in job/GCS/Hadoop: Could not finalize the
[
https://issues.apache.org/jira/browse/FLINK-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12381:
---
Component/s: Runtime / Coordination
> W/o HA, upon a full restart, checkpointing crashes
> -
[
https://issues.apache.org/jira/browse/FLINK-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-12384:
---
Component/s: Runtime / Coordination
> Rolling the etcd servers causes "Connected to an old s
[
https://issues.apache.org/jira/browse/FLINK-12326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-12326.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed in master: 84eec21108f2c05fa872c9a3735457d73f75d
asfgit closed pull request #8347: [FLINK-12326][python] Add basic test
framework for python api
URL: https://github.com/apache/flink/pull/8347
This is an automated message from the Apache Git Service.
To respond to the messa
sunjincheng121 commented on issue #8347: [FLINK-12326][python] Add basic test
framework for python api
URL: https://github.com/apache/flink/pull/8347#issuecomment-490351312
Thanks for the quick update! @dianfu
+1 to merged.
@flinkbot approve all
-
dianfu commented on issue #8347: [FLINK-12326][python] Add basic test framework
for python api
URL: https://github.com/apache/flink/pull/8347#issuecomment-490350804
@sunjincheng121 Thanks a lot for the review. The latest comments make sense.
Have updated the PR.
--
dianfu commented on a change in pull request #8347: [FLINK-12326][python] Add
basic test framework for python api
URL: https://github.com/apache/flink/pull/8347#discussion_r281915661
##
File path: flink-python/pyflink/table/tests/test_table.py
##
@@ -0,0 +1,70 @@
+#
#
zhijiangW commented on issue #8242: [FLINK-6227][network] Introduce the
DataConsumptionException for downstream task failure
URL: https://github.com/apache/flink/pull/8242#issuecomment-490348518
Yes, I think we are on the same page now.
I would focus on `b, c` in this PR, and launch
zhijiangW edited a comment on issue #8242: [FLINK-6227][network] Introduce the
DataConsumptionException for downstream task failure
URL: https://github.com/apache/flink/pull/8242#issuecomment-490348518
Yes, I think we are on the same page now.
I would focus on `b, c` in this PR, and
[
https://issues.apache.org/jira/browse/FLINK-12440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenqiu Huang reassigned FLINK-12440:
-
Assignee: sunjincheng (was: Zhenqiu Huang)
> Add all connector support align Java Tabl
[
https://issues.apache.org/jira/browse/FLINK-12440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenqiu Huang reassigned FLINK-12440:
-
Assignee: Zhenqiu Huang
> Add all connector support align Java Table API
>
[
https://issues.apache.org/jira/browse/FLINK-12441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuefu Zhang reassigned FLINK-12441:
---
Assignee: (was: Xuefu Zhang)
> Add column stats for decimal type
>
Xuefu Zhang created FLINK-12442:
---
Summary: Add some more (negative) test cases for FLINK-12365
Key: FLINK-12442
URL: https://issues.apache.org/jira/browse/FLINK-12442
Project: Flink
Issue Type:
sunjincheng121 commented on a change in pull request #8347:
[FLINK-12326][python] Add basic test framework for python api
URL: https://github.com/apache/flink/pull/8347#discussion_r281897668
##
File path: flink-python/pyflink/table/tests/test_table.py
##
@@ -0,0 +1,70 @@
+
sunjincheng121 commented on a change in pull request #8347:
[FLINK-12326][python] Add basic test framework for python api
URL: https://github.com/apache/flink/pull/8347#discussion_r281897834
##
File path: flink-python/pyflink/find_flink_home.py
##
@@ -15,7 +15,9 @@
# See
Xuefu Zhang created FLINK-12441:
---
Summary: Add column stats for decimal type
Key: FLINK-12441
URL: https://issues.apache.org/jira/browse/FLINK-12441
Project: Flink
Issue Type: Sub-task
JingsongLi closed pull request #8015: [FLINK-11974][streaming] Introduce
StreamOperatorSubstitutor to help table perform the whole Operator CodeGen
URL: https://github.com/apache/flink/pull/8015
This is an automated message
[
https://issues.apache.org/jira/browse/FLINK-10979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-10979.
---
Resolution: Fixed
> Add support for group keys in Unbounded Aggregate/FlatAggregate operator
> -
[
https://issues.apache.org/jira/browse/FLINK-10979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835283#comment-16835283
]
Hequn Cheng commented on FLINK-10979:
-
Will be implemented directly by flatAggregate
shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281905258
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingExe
Aitozi commented on issue #8280: [FLINK-12297]Harden ClosureCleaner to handle
the wrapped function
URL: https://github.com/apache/flink/pull/8280#issuecomment-490336487
Thanks @StephanEwen for your valuable suggestion, I will address your
comments as far as i have time (about at this weeke
shuai-xu commented on a change in pull request #8296: [FLINK-12228] [runtime]
Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281903791
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/TestingSchedu
JingsongLi commented on a change in pull request #8302:
[FLINK-12269][table-blink] Support Temporal Table Join in blink planner and
runtime
URL: https://github.com/apache/flink/pull/8302#discussion_r281903520
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/ap
JingsongLi commented on a change in pull request #8302:
[FLINK-12269][table-blink] Support Temporal Table Join in blink planner and
runtime
URL: https://github.com/apache/flink/pull/8302#discussion_r281903477
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/ap
flinkbot commented on issue #8366: [FLINK-12415][doc-zh]Translate HistoryServer
page into Chinese
URL: https://github.com/apache/flink/pull/8366#issuecomment-490334809
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-12415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12415:
---
Labels: pull-request-available (was: )
> Translate "History Server" page into Chinese
> ---
Armstrongya opened a new pull request #8366: [FLINK-12415][doc-zh]Translate
HistoryServer page into Chinese
URL: https://github.com/apache/flink/pull/8366
## What is the purpose of the change
This change mainly translate "History Server" page into Chinese.
## Brief
KurtYoung commented on a change in pull request #8302:
[FLINK-12269][table-blink] Support Temporal Table Join in blink planner and
runtime
URL: https://github.com/apache/flink/pull/8302#discussion_r281893667
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/ap
KurtYoung commented on a change in pull request #8302:
[FLINK-12269][table-blink] Support Temporal Table Join in blink planner and
runtime
URL: https://github.com/apache/flink/pull/8302#discussion_r281893334
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apa
KurtYoung commented on a change in pull request #8302:
[FLINK-12269][table-blink] Support Temporal Table Join in blink planner and
runtime
URL: https://github.com/apache/flink/pull/8302#discussion_r281898716
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apa
KurtYoung commented on a change in pull request #8302:
[FLINK-12269][table-blink] Support Temporal Table Join in blink planner and
runtime
URL: https://github.com/apache/flink/pull/8302#discussion_r281898810
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apa
xuefuz commented on issue #8314: [FLINK-12365][table] Add stats related catalog
APIs
URL: https://github.com/apache/flink/pull/8314#issuecomment-490331675
Pushed fix for the test. Thanks for the review, @KurtYoung .
This is a
KurtYoung commented on a change in pull request #8302:
[FLINK-12269][table-blink] Support Temporal Table Join in blink planner and
runtime
URL: https://github.com/apache/flink/pull/8302#discussion_r281900158
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apa
KurtYoung commented on a change in pull request #8302:
[FLINK-12269][table-blink] Support Temporal Table Join in blink planner and
runtime
URL: https://github.com/apache/flink/pull/8302#discussion_r281899855
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apa
KurtYoung commented on a change in pull request #8302:
[FLINK-12269][table-blink] Support Temporal Table Join in blink planner and
runtime
URL: https://github.com/apache/flink/pull/8302#discussion_r281898829
##
File path:
flink-table/flink-table-runtime-blink/src/main/java/org/apa
[
https://issues.apache.org/jira/browse/FLINK-12406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-12406:
---
Component/s: API / DataSet
> Report BLOCKING_PERSISTENT result partition meta back to client
> -
sunjincheng created FLINK-12440:
---
Summary: Add all connector support align Java Table API
Key: FLINK-12440
URL: https://issues.apache.org/jira/browse/FLINK-12440
Project: Flink
Issue Type: Sub-
sunjincheng created FLINK-12439:
---
Summary: Add FileSystem Connector with CSV format support in
Python Table API
Key: FLINK-12439
URL: https://issues.apache.org/jira/browse/FLINK-12439
Project: Flink
JingsongLi commented on a change in pull request #8295: [FLINK-11974][runtime]
Introduce StreamOperatorFactory
URL: https://github.com/apache/flink/pull/8295#discussion_r281891845
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperat
KurtYoung commented on issue #8314: [FLINK-12365][table] Add stats related
catalog APIs
URL: https://github.com/apache/flink/pull/8314#issuecomment-490319734
Changes LGTM, please fix the test failure:
21:22:05.992 [ERROR]
testStatistics(org.apache.flink.table.catalog.GenericInMemoryCata
Armstrong Nova created FLINK-12438:
--
Summary: Translate "Task Lifecycle" page into Chinese
Key: FLINK-12438
URL: https://issues.apache.org/jira/browse/FLINK-12438
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-12435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kurt Young closed FLINK-12435.
--
Resolution: Invalid
> UT Failures: GroupWindowTest.testExpressionOnWindowHavingFunction and
> GroupWi
[
https://issues.apache.org/jira/browse/FLINK-12435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835242#comment-16835242
]
Kurt Young commented on FLINK-12435:
This class doesn't exist anymore
> UT Failures
leesf edited a comment on issue #8226: [FLINK-12181][Tests] Port
ExecutionGraphRestartTest to new codebase
URL: https://github.com/apache/flink/pull/8226#issuecomment-490022810
@azagrebin Thanks for you review and sorry for lately reply. Updated the PR
and address your comments, would you
[
https://issues.apache.org/jira/browse/FLINK-12327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo reassigned FLINK-12327:
Assignee: Huang Xingbo
> Add simplicity support for submitting Python Table API job in Cl
sunjincheng121 commented on a change in pull request #8347:
[FLINK-12326][python] Add basic test framework for python api
URL: https://github.com/apache/flink/pull/8347#discussion_r281870466
##
File path: flink-python/pyflink/testing/source_sink_utils.py
##
@@ -0,0 +1,127
sunjincheng121 commented on a change in pull request #8347:
[FLINK-12326][python] Add basic test framework for python api
URL: https://github.com/apache/flink/pull/8347#discussion_r281870867
##
File path: flink-python/pyflink/table/tests/test_table.py
##
@@ -0,0 +1,75 @@
+
[
https://issues.apache.org/jira/browse/FLINK-12437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abdul Qadeer updated FLINK-12437:
-
Description:
This issue is observed in Standalone cluster deployment mode with Zookeeper HA
ena
Abdul Qadeer created FLINK-12437:
Summary: Taskmanager doesn't initiate registration after
jobmanager marks it terminated
Key: FLINK-12437
URL: https://issues.apache.org/jira/browse/FLINK-12437
Projec
[
https://issues.apache.org/jira/browse/FLINK-12437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abdul Qadeer updated FLINK-12437:
-
Description:
This issue is observed in Standalone cluster deployment mode with Zookeeper HA
ena
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_r281861009
##
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_r281860485
##
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_r281860069
##
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_r281857308
##
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_r281856850
##
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_r281856367
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
[
https://issues.apache.org/jira/browse/FLINK-12368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Zhen Wu closed FLINK-12368.
--
Resolution: Fixed
Fix Version/s: 1.9.0
Stephan merged the PR
> add subtask index to Fl
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_r281854488
##
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_r281854134
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
[
https://issues.apache.org/jira/browse/FLINK-12240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-12240.
Resolution: Fixed
merged in 1.9.0: 94c08c5cb934a6aabd6f5a2fbba4af6704f80615
> Support view related operat
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_r281853049
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/cata
[
https://issues.apache.org/jira/browse/FLINK-12417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-12417:
-
Summary: Unify ReadableCatalog and ReadableWritableCatalog interfaces to
Catalog interface (was: Merge
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-490271830
@flinkbot attention @dawidwys
--
piyushnarang commented on issue #8117: [FLINK-12115] [filesystems]: Add support
for AzureFS
URL: https://github.com/apache/flink/pull/8117#issuecomment-490264770
@tillrohrmann - I'm not really sure I understand why we need the
flink-hadoop-fs-shaded module. Is the whole point of that to re
xuefuz commented on issue #8314: [FLINK-12365][table] Add stats related catalog
APIs
URL: https://github.com/apache/flink/pull/8314#issuecomment-490259634
I have added more column stats types, leaving out Decimal because that's
more involved to a different JIRA after this. @KurtYoung could
[
https://issues.apache.org/jira/browse/FLINK-12399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835059#comment-16835059
]
Fabian Hueske commented on FLINK-12399:
---
Thanks for looking into this [~walterddr]
flinkbot commented on issue #8365: [FLINK-12417][table] Unify ReadableCatalog
and ReadableWritableCatalog interfaces to Catalog interface
URL: https://github.com/apache/flink/pull/8365#issuecomment-490221019
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot.
bowenli86 opened a new pull request #8365: [FLINK-12417][table] Unify
ReadableCatalog and ReadableWritableCatalog interfaces to Catalog interface
URL: https://github.com/apache/flink/pull/8365
## What is the purpose of the change
This PR unifies `ReadableCatalog` and `ReadableWritabl
[
https://issues.apache.org/jira/browse/FLINK-12417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12417:
---
Labels: pull-request-available (was: )
> Merge ReadableCatalog and ReadableWritableCatalog
[
https://issues.apache.org/jira/browse/FLINK-12417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835032#comment-16835032
]
Bowen Li commented on FLINK-12417:
--
[~twalthr] Probably just "Catalog"? I understand th
bowenli86 opened a new pull request #8353: [FLINK-12233][hive] Support table
related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8353
## What is the purpose of the change
This PR introduced HiveCatalogTable and implemented table related catalog
APIs in HiveCa
1 - 100 of 258 matches
Mail list logo
