[GitHub] [flink] 1996fanrui commented on pull request #20214: [FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource

2022-07-07 Thread GitBox
1996fanrui commented on PR #20214: URL: https://github.com/apache/flink/pull/20214#issuecomment-1178583874 Hi @PatrickRen , could you help review in your free time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-28454) Fix the wrong timestamp example of KafkaSource

2022-07-07 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-28454: --- Description: [https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/datastream/kafka/]

[jira] [Updated] (FLINK-28454) Fix the wrong timestamp example of KafkaSource

2022-07-07 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-28454: --- Attachment: image-2022-07-08-13-46-05-540.png > Fix the wrong timestamp example of KafkaSource >

[jira] [Updated] (FLINK-28454) Fix the wrong timestamp example of KafkaSource

2022-07-07 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-28454: --- Attachment: image-2022-07-08-13-43-14-278.png > Fix the wrong timestamp example of KafkaSource >

[jira] [Updated] (FLINK-28454) Fix the wrong timestamp example of KafkaSource

2022-07-07 Thread fanrui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fanrui updated FLINK-28454: --- Attachment: image-2022-07-08-13-42-49-902.png > Fix the wrong timestamp example of KafkaSource >

[GitHub] [flink] flinkbot commented on pull request #20214: [FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource

2022-07-07 Thread GitBox
flinkbot commented on PR #20214: URL: https://github.com/apache/flink/pull/20214#issuecomment-1178562814 ## CI report: * 2e3e781743dcc3237221b231dedb2ba88d4c29cb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28454) Fix the wrong timestamp example of KafkaSource

2022-07-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28454: --- Labels: pull-request-available (was: ) > Fix the wrong timestamp example of KafkaSource >

[GitHub] [flink] 1996fanrui opened a new pull request, #20214: [FLINK-28454][kafka][docs] Fix the wrong timestamp unit of KafkaSource

2022-07-07 Thread GitBox
1996fanrui opened a new pull request, #20214: URL: https://github.com/apache/flink/pull/20214 ## What is the purpose of the change Fix the wrong timestamp unit of KafkaSource. ## Brief change log Fix the wrong timestamp unit of KafkaSource. ## Verifying this

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #302: [FLINK-28297][FLINK-27914] Improve operator metric groups + Add JOSDK metric integration

2022-07-07 Thread GitBox
gyfora commented on code in PR #302: URL: https://github.com/apache/flink-kubernetes-operator/pull/302#discussion_r916467085 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/OperatorJosdkMetrics.java: ## @@ -0,0 +1,143 @@ +/* + * Licensed

[jira] [Created] (FLINK-28454) Fix the wrong timestamp example of KafkaSource

2022-07-07 Thread fanrui (Jira)
fanrui created FLINK-28454: -- Summary: Fix the wrong timestamp example of KafkaSource Key: FLINK-28454 URL: https://issues.apache.org/jira/browse/FLINK-28454 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot commented on pull request #20213: [hotfix][docs] Fix formatting in Chinese doc

2022-07-07 Thread GitBox
flinkbot commented on PR #20213: URL: https://github.com/apache/flink/pull/20213#issuecomment-1178535668 ## CI report: * a9467f4326596ef1d15d8685dc38d6308a309cbb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-28364) Python Job support for Kubernetes Operator

2022-07-07 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564079#comment-17564079 ] Nicholas Jiang commented on FLINK-28364: [~dianfu][~gyfora][~thw], IMO, after

[jira] [Comment Edited] (FLINK-28364) Python Job support for Kubernetes Operator

2022-07-07 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564079#comment-17564079 ] Nicholas Jiang edited comment on FLINK-28364 at 7/8/22 4:21 AM:

[GitHub] [flink] polaris6 opened a new pull request, #20213: [hotfix][docs] Fix formatting in Chinese doc

2022-07-07 Thread GitBox
polaris6 opened a new pull request, #20213: URL: https://github.com/apache/flink/pull/20213 Fix formatting in Chinese doc: https://nightlies.apache.org/flink/flink-docs-master/zh/docs/deployment/resource-providers/standalone/overview/ ## Before modification:

[jira] [Resolved] (FLINK-28247) Exception will be thrown when over window contains grouping in Hive Dialect

2022-07-07 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-28247. Fix Version/s: 1.16.0 Resolution: Fixed > Exception will be thrown when over window contains

[jira] [Commented] (FLINK-28247) Exception will be thrown when over window contains grouping in Hive Dialect

2022-07-07 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564078#comment-17564078 ] Rui Li commented on FLINK-28247: Fixed in master: a069a306a0c95ba62bbc63f6afc995fd3216a326 > Exception

[GitHub] [flink] Vancior commented on a diff in pull request #20190: [FLINK-28426][python] Supports m1 wheel package in PyFlink

2022-07-07 Thread GitBox
Vancior commented on code in PR #20190: URL: https://github.com/apache/flink/pull/20190#discussion_r916446550 ## tools/azure-pipelines/build-python-wheels.yml: ## @@ -14,15 +14,9 @@ # limitations under the License. jobs: - - job: build_wheels -strategy: - matrix:

[GitHub] [flink] flinkbot commented on pull request #20212: [FLINK-28314][runtime-web] introduce "Cluster Environment" tab under history server

2022-07-07 Thread GitBox
flinkbot commented on PR #20212: URL: https://github.com/apache/flink/pull/20212#issuecomment-1178524952 ## CI report: * 247628bfcf13dd6ecd1393abbd3cc552c3525231 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] lirui-apache closed pull request #20071: [FLINK-28247][hive] fix "no any field presented in group by" exception when over window contains grouping function in Hive dialect

2022-07-07 Thread GitBox
lirui-apache closed pull request #20071: [FLINK-28247][hive] fix "no any field presented in group by" exception when over window contains grouping function in Hive dialect URL: https://github.com/apache/flink/pull/20071 -- This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-28314) [UI] Introduce "Cluster Environment" tab under history server

2022-07-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28314: --- Labels: pull-request-available (was: ) > [UI] Introduce "Cluster Environment" tab under

[GitHub] [flink] yangjunhan commented on pull request #20212: [FLINK-28314][runtime-web] introduce "Cluster Environment" tab under history server

2022-07-07 Thread GitBox
yangjunhan commented on PR #20212: URL: https://github.com/apache/flink/pull/20212#issuecomment-1178520078 This PR includes UI changes regarding the [FLIP](https://cwiki.apache.org/confluence/display/FLINK/FLIP-241%3A+Completed+Jobs+Information+Enhancement). Could @simplejason help review

[GitHub] [flink] yangjunhan opened a new pull request, #20212: [FLINK-28314][runtime-web] introduce "Cluster Environment" tab under history server

2022-07-07 Thread GitBox
yangjunhan opened a new pull request, #20212: URL: https://github.com/apache/flink/pull/20212 ## What is the purpose of the change Completed Job UI Enhancement based on FLIP-241

[GitHub] [flink] RocMarshal commented on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

2022-07-07 Thread GitBox
RocMarshal commented on PR #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-1178509222 > @RocMarshal Thanks for your contribution, the syntax pr has merged into master, you can continue this work. @lsyldliu Nice work on FLINK-21683 !. Would you like to take the

[GitHub] [flink] flinkbot commented on pull request #20211: [FLINK-28451][hive] Use UserCodeClassloader instead of the current thread's classloader to load function

2022-07-07 Thread GitBox
flinkbot commented on PR #20211: URL: https://github.com/apache/flink/pull/20211#issuecomment-1178505039 ## CI report: * d53356a9eb09e70a422297812adeea7528b39be7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 commented on pull request #20208: [hotfix][flink-rpc] Fix the RemoteRpcInvocation class typo.

2022-07-07 Thread GitBox
liuzhuang2017 commented on PR #20208: URL: https://github.com/apache/flink/pull/20208#issuecomment-1178503599 @flinkbot run azure -- 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 the specific

[jira] [Commented] (FLINK-28177) Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable

2022-07-07 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564066#comment-17564066 ] Huang Xingbo commented on FLINK-28177: --

[jira] [Updated] (FLINK-28177) Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable

2022-07-07 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28177: - Priority: Critical (was: Major) >

[jira] [Updated] (FLINK-28451) HiveFunctionDefinitionFactory load udf using user classloader instead of thread context classloader

2022-07-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28451: --- Labels: pull-request-available (was: ) > HiveFunctionDefinitionFactory load udf using user

[GitHub] [flink] luoyuxia opened a new pull request, #20211: [FLINK-28451][hive] Use UserCodeClassloader instead of the current thread's classloader to load function

2022-07-07 Thread GitBox
luoyuxia opened a new pull request, #20211: URL: https://github.com/apache/flink/pull/20211 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[jira] [Closed] (FLINK-28442) SplitGenerator should use Ordered Packing

2022-07-07 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28442. Resolution: Fixed master: 38257d6595596c8e7f9c8060ba4ea0b252594139 > SplitGenerator should use

[jira] [Assigned] (FLINK-28247) Exception will be thrown when over window contains grouping in Hive Dialect

2022-07-07 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-28247: -- Assignee: luoyuxia > Exception will be thrown when over window contains grouping in Hive Dialect >

[GitHub] [flink-table-store] JingsongLi merged pull request #206: [FLINK-28442] SplitGenerator should use Ordered Packing

2022-07-07 Thread GitBox
JingsongLi merged PR #206: URL: https://github.com/apache/flink-table-store/pull/206 -- 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 the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

2022-07-07 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564062#comment-17564062 ] Huang Xingbo commented on FLINK-27703: --

[GitHub] [flink] flinkbot commented on pull request #20210: [FLINK-27205][docs-zh] Translate "Concepts -> Glossary" page into Chinese.

2022-07-07 Thread GitBox
flinkbot commented on PR #20210: URL: https://github.com/apache/flink/pull/20210#issuecomment-1178486408 ## CI report: * 84db3782d879ab99d18863e7877923e4aa32be38 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] lsyldliu commented on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

2022-07-07 Thread GitBox
lsyldliu commented on PR #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-1178485595 @RocMarshal Thanks for your contribution, the syntax pr has merged into master, you can continue this work. -- This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-28325) DataOutputSerializer#writeBytes increase position twice

2022-07-07 Thread Li Peng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Li Peng updated FLINK-28325: Attachment: image.png > DataOutputSerializer#writeBytes increase position twice >

[jira] [Commented] (FLINK-28453) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

2022-07-07 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564059#comment-17564059 ] Huang Xingbo commented on FLINK-28453: -- cc [~renqs] > KafkaSourceLegacyITCase.testBrokerFailure

[jira] [Created] (FLINK-28453) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

2022-07-07 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-28453: Summary: KafkaSourceLegacyITCase.testBrokerFailure hang on azure Key: FLINK-28453 URL: https://issues.apache.org/jira/browse/FLINK-28453 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #20209: [FLINK-28307][runtime-web] Completed jobs UI enhancement

2022-07-07 Thread GitBox
flinkbot commented on PR #20209: URL: https://github.com/apache/flink/pull/20209#issuecomment-1178481593 ## CI report: * a2672368ed4e20b6ee03ad5545485918e89c9fcf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] yangjunhan closed pull request #20209: [FLINK-28307][runtime-web] Completed jobs UI enhancement

2022-07-07 Thread GitBox
yangjunhan closed pull request #20209: [FLINK-28307][runtime-web] Completed jobs UI enhancement URL: https://github.com/apache/flink/pull/20209 -- 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 the

[GitHub] [flink] liuzhuang2017 opened a new pull request, #20210: [FLINK-27205][docs-zh] Translate "Concepts -> Glossary" page into Chinese.

2022-07-07 Thread GitBox
liuzhuang2017 opened a new pull request, #20210: URL: https://github.com/apache/flink/pull/20210 ## What is the purpose of the change - Translate Glossary page into Chinese: https://nightlies.apache.org/flink/flink-docs-master/zh/docs/concepts/glossary/. - The markdown file is

[GitHub] [flink] yangjunhan commented on pull request #20209: [FLINK-28307][runtime-web] Completed jobs UI enhancement

2022-07-07 Thread GitBox
yangjunhan commented on PR #20209: URL: https://github.com/apache/flink/pull/20209#issuecomment-1178478120 This PR includes UI changes regarding the [Completed Jobs Information Enhancement

[jira] [Updated] (FLINK-28307) FLIP-241: Completed Jobs Information Enhancement

2022-07-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28307: --- Labels: pull-request-available (was: ) > FLIP-241: Completed Jobs Information Enhancement

[GitHub] [flink] yangjunhan opened a new pull request, #20209: [FLINK-28307][runtime-web] Completed jobs UI enhancement

2022-07-07 Thread GitBox
yangjunhan opened a new pull request, #20209: URL: https://github.com/apache/flink/pull/20209 ## What is the purpose of the change Completed Job UI Enhancement based on FLIP-241

[GitHub] [flink-kubernetes-operator] SteNicholas commented on pull request #302: [FLINK-28297][FLINK-27914] Improve operator metric groups + Add JOSDK metric integration

2022-07-07 Thread GitBox
SteNicholas commented on PR #302: URL: https://github.com/apache/flink-kubernetes-operator/pull/302#issuecomment-1178475779 @gyfora, thanks for the improvement for JOSDK metrics. I have verified the JOSDK metrics and the metrics look good to me. ``` -- Counters

[jira] [Commented] (FLINK-26621) flink-tests failed on azure due to Error occurred in starting fork

2022-07-07 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564056#comment-17564056 ] Huang Xingbo commented on FLINK-26621: --

[jira] [Commented] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

2022-07-07 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564055#comment-17564055 ] Huang Xingbo commented on FLINK-26721: --

[jira] [Updated] (FLINK-28388) Python doc build breaking nightly docs

2022-07-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-28388: Affects Version/s: 1.16.0 (was: shaded-7.0) > Python doc build breaking

[GitHub] [flink] PatrickRen commented on a diff in pull request #20205: [FLINK-28250][Connector/Kafka] Fix exactly-once Kafka Sink out of memory

2022-07-07 Thread GitBox
PatrickRen commented on code in PR #20205: URL: https://github.com/apache/flink/pull/20205#discussion_r916412313 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaCommitter.java: ## @@ -112,6 +112,8 @@ public void

[jira] [Commented] (FLINK-27703) FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed with The marker file was not found within 10000 msecs

2022-07-07 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564053#comment-17564053 ] Huang Xingbo commented on FLINK-27703: --

[jira] [Closed] (FLINK-28441) The parsing result of configuration `pipeline.cached-files` is incorrect

2022-07-07 Thread xiaozilong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaozilong closed FLINK-28441. -- Resolution: Invalid > The parsing result of configuration `pipeline.cached-files` is incorrect >

[jira] [Closed] (FLINK-28388) Python doc build breaking nightly docs

2022-07-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-28388. --- Fix Version/s: 1.16.0 Resolution: Fixed Fixed in master via 974fea145cc6189eae3410203339aa2950dbbd4d

[jira] [Commented] (FLINK-26621) flink-tests failed on azure due to Error occurred in starting fork

2022-07-07 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564052#comment-17564052 ] Huang Xingbo commented on FLINK-26621: --

[GitHub] [flink] dianfu closed pull request #20189: [FLINK-28388][docs][tests] Fix documentation build

2022-07-07 Thread GitBox
dianfu closed pull request #20189: [FLINK-28388][docs][tests] Fix documentation build URL: https://github.com/apache/flink/pull/20189 -- 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 the specific

[jira] [Comment Edited] (FLINK-28451) HiveFunctionDefinitionFactory load udf using user classloader instead of thread context classloader

2022-07-07 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564051#comment-17564051 ] luoyuxia edited comment on FLINK-28451 at 7/8/22 2:28 AM: -- [~lsy] Thanks for

[jira] [Commented] (FLINK-28451) HiveFunctionDefinitionFactory load udf using user classloader instead of thread context classloader

2022-07-07 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564051#comment-17564051 ] luoyuxia commented on FLINK-28451: -- [~lsy] Thanks for reporting it. I'll fix it. Previouly, I also have

[GitHub] [flink-docker] Myasuka commented on a diff in pull request #117: [FLINK-28057] Fix LD_PRELOAD on ARM images

2022-07-07 Thread GitBox
Myasuka commented on code in PR #117: URL: https://github.com/apache/flink-docker/pull/117#discussion_r916413243 ## 1.15/scala_2.12-java11-debian/docker-entrypoint.sh: ## @@ -91,7 +91,12 @@ prepare_configuration() { maybe_enable_jemalloc() { if [

[GitHub] [flink-docker] Myasuka commented on a diff in pull request #117: [FLINK-28057] Fix LD_PRELOAD on ARM images

2022-07-07 Thread GitBox
Myasuka commented on code in PR #117: URL: https://github.com/apache/flink-docker/pull/117#discussion_r916412298 ## docker-entrypoint.sh: ## @@ -91,7 +91,12 @@ prepare_configuration() { maybe_enable_jemalloc() { if [ "${DISABLE_JEMALLOC:-false}" == "false" ]; then -

[GitHub] [flink] sunshineJK commented on a diff in pull request #20127: [FLINK-26270] Flink SQL write data to kafka by CSV format , whether d…

2022-07-07 Thread GitBox
sunshineJK commented on code in PR #20127: URL: https://github.com/apache/flink/pull/20127#discussion_r916412128 ## flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatOptions.java: ## @@ -87,5 +87,12 @@ public class CsvFormatOptions {

[GitHub] [flink] zoltar9264 commented on pull request #20152: [FLINK-27155][changelog] Reduce multiple reads to the same Changelog …

2022-07-07 Thread GitBox
zoltar9264 commented on PR #20152: URL: https://github.com/apache/flink/pull/20152#issuecomment-1178465547 Thanks a lot for your advice @rkhachatryan , I feel like I can learn a lot from it. Since there are still some personal matters this week, I will be considering your suggestions one

[GitHub] [flink] flinkbot commented on pull request #20208: [hotfix][flink-rpc] Fix the RemoteRpcInvocation class typo.

2022-07-07 Thread GitBox
flinkbot commented on PR #20208: URL: https://github.com/apache/flink/pull/20208#issuecomment-1178458237 ## CI report: * 52f8097b674005819e871edbfc66d8cfb9989c9d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] liuzhuang2017 commented on pull request #20208: [hotfix][flink-rpc] Fix the RemoteRpcInvocation class typo.

2022-07-07 Thread GitBox
liuzhuang2017 commented on PR #20208: URL: https://github.com/apache/flink/pull/20208#issuecomment-1178457848 @zentol , Sorry to bother you, can you help me review this pull request? Thank you. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-kubernetes-operator] SteNicholas commented on a diff in pull request #302: [FLINK-28297][FLINK-27914] Improve operator metric groups + Add JOSDK metric integration

2022-07-07 Thread GitBox
SteNicholas commented on code in PR #302: URL: https://github.com/apache/flink-kubernetes-operator/pull/302#discussion_r916401412 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/metrics/KubernetesOperatorMetricOptions.java: ## @@ -23,8 +23,22 @@

[GitHub] [flink] liuzhuang2017 commented on pull request #20208: [hotfix][flink-rpc] Fix the RemoteRpcInvocation class typo.

2022-07-07 Thread GitBox
liuzhuang2017 commented on PR #20208: URL: https://github.com/apache/flink/pull/20208#issuecomment-1178456083 @flinkbot run azure -- 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 the specific

[GitHub] [flink] liuzhuang2017 opened a new pull request, #20208: [hotfix][flink-rpc] Fix the RemoteRpcInvocation class typo.

2022-07-07 Thread GitBox
liuzhuang2017 opened a new pull request, #20208: URL: https://github.com/apache/flink/pull/20208 ## What is the purpose of the change - Change the keyword `th` to `the`. ## Brief change log - Change the keyword `th` to `the`. ## Verifying this change

[GitHub] [flink] luoyuxia commented on pull request #19727: [FLINK-27618][sql] Flink supports CUME_DIST function

2022-07-07 Thread GitBox
luoyuxia commented on PR #19727: URL: https://github.com/apache/flink/pull/19727#issuecomment-1178453567 @flinkbot run azure -- 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 the specific comment.

[GitHub] [flink] zoltar9264 commented on pull request #20093: [FLINK-28172][changelog] Scatter dstl files into separate directories…

2022-07-07 Thread GitBox
zoltar9264 commented on PR #20093: URL: https://github.com/apache/flink/pull/20093#issuecomment-1178453865 Thanks @rkhachatryan . Done. -- 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 the

[GitHub] [flink] JesseAtSZ commented on pull request #20091: [FLINK-27570][runtime] Fix initialize base locations for checkpoint

2022-07-07 Thread GitBox
JesseAtSZ commented on PR #20091: URL: https://github.com/apache/flink/pull/20091#issuecomment-1178450932 @rkhachatryan If we modify `FINALIZE_CHECKPOINT_FAILURE` has a great impact, we can change `initializeBaseLocationsForCheckpoint` first. -- This is an automated message from the

[GitHub] [flink] flinkbot commented on pull request #20207: Update generating_watermarks.md

2022-07-07 Thread GitBox
flinkbot commented on PR #20207: URL: https://github.com/apache/flink/pull/20207#issuecomment-1178449071 ## CI report: * 11628bdae7022960a7700d4c710225327d5b2675 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] wingwuyao opened a new pull request, #20207: Update generating_watermarks.md

2022-07-07 Thread GitBox
wingwuyao opened a new pull request, #20207: URL: https://github.com/apache/flink/pull/20207 There seems to be a problem with the spelling of 'punctuated', fix that ## What is the purpose of the change *(For example: This pull request makes task deployment go through

[jira] [Closed] (FLINK-28439) Support SUBSTR and REGEXP built-in function in Table API

2022-07-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-28439. --- Assignee: LuNing Wang Resolution: Fixed Merged to master via 90c8284b10ecad84d2c954efe0a98e8fe87cf1dd

[GitHub] [flink] dianfu merged pull request #20201: [FLINK-28439][table][python] Support SUBSTR and REGEXP built-in function in Table API

2022-07-07 Thread GitBox
dianfu merged PR #20201: URL: https://github.com/apache/flink/pull/20201 -- 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 the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] wingwuyao closed pull request #20199: Update and rename docs/content/docs/dev/datastream/event-time/generat…

2022-07-07 Thread GitBox
wingwuyao closed pull request #20199: Update and rename docs/content/docs/dev/datastream/event-time/generat… URL: https://github.com/apache/flink/pull/20199 -- 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

[GitHub] [flink] lincoln-lil commented on pull request #19983: [FLINK-27878][datastream] Add Retry Support For Async I/O In DataStream API

2022-07-07 Thread GitBox
lincoln-lil commented on PR #19983: URL: https://github.com/apache/flink/pull/19983#issuecomment-1178431723 @flinkbot run azure -- 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 the specific

[jira] [Updated] (FLINK-28452) "Reduce" and "aggregate" operations of "window_all" are supported in Python datastream API

2022-07-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-28452: Affects Version/s: (was: 1.15.1) > "Reduce" and "aggregate" operations of "window_all" are supported

[jira] [Assigned] (FLINK-28452) "Reduce" and "aggregate" operations of "window_all" are supported in Python datastream API

2022-07-07 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-28452: --- Assignee: zhangjingcun > "Reduce" and "aggregate" operations of "window_all" are supported in

[jira] [Created] (FLINK-28452) "Reduce" and "aggregate" operations of "window_all" are supported in Python datastream API

2022-07-07 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-28452: Summary: "Reduce" and "aggregate" operations of "window_all" are supported in Python datastream API Key: FLINK-28452 URL: https://issues.apache.org/jira/browse/FLINK-28452

[GitHub] [flink] flinkbot commented on pull request #20206: [FLINK-25909][runtime][security] Add HBaseDelegationTokenProvider

2022-07-07 Thread GitBox
flinkbot commented on PR #20206: URL: https://github.com/apache/flink/pull/20206#issuecomment-1178425468 ## CI report: * 9ccb31920dd2de1f7c4aedce50fd1e194fc5ac80 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-25909) Move HBase token obtain functionality into HBaseDelegationTokenProvider

2022-07-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25909: --- Labels: pull-request-available (was: ) > Move HBase token obtain functionality into

[GitHub] [flink] JackWangCS commented on a diff in pull request #20206: [FLINK-25909][runtime][security] Add HBaseDelegationTokenProvider

2022-07-07 Thread GitBox
JackWangCS commented on code in PR #20206: URL: https://github.com/apache/flink/pull/20206#discussion_r916381471 ## flink-runtime/src/main/resources/META-INF/services/org.apache.flink.runtime.security.token.DelegationTokenProvider: ## @@ -14,3 +14,4 @@ # limitations under the

[GitHub] [flink] JackWangCS opened a new pull request, #20206: [FLINK-25908][runtime][security] Add HBaseDelegationTokenProvider

2022-07-07 Thread GitBox
JackWangCS opened a new pull request, #20206: URL: https://github.com/apache/flink/pull/20206 ## What is the purpose of the change This PR adds HBaseDelegationTokenProvider to obtain HBase Delegation tokens using the new delegation token framework. ## Brief change log

[GitHub] [flink] bzhaoopenstack commented on pull request #20193: [FLINK-28433][connector/jdbc]Add mariadb jdbc connection validation

2022-07-07 Thread GitBox
bzhaoopenstack commented on PR #20193: URL: https://github.com/apache/flink/pull/20193#issuecomment-1178417684 > @bzhaoopenstack Thanks for the PR, but in order to add support for MariaDB I would also like to see a test and documentation in place. Thanks very much for reply and

[jira] [Commented] (FLINK-10206) Add hbase sink connector

2022-07-07 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564023#comment-17564023 ] Jing Ge commented on FLINK-10206: - There is a new HBaseDynamicTableSink since the last comment. Could we

[GitHub] [flink] flinkbot commented on pull request #20205: [FLINK-28250][Connector/Kafka] Fix exactly-once Kafka Sink out of memory

2022-07-07 Thread GitBox
flinkbot commented on PR #20205: URL: https://github.com/apache/flink/pull/20205#issuecomment-1178341140 ## CI report: * 7304f9dd3c2c65dd985f5de831496b091b58b556 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28250) exactly-once sink kafka cause out of memory

2022-07-07 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28250: --- Labels: pull-request-available (was: ) > exactly-once sink kafka cause out of memory >

[GitHub] [flink] charles-tan opened a new pull request, #20205: [FLINK-28250][Connector/Kafka] Fix exactly-once Kafka Sink out of memory

2022-07-07 Thread GitBox
charles-tan opened a new pull request, #20205: URL: https://github.com/apache/flink/pull/20205 ## What is the purpose of the change The goal of this PR is to address a memory leak where the Kafka Producer does not get cleaned up after kafka commit is successful. ##

[jira] [Updated] (FLINK-10740) FLIP-27: Refactor Source Interface

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10740: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor

[jira] [Updated] (FLINK-10206) Add hbase sink connector

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10206: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-27891) Add ARRAY_APPEND and ARRAY_PREPEND supported in SQL & Table API

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-27891: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-9219) Add support for OpenGIS features in Table & SQL API

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9219: -- Labels: auto-deprioritized-major auto-unassigned stale-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-11463) Rework end-to-end tests in Java

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11463: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-12130) Apply command line options to configuration before installing security modules

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12130: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-13213) MinIdleStateRetentionTime/MaxIdleStateRetentionTime in TableConfig will be removed after call toAppendStream/toRetractStream without QueryConfig parameters

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13213: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

[jira] [Updated] (FLINK-13301) Some PlannerExpression resultType is not consistent with Calcite Type inference

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13301: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-11934) Remove the deprecate methods in TableEnvironment

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11934: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned stale-assigned

[jira] [Updated] (FLINK-13218) '*.count not supported in TableApi query

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13218: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-13247) Implement external shuffle service for YARN

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13247: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-14527) Add integration tests for PostgreSQL and MySQL dialects in Flink JDBC module

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14527: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-17231) Deprecate possible implicit fallback from LB to NodePort When retrieving Endpoint of LB Service

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17231: --- Labels: auto-unassigned pull-request-available stale-assigned (was: auto-unassigned

[jira] [Updated] (FLINK-13503) Add contract in `LookupableTableSource` to specify the behavior when lookupKeys contains null

2022-07-07 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13503: --- Labels: auto-deprioritized-major auto-unassigned pull-request-available stale-minor (was:

  1   2   3   4   >