[GitHub] [flink] snuyanzin commented on pull request #19340: [FLINK-26961][BP-1.14][connectors][filesystems][formats] Update Jackson Databi…

2022-04-04 Thread GitBox
snuyanzin commented on PR #19340: URL: https://github.com/apache/flink/pull/19340#issuecomment-1087445098 probably the reason of failing is ``` Apr 04 11:16:48 Failure: There are unwanted classes in the

[jira] [Closed] (FLINK-25797) Translate datastream/formats/parquet.md page into Chinese.

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

[jira] [Closed] (FLINK-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors"

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25738. -- Fix Version/s: 1.15.0 Resolution: Fixed All subtasks have been completed >

[GitHub] [flink] MartijnVisser merged pull request #19348: [FLINK-25797][BP 1.15][Docs] Translate datastream/formats/parquet.md page into Chinese

2022-04-04 Thread GitBox
MartijnVisser merged PR #19348: URL: https://github.com/apache/flink/pull/19348 -- 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] MartijnVisser commented on pull request #19340: [FLINK-26961][BP-1.14][connectors][filesystems][formats] Update Jackson Databi…

2022-04-04 Thread GitBox
MartijnVisser commented on PR #19340: URL: https://github.com/apache/flink/pull/19340#issuecomment-1087433641 @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] [Assigned] (FLINK-27048) Add ArchUnit tests for Elasticsearch to only depend on public API

2022-04-04 Thread Alexander Preuss (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Preuss reassigned FLINK-27048: Assignee: Alexander Preuss > Add ArchUnit tests for Elasticsearch to only depend

[jira] [Created] (FLINK-27048) Add ArchUnit tests for Elasticsearch to only depend on public API

2022-04-04 Thread Alexander Preuss (Jira)
Alexander Preuss created FLINK-27048: Summary: Add ArchUnit tests for Elasticsearch to only depend on public API Key: FLINK-27048 URL: https://issues.apache.org/jira/browse/FLINK-27048 Project:

[GitHub] [flink-web] mbalassi commented on pull request #519: Add Kubernetes Operator 0.1.0 release

2022-04-04 Thread GitBox
mbalassi commented on PR #519: URL: https://github.com/apache/flink-web/pull/519#issuecomment-1087420546 @gyfora roger that, reviewing and merging asap. -- 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

[GitHub] [flink] twalthr commented on a diff in pull request #19190: [FLINK-13785][table] Port time functions to new type inference

2022-04-04 Thread GitBox
twalthr commented on code in PR #19190: URL: https://github.com/apache/flink/pull/19190#discussion_r841592437 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/CallContext.java: ## @@ -93,6 +93,17 @@ default ValidationException

[jira] [Comment Edited] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516747#comment-17516747 ] Francesco Guardiani edited comment on FLINK-26760 at 4/4/22 11:04 AM:

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516747#comment-17516747 ] Francesco Guardiani commented on FLINK-26760: - Ok just checked the TPC-DS spec: > Comment:

[GitHub] [flink] metaswirl commented on pull request #19272: [FLINK-26710] fix TestLoggerResource

2022-04-04 Thread GitBox
metaswirl commented on PR #19272: URL: https://github.com/apache/flink/pull/19272#issuecomment-1087411017 @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] [Comment Edited] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516744#comment-17516744 ] Francesco Guardiani edited comment on FLINK-26760 at 4/4/22 10:58 AM:

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516744#comment-17516744 ] Francesco Guardiani commented on FLINK-26760: - Just checked, the bench files effectively

[GitHub] [flink] flinkbot commented on pull request #19351: [FLINK-27045][tests] Remove shared executor

2022-04-04 Thread GitBox
flinkbot commented on PR #19351: URL: https://github.com/apache/flink/pull/19351#issuecomment-1087407592 ## CI report: * 1580f63c4fd8e395ed41542e6ee322082cc6b23f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] slinkydeveloper commented on a diff in pull request #19113: [FLINK-26519][table] Remove FlinkTypeFactory singleton

2022-04-04 Thread GitBox
slinkydeveloper commented on code in PR #19113: URL: https://github.com/apache/flink/pull/19113#discussion_r841606149 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkTypeSystem.java: ## @@ -0,0 +1,198 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-27047) DispatcherResourceCleanupTest is unstable

2022-04-04 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27047: Summary: DispatcherResourceCleanupTest is unstable Key: FLINK-27047 URL: https://issues.apache.org/jira/browse/FLINK-27047 Project: Flink Issue

[GitHub] [flink] slinkydeveloper commented on a diff in pull request #19113: [FLINK-26519][table] Remove FlinkTypeFactory singleton

2022-04-04 Thread GitBox
slinkydeveloper commented on code in PR #19113: URL: https://github.com/apache/flink/pull/19113#discussion_r841602316 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/AggregateUtil.scala: ## @@ -404,12 +422,13 @@ object AggregateUtil

[jira] [Updated] (FLINK-27045) Remove shared TestingUtils executor

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

[GitHub] [flink] zentol opened a new pull request, #19351: [FLINK-27045][tests] Remove shared executor

2022-04-04 Thread GitBox
zentol opened a new pull request, #19351: URL: https://github.com/apache/flink/pull/19351 Sharing an executor can lead to surprising behaviors, especially since the ownership of the executor isn't well-defined. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] morhidi commented on pull request #18933: [FLINK-26368] [kafka] Add setProperty method to KafkaSinkBuilder

2022-04-04 Thread GitBox
morhidi commented on PR #18933: URL: https://github.com/apache/flink/pull/18933#issuecomment-1087395191 > @morhidi could you please review? sure, I'll have a look at it later today! -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot commented on pull request #19350: [FLINK-27046][tests][JUnit5 migration] flink-X-glue-schema-registry

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

[jira] [Updated] (FLINK-27046) [JUnit5 Migration] Module: flink-*-glue-schema-registry

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

[GitHub] [flink] RyanSkraba opened a new pull request, #19350: [FLINK-27046][tests][JUnit5 migration] flink-X-glue-schema-registry

2022-04-04 Thread GitBox
RyanSkraba opened a new pull request, #19350: URL: https://github.com/apache/flink/pull/19350 ## What is the purpose of the change Update the `flink-formats/flink-avro-glue-schema-registry` and `flink-formats/flink-json-glue-schema-registry` module to AssertJ and JUnit 5 following

[GitHub] [flink] flinkbot commented on pull request #19349: [FLINK-27043][table] Removing old csv format references

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

[jira] [Updated] (FLINK-27043) Remove CSV connector test usages

2022-04-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27043: --- Labels: pull-request-available (was: ) > Remove CSV connector test usages >

[GitHub] [flink] slinkydeveloper opened a new pull request, #19349: [FLINK-27043][table] Removing old csv format references

2022-04-04 Thread GitBox
slinkydeveloper opened a new pull request, #19349: URL: https://github.com/apache/flink/pull/19349 This PR is preliminary work to get https://issues.apache.org/jira/browse/FLINK-26952 solved (which is blocked currently by an issue of the new csv format). Changelog: * Remove

[GitHub] [flink-connector-elasticsearch] JingGe opened a new pull request, #5: [Flink-26884] Copy elasticsearch connectors to the external repo

2022-04-04 Thread GitBox
JingGe opened a new pull request, #5: URL: https://github.com/apache/flink-connector-elasticsearch/pull/5 ## What is the purpose of the change With this PR, Elasticsearch connectors will be moved to the external repo. ## Brief change log - create a new maven

[GitHub] [flink] twalthr commented on a diff in pull request #19087: [FLINK-26467][table-planner] Compile RowDataToStringConverter lazily

2022-04-04 Thread GitBox
twalthr commented on code in PR #19087: URL: https://github.com/apache/flink/pull/19087#discussion_r841582266 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/RowDataToStringConverterImpl.java: ## @@ -51,9 +53,18 @@ public

[jira] [Created] (FLINK-27046) [JUnit5 Migration] Module: flink-*-glue-schema-registry

2022-04-04 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-27046: --- Summary: [JUnit5 Migration] Module: flink-*-glue-schema-registry Key: FLINK-27046 URL: https://issues.apache.org/jira/browse/FLINK-27046 Project: Flink Issue

[jira] [Commented] (FLINK-27046) [JUnit5 Migration] Module: flink-*-glue-schema-registry

2022-04-04 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516727#comment-17516727 ] Ryan Skraba commented on FLINK-27046: - Can I take this? > [JUnit5 Migration] Module:

[GitHub] [flink-web] matriv commented on a diff in pull request #504: [FLINK-25897] Update gradle quickstart to gradle 7.3.3

2022-04-04 Thread GitBox
matriv commented on code in PR #504: URL: https://github.com/apache/flink-web/pull/504#discussion_r841553926 ## q/gradle-quickstart.sh: ## @@ -169,17 +168,23 @@ dependencies { // Compile-time dependencies that should NOT be part of the // shadow jar and are provided

[jira] [Assigned] (FLINK-22857) Add possibility to call built-in functions in SpecializedFunction

2022-04-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-22857: Assignee: Timo Walther > Add possibility to call built-in functions in

[jira] [Comment Edited] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516717#comment-17516717 ] Timo Walther edited comment on FLINK-26760 at 4/4/22 9:38 AM: -- UTF-8 is the

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516717#comment-17516717 ] Timo Walther commented on FLINK-26760: -- UTF-8 is the default within the engine but I don't know why

[jira] [Created] (FLINK-27045) Remove shared TestingUtils executor

2022-04-04 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27045: Summary: Remove shared TestingUtils executor Key: FLINK-27045 URL: https://issues.apache.org/jira/browse/FLINK-27045 Project: Flink Issue Type:

[GitHub] [flink-web] dmvk commented on a diff in pull request #504: [FLINK-25897] Update gradle quickstart to gradle 7.3.3

2022-04-04 Thread GitBox
dmvk commented on code in PR #504: URL: https://github.com/apache/flink-web/pull/504#discussion_r841540013 ## q/gradle-quickstart.sh: ## @@ -169,17 +168,23 @@ dependencies { // Compile-time dependencies that should NOT be part of the // shadow jar and are provided in

[GitHub] [flink] XComp commented on a diff in pull request #19275: [FLINK-24491][runtime] Make the job termination wait until the archiving of ExecutionGraphInfo finishes

2022-04-04 Thread GitBox
XComp commented on code in PR #19275: URL: https://github.com/apache/flink/pull/19275#discussion_r841538152 ## flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherResourceCleanupTest.java: ## @@ -186,6 +193,9 @@ private void startDispatcher(

[jira] [Comment Edited] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516711#comment-17516711 ] Arvid Heise edited comment on FLINK-26760 at 4/4/22 9:25 AM: - Why are our

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516711#comment-17516711 ] Arvid Heise commented on FLINK-26760: - Why are our benchmarks not use UTF-8? I thought that was the

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516708#comment-17516708 ] Francesco Guardiani commented on FLINK-26760: - Another incident: I'm trying to convert our

[jira] [Closed] (FLINK-27027) Get rid of oddly named mvn-${sys mvn.forkNumber}.log files

2022-04-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27027. Resolution: Fixed master: 3416b6440acf3b1d6258d68418d53740fba8bf2f

[jira] [Commented] (FLINK-27010) Support setting sql client args via flink conf

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516706#comment-17516706 ] Martijn Visser commented on FLINK-27010: I don't think this is a good idea. I think the SQL

[GitHub] [flink] zentol merged pull request #19342: [FLINK-27027] Get rid of oddly named mvn-${sys mvn.forkNumber}.log files

2022-04-04 Thread GitBox
zentol merged PR #19342: URL: https://github.com/apache/flink/pull/19342 -- 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] zentol commented on pull request #19342: [FLINK-27027] Get rid of oddly named mvn-${sys mvn.forkNumber}.log files

2022-04-04 Thread GitBox
zentol commented on PR #19342: URL: https://github.com/apache/flink/pull/19342#issuecomment-1087315513 > We don't know where this separate log is coming from, do we? Not entirely; I think it's a case of certain classes being loaded outside of a fork. -- This is an automated

[jira] [Closed] (FLINK-27026) Upgrade checkstyle plugin

2022-04-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27026. Resolution: Fixed master: 7ad47230f2227de938a1722c41e1a91f42eba41a > Upgrade checkstyle

[GitHub] [flink] zentol merged pull request #19343: [FLINK-27026][build] Upgrade checkstyle plugin

2022-04-04 Thread GitBox
zentol merged PR #19343: URL: https://github.com/apache/flink/pull/19343 -- 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] [Closed] (FLINK-27034) Use testcontainers for google cloud pubsub e2e test

2022-04-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27034. Resolution: Fixed master: db8522cfddbafca0b936eecc7506335d85227e11 > Use testcontainers

[GitHub] [flink] zentol merged pull request #19346: [FLINK-27034][gcp][tests] Use testcontainers

2022-04-04 Thread GitBox
zentol merged PR #19346: URL: https://github.com/apache/flink/pull/19346 -- 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-27011) Add state access examples of Python DataStream API

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516701#comment-17516701 ] Martijn Visser commented on FLINK-27011: [~dianfu] Will these examples also be validated during

[GitHub] [flink] twalthr closed pull request #19236: [FLINK-26712][table-planner] Metadata keys should not conflict with physical columns

2022-04-04 Thread GitBox
twalthr closed pull request #19236: [FLINK-26712][table-planner] Metadata keys should not conflict with physical columns URL: https://github.com/apache/flink/pull/19236 -- 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-27042) StreamTaskTest#testMailboxMetricsScheduling is unstable

2022-04-04 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-27042: -- Fix Version/s: (was: 1.15.1) > StreamTaskTest#testMailboxMetricsScheduling is

[jira] [Updated] (FLINK-27042) StreamTaskTest#testMailboxMetricsScheduling is unstable

2022-04-04 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-27042: -- Affects Version/s: 1.16.0 (was: 1.15.0) >

[jira] [Assigned] (FLINK-27042) StreamTaskTest#testMailboxMetricsScheduling is unstable

2022-04-04 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-27042: - Assignee: Sebastian Mattheis > StreamTaskTest#testMailboxMetricsScheduling is

[jira] [Created] (FLINK-27044) Drop support for Hive versions 1.*, 2.1.* and 2.2.*

2022-04-04 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-27044: -- Summary: Drop support for Hive versions 1.*, 2.1.* and 2.2.* Key: FLINK-27044 URL: https://issues.apache.org/jira/browse/FLINK-27044 Project: Flink

[jira] [Commented] (FLINK-27018) timestamp missing end zero when outputing to kafka

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516697#comment-17516697 ] Martijn Visser commented on FLINK-27018: [~jeff-zou] Can you please try this in the latest

[jira] [Commented] (FLINK-27020) use hive dialect in SqlClient would thrown an error based on 1.15 version

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516696#comment-17516696 ] Martijn Visser commented on FLINK-27020: [~jingzhang] Have you changed the planner to the old

[jira] [Commented] (FLINK-27025) Cannot read parquet file, after putting the jar in the right place with right permissions

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516694#comment-17516694 ] Martijn Visser commented on FLINK-27025: [~marsupialtail] Based on your attachment you're trying

[jira] [Updated] (FLINK-27025) Cannot read parquet file, after putting the jar in the right place with right permissions

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27025: --- Priority: Major (was: Blocker) > Cannot read parquet file, after putting the jar in the

[jira] [Commented] (FLINK-8929) "UnknownTaskExecutorException: No TaskExecutor registered" when having tab open for taskmanager that does not exist (anymore)

2022-04-04 Thread Doug (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516690#comment-17516690 ] Doug commented on FLINK-8929: - We are also facing same issue. Anybody found solution on it ?        ERROR

[GitHub] [flink] Humbedooh commented on pull request #19348: [FLINK-25797][BP 1.15][Docs] Translate datastream/formats/parquet.md page into Chinese

2022-04-04 Thread GitBox
Humbedooh commented on PR #19348: URL: https://github.com/apache/flink/pull/19348#issuecomment-1087259265 testing why mails are going to the wrong place, ignore me please -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] MartijnVisser merged pull request #19339: [FLINK-26961][BP-1.15][connectors][filesystems][formats] Update Jackson Databi…

2022-04-04 Thread GitBox
MartijnVisser merged PR #19339: URL: https://github.com/apache/flink/pull/19339 -- 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-26999) Introduce ClickHouse Connector

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516675#comment-17516675 ] Martijn Visser commented on FLINK-26999: [~monster#12] [~RocMarshal] Thanks for the FLIP and the

[jira] [Created] (FLINK-27043) Remove CSV connector test usages

2022-04-04 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-27043: --- Summary: Remove CSV connector test usages Key: FLINK-27043 URL: https://issues.apache.org/jira/browse/FLINK-27043 Project: Flink Issue Type:

[jira] [Commented] (FLINK-26978) Flink-SQL cannot display Timestamp time correctly.

2022-04-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516673#comment-17516673 ] Timo Walther commented on FLINK-26978: -- [~CharlieX47] can you check this with the latest master?

[GitHub] [flink] gaborgsomogyi commented on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

2022-04-04 Thread GitBox
gaborgsomogyi commented on PR #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1087223293 @dmvk thanks for the review and taking care! New PRs are on the way... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Resolved] (FLINK-25907) Add pluggable delegation token manager

2022-04-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-25907. --- Resolution: Fixed > Add pluggable delegation token manager >

[jira] [Updated] (FLINK-25907) Add pluggable delegation token manager

2022-04-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-25907: -- Affects Version/s: (was: 1.16.0) > Add pluggable delegation token manager >

[jira] [Updated] (FLINK-25907) Add pluggable delegation token manager

2022-04-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek updated FLINK-25907: -- Fix Version/s: 1.16.0 > Add pluggable delegation token manager >

[jira] [Commented] (FLINK-25907) Add pluggable delegation token manager

2022-04-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516663#comment-17516663 ] David Morávek commented on FLINK-25907: --- master: 26aa543b3bbe2b606bbc6d332a2ef7c5b46d25eb > Add

[GitHub] [flink] flinkbot commented on pull request #19348: [FLINK-25797][BP 1.15][Docs] Translate datastream/formats/parquet.md page into Chinese

2022-04-04 Thread GitBox
flinkbot commented on PR #19348: URL: https://github.com/apache/flink/pull/19348#issuecomment-1087222115 ## CI report: * 446911bf1ac8d4fb5ef2d113f64257d03982f26b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] dmvk merged pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

2022-04-04 Thread GitBox
dmvk merged PR #18664: URL: https://github.com/apache/flink/pull/18664 -- 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-25738) Translate/fix translations for "FileSystem" connector page of "Connectors > DataStream Connectors"

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25738?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516662#comment-17516662 ] Martijn Visser commented on FLINK-25738: [~RocMarshal] I was still waiting on a backport for

[jira] [Commented] (FLINK-27031) ChangelogRescalingITCase.test failed due to IllegalStateException

2022-04-04 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516661#comment-17516661 ] Roman Khachatryan commented on FLINK-27031: --- Sure [~mapohl], I'll take a look. >

[jira] [Assigned] (FLINK-27031) ChangelogRescalingITCase.test failed due to IllegalStateException

2022-04-04 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-27031: - Assignee: Roman Khachatryan > ChangelogRescalingITCase.test failed due to

[GitHub] [flink] MartijnVisser opened a new pull request, #19348: [FLINK-25797][BP 1.15][Docs] Translate datastream/formats/parquet.md page into Chinese

2022-04-04 Thread GitBox
MartijnVisser opened a new pull request, #19348: URL: https://github.com/apache/flink/pull/19348 Unchanged backport of https://github.com/apache/flink/pull/18646 -- 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] MartijnVisser commented on pull request #18151: [FLINK-25379][connectors] Support limit push down in DATAGEN connector

2022-04-04 Thread GitBox
MartijnVisser commented on PR #18151: URL: https://github.com/apache/flink/pull/18151#issuecomment-1087209729 > slink @slinkydeveloper Can you help with the review? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Closed] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26524. -- Resolution: Cannot Reproduce > Elasticsearch (v5.3.3) sink end-to-end test >

[jira] [Commented] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516656#comment-17516656 ] Martijn Visser commented on FLINK-26760: [~wanglijie95] Can you open a ticket for that

[jira] [Commented] (FLINK-26952) Remove old CSV connector

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516655#comment-17516655 ] Martijn Visser commented on FLINK-26952: [~wanglijie95] I think removing the old connector isn't

[jira] [Assigned] (FLINK-26760) The new CSV source (file system source + CSV format) does not support reading files whose file encoding is not UTF-8

2022-04-04 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-26760: -- Assignee: Arvid Heise > The new CSV source (file system source + CSV format) does

[GitHub] [flink] ZhangChaoming commented on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-04-04 Thread GitBox
ZhangChaoming commented on PR #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1087202752 @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] ZhangChaoming commented on pull request #18386: [FLINK-25684][table] Support enhanced `show databases` syntax

2022-04-04 Thread GitBox
ZhangChaoming commented on PR #18386: URL: https://github.com/apache/flink/pull/18386#issuecomment-1087202410 @RocMarshal OK -- 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] [Closed] (FLINK-26899) Introduce write/query table document for table store

2022-04-04 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26899. Resolution: Fixed master: 42799f71ba226342a1a603002cf4b9b940d85b88 > Introduce write/query table

[GitHub] [flink-table-store] JingsongLi merged pull request #72: [FLINK-26899] Introduce write/query table document for table store

2022-04-04 Thread GitBox
JingsongLi merged PR #72: URL: https://github.com/apache/flink-table-store/pull/72 -- 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] gyfora commented on pull request #18933: [FLINK-26368] [kafka] Add setProperty method to KafkaSinkBuilder

2022-04-04 Thread GitBox
gyfora commented on PR #18933: URL: https://github.com/apache/flink/pull/18933#issuecomment-1087172370 @morhidi could you please review pelase? -- 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] [Assigned] (FLINK-26913) Add ITCase for computed column and watermark

2022-04-04 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26913: Assignee: Jane Chan > Add ITCase for computed column and watermark >

<    1   2