[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

[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 *

[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 *

[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:

[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

[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

[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

[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=17055609#comment-17055609 ] Sivaprasanna Sethuraman commented on FLINK-10114: - [~gaoyunhaii] I believe relying on

[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

[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"

[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

[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 *

[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 *

[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

[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: *

[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 *

[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=17055578#comment-17055578 ] Hequn Cheng edited comment on FLINK-16167 at 3/10/20, 5:12 AM: --- Resolved

[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=17055578#comment-17055578 ] Hequn Cheng commented on FLINK-16167: - Resolved in 1.10.1 via

[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=17055574#comment-17055574 ] Hequn Cheng commented on FLINK-16167: - [~yuwenbing] Thanks a lot for the contribution. > update

[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:

[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:

[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=17055566#comment-17055566 ] Zili Chen edited comment on FLINK-16018 at 3/10/20, 4:24 AM: - A rough

[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 *

[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=17055566#comment-17055566 ] Zili Chen commented on FLINK-16018: --- A general thought is we respect {{timeout}} parameter in

[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:

[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:

[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:

[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:

[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

[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=17055563#comment-17055563 ] liangji commented on FLINK-16489: - Thank you. After add JM HA, this problem is solved. > Use flink on

[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

[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 *

[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:

[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: *

[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:

[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 *

[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:

[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:

[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_r390079193 ## File path:

[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:

[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:

[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:

[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:

[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

[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

[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: *

[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 > -- > >

[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

[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

[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

[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 *

[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

[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

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

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

[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:

[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 >

[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=17055545#comment-17055545 ] Hequn Cheng commented on FLINK-16273: - Fixed in 1.11.0 via f21fa9675b15b8a9673fa529a1d368427f846161

[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

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

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

[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

[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:

[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

[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

[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:

[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:

[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

[GitHub] [flink-statefun] tzulitai opened a new pull request #55: [FLINK-16518] [kafka] Set client properties as strings in KafkaSinkProvider

tzulitai opened a new pull request #55: [FLINK-16518] [kafka] Set client properties as strings in KafkaSinkProvider URL: https://github.com/apache/flink-statefun/pull/55 The put method is strongly discourage to be used on `Properties` as a bad practice, since it allows putting non-string

[GitHub] [flink-statefun] tzulitai closed pull request #53: [FLINK-16507] [releasing] update_branch_version.sh should also update Python SDK version

tzulitai closed pull request #53: [FLINK-16507] [releasing] update_branch_version.sh should also update Python SDK version URL: https://github.com/apache/flink-statefun/pull/53 This is an automated message from the Apache

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

[ https://issues.apache.org/jira/browse/FLINK-16476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055541#comment-17055541 ] godfrey he commented on FLINK-16476: The error message is reported by

[jira] [Updated] (FLINK-16506) SqlCreateTable can not get the original text when there exists non-ascii char in the column definition

[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-16506: --- Description: We can reproduce this problem in FlinkSqlParserImplTest, add one more column

[jira] [Updated] (FLINK-16506) SqlCreateTable can not get the original text when there exists non-ascii char in the column definition

[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-16506: --- Affects Version/s: 1.10.0 > SqlCreateTable can not get the original text when there exists

[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_r390068747 ## File path:

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

[ https://issues.apache.org/jira/browse/FLINK-16476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055531#comment-17055531 ] Jark Wu commented on FLINK-16476: - But it seems that {{CompletedCheckpointTest}} doesn't use

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

[ https://issues.apache.org/jira/browse/FLINK-16476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16476: --- Assignee: godfrey he > SelectivityEstimatorTest logs LinkageErrors >

[jira] [Commented] (FLINK-16506) SqlCreateTable can not get the original text when there exists non-ascii char in the column definition

[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055527#comment-17055527 ] Terry Wang commented on FLINK-16506: cc [~danny0405] to have a look > SqlCreateTable can not get

[jira] [Updated] (FLINK-16025) Service could expose blob server port mismatched with JM Container

[ https://issues.apache.org/jira/browse/FLINK-16025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-16025: -- Fix Version/s: (was: 1.11.0) 1.10.1 > Service could expose blob server port

[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: * 04fbc2dcd76c47ce9fe126469d6b7d96da58651a Travis:

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

Tzu-Li (Gordon) Tai created FLINK-16518: --- Summary: Stateful Function's KafkaSinkProvider should use `setProperty` instead of `put` for resolving client properties Key: FLINK-16518 URL:

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

flinkbot commented 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 UNKNOWN

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

flinkbot commented on issue #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest URL: https://github.com/apache/flink/pull/11357#issuecomment-596870971 Thanks a lot for your contribution to the Apache Flink project. I'm the

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

dianfu commented on a change in pull request #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#discussion_r390058585 ## File path:

[GitHub] [flink] TisonKun commented on issue #11311: [FLINK-16427][api] Remove directly throw ProgramInvocationExceptions in RemoteStreamEnvironment

TisonKun commented on issue #11311: [FLINK-16427][api] Remove directly throw ProgramInvocationExceptions in RemoteStreamEnvironment URL: https://github.com/apache/flink/pull/11311#issuecomment-596870391 Thanks! This is an

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

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

[GitHub] [flink] godfreyhe opened a new pull request #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest

godfreyhe opened a new pull request #11357: [FLINK-16476] [table-planner-blink] Remove PowerMockito to avoid LinkageError in SelectivityEstimatorTest URL: https://github.com/apache/flink/pull/11357 ## What is the purpose of the change *Remove PowerMockito to avoid

[jira] [Closed] (FLINK-16514) SQLClientKafkaITCase fails with output mismatch

[ https://issues.apache.org/jira/browse/FLINK-16514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16514. --- Resolution: Duplicate > SQLClientKafkaITCase fails with output mismatch >

[jira] [Assigned] (FLINK-16083) Translate "Dynamic Table" page of "Streaming Concepts" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16083: --- Assignee: ShijieZhang > Translate "Dynamic Table" page of "Streaming Concepts" into Chinese >

  1   2   3   4   5   >