[jira] [Commented] (FLINK-29432) Replace GenericUDFNvl with GenericUDFCoalesce

2022-10-10 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615480#comment-17615480 ] Samrat Deb commented on FLINK-29432: Thanks [~luoyuxia] for your view on the issue !  I completely

[jira] [Commented] (FLINK-26999) Introduce ClickHouse Connector

2022-10-10 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615467#comment-17615467 ] RocMarshal commented on FLINK-26999: [~rmetzger] , The FLIP current content should be deprecated

[GitHub] [flink] yuzelin commented on pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-10-10 Thread GitBox
yuzelin commented on PR #20931: URL: https://github.com/apache/flink/pull/20931#issuecomment-1274069957 @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] flinkbot commented on pull request #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

2022-10-10 Thread GitBox
flinkbot commented on PR #21012: URL: https://github.com/apache/flink/pull/21012#issuecomment-1274042879 ## CI report: * 35800afb006d8268985089c7829eba83192a0ace UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-29526) Java doc mistake in SequenceNumberRange#contains()

2022-10-10 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-29526: -- Assignee: Feifan Wang > Java doc mistake in SequenceNumberRange#contains() >

[GitHub] [flink] zoltar9264 commented on pull request #20975: [FLINK-29526][state/changelog] fix java doc mistake in SequenceNumber…

2022-10-10 Thread GitBox
zoltar9264 commented on PR #20975: URL: https://github.com/apache/flink/pull/20975#issuecomment-1274040459 @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] zoltar9264 commented on a diff in pull request #20975: [FLINK-29526][state/changelog] fix java doc mistake in SequenceNumber…

2022-10-10 Thread GitBox
zoltar9264 commented on code in PR #20975: URL: https://github.com/apache/flink/pull/20975#discussion_r991782319 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/SequenceNumberRange.java: ## @@ -29,7 +29,7 @@ public interface SequenceNumberRange {

[jira] [Updated] (FLINK-29543) Jar Run Rest Handler Support Flink Configuration

2022-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29543: --- Labels: pull-request-available (was: ) > Jar Run Rest Handler Support Flink Configuration

[jira] [Commented] (FLINK-27344) FLIP-222: Support full job lifecycle statements in SQL client

2022-10-10 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615441#comment-17615441 ] Paul Lin commented on FLINK-27344: -- [~ekoblov] Sure. It's documented in the FLIP

[GitHub] [flink] czy006 opened a new pull request, #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

2022-10-10 Thread GitBox
czy006 opened a new pull request, #21012: URL: https://github.com/apache/flink/pull/21012 # What is the purpose of the change Add new feature from FLIP-256 about support jm rest API flinkconfiguration # Brief change log - Add JM Rest Api Jar Run Rest Handler Support

[GitHub] [flink] zoltar9264 commented on pull request #20965: [FLINK-29244][state/changelog] Add metric lastMaterializationDuration…

2022-10-10 Thread GitBox
zoltar9264 commented on PR #20965: URL: https://github.com/apache/flink/pull/20965#issuecomment-1274037452 @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] zoltar9264 commented on a diff in pull request #20965: [FLINK-29244][state/changelog] Add metric lastMaterializationDuration…

2022-10-10 Thread GitBox
zoltar9264 commented on code in PR #20965: URL: https://github.com/apache/flink/pull/20965#discussion_r991780193 ## docs/content.zh/docs/ops/metrics.md: ## @@ -1581,6 +1581,11 @@ Note that the metrics are only available via reporters. The number of failed

[GitHub] [flink] zoltar9264 commented on a diff in pull request #20965: [FLINK-29244][state/changelog] Add metric lastMaterializationDuration…

2022-10-10 Thread GitBox
zoltar9264 commented on code in PR #20965: URL: https://github.com/apache/flink/pull/20965#discussion_r991779836 ## flink-state-backends/flink-statebackend-common/src/main/java/org/apache/flink/state/common/PeriodicMaterializationManager.java: ## @@ -251,6 +254,8 @@ private

[GitHub] [flink] zoltar9264 commented on a diff in pull request #20965: [FLINK-29244][state/changelog] Add metric lastMaterializationDuration…

2022-10-10 Thread GitBox
zoltar9264 commented on code in PR #20965: URL: https://github.com/apache/flink/pull/20965#discussion_r991779398 ## docs/content.zh/docs/ops/metrics.md: ## @@ -1581,6 +1581,11 @@ Note that the metrics are only available via reporters. The number of failed

[GitHub] [flink] flinkbot commented on pull request #21011: [FLINK-29333][TABLE]Support the tableconfig object get configuration infos from flink-conf.yaml file

2022-10-10 Thread GitBox
flinkbot commented on PR #21011: URL: https://github.com/apache/flink/pull/21011#issuecomment-1274031819 ## CI report: * 4bc7cb104b31f5c7abd3b52b3b926b0051507b87 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29333) Flink SQL Planner Module doesn't read config from flink-conf.yaml

2022-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29333: --- Labels: pull-request-available (was: ) > Flink SQL Planner Module doesn't read config from

[GitHub] [flink] hehuiyuan opened a new pull request, #21011: [FLINK-29333][TABLE]Support the tableconfig object get configuration infos from flink-conf.yaml file

2022-10-10 Thread GitBox
hehuiyuan opened a new pull request, #21011: URL: https://github.com/apache/flink/pull/21011 ## What is the purpose of the change Support the tableconfig object get configuration infos from flink-conf.yaml file ## Does this pull request potentially affect one of

[jira] [Resolved] (FLINK-27423) Upgrade Hive 3.1 connector from 3.1.2 to 3.1.3

2022-10-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-27423. -- Resolution: Fixed Close it seems it has been fixed. Feel free to open it if not. > Upgrade Hive 3.1

[jira] [Commented] (FLINK-27384) In the Hive dimension table, when the data is changed on the original partition, the create_time configuration does not take effect

2022-10-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615432#comment-17615432 ] luoyuxia commented on FLINK-27384: -- [~leonard] Seems the prs for release-1.4&1.15 branches are ready.

[jira] [Resolved] (FLINK-27604) flink sql read hive on hbase throw NPE

2022-10-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-27604. -- Resolution: Fixed > flink sql read hive on hbase throw NPE > -- >

[jira] [Comment Edited] (FLINK-27604) flink sql read hive on hbase throw NPE

2022-10-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615429#comment-17615429 ] luoyuxia edited comment on FLINK-27604 at 10/11/22 2:53 AM:

[jira] [Commented] (FLINK-27604) flink sql read hive on hbase throw NPE

2022-10-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615429#comment-17615429 ] luoyuxia commented on FLINK-27604: -- [~18579099...@163.com] Thanks for reporting it. Currently, it's not

[jira] [Closed] (FLINK-26990) BatchArrowPythonGroupWindowAggregateFunctionOperatorTest.testFinishBundleTriggeredByTime failed

2022-10-10 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-26990. Resolution: Cannot Reproduce >

[jira] [Assigned] (FLINK-27598) Improve the exception message when mixing use Python UDF and Pandas UDF

2022-10-10 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-27598: Assignee: Xingbo Huang > Improve the exception message when mixing use Python UDF and

[jira] [Closed] (FLINK-27715) Add more Python ML examples

2022-10-10 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-27715. Resolution: Fixed Merged into master via 91e74648bf47d1027ef3362c61456b90fcf89535 > Add more

[jira] [Closed] (FLINK-28394) Python py36-cython: InvocationError for command install_command.sh fails with exit code 1

2022-10-10 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-28394. Resolution: Cannot Reproduce > Python py36-cython: InvocationError for command install_command.sh

[jira] [Assigned] (FLINK-28526) Fail to lateral join with UDTF from Table with timstamp column

2022-10-10 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-28526: Assignee: Xingbo Huang > Fail to lateral join with UDTF from Table with timstamp column

[jira] [Assigned] (FLINK-28742) Table.to_pandas fails with lit("xxx")

2022-10-10 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-28742: Assignee: Xingbo Huang > Table.to_pandas fails with lit("xxx") >

[jira] [Assigned] (FLINK-28528) Table.getSchema fails on table with watermark

2022-10-10 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-28528: Assignee: Xingbo Huang > Table.getSchema fails on table with watermark >

[jira] [Closed] (FLINK-28786) Cannot run PyFlink 1.16 on MacOS with M1 chip

2022-10-10 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-28786. Resolution: Not A Problem > Cannot run PyFlink 1.16 on MacOS with M1 chip >

[GitHub] [flink-ml] weibozhao commented on a diff in pull request #156: [FLINK-29323] Refine Transformer for VectorAssembler

2022-10-10 Thread GitBox
weibozhao commented on code in PR #156: URL: https://github.com/apache/flink-ml/pull/156#discussion_r991765238 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java: ## @@ -47,10 +47,15 @@ /** * A Transformer which combines a given

[GitHub] [flink] HuangXingBo commented on a diff in pull request #20756: [FLINK-27929][python] Drop support for python36

2022-10-10 Thread GitBox
HuangXingBo commented on code in PR #20756: URL: https://github.com/apache/flink/pull/20756#discussion_r991762362 ## flink-python/setup.py: ## @@ -316,16 +316,10 @@ def extracted_output_files(base_dir, file_path, output_directory): 'python_full_version

[jira] [Commented] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615420#comment-17615420 ] Xintong Song commented on FLINK-29572: -- I think this was introduced by FLINK-24474. In

[jira] [Updated] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-10 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-29572: - Issue Type: Bug (was: Improvement) > Flink Task Manager skip loopback interface for resource

[jira] [Assigned] (FLINK-29000) Support python UDF in the SQL Gateway

2022-10-10 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang reassigned FLINK-29000: Assignee: Xingbo Huang > Support python UDF in the SQL Gateway >

[jira] [Commented] (FLINK-29575) Can't Add Temporary Function USING JAR

2022-10-10 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615418#comment-17615418 ] Xingbo Huang commented on FLINK-29575: -- This feature is introduced in release-1.16, the version of

[GitHub] [flink] luoyuxia commented on pull request #20907: Flink 29337 hive3

2022-10-10 Thread GitBox
luoyuxia commented on PR #20907: URL: https://github.com/apache/flink/pull/20907#issuecomment-1274002208 @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.

[jira] [Assigned] (FLINK-29427) LookupJoinITCase failed with classloader problem

2022-10-10 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reassigned FLINK-29427: - Assignee: Alexander Smirnov > LookupJoinITCase failed with classloader problem >

[jira] [Closed] (FLINK-29462) LookupJoinITCase failed on azure due to classloader leaking

2022-10-10 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-29462. Resolution: Duplicate > LookupJoinITCase failed on azure due to classloader leaking >

[jira] [Commented] (FLINK-29545) kafka consuming stop when trigger first checkpoint

2022-10-10 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615416#comment-17615416 ] xiaogang zhou commented on FLINK-29545: --- [~martijnvisser] this can also happen in 1.15.   

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

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

[jira] [Updated] (FLINK-29559) Disable Join Reorder for these tables whose statistics are unavailable

2022-10-10 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-29559: -- Description: For these tables without table statistics, we need to disable join reorder for

[jira] [Updated] (FLINK-29559) Disable Join Reorder for these tables whose statistics are unavailable in batch mode

2022-10-10 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-29559: -- Summary: Disable Join Reorder for these tables whose statistics are unavailable in batch mode

[GitHub] [flink] lsyldliu commented on a diff in pull request #20652: [FLINK-22315][table] Support add/modify column/constraint/watermark for ALTER TABLE statement

2022-10-10 Thread GitBox
lsyldliu commented on code in PR #20652: URL: https://github.com/apache/flink/pull/20652#discussion_r991742960 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterTableSchema.java: ## @@ -72,4 +87,14 @@ public Optional getWatermark() {

[GitHub] [flink] hehuiyuan closed pull request #20995: [FLINK-29553][table]Support UNIX_TIMESTAMP built-in function in Table API

2022-10-10 Thread GitBox
hehuiyuan closed pull request #20995: [FLINK-29553][table]Support UNIX_TIMESTAMP built-in function in Table API URL: https://github.com/apache/flink/pull/20995 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] fsk119 commented on pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-10-10 Thread GitBox
fsk119 commented on PR #20931: URL: https://github.com/apache/flink/pull/20931#issuecomment-1273985394 @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] luoyuxia commented on a diff in pull request #20987: [FLINK-29432][Connector/Hive] Remove use of GenericNVL and use Colaese

2022-10-10 Thread GitBox
luoyuxia commented on code in PR #20987: URL: https://github.com/apache/flink/pull/20987#discussion_r991746653 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserTypeCheckProcFactory.java: ## @@ -1216,7 +1216,7 @@

[jira] [Assigned] (FLINK-29483) flink python udf arrow in thread model bug

2022-10-10 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-29483: --- Assignee: jackylau > flink python udf arrow in thread model bug >

[jira] [Commented] (FLINK-29432) Replace GenericUDFNvl with GenericUDFCoalesce

2022-10-10 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615410#comment-17615410 ] luoyuxia commented on FLINK-29432: -- Thanks for contribution. But to put it briefly, I prefer not to

[jira] [Created] (FLINK-29575) Can't Add Temporary Function USING JAR

2022-10-10 Thread Angelo Kastroulis (Jira)
Angelo Kastroulis created FLINK-29575: - Summary: Can't Add Temporary Function USING JAR Key: FLINK-29575 URL: https://issues.apache.org/jira/browse/FLINK-29575 Project: Flink Issue Type:

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #156: [FLINK-29323] Refine Transformer for VectorAssembler

2022-10-10 Thread GitBox
yunfengzhou-hub commented on code in PR #156: URL: https://github.com/apache/flink-ml/pull/156#discussion_r991744425 ## flink-ml-python/pyflink/ml/lib/feature/vectorassembler.py: ## @@ -31,17 +33,38 @@ class _VectorAssemblerParams( Params for :class:`VectorAssembler`.

[GitHub] [flink] luoyuxia commented on pull request #20999: [FLINK-29408][hive] fix HiveCatalogITCase fail with NPE

2022-10-10 Thread GitBox
luoyuxia commented on PR #20999: URL: https://github.com/apache/flink/pull/20999#issuecomment-1273971517 The `load data inpath` statement in `HiveDialectQueryITCase` will **move** `/csv/test.csv` to other place, then other tests will get `null` by

[GitHub] [flink] flinkbot commented on pull request #21010: [FLINK-29495][Connector/Pulsar] Refactor FailsOnJava11 class for supporting both JUnit4 and JUnit5.

2022-10-10 Thread GitBox
flinkbot commented on PR #21010: URL: https://github.com/apache/flink/pull/21010#issuecomment-1273971304 ## CI report: * 19da765ddf23e66964531ff98b7bb5691d67ae60 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] syhily opened a new pull request, #21010: [FLINK-29495][Connector/Pulsar] Refactor FailsOnJava11 class for supporting both JUnit4 and JUnit5.

2022-10-10 Thread GitBox
syhily opened a new pull request, #21010: URL: https://github.com/apache/flink/pull/21010 ## What is the purpose of the change There are known issues with Pulsar on Java 11, which is why we want to disable test runs on Java 11. However, the tests still use the JUnit4 annotation for

[GitHub] [flink] bzhaoopenstack commented on pull request #20498: [FLINK-28829][k8s] Support prepreparing K8S resources before JM creation

2022-10-10 Thread GitBox
bzhaoopenstack commented on PR #20498: URL: https://github.com/apache/flink/pull/20498#issuecomment-1273954844 @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-29545) kafka consuming stop when trigger first checkpoint

2022-10-10 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaogang zhou updated FLINK-29545: -- Description: the task dag is like attached file. the task is started to consume from

[jira] [Comment Edited] (FLINK-24302) Direct buffer memory leak on Pulsar connector with Java 11

2022-10-10 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615386#comment-17615386 ] Yufan Sheng edited comment on FLINK-24302 at 10/11/22 12:35 AM: Support

[jira] [Commented] (FLINK-24302) Direct buffer memory leak on Pulsar connector with Java 11

2022-10-10 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615386#comment-17615386 ] Yufan Sheng commented on FLINK-24302: - Support flink-connector-pulsar on Java 11 seems harder than

[GitHub] [flink] flinkbot commented on pull request #21009: [FLINK-29574] Upgrade software.amazon.glue:schema-registry-common and…

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

[jira] [Updated] (FLINK-29574) Upgrade software.amazon.glue:schema-registry-common and software.amazon.glue:schema-registry-serde dependency from 1.1.8 to 1.1.14

2022-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29574: --- Labels: pull-request-available (was: ) > Upgrade

[GitHub] [flink] hlteoh37 opened a new pull request, #21009: [FLINK-29574] Upgrade software.amazon.glue:schema-registry-common and…

2022-10-10 Thread GitBox
hlteoh37 opened a new pull request, #21009: URL: https://github.com/apache/flink/pull/21009 … software.amazon.glue:schema-registry-serde dependency from 1.1.8 to 1.1.14 ## What is the purpose of the change - Update Glue schema registry dependencies ## Brief change log

[jira] [Created] (FLINK-29574) Upgrade software.amazon.glue:schema-registry-common and software.amazon.glue:schema-registry-serde dependency from 1.1.8 to 1.1.14

2022-10-10 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-29574: --- Summary: Upgrade software.amazon.glue:schema-registry-common and software.amazon.glue:schema-registry-serde dependency from 1.1.8 to 1.1.14 Key: FLINK-29574 URL:

[jira] [Commented] (FLINK-29495) PulsarSinkE2ECase hang

2022-10-10 Thread Yufan Sheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615377#comment-17615377 ] Yufan Sheng commented on FLINK-29495: - [~martijnvisser] Tks, but how could we know your modification

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Closed] (FLINK-29513) Update Kafka version to 3.2.3

2022-10-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-29513. -- Fix Version/s: 1.16.0 Resolution: Fixed Also fixed in release-1.16 via

[GitHub] [flink] MartijnVisser merged pull request #20977: [FLINK-29513][BP 1.16][Connector/Kafka] Update Kafka to version 3.2.3

2022-10-10 Thread GitBox
MartijnVisser merged PR #20977: URL: https://github.com/apache/flink/pull/20977 -- 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] ferenc-csaky commented on a diff in pull request #20987: [FLINK-29432][Connector/Hive] Remove use of GenericNVL and use Colaese

2022-10-10 Thread GitBox
ferenc-csaky commented on code in PR #20987: URL: https://github.com/apache/flink/pull/20987#discussion_r991586643 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserTypeCheckProcFactory.java: ## @@ -1216,7 +1216,7 @@

[jira] [Commented] (FLINK-29495) PulsarSinkE2ECase hang

2022-10-10 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615279#comment-17615279 ] Martijn Visser commented on FLINK-29495: Test disabled in master via

[GitHub] [flink] MartijnVisser merged pull request #21005: [FLINK-29495][Connector/Pulsar] Refactor Pulsar tests to disable them on Java 11

2022-10-10 Thread GitBox
MartijnVisser merged PR #21005: URL: https://github.com/apache/flink/pull/21005 -- 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] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[GitHub] [flink] mxm commented on a diff in pull request #20953: [FLINK-29501] Add option to override job vertex parallelisms during job submission

2022-10-10 Thread GitBox
mxm commented on code in PR #20953: URL: https://github.com/apache/flink/pull/20953#discussion_r991532503 ## flink-core/src/main/java/org/apache/flink/configuration/ConfigOption.java: ## @@ -64,22 +64,37 @@ * * * typeClass == atomic class (e.g. {@code

[GitHub] [flink] leletan commented on pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-10-10 Thread GitBox
leletan commented on PR #20852: URL: https://github.com/apache/flink/pull/20852#issuecomment-1273650082 Hi folks, @pnowojski @stevenzwu @zentol Thanks for your review again. I believe I addressed all comments, except the pending naming of the old CheckpointType class name (will add in a

[jira] [Updated] (FLINK-29573) Flink does not work for windows if installing on other drive except for C drive

2022-10-10 Thread kris wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kris wang updated FLINK-29573: -- Description: {{ flink_service.bat }}-{-}> \{{flink_inner.bat }}{-}{-}> \{{start-cluster.sh

[jira] [Created] (FLINK-29573) Flink does not work for windows if installing on other drive except for C drive

2022-10-10 Thread kris wang (Jira)
kris wang created FLINK-29573: - Summary: Flink does not work for windows if installing on other drive except for C drive Key: FLINK-29573 URL: https://issues.apache.org/jira/browse/FLINK-29573 Project:

[jira] [Updated] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-10 Thread Kevin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kevin Li updated FLINK-29572: - Description: Currently Flink Task Manager use different local interface to bind to connect to Resource

[jira] [Commented] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-10 Thread Kevin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615214#comment-17615214 ] Kevin Li commented on FLINK-29572: -- {quote}Task Manager Log: 2022-10-08 17:22:32,983 INFO

[jira] [Created] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-10 Thread Kevin Li (Jira)
Kevin Li created FLINK-29572: Summary: Flink Task Manager skip loopback interface for resource manager registration Key: FLINK-29572 URL: https://issues.apache.org/jira/browse/FLINK-29572 Project: Flink

[jira] [Closed] (FLINK-29561) Log the job id when clean up session job failed

2022-10-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-29561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-29561. -- Resolution: Fixed

[GitHub] [flink-kubernetes-operator] mbalassi merged pull request #398: [FLINK-29561] Add job id in the cleanup job failed message.

2022-10-10 Thread GitBox
mbalassi merged PR #398: URL: https://github.com/apache/flink-kubernetes-operator/pull/398 -- 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-kubernetes-operator] mbalassi commented on pull request #398: [FLINK-29561] Add job id in the cleanup job failed message.

2022-10-10 Thread GitBox
mbalassi commented on PR #398: URL: https://github.com/apache/flink-kubernetes-operator/pull/398#issuecomment-1273572910 LGTM -- 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-29561) Log the job id when clean up session job failed

2022-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29561: --- Labels: pull-request-available (was: ) > Log the job id when clean up session job failed >

[jira] [Assigned] (FLINK-29561) Log the job id when clean up session job failed

2022-10-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-29561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi reassigned FLINK-29561: -- Assignee: Xin Hao > Log the job id when clean up session job failed >

[jira] [Comment Edited] (FLINK-29503) Add backpressureLevel field without hyphens

2022-10-10 Thread Tiger (Apache) Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615198#comment-17615198 ] Tiger (Apache) Wang edited comment on FLINK-29503 at 10/10/22 4:25 PM:

[jira] [Commented] (FLINK-29504) Jar upload spec should define a schema

2022-10-10 Thread Tiger (Apache) Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615200#comment-17615200 ] Tiger (Apache) Wang commented on FLINK-29504: - Verified the issue no longer repros, with the

[jira] [Commented] (FLINK-29503) Add backpressureLevel field without hyphens

2022-10-10 Thread Tiger (Apache) Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615198#comment-17615198 ] Tiger (Apache) Wang commented on FLINK-29503: - Verified the issue no longer repros.   I

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on a diff in pull request #394: [FLINK-29394] Add observe Flink job health

2022-10-10 Thread GitBox
gaborgsomogyi commented on code in PR #394: URL: https://github.com/apache/flink-kubernetes-operator/pull/394#discussion_r991457409 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractDeploymentObserver.java: ## @@ -139,8

[GitHub] [flink] flinkbot commented on pull request #21008: [FLINK-29571] Support Map ConfigOptions

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

[jira] [Updated] (FLINK-29571) Flink configuration only supports Map

2022-10-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29571: --- Labels: pull-request-available (was: ) > Flink configuration only supports Map >

[GitHub] [flink] mxm opened a new pull request, #21008: [FLINK-29571] Support Map ConfigOptions

2022-10-10 Thread GitBox
mxm opened a new pull request, #21008: URL: https://github.com/apache/flink/pull/21008 ## What is the purpose of the change Allow Map ConfigOptions ## Brief change log - Allow Map ConfigOptions ## Verifying this change Tests ## Does this pull request

[jira] [Commented] (FLINK-29571) Flink configuration only supports Map

2022-10-10 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615181#comment-17615181 ] Gyula Fora commented on FLINK-29571: cc [~twalthr]  > Flink configuration only supports Map >

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #394: [FLINK-29394] Add observe Flink job health

2022-10-10 Thread GitBox
gaborgsomogyi commented on PR #394: URL: https://github.com/apache/flink-kubernetes-operator/pull/394#issuecomment-1273478676 From high level perspective now we fill `clusterInfo` from multiple places but if we want to use it as custom and flexible storage then we need to go this

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on a diff in pull request #394: [FLINK-29394] Add observe Flink job health

2022-10-10 Thread GitBox
gaborgsomogyi commented on code in PR #394: URL: https://github.com/apache/flink-kubernetes-operator/pull/394#discussion_r991402891 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractDeploymentObserver.java: ## @@

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on a diff in pull request #394: [FLINK-29394] Add observe Flink job health

2022-10-10 Thread GitBox
gaborgsomogyi commented on code in PR #394: URL: https://github.com/apache/flink-kubernetes-operator/pull/394#discussion_r991401325 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractDeploymentObserver.java: ## @@

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on a diff in pull request #394: [FLINK-29394] Add observe Flink job health

2022-10-10 Thread GitBox
gaborgsomogyi commented on code in PR #394: URL: https://github.com/apache/flink-kubernetes-operator/pull/394#discussion_r991399660 ## docs/content/docs/custom-resource/reference.md: ## @@ -251,6 +261,7 @@ This page serves as a full reference for FlinkDeployment custom

[GitHub] [flink] zentol commented on pull request #21006: [FLINK-29568][rest][docs] Remove whitespace

2022-10-10 Thread GitBox
zentol commented on PR #21006: URL: https://github.com/apache/flink/pull/21006#issuecomment-1273457155 > Still think it's funny that it requires 231 line changes and 697 lines removed to get rid of a whitespace sweat_smile One of these days we'll manage to only have these generated

  1   2   3   4   >