[jira] [Updated] (FLINK-15793) Move kubernetes-entry.sh out of FLINK_HOME/bin

2020-08-11 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15793: -- Affects Version/s: 1.11.0 > Move kubernetes-entry.sh out of FLINK_HOME/bin >

[GitHub] [flink] flinkbot edited a comment on pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13121: URL: https://github.com/apache/flink/pull/13121#issuecomment-672466655 ## CI report: * a572964939815f96ee78d0ff1939bf444812b7da Azure:

[GitHub] [flink] flinkbot commented on pull request #13125: [FLINK-18643] Deploy Flink snapshot build with nightly CI job

2020-08-11 Thread GitBox
flinkbot commented on pull request #13125: URL: https://github.com/apache/flink/pull/13125#issuecomment-672622123 ## CI report: * b6c7c2440191c0fba1a8ca796bbc15e70eeb049e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13125: [FLINK-18643] Deploy Flink snapshot build with nightly CI job

2020-08-11 Thread GitBox
flinkbot commented on pull request #13125: URL: https://github.com/apache/flink/pull/13125#issuecomment-672611771 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] rmetzger opened a new pull request #13125: [FLINK-18643] Deploy Flink snapshot build with nightly CI job

2020-08-11 Thread GitBox
rmetzger opened a new pull request #13125: URL: https://github.com/apache/flink/pull/13125 ## What is the purpose of the change Every night, we will deploy a SNAPSHOT version to Apache's snapshot maven repository. The Flink PMC got special credentials for that purpose. We are

[jira] [Updated] (FLINK-18643) Migrate Jenkins jobs to ci-builds.apache.org

2020-08-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18643: --- Labels: pull-request-available (was: ) > Migrate Jenkins jobs to ci-builds.apache.org >

[GitHub] [flink] flinkbot edited a comment on pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13119: URL: https://github.com/apache/flink/pull/13119#issuecomment-672011891 ## CI report: * 9b7c269c1f59721e9a2f9accea9fd3d30e18b65a Azure:

[GitHub] [flink] klion26 commented on a change in pull request #13088: [FLINK-18814][docs-zh] Translate the 'Side Outputs' page of 'DataStream API' into Chinese

2020-08-11 Thread GitBox
klion26 commented on a change in pull request #13088: URL: https://github.com/apache/flink/pull/13088#discussion_r469014440 ## File path: docs/dev/stream/side_output.zh.md ## @@ -26,21 +26,15 @@ under the License. * This will be replaced by the TOC {:toc} -In addition to

[GitHub] [flink] klion26 commented on a change in pull request #13089: [FLINK-18813][docs-zh] Translate the 'Local Installation' page of 'Try Flink' into Chinese

2020-08-11 Thread GitBox
klion26 commented on a change in pull request #13089: URL: https://github.com/apache/flink/pull/13089#discussion_r469011734 ## File path: docs/try-flink/local_installation.zh.md ## @@ -26,36 +26,35 @@ under the License. {% if site.version contains "SNAPSHOT" %} - NOTE:

[GitHub] [flink] flinkbot edited a comment on pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13119: URL: https://github.com/apache/flink/pull/13119#issuecomment-672011891 ## CI report: * 9b7c269c1f59721e9a2f9accea9fd3d30e18b65a Azure:

[GitHub] [flink] shuiqiangchen commented on pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
shuiqiangchen commented on pull request #13119: URL: https://github.com/apache/flink/pull/13119#issuecomment-672577709 @hequn8128 Thank you for your comments, I have updated the PR according to your suggestions, please have a look at it.

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
shuiqiangchen commented on a change in pull request #13119: URL: https://github.com/apache/flink/pull/13119#discussion_r469006454 ## File path: flink-python/pyflink/datastream/data_stream.py ## @@ -563,6 +654,27 @@ def key_by(self, key_selector: Union[Callable, KeySelector],

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
shuiqiangchen commented on a change in pull request #13119: URL: https://github.com/apache/flink/pull/13119#discussion_r469004979 ## File path: flink-python/pyflink/datastream/tests/test_data_stream.py ## @@ -242,6 +242,68 @@ def test_print_with_align_output(self):

[GitHub] [flink] flinkbot edited a comment on pull request #13124: [FLINK-18815][test-stability] Close safety net guarded closeable iff it is still registered

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13124: URL: https://github.com/apache/flink/pull/13124#issuecomment-672568955 ## CI report: * facd84875f0fde6ee7b446871ec6c7b1d5954bf1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13101: [FLINK-18867][hive] Generic table stored in Hive catalog is incompati…

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13101: URL: https://github.com/apache/flink/pull/13101#issuecomment-671238135 ## CI report: * 52a3dda64175007c4eb7b0d24edb71d95ccdaebf Azure:

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
shuiqiangchen commented on a change in pull request #13119: URL: https://github.com/apache/flink/pull/13119#discussion_r469004979 ## File path: flink-python/pyflink/datastream/tests/test_data_stream.py ## @@ -242,6 +242,68 @@ def test_print_with_align_output(self):

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
shuiqiangchen commented on a change in pull request #13119: URL: https://github.com/apache/flink/pull/13119#discussion_r469004979 ## File path: flink-python/pyflink/datastream/tests/test_data_stream.py ## @@ -242,6 +242,68 @@ def test_print_with_align_output(self):

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
shuiqiangchen commented on a change in pull request #13119: URL: https://github.com/apache/flink/pull/13119#discussion_r469004979 ## File path: flink-python/pyflink/datastream/tests/test_data_stream.py ## @@ -242,6 +242,68 @@ def test_print_with_align_output(self):

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
shuiqiangchen commented on a change in pull request #13119: URL: https://github.com/apache/flink/pull/13119#discussion_r469004979 ## File path: flink-python/pyflink/datastream/tests/test_data_stream.py ## @@ -242,6 +242,68 @@ def test_print_with_align_output(self):

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
shuiqiangchen commented on a change in pull request #13119: URL: https://github.com/apache/flink/pull/13119#discussion_r469004707 ## File path: flink-python/pyflink/datastream/data_stream.py ## @@ -563,6 +654,27 @@ def key_by(self, key_selector: Union[Callable, KeySelector],

[jira] [Created] (FLINK-18898) .flink-runtime.version.properties file does not exist in flink-dist.jar

2020-08-11 Thread Aki Tanaka (Jira)
Aki Tanaka created FLINK-18898: -- Summary: .flink-runtime.version.properties file does not exist in flink-dist.jar Key: FLINK-18898 URL: https://issues.apache.org/jira/browse/FLINK-18898 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #13124: [FLINK-18815][test-stability] Close safety net guarded closeable iff it is still registered

2020-08-11 Thread GitBox
flinkbot commented on pull request #13124: URL: https://github.com/apache/flink/pull/13124#issuecomment-672568955 ## CI report: * facd84875f0fde6ee7b446871ec6c7b1d5954bf1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13101: [FLINK-18867][hive] Generic table stored in Hive catalog is incompati…

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13101: URL: https://github.com/apache/flink/pull/13101#issuecomment-671238135 ## CI report: * 52a3dda64175007c4eb7b0d24edb71d95ccdaebf Azure:

[jira] [Updated] (FLINK-18815) AbstractCloseableRegistryTest.testClose unstable

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

[GitHub] [flink] kezhuw commented on pull request #13124: [FLINK-18815][test-stability] Close safety net guarded closeable iff it is still registered

2020-08-11 Thread GitBox
kezhuw commented on pull request #13124: URL: https://github.com/apache/flink/pull/13124#issuecomment-672567046 @flinkbot attention @tillrohrmann This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot commented on pull request #13124: [Flink 18815][test-stability] Close safety net guarded closeable iff it is still registered

2020-08-11 Thread GitBox
flinkbot commented on pull request #13124: URL: https://github.com/apache/flink/pull/13124#issuecomment-672566215 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] kezhuw opened a new pull request #13124: [Flink 18815][test-stability] Close safety net guarded closeable iff it is still registered

2020-08-11 Thread GitBox
kezhuw opened a new pull request #13124: URL: https://github.com/apache/flink/pull/13124 ## What is the purpose of the change Guard safety net closeable concurrenting closing between `SafetyNetCloseableRegistry#close` and

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

2020-08-11 Thread liufangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175975#comment-17175975 ] liufangliang commented on FLINK-18202: -- Hi [~libenchao] [~FrankZou] [~jark] , Sounds good to me. if

[jira] [Assigned] (FLINK-18775) Rework PyFlink Documentation

2020-08-11 Thread sunjincheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-18775: --- Assignee: Wei Zhong (was: sunjincheng) > Rework PyFlink Documentation >

[GitHub] [flink] flinkbot edited a comment on pull request #13004: [FLINK-18719][runtime] Define interfaces for new active RMs and implement

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13004: URL: https://github.com/apache/flink/pull/13004#issuecomment-664960056 ## CI report: * Unknown: [CANCELED](TBD) * f1bfc953a17f24a74ac3da5db2d9dd790f90de8c Azure:

[jira] [Commented] (FLINK-18832) BoundedBlockingSubpartition does not work with StreamTask

2020-08-11 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175960#comment-17175960 ] Zhijiang commented on FLINK-18832: -- Thanks for the explanation [~dwysakowicz]. If so, I think we can

[GitHub] [flink] flinkbot edited a comment on pull request #13004: [FLINK-18719][runtime] Define interfaces for new active RMs and implement

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13004: URL: https://github.com/apache/flink/pull/13004#issuecomment-664960056 ## CI report: * Unknown: [CANCELED](TBD) * f1bfc953a17f24a74ac3da5db2d9dd790f90de8c UNKNOWN Bot commands The @flinkbot bot supports the

[jira] [Updated] (FLINK-18826) Support to emit and encode upsert messages to Kafka

2020-08-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18826: Description: Currently, it is not possible to emit the results of a group by query into Kafka. We can

[jira] [Updated] (FLINK-18826) Support to emit and encode upsert messages to Kafka

2020-08-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18826: Description: Currently, it is not possible to emit the results of a group by query into Kafka. We can

[jira] [Assigned] (FLINK-18826) Support to emit and encode upsert messages to Kafka

2020-08-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18826: --- Assignee: Shengkai Fang > Support to emit and encode upsert messages to Kafka >

[GitHub] [flink] xintongsong commented on pull request #13004: [FLINK-18719][runtime] Define interfaces for new active RMs and implement

2020-08-11 Thread GitBox
xintongsong commented on pull request #13004: URL: https://github.com/apache/flink/pull/13004#issuecomment-672548350 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-18852) StreamScan should keep the same parallelism as the input

2020-08-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175959#comment-17175959 ] Jark Wu commented on FLINK-18852: - Sure. Assigned to you [~liupengcheng] > StreamScan should keep the

[jira] [Assigned] (FLINK-18852) StreamScan should keep the same parallelism as the input

2020-08-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18852: --- Assignee: liupengcheng > StreamScan should keep the same parallelism as the input >

[GitHub] [flink] flinkbot edited a comment on pull request #13123: [hotfix][docs]Correct the grammar

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13123: URL: https://github.com/apache/flink/pull/13123#issuecomment-672516148 ## CI report: * f09131c5dc3b1a55ffaebaf9a8f4db6bc48ee931 Azure:

[jira] [Commented] (FLINK-18852) StreamScan should keep the same parallelism as the input

2020-08-11 Thread liupengcheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175958#comment-17175958 ] liupengcheng commented on FLINK-18852: -- hi [~jark], yes, I only tested the legacy planner, and the

[jira] [Closed] (FLINK-18844) Support maxwell-json format to read Maxwell changelogs

2020-08-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18844. --- Resolution: Fixed Implemented in master (1.12.0): 2d75031d3d6bdc11c7b3fcf25cd43f396677003c > Support

[GitHub] [flink] xintongsong commented on pull request #13004: [FLINK-18719][runtime] Define interfaces for new active RMs and implement

2020-08-11 Thread GitBox
xintongsong commented on pull request #13004: URL: https://github.com/apache/flink/pull/13004#issuecomment-672544126 Thanks for the review, @XComp & @tillrohrmann. I have rebased onto master branch, and addressed comments in the fixup commits. There's also a revert commit, since we

[GitHub] [flink] wuchong merged pull request #13090: [FLINK-18844][json][maxwell] Support maxwell-json format to read Maxwell changelogs

2020-08-11 Thread GitBox
wuchong merged pull request #13090: URL: https://github.com/apache/flink/pull/13090 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] wuchong commented on pull request #13090: [FLINK-18844][json][maxwell] Support maxwell-json format to read Maxwell changelogs

2020-08-11 Thread GitBox
wuchong commented on pull request #13090: URL: https://github.com/apache/flink/pull/13090#issuecomment-672543906 Build is passed. Merging... This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-18897) Add documentation for the maxwell-json format

2020-08-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175956#comment-17175956 ] Jark Wu commented on FLINK-18897: - [~shen_dijie] do you want to take this issue? > Add documentation

[jira] [Created] (FLINK-18897) Add documentation for the maxwell-json format

2020-08-11 Thread Jark Wu (Jira)
Jark Wu created FLINK-18897: --- Summary: Add documentation for the maxwell-json format Key: FLINK-18897 URL: https://issues.apache.org/jira/browse/FLINK-18897 Project: Flink Issue Type: Sub-task

[GitHub] [flink] xintongsong commented on a change in pull request #13004: [FLINK-18719][runtime] Define interfaces for new active RMs and implement

2020-08-11 Thread GitBox
xintongsong commented on a change in pull request #13004: URL: https://github.com/apache/flink/pull/13004#discussion_r468977562 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ResourceEventHandler.java ## @@ -0,0 +1,60 @@ +/* + *

[GitHub] [flink] hequn8128 commented on a change in pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
hequn8128 commented on a change in pull request #13119: URL: https://github.com/apache/flink/pull/13119#discussion_r468972272 ## File path: flink-python/pyflink/datastream/data_stream.py ## @@ -563,6 +654,27 @@ def key_by(self, key_selector: Union[Callable, KeySelector],

[jira] [Comment Edited] (FLINK-18848) table.to_pandas should handle retraction rows properly

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175953#comment-17175953 ] Dian Fu edited comment on FLINK-18848 at 8/12/20, 2:59 AM: --- As Table.execute

[jira] [Comment Edited] (FLINK-18848) table.to_pandas should handle retraction rows properly

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175953#comment-17175953 ] Dian Fu edited comment on FLINK-18848 at 8/12/20, 2:59 AM: --- As Table.execute

[jira] [Commented] (FLINK-18848) table.to_pandas should handle retraction rows properly

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175953#comment-17175953 ] Dian Fu commented on FLINK-18848: - As Table.execute doesn't support upsert table in 1.11 and so we

[jira] [Updated] (FLINK-18848) table.to_pandas should handle retraction rows properly

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18848: Affects Version/s: (was: 1.11.0) 1.12.0 > table.to_pandas should handle

[jira] [Updated] (FLINK-18848) table.to_pandas should handle retraction rows properly

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18848: Fix Version/s: (was: 1.11.2) > table.to_pandas should handle retraction rows properly >

[jira] [Closed] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18893. --- Resolution: Fixed > Python tests fails with "AppendStreamTableSink requires that Table has only > insert

[jira] [Updated] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18893: Fix Version/s: (was: 1.11.2) > Python tests fails with "AppendStreamTableSink requires that Table has

[jira] [Comment Edited] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175948#comment-17175948 ] Dian Fu edited comment on FLINK-18893 at 8/12/20, 2:55 AM: --- master: Fixed via 

[jira] [Commented] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175948#comment-17175948 ] Dian Fu commented on FLINK-18893: - Fixed in master via 3932683871e7d1aaa74d318aa4cee90d9b2f9e61 >

[GitHub] [flink] dianfu closed pull request #13120: [FLINK-18893][python] Fix Table.to_pandas for TableEnvironment created via EnvironmentSettings

2020-08-11 Thread GitBox
dianfu closed pull request #13120: URL: https://github.com/apache/flink/pull/13120 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Commented] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175947#comment-17175947 ] Dian Fu commented on FLINK-18893: - Just found that *Table.execute* doesn't support upsert table in 1.11

[GitHub] [flink] flinkbot commented on pull request #13123: [hotfix][docs]Correct the grammar

2020-08-11 Thread GitBox
flinkbot commented on pull request #13123: URL: https://github.com/apache/flink/pull/13123#issuecomment-672516148 ## CI report: * f09131c5dc3b1a55ffaebaf9a8f4db6bc48ee931 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #13122: [FLINK-18824][Table SQL][Formats]Support serialization for canal-json format

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13122: URL: https://github.com/apache/flink/pull/13122#issuecomment-672466736 ## CI report: * 0517cad763355d9f74172ad6d1e7c70a2038e742 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13119: URL: https://github.com/apache/flink/pull/13119#issuecomment-672011891 ## CI report: * 9b7c269c1f59721e9a2f9accea9fd3d30e18b65a Azure:

[GitHub] [flink] xintongsong commented on a change in pull request #13004: [FLINK-18719][runtime] Define interfaces for new active RMs and implement

2020-08-11 Thread GitBox
xintongsong commented on a change in pull request #13004: URL: https://github.com/apache/flink/pull/13004#discussion_r468971000 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ResourceEventHandler.java ## @@ -0,0 +1,60 @@ +/* + *

[GitHub] [flink] xintongsong commented on a change in pull request #13004: [FLINK-18719][runtime] Define interfaces for new active RMs and implement

2020-08-11 Thread GitBox
xintongsong commented on a change in pull request #13004: URL: https://github.com/apache/flink/pull/13004#discussion_r468971000 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ResourceEventHandler.java ## @@ -0,0 +1,60 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13121: URL: https://github.com/apache/flink/pull/13121#issuecomment-672466655 ## CI report: * a572964939815f96ee78d0ff1939bf444812b7da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13119: [FLINK-18885][python] Add partitioning interfaces for Python DataStre…

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13119: URL: https://github.com/apache/flink/pull/13119#issuecomment-672011891 ## CI report: * 9b7c269c1f59721e9a2f9accea9fd3d30e18b65a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13122: [FLINK-18824][Table SQL][Formats]Support serialization for canal-json format

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13122: URL: https://github.com/apache/flink/pull/13122#issuecomment-672466736 ## CI report: * 0517cad763355d9f74172ad6d1e7c70a2038e742 Azure:

[GitHub] [flink] flinkbot commented on pull request #13123: [hotfix][docs]Correct the grammar

2020-08-11 Thread GitBox
flinkbot commented on pull request #13123: URL: https://github.com/apache/flink/pull/13123#issuecomment-672478874 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] diohabara opened a new pull request #13123: [hotfix][docs]Correct the grammar

2020-08-11 Thread GitBox
diohabara opened a new pull request #13123: URL: https://github.com/apache/flink/pull/13123 ## What is the purpose of the change To fix typo in the documentation. ## Brief change log Correct Scala code in the documentation since it was written like Java. ##

[GitHub] [flink] flinkbot commented on pull request #13122: [FLINK-18824][Table SQL][Formats]Support serialization for canal-json format

2020-08-11 Thread GitBox
flinkbot commented on pull request #13122: URL: https://github.com/apache/flink/pull/13122#issuecomment-672466736 ## CI report: * 0517cad763355d9f74172ad6d1e7c70a2038e742 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

2020-08-11 Thread GitBox
flinkbot commented on pull request #13121: URL: https://github.com/apache/flink/pull/13121#issuecomment-672466655 ## CI report: * a572964939815f96ee78d0ff1939bf444812b7da UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-18863) Support read_text_file() and print() interface for Python DataStream API.

2020-08-11 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18863. --- Resolution: Resolved > Support read_text_file() and print() interface for Python DataStream API. >

[jira] [Commented] (FLINK-18863) Support read_text_file() and print() interface for Python DataStream API.

2020-08-11 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175931#comment-17175931 ] Hequn Cheng commented on FLINK-18863: - Resolved in 1.12.0 via 

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13117: [FLINK-18863][python] Support read_text_file() and print() interface …

2020-08-11 Thread GitBox
shuiqiangchen commented on a change in pull request #13117: URL: https://github.com/apache/flink/pull/13117#discussion_r468962646 ## File path: flink-python/pyflink/datastream/tests/test_stream_execution_environment.py ## @@ -254,3 +254,20 @@ def test_add_custom_source(self):

[GitHub] [flink] hequn8128 merged pull request #13117: [FLINK-18863][python] Support read_text_file() and print() interface …

2020-08-11 Thread GitBox
hequn8128 merged pull request #13117: URL: https://github.com/apache/flink/pull/13117 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] hequn8128 commented on a change in pull request #13117: [FLINK-18863][python] Support read_text_file() and print() interface …

2020-08-11 Thread GitBox
hequn8128 commented on a change in pull request #13117: URL: https://github.com/apache/flink/pull/13117#discussion_r468962114 ## File path: flink-python/pyflink/datastream/tests/test_stream_execution_environment.py ## @@ -254,3 +254,20 @@ def test_add_custom_source(self):

[GitHub] [flink] hequn8128 commented on a change in pull request #13117: [FLINK-18863][python] Support read_text_file() and print() interface …

2020-08-11 Thread GitBox
hequn8128 commented on a change in pull request #13117: URL: https://github.com/apache/flink/pull/13117#discussion_r468962114 ## File path: flink-python/pyflink/datastream/tests/test_stream_execution_environment.py ## @@ -254,3 +254,20 @@ def test_add_custom_source(self):

[GitHub] [flink] flinkbot commented on pull request #13122: [FLINK-18824][Table SQL][Formats]Support serialization for canal-json format

2020-08-11 Thread GitBox
flinkbot commented on pull request #13122: URL: https://github.com/apache/flink/pull/13122#issuecomment-672456839 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-18824) Support serialization for canal-json format

2020-08-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18824: --- Labels: pull-request-available (was: ) > Support serialization for canal-json format >

[GitHub] [flink] caozhen1937 opened a new pull request #13122: [FLINK-18824][Table SQL][Formats]Support serialization for canal-json format

2020-08-11 Thread GitBox
caozhen1937 opened a new pull request #13122: URL: https://github.com/apache/flink/pull/13122 ## What is the purpose of the change *Support serialization for canal-json format* ## Brief change log - add SerializationSchema for serialize data to byte[]

[jira] [Created] (FLINK-18896) Translate "stateful-functions" page into Chinese

2020-08-11 Thread Feng Jie (Jira)
Feng Jie created FLINK-18896: Summary: Translate "stateful-functions" page into Chinese Key: FLINK-18896 URL: https://issues.apache.org/jira/browse/FLINK-18896 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #13120: [FLINK-18893][python] Fix Table.to_pandas for TableEnvironment created via EnvironmentSettings

2020-08-11 Thread GitBox
flinkbot edited a comment on pull request #13120: URL: https://github.com/apache/flink/pull/13120#issuecomment-672435131 ## CI report: * df3605638ffe3f3bd5808b3aef30fde9a83084a8 Azure:

[jira] [Commented] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175927#comment-17175927 ] Dian Fu commented on FLINK-18893: - Thanks [~rmetzger], I will fix this issue ASAP. > Python tests fails

[GitHub] [flink] flinkbot commented on pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

2020-08-11 Thread GitBox
flinkbot commented on pull request #13121: URL: https://github.com/apache/flink/pull/13121#issuecomment-672447411 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] wangyang0918 opened a new pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

2020-08-11 Thread GitBox
wangyang0918 opened a new pull request #13121: URL: https://github.com/apache/flink/pull/13121 ## What is the purpose of the change Currently, the native K8s integration does not using the existing script(e.g. jobmanager.sh, taskmanager.sh) to start JobManager and

[GitHub] [flink] flinkbot commented on pull request #13120: [FLINK-18893][python] Fix Table.to_pandas for TableEnvironment created via EnvironmentSettings

2020-08-11 Thread GitBox
flinkbot commented on pull request #13120: URL: https://github.com/apache/flink/pull/13120#issuecomment-672435131 ## CI report: * df3605638ffe3f3bd5808b3aef30fde9a83084a8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175916#comment-17175916 ] Dian Fu commented on FLINK-17274: -

[GitHub] [flink] flinkbot commented on pull request #13120: [FLINK-18893][python] Fix Table.to_pandas for TableEnvironment created via EnvironmentSettings

2020-08-11 Thread GitBox
flinkbot commented on pull request #13120: URL: https://github.com/apache/flink/pull/13120#issuecomment-672428473 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

2020-08-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18893: --- Labels: pull-request-available test-stability (was: test-stability) > Python tests fails

[jira] [Assigned] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-18893: --- Assignee: Dian Fu > Python tests fails with "AppendStreamTableSink requires that Table has only >

[GitHub] [flink] dianfu opened a new pull request #13120: [FLINK-18893][python] Fix Table.to_pandas for TableEnvironment created via EnvironmentSettings

2020-08-11 Thread GitBox
dianfu opened a new pull request #13120: URL: https://github.com/apache/flink/pull/13120 ## What is the purpose of the change *This pull request fix Table.to_pandas for TableEnvironment created via EnvironmentSettings* ## Verifying this change This change is

[jira] [Updated] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18893: Affects Version/s: 1.11.2 1.12.0 > Python tests fails with "AppendStreamTableSink

[jira] [Updated] (FLINK-18893) Python tests fails with "AppendStreamTableSink requires that Table has only insert changes."

2020-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18893: Fix Version/s: 1.11.2 1.12.0 > Python tests fails with "AppendStreamTableSink requires

[jira] [Updated] (FLINK-17458) TaskExecutorSubmissionTest#testFailingScheduleOrUpdateConsumers

2020-08-11 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17458: Fix Version/s: 1.10.3 1.11.2 1.12.0 >

[jira] [Updated] (FLINK-18895) Not able to access Flink 1.7.2 with HDP 3.0.1 cluster

2020-08-11 Thread Pasha Shaik (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pasha Shaik updated FLINK-18895: Attachment: 0ECDB56A-3A76-424F-8926-A9FEB1BD96BB.jpeg

[jira] [Updated] (FLINK-18895) Not able to access Flink 1.7.2 with HDP 3.0.1 cluster

2020-08-11 Thread Pasha Shaik (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pasha Shaik updated FLINK-18895: Attachment: (was: FlinkUI-Working.png) > Not able to access Flink 1.7.2 with HDP 3.0.1

[jira] [Updated] (FLINK-18895) Not able to access Flink 1.7.2 with HDP 3.0.1 cluster

2020-08-11 Thread Pasha Shaik (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pasha Shaik updated FLINK-18895: Attachment: (was: Flink_Execution_Exception.png) > Not able to access Flink 1.7.2 with HDP

[jira] [Updated] (FLINK-18895) Not able to access Flink 1.7.2 with HDP 3.0.1 cluster

2020-08-11 Thread Pasha Shaik (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pasha Shaik updated FLINK-18895: Attachment: (was: HDP_3.0.1_AllWorking.png) > Not able to access Flink 1.7.2 with HDP 3.0.1

[jira] [Updated] (FLINK-18895) Not able to access Flink 1.7.2 with HDP 3.0.1 cluster

2020-08-11 Thread Pasha Shaik (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pasha Shaik updated FLINK-18895: Attachment: (was: FlinkMountedOnYark_Working.png) > Not able to access Flink 1.7.2 with HDP

[jira] [Updated] (FLINK-18895) Not able to access Flink 1.7.2 with HDP 3.0.1 cluster

2020-08-11 Thread Pasha Shaik (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pasha Shaik updated FLINK-18895: Attachment: (was: Flink_Integrationtest_IO_Exception.png) > Not able to access Flink 1.7.2

  1   2   3   4   >