[GitHub] [flink] yumengz5 edited a comment on issue #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint

yumengz5 edited a comment on issue #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint URL: https://github.com/apache/flink/pull/8617#issuecomment-506202631 In my opinion, If the checkpoint is timeout, this checkpoint will be discarded. But the checkpoint

[GitHub] [flink] yumengz5 commented on issue #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint

yumengz5 commented on issue #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint URL: https://github.com/apache/flink/pull/8617#issuecomment-506202631 In my opinion, If the checkpoint is timeout, this checkpoint will be discarded. But the checkpoint coordinator

[GitHub] [flink] wsry commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure.

wsry commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure. URL: https://github.com/apache/flink/pull/8880#discussion_r298015077 ## File path:

[GitHub] [flink] wsry commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure.

wsry commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure. URL: https://github.com/apache/flink/pull/8880#discussion_r298015030 ## File path:

[jira] [Updated] (FLINK-11388) Add an OSS RecoverableWriter

[ https://issues.apache.org/jira/browse/FLINK-11388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11388: --- Labels: pull-request-available (was: ) > Add an OSS RecoverableWriter >

[GitHub] [flink] wujinhu closed pull request #7798: [FLINK-11388][fs] Add Aliyun OSS recoverable writer

wujinhu closed pull request #7798: [FLINK-11388][fs] Add Aliyun OSS recoverable writer URL: https://github.com/apache/flink/pull/7798 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r298012822 ## File path: docs/flinkDev/building.md ## @@ -58,6 +58,17 @@ mvn clean install

[GitHub] [flink] JingsongLi commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect all / minus all to blink planner

JingsongLi commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect all / minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r298013117 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r298012822 ## File path: docs/flinkDev/building.md ## @@ -58,6 +58,17 @@ mvn clean install

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r298012822 ## File path: docs/flinkDev/building.md ## @@ -58,6 +58,17 @@ mvn clean install

[jira] [Commented] (FLINK-12751) Create file based HA support

[ https://issues.apache.org/jira/browse/FLINK-12751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873830#comment-16873830 ] Yang Wang commented on FLINK-12751: --- [~borisl] Sorry for the late. Just as you say, job manager

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r298012822 ## File path: docs/flinkDev/building.md ## @@ -58,6 +58,17 @@ mvn clean install

[GitHub] [flink] wsry commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure.

wsry commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure. URL: https://github.com/apache/flink/pull/8880#discussion_r298012847 ## File path:

[jira] [Updated] (FLINK-13011) Release the PyFlink into PyPI

[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-13011: Description: FLINK-12962 adds the ability to build a PyFlink distribution package, but we have

[jira] [Updated] (FLINK-12999) Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) T(a, b, c)"

[ https://issues.apache.org/jira/browse/FLINK-12999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-12999: - Summary: Can't generate valid execution plan for "SELECT uuid() FROM (VALUES(1,2,3)) T(a, b,

[jira] [Updated] (FLINK-13011) Release the PyFlink into PyPI

[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-13011: Description: FLINK-12962 adds the ability to build a PyFlink distribution package, but we have

[jira] [Updated] (FLINK-12882) Remove ExecutionAttemptID field from ShuffleEnvironment#createResultPartitionWriters

[ https://issues.apache.org/jira/browse/FLINK-12882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12882: - Description: The ResultPartitionID could be got directly from ResultPartitionDeploymentDescriptor, so

[jira] [Updated] (FLINK-12882) Remove ExecutionAttemptID argument from ResultPartitionFactory#create

[ https://issues.apache.org/jira/browse/FLINK-12882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12882: - Summary: Remove ExecutionAttemptID argument from ResultPartitionFactory#create (was: Remove

[GitHub] [flink] godfreyhe commented on issue #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on issue #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#issuecomment-506192171 update commit message as `Support intersect all/minus all in blink planner` ?

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r298004677 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r298003160 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r298005605 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r298002892 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r298004640 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r298003884 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r298004962 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r298003032 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r298003359 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r298004832 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@ +---

[GitHub] [flink] knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

knaufk commented on a change in pull request #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#discussion_r298003620 ## File path: docs/getting-started/tutorials/table_api.md ## @@ -0,0 +1,250 @@ +---

[jira] [Commented] (FLINK-13004) Correct the logic of needToCleanupState in KeyedProcessFunctionWithCleanupState

[ https://issues.apache.org/jira/browse/FLINK-13004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873815#comment-16873815 ] Yun Tang commented on FLINK-13004: -- [~jark], actually, the {{timestamp}} passed in was wrapper

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297967960 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297985745 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r298000417 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297973779 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297962213 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297963859 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297962835 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297964789 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297966548 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297962742 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297964429 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297974855 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297985301 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297969993 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297973264 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297974008 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297963892 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297999767 ## File path:

[GitHub] [flink] knaufk commented on issue #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough

knaufk commented on issue #8903: [FLINK-12747][docs] Getting Started - Table API Example Walkthrough URL: https://github.com/apache/flink/pull/8903#issuecomment-506153339 Thanks a lot @sjwiesman for the contribution! A few general thoughts: * I really like that it's not the

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297975145 ## File path:

[GitHub] [flink] godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner

godfreyhe commented on a change in pull request #8898: [FLINK-12936][table-planner-blink] Support intersect/minus all to blink planner URL: https://github.com/apache/flink/pull/8898#discussion_r297984695 ## File path:

[GitHub] [flink] wsry commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure.

wsry commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure. URL: https://github.com/apache/flink/pull/8880#discussion_r297994922 ## File path:

[jira] [Commented] (FLINK-13011) Release the PyFlink into PyPI

[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873799#comment-16873799 ] sunjincheng commented on FLINK-13011: - I appreciate it if you can give some suggestions about how to

[GitHub] [flink] sunjincheng121 commented on issue #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

sunjincheng121 commented on issue #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#issuecomment-506150106 I have opened the JIRA(https://issues.apache.org/jira/browse/FLINK-13011) for Release the PyFlink into PyPI.

[jira] [Created] (FLINK-13011) Release the PyFlink into PyPI

sunjincheng created FLINK-13011: --- Summary: Release the PyFlink into PyPI Key: FLINK-13011 URL: https://issues.apache.org/jira/browse/FLINK-13011 Project: Flink Issue Type: Sub-task

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297963075 ## File path: flink-python/pyflink/version.py ## @@ -16,4 +16,4 @@ # limitations

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297984293 ## File path: flink-dist/src/main/flink-bin/bin/find-flink-home.sh ## @@ -0,0 +1,28

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297983205 ## File path: docs/flinkDev/building.md ## @@ -58,6 +58,17 @@ mvn clean install

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297963181 ## File path: flink-python/pyflink/shell.py ## @@ -131,8 +139,8 @@ * t.select("a

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

sunjincheng121 commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297971249 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -296,7 +296,10 @@

[jira] [Commented] (FLINK-4399) Add support for oversized messages

[ https://issues.apache.org/jira/browse/FLINK-4399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873791#comment-16873791 ] Biao Liu commented on FLINK-4399: - Recently at-least two users met the oversized message issue. I'll try

[jira] [Created] (FLINK-13010) Refactor the process of SchedulerNG#requestPartitionState

zhijiang created FLINK-13010: Summary: Refactor the process of SchedulerNG#requestPartitionState Key: FLINK-13010 URL: https://issues.apache.org/jira/browse/FLINK-13010 Project: Flink Issue

[jira] [Updated] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots thro

[ https://issues.apache.org/jira/browse/FLINK-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13009: -- Description: The test

[jira] [Updated] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots thro

[ https://issues.apache.org/jira/browse/FLINK-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13009: -- Description: The test

[jira] [Assigned] (FLINK-4399) Add support for oversized messages

[ https://issues.apache.org/jira/browse/FLINK-4399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-4399: --- Assignee: Biao Liu > Add support for oversized messages > -- > >

[GitHub] [flink] flinkbot commented on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala

flinkbot commented on issue #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala URL: https://github.com/apache/flink/pull/8906#issuecomment-506144046 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-13008) fix the findbugs warning in AggregationsFunction

[ https://issues.apache.org/jira/browse/FLINK-13008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13008: --- Labels: pull-request-available (was: ) > fix the findbugs warning in AggregationsFunction

[GitHub] [flink] klion26 commented on issue #8895: [FLINK-12536][Runtime/Network]Make BufferOrEventSequence#getNext non blocking

klion26 commented on issue #8895: [FLINK-12536][Runtime/Network]Make BufferOrEventSequence#getNext non blocking URL: https://github.com/apache/flink/pull/8895#issuecomment-506143844 Travis build failed seems irrelevant, have filed a

[GitHub] [flink] wangpeibin713 opened a new pull request #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala

wangpeibin713 opened a new pull request #8906: [FLINK-13008]fix the findbugs warning in AggregationsFunctio.scala URL: https://github.com/apache/flink/pull/8906 ## What is the purpose of the change - The goal is to fix the findbugs warning in AggregationsFunctio.scala

[jira] [Updated] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots thro

[ https://issues.apache.org/jira/browse/FLINK-13009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-13009: -- Summary:

[jira] [Created] (FLINK-13009) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots

Congxian Qiu(klion26) created FLINK-13009: - Summary: YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots

[GitHub] [flink] wuchong commented on issue #8530: [FLINK-12611][table-planner-blink] Make time indicator nullable in blink

wuchong commented on issue #8530: [FLINK-12611][table-planner-blink] Make time indicator nullable in blink URL: https://github.com/apache/flink/pull/8530#issuecomment-506143355 This looks good to me. +1 to merge. I will rebase this and merge it.

[GitHub] [flink] wsry commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure.

wsry commented on a change in pull request #8880: [FLINK-12986] [network] Fix instability of BoundedBlockingSubpartition under memory pressure. URL: https://github.com/apache/flink/pull/8880#discussion_r297963987 ## File path:

[jira] [Commented] (FLINK-12848) Method equals() in RowTypeInfo should consider fieldsNames

[ https://issues.apache.org/jira/browse/FLINK-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873786#comment-16873786 ] Jark Wu commented on FLINK-12848: - Hi [~aloyszhang] [~yanghua] [~enricoc], thanks for reporting this. 

[GitHub] [flink] klion26 commented on issue #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint

klion26 commented on issue #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint URL: https://github.com/apache/flink/pull/8617#issuecomment-506141650 Hi, @yumengz5 what do you mean "task will block all the time?", would you mind explain it more?

[GitHub] [flink] aloyszhang commented on a change in pull request #8902: [hotfix][docs] fix wrong link in streamfile_sink

aloyszhang commented on a change in pull request #8902: [hotfix][docs] fix wrong link in streamfile_sink URL: https://github.com/apache/flink/pull/8902#discussion_r297962271 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -24,7 +24,7 @@ under the License. -->

[GitHub] [flink] aloyszhang commented on a change in pull request #8902: [hotfix][docs] fix wrong link in streamfile_sink

aloyszhang commented on a change in pull request #8902: [hotfix][docs] fix wrong link in streamfile_sink URL: https://github.com/apache/flink/pull/8902#discussion_r297962271 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -24,7 +24,7 @@ under the License. -->

[jira] [Created] (FLINK-13008) fix the findbugs warning in AggregationsFunction

wangpeibin created FLINK-13008: -- Summary: fix the findbugs warning in AggregationsFunction Key: FLINK-13008 URL: https://issues.apache.org/jira/browse/FLINK-13008 Project: Flink Issue Type:

[GitHub] [flink] yumengz5 commented on issue #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint

yumengz5 commented on issue #8617: [FLINK-12619][StateBackend]Support TERMINATE/SUSPEND Job with Checkpoint URL: https://github.com/apache/flink/pull/8617#issuecomment-506135399 What if the checkpoint is timeout, the task will block all the time?

[jira] [Updated] (FLINK-12609) Align the Python data types with Java

[ https://issues.apache.org/jira/browse/FLINK-12609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12609: --- Labels: pull-request-available (was: ) > Align the Python data types with Java >

[GitHub] [flink] asfgit closed pull request #8847: [FLINK-12609][python] Align the Python data types with Java

asfgit closed pull request #8847: [FLINK-12609][python] Align the Python data types with Java URL: https://github.com/apache/flink/pull/8847 This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-12609) Align the Python data types with Java

[ https://issues.apache.org/jira/browse/FLINK-12609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-12609. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in master: 

[jira] [Created] (FLINK-13007) Integrate Flink's FunctionCatalog with Catalog APIs

Bowen Li created FLINK-13007: Summary: Integrate Flink's FunctionCatalog with Catalog APIs Key: FLINK-13007 URL: https://issues.apache.org/jira/browse/FLINK-13007 Project: Flink Issue Type:

[jira] [Updated] (FLINK-12999) Can't generate valid execution plan for "SELECT uuid() FROM VALUES(1,2,3) T(a, b, c)"

[ https://issues.apache.org/jira/browse/FLINK-12999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-12999: - Summary: Can't generate valid execution plan for "SELECT uuid() FROM VALUES(1,2,3) T(a, b, c)"

[GitHub] [flink] flinkbot edited a comment on issue #8847: [FLINK-12609][python] Align the Python data types with Java

flinkbot edited a comment on issue #8847: [FLINK-12609][python] Align the Python data types with Java URL: https://github.com/apache/flink/pull/8847#issuecomment-504894006 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8847: [FLINK-12609][python] Align the Python data types with Java

sunjincheng121 commented on a change in pull request #8847: [FLINK-12609][python] Align the Python data types with Java URL: https://github.com/apache/flink/pull/8847#discussion_r297952647 ## File path: flink-python/pyflink/table/table_environment.py ## @@ -494,9 +494,11

[GitHub] [flink] flinkbot commented on issue #8905: [FLINK-13006][hive] remove GenericUDTFReplicateRows from GenericUDTFTest because Hive 1.2.1 doesn't have it

flinkbot commented on issue #8905: [FLINK-13006][hive] remove GenericUDTFReplicateRows from GenericUDTFTest because Hive 1.2.1 doesn't have it URL: https://github.com/apache/flink/pull/8905#issuecomment-506129625 Thanks a lot for your contribution to the Apache Flink project. I'm the

[GitHub] [flink] bowenli86 opened a new pull request #8905: [FLINK-13006][hive] remove GenericUDTFReplicateRows from GenericUDTFTest because Hive 1.2.1 doesn't have it

bowenli86 opened a new pull request #8905: [FLINK-13006][hive] remove GenericUDTFReplicateRows from GenericUDTFTest because Hive 1.2.1 doesn't have it URL: https://github.com/apache/flink/pull/8905 ## What is the purpose of the change This PR removes GenericUDTFReplicateRows from

[GitHub] [flink] bowenli86 commented on issue #8889: [FLINK-12934][hive] add additional dependencies for flink-connector-hive to connect to remote hive metastore service

bowenli86 commented on issue #8889: [FLINK-12934][hive] add additional dependencies for flink-connector-hive to connect to remote hive metastore service URL: https://github.com/apache/flink/pull/8889#issuecomment-506129381 cc @xuefuz @lirui-apache @zjuwangg

[GitHub] [flink] bowenli86 commented on issue #8905: [FLINK-13006][hive] remove GenericUDTFReplicateRows from GenericUDTFTest because Hive 1.2.1 doesn't have it

bowenli86 commented on issue #8905: [FLINK-13006][hive] remove GenericUDTFReplicateRows from GenericUDTFTest because Hive 1.2.1 doesn't have it URL: https://github.com/apache/flink/pull/8905#issuecomment-506129301 cc @xuefuz @lirui-apache @zjuwangg

[jira] [Updated] (FLINK-13006) remove GenericUDTFReplicateRows from GenericUDTFTest because Hive 1.2.1 doesn't have it

[ https://issues.apache.org/jira/browse/FLINK-13006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13006: --- Labels: pull-request-available (was: ) > remove GenericUDTFReplicateRows from

[GitHub] [flink] flinkbot edited a comment on issue #8894: [FLINK-12961][datastream] Providing an internal execution method of StreamExecutionEnvironment accepting StreamGraph as input parameter

flinkbot edited a comment on issue #8894: [FLINK-12961][datastream] Providing an internal execution method of StreamExecutionEnvironment accepting StreamGraph as input parameter URL: https://github.com/apache/flink/pull/8894#issuecomment-505774524 Thanks a lot for your contribution to

[jira] [Commented] (FLINK-12953) View logs from Job view in Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-12953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873759#comment-16873759 ] vinoyang commented on FLINK-12953: -- Hi [~rmetzger] Agree. In our streaming platform, we have strong

[GitHub] [flink] ifndef-SleePy commented on issue #8894: [FLINK-12961][datastream] Providing an internal execution method of StreamExecutionEnvironment accepting StreamGraph as input parameter

ifndef-SleePy commented on issue #8894: [FLINK-12961][datastream] Providing an internal execution method of StreamExecutionEnvironment accepting StreamGraph as input parameter URL: https://github.com/apache/flink/pull/8894#issuecomment-506124650 @flinkbot attention @aljoscha

[jira] [Created] (FLINK-13006) remove GenericUDTFReplicateRows from GenericUDTFTest because Hive 1.2.1 doesn't have it

Bowen Li created FLINK-13006: Summary: remove GenericUDTFReplicateRows from GenericUDTFTest because Hive 1.2.1 doesn't have it Key: FLINK-13006 URL: https://issues.apache.org/jira/browse/FLINK-13006

[jira] [Commented] (FLINK-13004) Correct the logic of needToCleanupState in KeyedProcessFunctionWithCleanupState

[ https://issues.apache.org/jira/browse/FLINK-13004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873756#comment-16873756 ] Jark Wu commented on FLINK-13004: - I think the {{timestamp}} parameter should be primitive long. Thanks

[jira] [Commented] (FLINK-12771) Support ConnectorCatalogTable in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-12771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873755#comment-16873755 ] Bowen Li commented on FLINK-12771: -- Temporarily on hold this ticket and remove it from 1.9.0 > Support

[jira] [Updated] (FLINK-12771) Support ConnectorCatalogTable in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-12771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12771: - Fix Version/s: (was: 1.9.0) > Support ConnectorCatalogTable in HiveCatalog >

[jira] [Updated] (FLINK-13004) Correct the logic of needToCleanupState in KeyedProcessFunctionWithCleanupState

[ https://issues.apache.org/jira/browse/FLINK-13004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13004: Component/s: Table SQL / Planner > Correct the logic of needToCleanupState in >

  1   2   3   4   5   6   >