godfreyhe commented on a change in pull request #8288: [FLINK-12345]
[table-planner-blink] Add support for generating optimized logical plan for
stream window aggregate
URL: https://github.com/apache/flink/pull/8288#discussion_r281494186
##
File path:
flink-table/flink-table-plann
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_r281494358
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apa
bowenli86 commented on issue #8339: [FLINK-12240][hive] Support view related
operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8339#issuecomment-489948651
I've addressed your comments, can you take another look? @KurtYoung
wuchong 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_r281493168
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/apach
zhijiangW 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_r281493283
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/B
FaxianZhao commented on a change in pull request #7679: [FLINK-11501][Kafka
Connector] Add ratelimiting to Kafka consumer
URL: https://github.com/apache/flink/pull/7679#discussion_r281490411
##
File path:
flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/st
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228]
[runtime] Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281490791
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/EagerSc
[
https://issues.apache.org/jira/browse/FLINK-12423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Armstrong Nova updated FLINK-12423:
---
Description:
Hi guys,
Currently, Flink only support 4 registering metrics, {{Counters}
wuchong 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_r281491514
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache
dianfu commented on issue #8347: [FLINK-12326][python] Add basic test framework
for python api
URL: https://github.com/apache/flink/pull/8347#issuecomment-489929559
@sunjincheng121 @WeiZhong94 Thanks a lot for your review. Updated
accordingly!
godfreyhe commented on a change in pull request #8288: [FLINK-12345]
[table-planner-blink] Add support for generating optimized logical plan for
stream window aggregate
URL: https://github.com/apache/flink/pull/8288#discussion_r281486525
##
File path:
flink-table/flink-table-plann
KurtYoung commented on a change in pull request #8339: [FLINK-12240][hive]
Support view related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8339#discussion_r281479876
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apach
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_r281484044
##
File path: flink-python/pyflink/table/tests/test_table.py
##
@@ -0,0 +1,75 @@
+#
#
KurtYoung commented on a change in pull request #8339: [FLINK-12240][hive]
Support view related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8339#discussion_r281483556
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apach
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_r281481752
##
File path: flink-python/pyflink/table/tests/test_table.py
##
@@ -0,0 +1,75 @@
+#
#
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_r281471504
##
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apa
KurtYoung commented on a change in pull request #8317: [FLINK-12371]
[table-planner-blink] Add support for converting (NOT) IN/ (NOT) EXISTS to
SemiJoin, and generating optimized logical plan
URL: https://github.com/apache/flink/pull/8317#discussion_r281475435
##
File path:
flink-
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_r281474806
##
File path:
flink-table/flink-table-planner-blink/src/main/scala/org/ap
[
https://issues.apache.org/jira/browse/FLINK-11987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
LIU Xiao updated FLINK-11987:
-
Description:
We are using Flink 1.6.2 in our production environment, and kafka producer
occasionally th
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_r281473854
##
File path: flink-python/pyflink/testing/source_sink_utils.py
##
@@ -0,0 +1,127 @@
+
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_r281473572
##
File path: flink-python/pyflink/testing/source_sink_utils.py
##
@@ -0,0 +1,127 @@
+
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_r281473088
##
File path: flink-python/pyflink/testing/test_case_utils.py
##
@@ -0,0 +1,64 @@
+###
zhuzhurk commented on a change in pull request #8316: [FLINK-12369]
[coordination] Implement a region failover strategy regarding the next version
FailoverStrategy interfaces
URL: https://github.com/apache/flink/pull/8316#discussion_r281472899
##
File path:
flink-runtime/src/test/
Zor-X-L commented on issue #8331: [FLINK-11987][flink-connector-kafka-0.11]
convert NEXT_TRANSACTIONAL_ID_HINT_DESCRIPTOR to a non-static variabl…
URL: https://github.com/apache/flink/pull/8331#issuecomment-489922433
> The Pull Request description seems a bit off. Could you add a proper
de
bowenli86 commented on a change in pull request #8339: [FLINK-12240][hive]
Support view related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8339#discussion_r281471404
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apach
flinkbot commented on issue #8356: [FLINK-12424] [table-planner-blink] Supports
dag (multiple-sinks query) optimization
URL: https://github.com/apache/flink/pull/8356#issuecomment-489920416
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the commun
[
https://issues.apache.org/jira/browse/FLINK-12424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12424:
---
Labels: pull-request-available (was: )
> Supports dag (multiple-sinks query) optimization
>
godfreyhe opened a new pull request #8356: [FLINK-12424] [table-planner-blink]
Supports dag (multiple-sinks query) optimization
URL: https://github.com/apache/flink/pull/8356
## What is the purpose of the change
*Supports dag (multiple-sinks query) optimization*
## Bri
[
https://issues.apache.org/jira/browse/FLINK-12424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-12424:
---
Description:
Currently, Flink planner will optimize the plan in {{writeToSink}} method. If
there ar
[
https://issues.apache.org/jira/browse/FLINK-12424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-12424:
---
Description:
Currently, Flink planner will optimize the plan in {{writeToSink}} method. If
there ar
[
https://issues.apache.org/jira/browse/FLINK-12424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he updated FLINK-12424:
---
Description:
Currently, Flink planner will optimize the plan in {{writeToSink}} method. If
there ar
Jiangjie Qin created FLINK-12425:
Summary: Implement RPCs to allow clients release result partitions
in a Flink cluster.
Key: FLINK-12425
URL: https://issues.apache.org/jira/browse/FLINK-12425
Project
godfrey he created FLINK-12424:
--
Summary: Supports dag (multiple-sinks query) optimization
Key: FLINK-12424
URL: https://issues.apache.org/jira/browse/FLINK-12424
Project: Flink
Issue Type: New
xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support
view related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8339#discussion_r281461138
##
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/f
xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support
view related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8339#discussion_r281461138
##
File path:
flink-connectors/flink-connector-hive/src/test/java/org/apache/f
zhijiangW 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_r281460791
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/B
xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support
view related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8339#discussion_r281460262
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/f
xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support
view related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8339#discussion_r281459369
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/f
zhijiangW 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_r281459388
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/B
xuefuz commented on a change in pull request #8339: [FLINK-12240][hive] Support
view related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8339#discussion_r281459369
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/f
danny0405 commented on a change in pull request #8317: [FLINK-12371]
[table-planner-blink] Add support for converting (NOT) IN/ (NOT) EXISTS to
SemiJoin, and generating optimized logical plan
URL: https://github.com/apache/flink/pull/8317#discussion_r281458212
##
File path:
flink-
zhijiangW 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_r281457936
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/B
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228]
[runtime] Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281453729
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/EagerSc
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228]
[runtime] Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281454713
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/Executi
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228]
[runtime] Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281455320
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/Testing
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228]
[runtime] Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281455385
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/Testing
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228]
[runtime] Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281453965
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/EagerSc
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228]
[runtime] Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281455470
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/Testing
eaglewatcherwb commented on a change in pull request #8296: [FLINK-12228]
[runtime] Implement Eager Scheduling Strategy
URL: https://github.com/apache/flink/pull/8296#discussion_r281455438
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/Testing
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-489901309
@tillrohrmann thanks for the further suggestions! I agree with your overall
ideas.
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-489901309
@tillrohrmann thanks for the further suggestions! I agree with your overall
ideas.
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-489901309
@tillrohrmann thanks for the further suggestions! I agree with your overall
ideas.
zhijiangW commented on issue #8242: [FLINK-6227][network] Introduce the
DataConsumptionException for downstream task failure
URL: https://github.com/apache/flink/pull/8242#issuecomment-489901309
@tillrohrmann thanks for the further suggestions! I agree with your overall
ideas.
->Wha
[
https://issues.apache.org/jira/browse/FLINK-12330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12330:
---
Labels: pull-request-available (was: )
> Add integrated Tox for ensuring compatibility with
sunjincheng121 opened a new pull request #8355: [FLINK-12330][python]Add
integrated Tox for ensuring compatibility of multi-version of python.
URL: https://github.com/apache/flink/pull/8355
## What is the purpose of the change
Add integrated Tox for ensuring compatibility of multi-ve
flinkbot commented on issue #8355: [FLINK-12330][python]Add integrated Tox for
ensuring compatibility of multi-version of python.
URL: https://github.com/apache/flink/pull/8355#issuecomment-489901389
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help
KurtYoung commented on a change in pull request #8317: [FLINK-12371]
[table-planner-blink] Add support for converting (NOT) IN/ (NOT) EXISTS to
SemiJoin, and generating optimized logical plan
URL: https://github.com/apache/flink/pull/8317#discussion_r281452013
##
File path:
flink-
KurtYoung 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_r281447680
##
File path:
flink-table/flink-table-planner
KurtYoung 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_r281446411
##
File path:
flink-table/flink-table-planner
KurtYoung 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_r281447839
##
File path:
flink-table/flink-table-planner
KurtYoung 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_r281447320
##
File path:
flink-table/flink-table-planner
KurtYoung 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_r281450922
##
File path:
flink-table/flink-table-planner
KurtYoung 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_r281447197
##
File path:
flink-table/flink-table-planner
KurtYoung 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_r281446233
##
File path:
flink-table/flink-table-planner
wuchong commented on a change in pull request #8288: [FLINK-12345]
[table-planner-blink] Add support for generating optimized logical plan for
stream window aggregate
URL: https://github.com/apache/flink/pull/8288#discussion_r281450454
##
File path:
flink-table/flink-table-planner
wuchong commented on a change in pull request #8288: [FLINK-12345]
[table-planner-blink] Add support for generating optimized logical plan for
stream window aggregate
URL: https://github.com/apache/flink/pull/8288#discussion_r281448847
##
File path:
flink-table/flink-table-planner
[
https://issues.apache.org/jira/browse/FLINK-11839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-11839.
--
Resolution: Duplicate
> Introduce FlinkLogicalWindowAggregate
> -
[
https://issues.apache.org/jira/browse/FLINK-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834344#comment-16834344
]
Yun Tang commented on FLINK-12416:
--
[~slav4ik], would you please share the full command
[
https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834343#comment-16834343
]
Tom Goong commented on FLINK-11561:
---
[~jark] Sorry, I thought that the flink-parent d
wuchong commented on a change in pull request #8288: [FLINK-12345]
[table-planner-blink] Add support for generating optimized logical plan for
stream window aggregate
URL: https://github.com/apache/flink/pull/8288#discussion_r281446085
##
File path:
flink-table/flink-table-planner
KurtYoung commented on a change in pull request #8288: [FLINK-12345]
[table-planner-blink] Add support for generating optimized logical plan for
stream window aggregate
URL: https://github.com/apache/flink/pull/8288#discussion_r281444733
##
File path:
flink-table/flink-table-plann
KurtYoung commented on a change in pull request #8288: [FLINK-12345]
[table-planner-blink] Add support for generating optimized logical plan for
stream window aggregate
URL: https://github.com/apache/flink/pull/8288#discussion_r281444516
##
File path:
flink-table/flink-table-plann
[
https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834334#comment-16834334
]
Jark Wu commented on FLINK-11561:
-
[~Tom Goong] Yes, it is in flink-web project. What do
Armstrong Nova created FLINK-12423:
--
Summary: Add Timer metric type for flink-metrics module
Key: FLINK-12423
URL: https://issues.apache.org/jira/browse/FLINK-12423
Project: Flink
Issue Type
zjffdu commented on a change in pull request #8144: [FLINK-12159]. Enable
YarnMiniCluster integration test under non-secure mode
URL: https://github.com/apache/flink/pull/8144#discussion_r281442692
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDesc
Jeff Zhang created FLINK-12422:
--
Summary: Remove IN_TESTS for make test code and production code
consistent
Key: FLINK-12422
URL: https://issues.apache.org/jira/browse/FLINK-12422
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16834331#comment-16834331
]
Tom Goong commented on FLINK-11561:
---
this file is located in "flink-web" project. Wil
[
https://issues.apache.org/jira/browse/FLINK-12421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-12421:
Issue Type: Sub-task (was: Task)
Parent: FLINK-11529
> Synchronize the latest documentation chang
[
https://issues.apache.org/jira/browse/FLINK-12421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-12421:
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-11525
> Synchronize the latest documentatio
[
https://issues.apache.org/jira/browse/FLINK-12421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-12421:
Issue Type: Task (was: Sub-task)
Parent: (was: FLINK-11525)
> Synchronize the latest document
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_r281428840
##
File path: flink-python/pyflink/testing/test_case_utils.py
##
@@ -0,0 +1,64 @@
flinkbot edited a comment on issue #8347: [FLINK-12326][python] Add basic test
framework for python api
URL: https://github.com/apache/flink/pull/8347#issuecomment-489486437
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
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_r281433379
##
File path: flink-python/pyflink/table/tests/test_table.py
##
@@ -0,0 +1,75 @@
+
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_r281437149
##
File path: flink-python/pyflink/table/tests/test_table.py
##
@@ -0,0 +1,75 @@
+
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_r281433677
##
File path: flink-python/pyflink/table/tests/test_end_to_end.py
##
@@ -1,73 +0,0
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_r281437349
##
File path: flink-python/pyflink/testing/test_case_utils.py
##
@@ -0,0 +1,64 @@
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_r281433195
##
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_r281438679
##
File path: flink-python/pyflink/find_flink_home.py
##
@@ -41,5 +41,19 @@ def _f
wuchong opened a new pull request #8354: [FLINK-12421][docs-zh] Synchronize the
latest documentation changes (commits to 7b46f604) into Chinese documents
URL: https://github.com/apache/flink/pull/8354
## What is the purpose of the change
There are several commits to documentation
[
https://issues.apache.org/jira/browse/FLINK-12421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12421:
---
Labels: pull-request-available (was: )
> Synchronize the latest documentation changes into
sunjincheng121 commented on issue #8347: [FLINK-12326][python] Add basic test
framework for python api
URL: https://github.com/apache/flink/pull/8347#issuecomment-489879981
@flinkbot approve-until architecture
This is an auto
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_r281432761
##
File path: flink-python/pyflink/testing/source_sink_utils.py
##
@@ -0,0 +1,127
flinkbot commented on issue #8354: [FLINK-12421][docs-zh] Synchronize the
latest documentation changes (commits to 7b46f604) into Chinese documents
URL: https://github.com/apache/flink/pull/8354#issuecomment-489880058
Thanks a lot for your contribution to the Apache Flink project. I'm the
Jark Wu created FLINK-12421:
---
Summary: Synchronize the latest documentation changes into Chinese
documents
Key: FLINK-12421
URL: https://issues.apache.org/jira/browse/FLINK-12421
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-11637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Goong reassigned FLINK-11637:
-
Assignee: Tom Goong
> Translate "Checkpoints" page into Chinese
> -
[
https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Goong reassigned FLINK-11634:
-
Assignee: Tom Goong
> Translate "State Backends" page into Chinese
> --
[
https://issues.apache.org/jira/browse/FLINK-11561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Goong reassigned FLINK-11561:
-
Assignee: Tom Goong
> Translate "Flink Architecture" page into Chinese
> --
[
https://issues.apache.org/jira/browse/FLINK-11754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-11754.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed in flink-web: 7f603e6b557bf14a933ec741282fc25a4c26daf5
[
https://issues.apache.org/jira/browse/FLINK-12420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li updated FLINK-12420:
---
Component/s: Table SQL / API
> Add support of cache/invalidateCache for TableAPI
> -
Ruidong Li created FLINK-12420:
--
Summary: Add support of cache/invalidateCache for TableAPI
Key: FLINK-12420
URL: https://issues.apache.org/jira/browse/FLINK-12420
Project: Flink
Issue Type: Sub
1 - 100 of 350 matches
Mail list logo