[GitHub] [flink-table-store] JingsongLi merged pull request #428: [FLINK-30341] Introduce audit_log system table

2022-12-12 Thread GitBox
JingsongLi merged PR #428: URL: https://github.com/apache/flink-table-store/pull/428 -- 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-30371) JdbcOutputFormat is at risk of database connection leaks

2022-12-12 Thread Echo Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645992#comment-17645992 ] Echo Lee commented on FLINK-30371: -- CC [~martijnvisser]  Can you assign this ticket to me? >

[GitHub] [flink-connector-hbase] zentol commented on a diff in pull request #4: [FLINK-30062][Connectors/HBase] ADDENDUM: Bundle the exact same dependencies as it was in core

2022-12-12 Thread GitBox
zentol commented on code in PR #4: URL: https://github.com/apache/flink-connector-hbase/pull/4#discussion_r1045592944 ## flink-sql-connector-hbase-2.2/pom.xml: ## @@ -39,15 +39,25 @@ under the License. org.apache.flink

[GitHub] [flink-table-store] JingsongLi merged pull request #431: [FLINK-30341] Document audit log table

2022-12-12 Thread GitBox
JingsongLi merged PR #431: URL: https://github.com/apache/flink-table-store/pull/431 -- 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-29405) InputFormatCacheLoaderTest is unstable

2022-12-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646018#comment-17646018 ] Leonard Xu commented on FLINK-29405: I upgrade this priority to blocker as too many failures

[GitHub] [flink] dannycranmer commented on a diff in pull request #21407: [FLINK-30224][Connectors/Kinesis] An IT test for slow FlinKinesisConsumer's run() which caused an NPE in close

2022-12-12 Thread GitBox
dannycranmer commented on code in PR #21407: URL: https://github.com/apache/flink/pull/21407#discussion_r1045654367 ## flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisITCase.java: ## @@ -175,6 +184,40 @@ private

[GitHub] [flink] dannycranmer commented on pull request #21407: [FLINK-30224][Connectors/Kinesis] An IT test for slow FlinKinesisConsumer's run() which caused an NPE in close

2022-12-12 Thread GitBox
dannycranmer commented on PR #21407: URL: https://github.com/apache/flink/pull/21407#issuecomment-1346244117 @astamur it looks like you did not use the standard PR template, can you please fix the description? -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Resolved] (FLINK-30321) Upgrade ZLIB of FRocksDB to 1.2.13

2022-12-12 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei resolved FLINK-30321. Fix Version/s: 1.17.0 Resolution: Fixed > Upgrade ZLIB of FRocksDB to 1.2.13 >

[jira] [Closed] (FLINK-30362) Flink-connector-hive can't build with maven 3.8

2022-12-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-30362. Fix Version/s: (was: 1.17.0) (was: 1.16.1)

[jira] [Commented] (FLINK-30321) Upgrade ZLIB of FRocksDB to 1.2.13

2022-12-12 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645985#comment-17645985 ] Yanfei Lei commented on FLINK-30321: Merged

[jira] [Created] (FLINK-30372) dependencyManagement bom for flink-dist

2022-12-12 Thread James Z.M. Gao (Jira)
James Z.M. Gao created FLINK-30372: -- Summary: dependencyManagement bom for flink-dist Key: FLINK-30372 URL: https://issues.apache.org/jira/browse/FLINK-30372 Project: Flink Issue Type: New

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #432: [FLINK-30373] Flink-table-runtime free for flink-table-store-codegen

2022-12-12 Thread GitBox
JingsongLi opened a new pull request, #432: URL: https://github.com/apache/flink-table-store/pull/432 - Copy `GeneratedClass`, It is now an implementation class, representing different codegen classes through generics. - Copy `CompileUtils`. - Copy `BinaryIndexedSortable` and

[GitHub] [flink-connector-rabbitmq] zentol commented on a diff in pull request #3: [FLINK-30279] Move existing RabbitMQ connector code from Flink repo to dedicated RabbitMQ repo

2022-12-12 Thread GitBox
zentol commented on code in PR #3: URL: https://github.com/apache/flink-connector-rabbitmq/pull/3#discussion_r1045606463 ## .github/workflows/ci.yml: ## @@ -49,27 +63,39 @@ jobs: with: maven-version: 3.8.6 + - name: Create cache dirs +run:

[jira] [Updated] (FLINK-29405) InputFormatCacheLoaderTest is unstable

2022-12-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-29405: --- Issue Type: Bug (was: Technical Debt) > InputFormatCacheLoaderTest is unstable >

[GitHub] [flink] luoyuxia commented on pull request #21401: [FLINK-29718][table] Supports hive sum function by native implementation

2022-12-12 Thread GitBox
luoyuxia commented on PR #21401: URL: https://github.com/apache/flink/pull/21401#issuecomment-1346082069 Btw, the test failed. -- 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-25512) Materialization Files are not cleaned up if no checkpoint is using it

2022-12-12 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-25512: -- Assignee: Yanfei Lei (was: Nicholas Jiang) > Materialization Files are not cleaned up if no

[jira] [Commented] (FLINK-25334) Manage and share gateways of taskmanagers between jobs in session cluster

2022-12-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-25334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645982#comment-17645982 ] David Morávek commented on FLINK-25334: --- Can you please provide some details on how you intend to

[jira] [Created] (FLINK-30371) JdbcOutputFormat is at risk of database connection leaks

2022-12-12 Thread Echo Lee (Jira)
Echo Lee created FLINK-30371: Summary: JdbcOutputFormat is at risk of database connection leaks Key: FLINK-30371 URL: https://issues.apache.org/jira/browse/FLINK-30371 Project: Flink Issue Type:

[jira] [Updated] (FLINK-30359) Encountered NoClassDefFoundError when using flink-sql-connector-elasticsearch6

2022-12-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30359: - Affects Version/s: elasticsearch-3.0.0 1.15.0 > Encountered

[GitHub] [flink-connector-hbase] zentol commented on pull request #5: [FLINK-30349] Sync missing HBase e2e tests to external repo

2022-12-12 Thread GitBox
zentol commented on PR #5: URL: https://github.com/apache/flink-connector-hbase/pull/5#issuecomment-1346170903 The e2e tests will need to be re-written to not rely on the legacy E2E infrastructure but use the connector e2e framework instead. -- This is an automated message from the

[jira] [Updated] (FLINK-30373) Flink-table-runtime free for flink-table-store-codegen

2022-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-30373: - Description: To remove the dependence of flink-table-store-core on flink-table-runtime,

[jira] [Assigned] (FLINK-30251) Move the IO with DFS during abort checkpoint to an asynchronous thread.

2022-12-12 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu reassigned FLINK-30251: Assignee: ming li > Move the IO with DFS during abort checkpoint to an asynchronous

[jira] [Commented] (FLINK-15635) Allow passing a ClassLoader to EnvironmentSettings

2022-12-12 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645970#comment-17645970 ] Timo Walther commented on FLINK-15635: -- [~prabhujoseph] the DataStream API still relies on

[jira] [Commented] (FLINK-29317) Add WebSocket in Dispatcher to support olap query submission and push results in session cluster

2022-12-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-29317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645973#comment-17645973 ] David Morávek commented on FLINK-29317: --- Some efforts in this direction make sense, but it is a

[jira] [Comment Edited] (FLINK-30341) Introduce audit_log system table

2022-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645961#comment-17645961 ] Jingsong Lee edited comment on FLINK-30341 at 12/12/22 9:55 AM: master:

[jira] [Updated] (FLINK-30361) Cluster deleted and created back while updating replicas

2022-12-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30361: --- Labels: pull-request-available (was: ) > Cluster deleted and created back while updating

[GitHub] [flink-kubernetes-operator] swathic95 opened a new pull request, #481: [FLINK-30361] Cluster deleted and created back while updating replicas

2022-12-12 Thread GitBox
swathic95 opened a new pull request, #481: URL: https://github.com/apache/flink-kubernetes-operator/pull/481 ## What is the purpose of the change Whenever we scale the standalone session cluster, currently the existing job managers and task managers are deleted and added

[GitHub] [flink] luoyuxia commented on a diff in pull request #21401: [FLINK-29718][table] Supports hive sum function by native implementation

2022-12-12 Thread GitBox
luoyuxia commented on code in PR #21401: URL: https://github.com/apache/flink/pull/21401#discussion_r1045472367 ## flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectAggITCase.java: ## @@ -0,0 +1,101 @@ +/* + * Licensed to the Apache

[jira] [Assigned] (FLINK-30359) Encountered NoClassDefFoundError when using flink-sql-connector-elasticsearch6

2022-12-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-30359: Assignee: Weijie Guo > Encountered NoClassDefFoundError when using >

[GitHub] [flink] zentol merged pull request #21448: [FLINK-30116][rest] Don't Show Env Vars in Web UI

2022-12-12 Thread GitBox
zentol merged PR #21448: URL: https://github.com/apache/flink/pull/21448 -- 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-30116) Don't Show Env Vars in Web UI

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

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #429: [FLINK-30209] Introduce StaticCompactorSource and ContinuousCompactorSource for stand-alone compact jobs

2022-12-12 Thread GitBox
JingsongLi commented on code in PR #429: URL: https://github.com/apache/flink-table-store/pull/429#discussion_r1045646900 ## flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSourceBuilder.java: ## @@ -44,8 +44,11 @@ import

[jira] [Commented] (FLINK-29637) Improve to reuse threads in TaskManager for different tasks between jobs

2022-12-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-29637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645979#comment-17645979 ] David Morávek commented on FLINK-29637: --- My initial impression is that this could introduce some

[jira] [Commented] (FLINK-30359) Encountered NoClassDefFoundError when using flink-sql-connector-elasticsearch6

2022-12-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645981#comment-17645981 ] Chesnay Schepler commented on FLINK-30359: -- [~Weijie Guo] Let's remove the exclusion from the

[jira] [Assigned] (FLINK-30370) Move existing delegation token framework authentication to providers

2022-12-12 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-30370: - Assignee: Gabor Somogyi > Move existing delegation token framework authentication to

[jira] [Updated] (FLINK-30359) Encountered NoClassDefFoundError when using flink-sql-connector-elasticsearch6

2022-12-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30359: - Fix Version/s: 1.16.1 elasticsearch-4.0.0

[jira] [Created] (FLINK-30370) Move existing delegation token framework authentication to providers

2022-12-12 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-30370: - Summary: Move existing delegation token framework authentication to providers Key: FLINK-30370 URL: https://issues.apache.org/jira/browse/FLINK-30370 Project:

[jira] [Created] (FLINK-30373) Flink-table-runtime free for flink-table-store-codegen

2022-12-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-30373: Summary: Flink-table-runtime free for flink-table-store-codegen Key: FLINK-30373 URL: https://issues.apache.org/jira/browse/FLINK-30373 Project: Flink Issue

[jira] [Updated] (FLINK-30116) Don't Show Env Vars in Web UI

2022-12-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30116: - Environment: In 1.16.0 a new REST endpoint was added that exposed JVM/classpath

[jira] [Assigned] (FLINK-30352) [Connectors][Elasticsearch] Document missing configuration properties

2022-12-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-30352: Assignee: Andriy Redko > [Connectors][Elasticsearch] Document missing

[GitHub] [flink] zentol closed pull request #21486: [FLINK-30362] exclude org.pentaho.* from hive-exec in flink-connector-hive flink-sql-connector-hive2/3

2022-12-12 Thread GitBox
zentol closed pull request #21486: [FLINK-30362] exclude org.pentaho.* from hive-exec in flink-connector-hive flink-sql-connector-hive2/3 URL: https://github.com/apache/flink/pull/21486 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] snuyanzin commented on pull request #21490: [FLINK-30368][table-planner] Fix calcite method RelMdUtil$numDistinctVals() wrongly return zero if the method input domainSize much larger

2022-12-12 Thread GitBox
snuyanzin commented on PR #21490: URL: https://github.com/apache/flink/pull/21490#issuecomment-1346155848 Thanks for your contribution Could you please clarify how we can be sure that this change does what expected? May be some tests could be helpful to have. Also it would be

[jira] [Commented] (FLINK-29405) InputFormatCacheLoaderTest is unstable

2022-12-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646015#comment-17646015 ] Leonard Xu commented on FLINK-29405:

[jira] [Updated] (FLINK-29405) InputFormatCacheLoaderTest is unstable

2022-12-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-29405: --- Priority: Blocker (was: Critical) > InputFormatCacheLoaderTest is unstable >

[jira] [Closed] (FLINK-30341) Introduce audit_log system table

2022-12-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-30341. Resolution: Fixed master: 81f4efc101620a134601c69a3b873f2a8d39fb70 > Introduce audit_log system

[GitHub] [flink-connector-hbase] zentol commented on a diff in pull request #4: [FLINK-30062][Connectors/HBase] ADDENDUM: Bundle the exact same dependencies as it was in core

2022-12-12 Thread GitBox
zentol commented on code in PR #4: URL: https://github.com/apache/flink-connector-hbase/pull/4#discussion_r1045591536 ## flink-sql-connector-hbase-2.2/pom.xml: ## @@ -39,15 +39,25 @@ under the License. org.apache.flink

[jira] [Updated] (FLINK-30373) Flink-table-runtime free for flink-table-store-codegen

2022-12-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30373: --- Labels: pull-request-available (was: ) > Flink-table-runtime free for

[jira] [Commented] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

2022-12-12 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646011#comment-17646011 ] Leonard Xu commented on FLINK-29461:

[jira] [Created] (FLINK-30374) DefaultExecutionGraphCacheTest fails with 239 exit code

2022-12-12 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-30374: -- Summary: DefaultExecutionGraphCacheTest fails with 239 exit code Key: FLINK-30374 URL: https://issues.apache.org/jira/browse/FLINK-30374 Project: Flink Issue

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #426: [FLINK-30323] Support table statistics in table store

2022-12-12 Thread GitBox
JingsongLi commented on code in PR #426: URL: https://github.com/apache/flink-table-store/pull/426#discussion_r1045664269 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/table/source/Split.java: ## @@ -23,5 +23,5 @@ /** An input split for reading. */

[jira] [Updated] (FLINK-30377) CommonExecSink does not use ClientWrapperClassLoader while extracting Type from KeyedStream

2022-12-12 Thread Prabhu Joseph (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabhu Joseph updated FLINK-30377: -- Description: CommonExecSink does not use ClientWrapperClassLoader while extracting Type from

[jira] [Created] (FLINK-30377) CommonExecSink does not use ClientWrapperClassLoader while extracting Type from KeyedStream

2022-12-12 Thread Prabhu Joseph (Jira)
Prabhu Joseph created FLINK-30377: - Summary: CommonExecSink does not use ClientWrapperClassLoader while extracting Type from KeyedStream Key: FLINK-30377 URL: https://issues.apache.org/jira/browse/FLINK-30377

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #423: [FLINK-27844] Support column type evolution in file meta

2022-12-12 Thread GitBox
JingsongLi commented on code in PR #423: URL: https://github.com/apache/flink-table-store/pull/423#discussion_r1044197565 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/DataValueConverter.java: ## @@ -0,0 +1,327 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-30379) Decouple connector docs integration from connector releases

2022-12-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30379: Summary: Decouple connector docs integration from connector releases Key: FLINK-30379 URL: https://issues.apache.org/jira/browse/FLINK-30379 Project: Flink

[jira] [Commented] (FLINK-30260) FLIP-271: Add initial Autoscaling implementation

2022-12-12 Thread ConradJam (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646067#comment-17646067 ] ConradJam commented on FLINK-30260: --- Hi [~mxm] I would like to know if there are related subtasks that

[GitHub] [flink] zentol commented on a diff in pull request #21221: [FLINK-29846] Upgrade ArchUnit to 1.0.0

2022-12-12 Thread GitBox
zentol commented on code in PR #21221: URL: https://github.com/apache/flink/pull/21221#discussion_r1045782253 ## flink-architecture-tests/flink-architecture-tests-production/archunit-violations/b8900323-6aab-4e7e-9b17-f53b3c3dca46: ## @@ -17,11 +17,10 @@ Method has return

[GitHub] [flink-connector-hbase] zentol merged pull request #4: [FLINK-30062][Connectors/HBase] ADDENDUM: Bundle the exact same dependencies as it was in core

2022-12-12 Thread GitBox
zentol merged PR #4: URL: https://github.com/apache/flink-connector-hbase/pull/4 -- 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] LadyForest commented on a diff in pull request #20652: [FLINK-22315][table] Support add/modify column/constraint/watermark for ALTER TABLE statement

2022-12-12 Thread GitBox
LadyForest commented on code in PR #20652: URL: https://github.com/apache/flink/pull/20652#discussion_r1045826171 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/AlterTableSchemaUtil.java: ## @@ -0,0 +1,525 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-30367) Enrich the thread dump info with deeper stack

2022-12-12 Thread Peter Vary (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646136#comment-17646136 ] Peter Vary commented on FLINK-30367: The depth of the stack trace could be set by the

[jira] [Updated] (FLINK-30386) Column constraint lacks primary key not enforced check

2022-12-12 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-30386: -- Summary: Column constraint lacks primary key not enforced check (was: Column primary key constraint

[jira] [Created] (FLINK-30386) Column primary key constraint lacks enforced check

2022-12-12 Thread Jane Chan (Jira)
Jane Chan created FLINK-30386: - Summary: Column primary key constraint lacks enforced check Key: FLINK-30386 URL: https://issues.apache.org/jira/browse/FLINK-30386 Project: Flink Issue Type: Bug

[GitHub] [flink-connector-kafka] zentol commented on pull request #1: [FLINK-30052][Connectors/Kafka] Move existing Kafka connector code from Flink repo to dedicated Kafka repo

2022-12-12 Thread GitBox
zentol commented on PR #1: URL: https://github.com/apache/flink-connector-kafka/pull/1#issuecomment-1346298301 hmm, squashed the commits and made some docs changes and now the e2e tests are failing :/ -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-30361) Cluster deleted and created back while updating replicas

2022-12-12 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30361: --- Fix Version/s: (was: kubernetes-operator-1.2.0) (was:

[jira] [Created] (FLINK-30378) Rework sql_download_table shortcode

2022-12-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30378: Summary: Rework sql_download_table shortcode Key: FLINK-30378 URL: https://issues.apache.org/jira/browse/FLINK-30378 Project: Flink Issue Type:

[GitHub] [flink] snuyanzin commented on a diff in pull request #21221: [FLINK-29846] Upgrade ArchUnit to 1.0.0

2022-12-12 Thread GitBox
snuyanzin commented on code in PR #21221: URL: https://github.com/apache/flink/pull/21221#discussion_r1045750909 ## flink-architecture-tests/flink-architecture-tests-production/archunit-violations/b8900323-6aab-4e7e-9b17-f53b3c3dca46: ## @@ -17,11 +17,10 @@ Method has return

[GitHub] [flink] flinkbot commented on pull request #21492: [FLINK-30378][docs] Add v2 sql_connector_download_table shortcode

2022-12-12 Thread GitBox
flinkbot commented on PR #21492: URL: https://github.com/apache/flink/pull/21492#issuecomment-1346391153 ## CI report: * 7f69cef11ff42cd53e758e2bf428e2942bacbcf9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Closed] (FLINK-30209) Introduce CompactFileStoreSource for compact jobs of Table Store

2022-12-12 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30209. --- Resolution: Fixed master: 20dd568f3c2a9b2afd4cb5eb512cd24976602e27 > Introduce

[jira] [Updated] (FLINK-20092) [Java 11] Multi-thread Flink compilation not working

2022-12-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-20092: - Issue Type: Improvement (was: Bug) > [Java 11] Multi-thread Flink compilation not

[jira] [Updated] (FLINK-20092) [Java 11] Multi-thread Flink compilation not working

2022-12-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-20092: - Issue Type: Technical Debt (was: Improvement) > [Java 11] Multi-thread Flink

[jira] [Updated] (FLINK-30380) Look into enabl parallel compilation

2022-12-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30380: - Summary: Look into enabl parallel compilation (was: Look into enable parallel

[jira] [Updated] (FLINK-30380) Look into enabling parallel compilation on CI

2022-12-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30380: - Summary: Look into enabling parallel compilation on CI (was: Look into enabl parallel

[GitHub] [flink-connector-hbase] zentol commented on pull request #4: [FLINK-30062][Connectors/HBase] ADDENDUM: Bundle the exact same dependencies as it was in core

2022-12-12 Thread GitBox
zentol commented on PR #4: URL: https://github.com/apache/flink-connector-hbase/pull/4#issuecomment-1346436879 > I compared the JAR files and all of them has the exact same content now, except the meta inf. Apparently you missed

[GitHub] [flink-statefun] tbal999 opened a new pull request, #323: Feature/tb

2022-12-12 Thread GitBox
tbal999 opened a new pull request, #323: URL: https://github.com/apache/flink-statefun/pull/323 this fixes the error: ``` [ERROR] Failed to execute goal org.apache.maven.plugins:maven-shade-plugin:3.0.0:shade (default) on project statefun-smoke-e2e-embedded: Error creating shaded

[jira] [Closed] (FLINK-30372) dependencyManagement bom for flink-dist

2022-12-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-30372. Resolution: Duplicate This is essentially a duplicate of FLINK-29866 which tries to

[GitHub] [flink-kubernetes-operator] swathic95 commented on pull request #481: [FLINK-30361] Cluster deleted and created back while updating replicas

2022-12-12 Thread GitBox
swathic95 commented on PR #481: URL: https://github.com/apache/flink-kubernetes-operator/pull/481#issuecomment-1346634367 Hi @gyfora , @morhidi , can you please review this PR -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Closed] (FLINK-30146) Evaluate operator error log whitelist entry: Exception while listing jobs

2022-12-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-30146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-30146. -- Resolution: Fixed > Evaluate operator error log whitelist entry: Exception while listing jobs

[jira] [Updated] (FLINK-30146) Evaluate operator error log whitelist entry: Exception while listing jobs

2022-12-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-30146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi updated FLINK-30146: --- Fix Version/s: kubernetes-operator-1.4.0 > Evaluate operator error log whitelist entry:

[jira] [Commented] (FLINK-30146) Evaluate operator error log whitelist entry: Exception while listing jobs

2022-12-12 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-30146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646143#comment-17646143 ] Márton Balassi commented on FLINK-30146: 1598352 in main > Evaluate operator error log

[jira] [Created] (FLINK-30376) Introduce a new flink busy join reorder rule which based on greedy algorithm

2022-12-12 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-30376: - Summary: Introduce a new flink busy join reorder rule which based on greedy algorithm Key: FLINK-30376 URL: https://issues.apache.org/jira/browse/FLINK-30376

[jira] [Commented] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

2022-12-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17646050#comment-17646050 ] Xingbo Huang commented on FLINK-29461: -- [~mapohl] I have prepared a PR to make the test more

[GitHub] [flink] astamur commented on a diff in pull request #21407: [FLINK-30224][Connectors/Kinesis] An IT test for slow FlinKinesisConsumer's run() which caused an NPE in close

2022-12-12 Thread GitBox
astamur commented on code in PR #21407: URL: https://github.com/apache/flink/pull/21407#discussion_r1045731622 ## flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisITCase.java: ## @@ -175,6 +184,40 @@ private void

[jira] [Updated] (FLINK-30378) Rework sql_download_table shortcode

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

[GitHub] [flink-table-store] tsreaper merged pull request #429: [FLINK-30209] Introduce StaticCompactorSource and ContinuousCompactorSource for stand-alone compact jobs

2022-12-12 Thread GitBox
tsreaper merged PR #429: URL: https://github.com/apache/flink-table-store/pull/429 -- 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] [Created] (FLINK-30380) Look into enable parallel compilation

2022-12-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30380: Summary: Look into enable parallel compilation Key: FLINK-30380 URL: https://issues.apache.org/jira/browse/FLINK-30380 Project: Flink Issue Type:

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

2022-12-12 Thread GitBox
LadyForest commented on code in PR #20652: URL: https://github.com/apache/flink/pull/20652#discussion_r1045810306 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/AlterTableSchemaUtil.java: ## @@ -0,0 +1,525 @@ +/* + * Licensed to the

[jira] [Updated] (FLINK-30146) Evaluate operator error log whitelist entry: Exception while listing jobs

2022-12-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30146: --- Labels: pull-request-available (was: ) > Evaluate operator error log whitelist entry:

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #482: [FLINK-30146] Log job listing exception as warning

2022-12-12 Thread GitBox
gaborgsomogyi commented on PR #482: URL: https://github.com/apache/flink-kubernetes-operator/pull/482#issuecomment-1346588408 Please see the e2e test run w/ turned on error log check [here](https://github.com/gaborgsomogyi/flink-kubernetes-operator/pull/1). -- This is an automated

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on pull request #482: [FLINK-30146] Log job listing exception as warning

2022-12-12 Thread GitBox
gaborgsomogyi commented on PR #482: URL: https://github.com/apache/flink-kubernetes-operator/pull/482#issuecomment-1346588770 cc @mbalassi -- 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

[jira] [Assigned] (FLINK-30382) Flink 1.16 to integrate KDS/KDF docs from flink-connector-aws

2022-12-12 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-30382: - Assignee: Danny Cranmer > Flink 1.16 to integrate KDS/KDF docs from

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

2022-12-12 Thread GitBox
LadyForest commented on code in PR #20652: URL: https://github.com/apache/flink/pull/20652#discussion_r1045944593 ## flink-connectors/flink-connector-hbase-1.4/src/test/java/org/apache/flink/connector/hbase1/HBaseConnectorITCase.java: ## @@ -152,7 +152,7 @@ public void

[GitHub] [flink] gzm55 commented on pull request #21228: [FLINK-29866][build] Split flink-dist

2022-12-12 Thread GitBox
gzm55 commented on PR #21228: URL: https://github.com/apache/flink/pull/21228#issuecomment-1346681800 1. the logger api (compile scope) and logger impl libs (test scope) should also be put in `flink-dist-pub` module 2. is there a `flink-disk-scala-pub` module? -- This is an automated

[jira] [Updated] (FLINK-30386) Column constraint lacks primary key not enforced check

2022-12-12 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-30386: -- Description: Currently, only table constraint performs the enforced check. Not sure if it is by

[GitHub] [flink-web] dannycranmer closed pull request #592: Add AWS v4.0.0 connectors

2022-12-12 Thread GitBox
dannycranmer closed pull request #592: Add AWS v4.0.0 connectors URL: https://github.com/apache/flink-web/pull/592 -- 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

[jira] [Updated] (FLINK-30361) Cluster deleted and created back while updating replicas

2022-12-12 Thread SwathiChandrashekar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] SwathiChandrashekar updated FLINK-30361: Fix Version/s: kubernetes-operator-1.3.0

[GitHub] [flink] Myasuka commented on a diff in pull request #21410: [FLINK-29776][flink-statebackend-changelog][JUnit5 Migration]Module: flink-statebackend-changelog.

2022-12-12 Thread GitBox
Myasuka commented on code in PR #21410: URL: https://github.com/apache/flink/pull/21410#discussion_r1045708784 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/FileStateBackendMigrationTest.java: ## @@ -18,18 +18,24 @@ package org.apache.flink.runtime.state;

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

2022-12-12 Thread GitBox
fsk119 commented on code in PR #20652: URL: https://github.com/apache/flink/pull/20652#discussion_r1040583566 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/AlterTableSchemaUtil.java: ## @@ -0,0 +1,783 @@ +/* + * Licensed to the

[jira] [Closed] (FLINK-30366) Python Group Agg failed in cleaning the idle state

2022-12-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-30366. Resolution: Fixed Merged into master via 72a70313b59352736514b4927a1dfadc2e8e4232 Merged into

[GitHub] [flink] zentol commented on a diff in pull request #21492: [FLINK-30378][docs] Add v2 sql_connector_download_table shortcode

2022-12-12 Thread GitBox
zentol commented on code in PR #21492: URL: https://github.com/apache/flink/pull/21492#discussion_r1045758661 ## docs/layouts/shortcodes/sql_connector_download_table_v2.html: ## @@ -0,0 +1,65 @@ +{{/* + Licensed to the Apache Software Foundation (ASF) under one + or more

[GitHub] [flink-connector-elasticsearch] reta commented on pull request #49: [FLINK-30352] [connectors/elasticsearch] Document missing configuration properties

2022-12-12 Thread GitBox
reta commented on PR #49: URL: https://github.com/apache/flink-connector-elasticsearch/pull/49#issuecomment-1346427838 > Please also update the chinese version of the docs under content.zh. @zentol what is the process here? I can only do English, someone will translate? -- This

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

2022-12-12 Thread GitBox
LadyForest commented on code in PR #20652: URL: https://github.com/apache/flink/pull/20652#discussion_r1045789810 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/AlterTableSchemaUtil.java: ## @@ -0,0 +1,525 @@ +/* + * Licensed to the

  1   2   3   4   >