[GitHub] [flink] Sxnan commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

Sxnan commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129#discussion_r390122473 ## File path: docs/dev/connectors/guarantees.zh.md ## @@ -23

[GitHub] [flink] Sxnan commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

Sxnan commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129#discussion_r390122451 ## File path: docs/dev/connectors/guarantees.zh.md ## @@ -23

[GitHub] [flink] Sxnan commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

Sxnan commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129#discussion_r390122347 ## File path: docs/dev/connectors/guarantees.zh.md ## @@ -23

[GitHub] [flink] Sxnan commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

Sxnan commented on a change in pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129#discussion_r390122414 ## File path: docs/dev/connectors/guarantees.zh.md ## @@ -43

[GitHub] [flink] flinkbot edited a comment on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client

flinkbot edited a comment on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client URL: https://github.com/apache/flink/pull/10526#issuecomment-564436777 ## CI report: * 4ce7cfd0e007e050facf3a61b0c5519519f4feee UNKNOWN * c6a292a504

[GitHub] [flink] flinkbot edited a comment on issue #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod

flinkbot edited a comment on issue #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod URL: https://github.com/apache/flink/pull/11360#issuecomment-596920933 ## CI report: * 0037e8816fb00f1a6d3f06a32b7acace3298e009 Travis: [PENDING](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN * f38af5e48e36464e94a14cb7b10e7fc74008

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11342: [FLINK-16483][python] Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work

flinkbot edited a comment on issue #11342: [FLINK-16483][python] Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work URL: https://github.com/apache/flink/pull/11342#issuecomment-596093049 ## CI report: * c506306f83eec4450719dfdfb2f

[jira] [Commented] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails

[ https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055631#comment-17055631 ] Zhijiang commented on FLINK-16477: -- Another failure instance  [https://dev.azure.com/rm

[GitHub] [flink] flinkbot edited a comment on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client

flinkbot edited a comment on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client URL: https://github.com/apache/flink/pull/10526#issuecomment-564436777 ## CI report: * 4ce7cfd0e007e050facf3a61b0c5519519f4feee UNKNOWN * c6a292a504

[jira] [Assigned] (FLINK-16512) Add persistence API

[ https://issues.apache.org/jira/browse/FLINK-16512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-16512: -- Assignee: Roman Khachatryan > Add persistence API > --- > >

[jira] [Assigned] (FLINK-16513) Implement persistence API

[ https://issues.apache.org/jira/browse/FLINK-16513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-16513: -- Assignee: Roman Khachatryan > Implement persistence API > - >

[GitHub] [flink] jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#discussion_r390113102 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskEx

[GitHub] [flink] jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager

jinglining commented on a change in pull request #11250: [FLINK-16302][rest]add log list and read log by name for taskmanager URL: https://github.com/apache/flink/pull/11250#discussion_r390113102 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskEx

[GitHub] [flink] JingsongLi commented on a change in pull request #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars

JingsongLi commented on a change in pull request #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars URL: https://github.com/apache/flink/pull/11328#discussion_r390112527 ## File path: flink-connectors/flink-sql-connector-hive-1.2.2/pom.x

[GitHub] [flink] flinkbot edited a comment on issue #11359: [FLINK-16095] [docs-zh] Translate "Modules" page of "Table API & SQL" into Chinese

flinkbot edited a comment on issue #11359: [FLINK-16095] [docs-zh] Translate "Modules" page of "Table API & SQL" into Chinese URL: https://github.com/apache/flink/pull/11359#issuecomment-596916485 ## CI report: * 4d5019079937eb3a8d991d5e5e54a5570330f56b Travis: [PENDING](https:/

[GitHub] [flink] flinkbot commented on issue #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod

flinkbot commented on issue #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod URL: https://github.com/apache/flink/pull/11360#issuecomment-596920933 ## CI report: * 0037e8816fb00f1a6d3f06a32b7acace3298e009 UNKNOWN Bot commands The @fli

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN * f38af5e48e36464e94a14cb7b10e7fc74008

[GitHub] [flink] bowenli86 commented on a change in pull request #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars

bowenli86 commented on a change in pull request #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars URL: https://github.com/apache/flink/pull/11328#discussion_r390110003 ## File path: flink-connectors/flink-sql-connector-hive-1.2.2/pom.xm

[GitHub] [flink] flinkbot commented on issue #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod

flinkbot commented on issue #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod URL: https://github.com/apache/flink/pull/11360#issuecomment-596916787 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to re

[GitHub] [flink] flinkbot edited a comment on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars

flinkbot edited a comment on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars URL: https://github.com/apache/flink/pull/11328#issuecomment-595621789 ## CI report: * f1d94b9792a597e9b935fe08001930a3eb27d789 UNKNOWN * b4a76d7

[GitHub] [flink] flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code

flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code URL: https://github.com/apache/flink/pull/11358#issuecomment-596885127 ## CI report: * cf3f3aac4aa052f71bd4954fd55b48c84350edf6 Travis: [SUCCESS](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot commented on issue #11359: [FLINK-16095] [chinese-translation] Translate "Modules" page of "Tabl…

flinkbot commented on issue #11359: [FLINK-16095] [chinese-translation] Translate "Modules" page of "Tabl… URL: https://github.com/apache/flink/pull/11359#issuecomment-596916485 ## CI report: * 4d5019079937eb3a8d991d5e5e54a5570330f56b UNKNOWN Bot commands The @fli

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN * f38af5e48e36464e94a14cb7b10e7fc74008

[jira] [Updated] (FLINK-16508) Name the ports exposed by the main Container in Pod

[ https://issues.apache.org/jira/browse/FLINK-16508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16508: --- Labels: pull-request-available (was: ) > Name the ports exposed by the main Container in Po

[GitHub] [flink] zhengcanbin opened a new pull request #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod

zhengcanbin opened a new pull request #11360: [FLINK-16508][k8s] Name the ports exposed by the main Container in Pod URL: https://github.com/apache/flink/pull/11360 ## What is the purpose of the change 1. Currently, we expose some ports via the main Container of the JobManager and t

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055609#comment-17055609 ] Sivaprasanna Sethuraman commented on FLINK-10114: - [~gaoyunhaii] I beli

[GitHub] [flink] flinkbot commented on issue #11359: [FLINK-16095] [chinese-translation] Translate "Modules" page of "Tabl…

flinkbot commented on issue #11359: [FLINK-16095] [chinese-translation] Translate "Modules" page of "Tabl… URL: https://github.com/apache/flink/pull/11359#issuecomment-596915123 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to re

[jira] [Updated] (FLINK-16095) Translate "Modules" page of "Table API & SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16095: --- Labels: pull-request-available (was: ) > Translate "Modules" page of "Table API & SQL" into

[GitHub] [flink] melotlee opened a new pull request #11359: [FLINK-16095] [chinese-translation] Translate "Modules" page of "Tabl…

melotlee opened a new pull request #11359: [FLINK-16095] [chinese-translation] Translate "Modules" page of "Tabl… URL: https://github.com/apache/flink/pull/11359 Translate "Modules" page of "Table API & SQL" into Chinese ## What is the purpose of the change *(This pull

[GitHub] [flink] flinkbot edited a comment on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars

flinkbot edited a comment on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars URL: https://github.com/apache/flink/pull/11328#issuecomment-595621789 ## CI report: * f1d94b9792a597e9b935fe08001930a3eb27d789 UNKNOWN * b4a76d7

[GitHub] [flink] flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL

flinkbot edited a comment on issue #11340: [Flink 14338] Upgrade Calcite version to 1.22 for Flink SQL URL: https://github.com/apache/flink/pull/11340#issuecomment-596050968 ## CI report: * 1e95f02cc2803e695eb28597de8f7344362826fd UNKNOWN * f38af5e48e36464e94a14cb7b10e7fc74008

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] JingsongLi commented on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars

JingsongLi commented on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars URL: https://github.com/apache/flink/pull/11328#issuecomment-596911964 @flinkbot run travis This i

[GitHub] [flink] flinkbot edited a comment on issue #11342: [FLINK-16483][python] Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work

flinkbot edited a comment on issue #11342: [FLINK-16483][python] Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work URL: https://github.com/apache/flink/pull/11342#issuecomment-596093049 ## CI report: * c506306f83eec4450719dfdfb2f

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client

flinkbot edited a comment on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client URL: https://github.com/apache/flink/pull/10526#issuecomment-564436777 ## CI report: * 4ce7cfd0e007e050facf3a61b0c5519519f4feee UNKNOWN * c6a292a504

[jira] [Closed] (FLINK-16167) update python_shell document execution

[ https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16167. --- Resolution: Resolved > update python_shell document execution >

[jira] [Updated] (FLINK-16167) update python_shell document execution

[ https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16167: Fix Version/s: 1.9.3 > update python_shell document execution > --

[jira] [Comment Edited] (FLINK-16167) update python_shell document execution

[ https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055578#comment-17055578 ] Hequn Cheng edited comment on FLINK-16167 at 3/10/20, 5:12 AM: ---

[jira] [Commented] (FLINK-16167) update python_shell document execution

[ https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055578#comment-17055578 ] Hequn Cheng commented on FLINK-16167: - Resolved in 1.10.1 via 1046a474612df54792897

[jira] [Updated] (FLINK-16167) update python_shell document execution

[ https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16167: Fix Version/s: 1.11.0 1.10.1 > update python_shell document execution > ---

[jira] [Commented] (FLINK-16167) update python_shell document execution

[ https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055574#comment-17055574 ] Hequn Cheng commented on FLINK-16167: - [~yuwenbing] Thanks a lot for the contributio

[GitHub] [flink] hequn8128 closed pull request #11142: [FLINK-16167][python][doc] update python_shell document execution

hequn8128 closed pull request #11142: [FLINK-16167][python][doc] update python_shell document execution URL: https://github.com/apache/flink/pull/11142 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code

flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code URL: https://github.com/apache/flink/pull/11358#issuecomment-596885127 ## CI report: * cf3f3aac4aa052f71bd4954fd55b48c84350edf6 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] hequn8128 commented on issue #11142: [FLINK-16167][python][doc] update python_shell document execution

hequn8128 commented on issue #11142: [FLINK-16167][python][doc] update python_shell document execution URL: https://github.com/apache/flink/pull/11142#issuecomment-596899058 @jingwen-ywb Thanks a lot for the update. Looks good to me. Will do some minor changes during merge. Merging...

[GitHub] [flink] flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism

flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism URL: https://github.com/apache/flink/pull/11356#issuecomment-596856858 ## CI report: * 8917c0690a4d84ac1ca15a4ca4f68af921f8bdc1 Travis: [SUCCESS](https://travis-ci.com/

[jira] [Comment Edited] (FLINK-16018) Improve error reporting when submitting batch job (instead of AskTimeoutException)

[ https://issues.apache.org/jira/browse/FLINK-16018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055566#comment-17055566 ] Zili Chen edited comment on FLINK-16018 at 3/10/20, 4:24 AM: -

[GitHub] [flink] flinkbot edited a comment on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client

flinkbot edited a comment on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client URL: https://github.com/apache/flink/pull/10526#issuecomment-564436777 ## CI report: * 4ce7cfd0e007e050facf3a61b0c5519519f4feee UNKNOWN * c6a292a504

[jira] [Commented] (FLINK-16018) Improve error reporting when submitting batch job (instead of AskTimeoutException)

[ https://issues.apache.org/jira/browse/FLINK-16018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055566#comment-17055566 ] Zili Chen commented on FLINK-16018: --- A general thought is we respect {{timeout}} param

[GitHub] [flink] zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter

zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter URL: https://github.com/apache/flink/pull/11307#discussion_r390087580 ## File path: flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/write

[GitHub] [flink] zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter

zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter URL: https://github.com/apache/flink/pull/11307#discussion_r390087719 ## File path: flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/write

[GitHub] [flink] zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter

zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter URL: https://github.com/apache/flink/pull/11307#discussion_r390087527 ## File path: flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/write

[GitHub] [flink] zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter

zenfenan commented on a change in pull request #11307: [FLINK-16371] [BulkWriter] Fix Hadoop Compression BulkWriter URL: https://github.com/apache/flink/pull/11307#discussion_r390087748 ## File path: flink-formats/flink-compress/src/main/java/org/apache/flink/formats/compress/Compr

[GitHub] [flink] flinkbot edited a comment on issue #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest

flinkbot edited a comment on issue #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest URL: https://github.com/apache/flink/pull/11357#issuecomment-596871878 ## CI report: * 6fb60fcf06b43330aea1ea022423e0be3615b228 UNK

[jira] [Commented] (FLINK-16489) Use flink on yarn，RM restart AM，but the flink job is not restart from the saved checkpoint.

[ https://issues.apache.org/jira/browse/FLINK-16489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055563#comment-17055563 ] liangji commented on FLINK-16489: - Thank you. After add JM HA, this problem is solved.

[jira] [Closed] (FLINK-16489) Use flink on yarn，RM restart AM，but the flink job is not restart from the saved checkpoint.

[ https://issues.apache.org/jira/browse/FLINK-16489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liangji closed FLINK-16489. --- Resolution: Fixed > Use flink on yarn，RM restart AM，but the flink job is not restart from the > saved check

[GitHub] [flink] flinkbot edited a comment on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client

flinkbot edited a comment on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client URL: https://github.com/apache/flink/pull/10526#issuecomment-564436777 ## CI report: * 4ce7cfd0e007e050facf3a61b0c5519519f4feee UNKNOWN * c6a292a504

[GitHub] [flink] flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code

flinkbot edited a comment on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code URL: https://github.com/apache/flink/pull/11358#issuecomment-596885127 ## CI report: * cf3f3aac4aa052f71bd4954fd55b48c84350edf6 Travis: [PENDING](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot edited a comment on issue #11342: [FLINK-16483][python] Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work

flinkbot edited a comment on issue #11342: [FLINK-16483][python] Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work URL: https://github.com/apache/flink/pull/11342#issuecomment-596093049 ## CI report: * 27f93cc605b980ae0ce93b1d550

[GitHub] [flink] flinkbot edited a comment on issue #11142: [FLINK-16167][python][doc] update python_shell document execution

flinkbot edited a comment on issue #11142: [FLINK-16167][python][doc] update python_shell document execution URL: https://github.com/apache/flink/pull/11142#issuecomment-588249138 ## CI report: * 7ad5d6fcd65591e484cafd878fb1601403a070db Travis: [SUCCESS](https://travis-ci.com/fl

[GitHub] [flink] flinkbot edited a comment on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client

flinkbot edited a comment on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client URL: https://github.com/apache/flink/pull/10526#issuecomment-564436777 ## CI report: * 4ce7cfd0e007e050facf3a61b0c5519519f4feee UNKNOWN * c6a292a504

[GitHub] [flink] TisonKun commented on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client

TisonKun commented on issue #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client URL: https://github.com/apache/flink/pull/10526#issuecomment-596887194 @aljoscha Thanks for your review! I've addressed your comments inline. For moving test to `

[GitHub] [flink] KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#discussion_r390079440 ## File path: flink-table/flink-sql-client/src/test/

[GitHub] [flink] KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#discussion_r390076434 ## File path: flink-table/flink-sql-client/src/main/

[GitHub] [flink] KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#discussion_r390074844 ## File path: flink-table/flink-sql-client/pom.xml #

[GitHub] [flink] KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#discussion_r390076202 ## File path: flink-table/flink-sql-client/src/main/

[GitHub] [flink] KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#discussion_r390075494 ## File path: flink-table/flink-sql-client/src/main/

[GitHub] [flink] KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#discussion_r390079359 ## File path: flink-table/flink-sql-client/src/main/

[GitHub] [flink] KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI

KurtYoung commented on a change in pull request #11334: [FLINK-16464][sql-client]result-mode tableau may shift when content contains Chinese String in SQL CLI URL: https://github.com/apache/flink/pull/11334#discussion_r390079193 ## File path: flink-table/flink-sql-client/src/main/

[GitHub] [flink] TisonKun commented on a change in pull request #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client

TisonKun commented on a change in pull request #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client URL: https://github.com/apache/flink/pull/10526#discussion_r390079194 ## File path: flink-clients/src/main/java/org/apache/flink/client/Client

[GitHub] [flink] flinkbot edited a comment on issue #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest

flinkbot edited a comment on issue #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest URL: https://github.com/apache/flink/pull/11357#issuecomment-596871878 ## CI report: * 6fb60fcf06b43330aea1ea022423e0be3615b228 UNK

[GitHub] [flink] flinkbot commented on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code

flinkbot commented on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code URL: https://github.com/apache/flink/pull/11358#issuecomment-596885127 ## CI report: * cf3f3aac4aa052f71bd4954fd55b48c84350edf6 UNKNOWN Bot commands The @flinkbot bot supports

[GitHub] [flink] flinkbot edited a comment on issue #11342: [FLINK-16483][python] Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work

flinkbot edited a comment on issue #11342: [FLINK-16483][python] Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work URL: https://github.com/apache/flink/pull/11342#issuecomment-596093049 ## CI report: * 27f93cc605b980ae0ce93b1d550

[jira] [Updated] (FLINK-15131) Add Source API classes

[ https://issues.apache.org/jira/browse/FLINK-15131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-15131: - Fix Version/s: 1.11.0 > Add Source API classes > -- > > Key:

[jira] [Resolved] (FLINK-15131) Add Source API classes

[ https://issues.apache.org/jira/browse/FLINK-15131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-15131. -- Resolution: Fixed Merged to master. 5a81fa0766abe3ef6c0e6b8f9217e9adcd18095f > Add Source AP

[GitHub] [flink] becketqin closed pull request #10486: [FLINK-15131][connector/source] Add the APIs for Source (FLIP-27).

becketqin closed pull request #10486: [FLINK-15131][connector/source] Add the APIs for Source (FLIP-27). URL: https://github.com/apache/flink/pull/10486 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] becketqin commented on issue #10486: [FLINK-15131][connector/source] Add the APIs for Source (FLIP-27).

becketqin commented on issue #10486: [FLINK-15131][connector/source] Add the APIs for Source (FLIP-27). URL: https://github.com/apache/flink/pull/10486#issuecomment-596881891 Thanks for the review. @StephanEwen @wuchong merged to master. 5a81fa0766abe3ef6c0e6b8f9217e9adcd18095f

[GitHub] [flink] flinkbot edited a comment on issue #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest

flinkbot edited a comment on issue #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest URL: https://github.com/apache/flink/pull/11357#issuecomment-596871878 ## CI report: * 6fb60fcf06b43330aea1ea022423e0be3615b228 UNK

[GitHub] [flink] flinkbot edited a comment on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars

flinkbot edited a comment on issue #11328: [FLINK-16455][hive] Introduce flink-sql-connector-hive modules to provide hive uber jars URL: https://github.com/apache/flink/pull/11328#issuecomment-595621789 ## CI report: * f1d94b9792a597e9b935fe08001930a3eb27d789 UNKNOWN * b4a76d7

[GitHub] [flink] dianfu commented on issue #11342: [FLINK-16483][python] Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work

dianfu commented on issue #11342: [FLINK-16483][python] Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work URL: https://github.com/apache/flink/pull/11342#issuecomment-596881203 @hequn8128 Thanks a lot for the review. Have updated the PR. --

[GitHub] [flink] flinkbot commented on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code

flinkbot commented on issue #11358: [FLINK-16516][python] Remove Python UDF Codegen Code URL: https://github.com/apache/flink/pull/11358#issuecomment-596880791 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull req

[jira] [Updated] (FLINK-16516) Remove Python UDF Codegen Code

[ https://issues.apache.org/jira/browse/FLINK-16516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16516: --- Labels: pull-request-available (was: ) > Remove Python UDF Codegen Code > -

[GitHub] [flink] HuangXingBo opened a new pull request #11358: [FLINK-16516][python] Remove Python UDF Codegen Code

HuangXingBo opened a new pull request #11358: [FLINK-16516][python] Remove Python UDF Codegen Code URL: https://github.com/apache/flink/pull/11358 ## What is the purpose of the change *This pull request will replace python udf codegen code with static class code* ## Brief ch

[jira] [Commented] (FLINK-16476) SelectivityEstimatorTest logs LinkageErrors

[ https://issues.apache.org/jira/browse/FLINK-16476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055547#comment-17055547 ] Jark Wu commented on FLINK-16476: - Good catch [~godfreyhe]! {{org.apache.flink.table.p

[GitHub] [flink] godfreyhe commented on a change in pull request #11260: [FLINK-16344][table-planner-blink] Preserve nullability for nested types

godfreyhe commented on a change in pull request #11260: [FLINK-16344][table-planner-blink] Preserve nullability for nested types URL: https://github.com/apache/flink/pull/11260#discussion_r390072796 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink

[jira] [Closed] (FLINK-16273) Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not available" problem for users

[ https://issues.apache.org/jira/browse/FLINK-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16273. --- Resolution: Fixed > Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not > availabl

[jira] [Commented] (FLINK-16273) Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not available" problem for users

[ https://issues.apache.org/jira/browse/FLINK-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055545#comment-17055545 ] Hequn Cheng commented on FLINK-16273: - Fixed in 1.11.0 via f21fa9675b15b8a9673fa529a

[GitHub] [flink] hequn8128 merged pull request #11341: [FLINK-16273][python] Set io.netty.tryReflectionSetAccessible to true by default

hequn8128 merged pull request #11341: [FLINK-16273][python] Set io.netty.tryReflectionSetAccessible to true by default URL: https://github.com/apache/flink/pull/11341 This is an automated message from the Apache Git Service.

[jira] [Commented] (FLINK-16476) SelectivityEstimatorTest logs LinkageErrors

[ https://issues.apache.org/jira/browse/FLINK-16476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055544#comment-17055544 ] godfrey he commented on FLINK-16476: I create another issue (https://issues.apache.o

[jira] [Assigned] (FLINK-16508) Name the ports exposed by the main Container in Pod

[ https://issues.apache.org/jira/browse/FLINK-16508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-16508: - Assignee: Canbin Zheng > Name the ports exposed by the main Container in Pod >

[GitHub] [flink] hequn8128 commented on issue #11341: [FLINK-16273][python] Set io.netty.tryReflectionSetAccessible to true by default

hequn8128 commented on issue #11341: [FLINK-16273][python] Set io.netty.tryReflectionSetAccessible to true by default URL: https://github.com/apache/flink/pull/11341#issuecomment-596878216 Merging... This is an automated mess

[jira] [Created] (FLINK-16519) CheckpointCoordinatorFailureTest logs LinkageErrors

godfrey he created FLINK-16519: -- Summary: CheckpointCoordinatorFailureTest logs LinkageErrors Key: FLINK-16519 URL: https://issues.apache.org/jira/browse/FLINK-16519 Project: Flink Issue Type: B

[jira] [Closed] (FLINK-16507) "update_branch_version" should also update the version in Stateful Function's Python SDK setup.py file

[ https://issues.apache.org/jira/browse/FLINK-16507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-16507. --- Fix Version/s: statefun-1.1 Resolution: Fixed Merged to master via e2ffb95b6a

[GitHub] [flink] flinkbot edited a comment on issue #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest

flinkbot edited a comment on issue #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest URL: https://github.com/apache/flink/pull/11357#issuecomment-596871878 ## CI report: * 6fb60fcf06b43330aea1ea022423e0be3615b228 UNK

[GitHub] [flink] flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism

flinkbot edited a comment on issue #11356: [FLINK-15000] [web] WebUI metrics is very slow in large parallelism URL: https://github.com/apache/flink/pull/11356#issuecomment-596856858 ## CI report: * 8917c0690a4d84ac1ca15a4ca4f68af921f8bdc1 Travis: [SUCCESS](https://travis-ci.com/

[GitHub] [flink] TisonKun commented on a change in pull request #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client

TisonKun commented on a change in pull request #10526: [FLINK-15090][build] Reverse the dependency from flink-streaming-java to flink-client URL: https://github.com/apache/flink/pull/10526#discussion_r390070761 ## File path: flink-clients/src/main/java/org/apache/flink/client/Client

[GitHub] [flink-statefun] tzulitai commented on issue #55: [FLINK-16518] [kafka] Set client properties as strings in KafkaSinkProvider

tzulitai commented on issue #55: [FLINK-16518] [kafka] Set client properties as strings in KafkaSinkProvider URL: https://github.com/apache/flink-statefun/pull/55#issuecomment-596877164 cc @igalshilman This is an automated

[jira] [Updated] (FLINK-16518) Stateful Function's KafkaSinkProvider should use `setProperty` instead of `put` for resolving client properties

[ https://issues.apache.org/jira/browse/FLINK-16518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16518: --- Labels: pull-request-available (was: ) > Stateful Function's KafkaSinkProvider should use `

  1   2   3   4   5   >