[jira] [Commented] (FLINK-21383) Docker image does not play well together with ConfigMap based flink-conf.yamls

[ https://issues.apache.org/jira/browse/FLINK-21383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297920#comment-17297920 ] Peng Zhang commented on FLINK-21383: It would be nice to address this issue. For us,

[GitHub] [flink] wuchong commented on a change in pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

wuchong commented on a change in pull request #15060: URL: https://github.com/apache/flink/pull/15060#discussion_r590038307 ## File path: docs/content/docs/connectors/table/hive/hive_read_write.md ## @@ -409,6 +409,28 @@ This configuration is set in the `TableConfig` and will

[jira] [Updated] (FLINK-21685) Flink JobManager failed to restart from checkpoint in kubernetes HA setup

[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng Zhang updated FLINK-21685: --- Summary: Flink JobManager failed to restart from checkpoint in kubernetes HA setup (was: Flink JobM

[jira] [Assigned] (FLINK-21416) FileBufferReaderITCase.testSequentialReading fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reassigned FLINK-21416: - Assignee: Guo Weijie > FileBufferReaderITCase.testSequentialReading fails on azure > --

[GitHub] [flink] lirui-apache commented on a change in pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

lirui-apache commented on a change in pull request #15060: URL: https://github.com/apache/flink/pull/15060#discussion_r590032900 ## File path: docs/content/docs/connectors/table/hive/hive_read_write.md ## @@ -409,6 +409,28 @@ This configuration is set in the `TableConfig` and w

[GitHub] [flink] flinkbot commented on pull request #15122: [FLINK-21684] Fix typo in StreamExecDeduplicate

flinkbot commented on pull request #15122: URL: https://github.com/apache/flink/pull/15122#issuecomment-793493161 ## CI report: * cf29f99f0debf8163921fbd379c82024de029655 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 55d3e458ed5e8a1bc78d6c4c6bc64dd55d4ac94f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15120: [FLINK-21679][table] Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

flinkbot edited a comment on pull request #15120: URL: https://github.com/apache/flink/pull/15120#issuecomment-793379581 ## CI report: * aba4ee6ebb01d9c326c575d0c9e64b8d2e74c019 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21382) Standalone K8s documentation does not explain usage of standby JobManagers

[ https://issues.apache.org/jira/browse/FLINK-21382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297904#comment-17297904 ] Peng Zhang commented on FLINK-21382: I also met the same problem: * tried to have 2

[GitHub] [flink] flinkbot edited a comment on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

flinkbot edited a comment on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-766281483 ## CI report: * 2e05b89cd87ce4ba54de32eff3c68985f766180f UNKNOWN * 97864e82641279ac227eda19b938ebce62262867 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Comment Edited] (FLINK-21684) Fix typo in StreamExecDeduplicate

[ https://issues.apache.org/jira/browse/FLINK-21684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297885#comment-17297885 ] wangpeibin edited comment on FLINK-21684 at 3/9/21, 7:39 AM: -

[jira] [Commented] (FLINK-17441) FlinkKinesisConsumerTest.testPeriodicWatermark: watermark count expected:<2> but was:<1>

[ https://issues.apache.org/jira/browse/FLINK-17441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297900#comment-17297900 ] Dawid Wysakowicz commented on FLINK-17441: -- [~danny.cranmer] Hey Danny, do you

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297898#comment-17297898 ] Dawid Wysakowicz commented on FLINK-19863: -- https://dev.azure.com/apache-flink/

[GitHub] [flink] wuchong commented on a change in pull request #15120: [FLINK-21679][table] Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceS

wuchong commented on a change in pull request #15120: URL: https://github.com/apache/flink/pull/15120#discussion_r590020610 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestFileFactory.java ## @@ -198,7 +196,9 @@ pu

[jira] [Commented] (FLINK-21472) FencingTokenException: Fencing token mismatch

[ https://issues.apache.org/jira/browse/FLINK-21472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297893#comment-17297893 ] Peng Zhang commented on FLINK-21472: [~fly_in_gis] The JobManager cannot recover fro

[GitHub] [flink] LinyuYao1021 commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

LinyuYao1021 commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-793481182 > My commit needs to be included into the PR so that it ends up in master. > If this environment variable is not available (for example here during CI verification, or wi

[GitHub] [flink] WeiZhong94 commented on pull request #15120: [FLINK-21679][table] Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

WeiZhong94 commented on pull request #15120: URL: https://github.com/apache/flink/pull/15120#issuecomment-793480447 @wuchong Thanks for your comment. I have updated this PR. This is an automated message from the Apache Git Se

[GitHub] [flink] flinkbot commented on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot commented on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 55d3e458ed5e8a1bc78d6c4c6bc64dd55d4ac94f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-21685) Flink JobManager failed to restart from checkpoint in K8S HA setup

[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng Zhang updated FLINK-21685: --- Attachment: 08-taskmanager-deployment.yaml > Flink JobManager failed to restart from checkpoint in K

[jira] [Updated] (FLINK-21685) Flink JobManager failed to restart from checkpoint in K8S HA setup

[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng Zhang updated FLINK-21685: --- Attachment: 06-jobmanager-deployment.yaml > Flink JobManager failed to restart from checkpoint in K8

[jira] [Updated] (FLINK-21685) Flink JobManager failed to restart from checkpoint in K8S HA setup

[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng Zhang updated FLINK-21685: --- Attachment: 03-config.yaml > Flink JobManager failed to restart from checkpoint in K8S HA setup > --

[GitHub] [flink] flinkbot edited a comment on pull request #15116: [FLINK-21656][hive] Add antlr parser for hive dialect

flinkbot edited a comment on pull request #15116: URL: https://github.com/apache/flink/pull/15116#issuecomment-792717669 ## CI report: * ac975834643c564ae10f738be8cd0be7f9659d59 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-21685) Flink JobManager failed to restart in K8S HA setup

Peng Zhang created FLINK-21685: -- Summary: Flink JobManager failed to restart in K8S HA setup Key: FLINK-21685 URL: https://issues.apache.org/jira/browse/FLINK-21685 Project: Flink Issue Type: Bu

[jira] [Updated] (FLINK-21685) Flink JobManager failed to restart from checkpoint in K8S HA setup

[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng Zhang updated FLINK-21685: --- Summary: Flink JobManager failed to restart from checkpoint in K8S HA setup (was: Flink JobManager

[jira] [Updated] (FLINK-21685) Flink JobManager failed to restart from checkpoint in K8S HA setup

[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng Zhang updated FLINK-21685: --- Attachment: flink-ha.log > Flink JobManager failed to restart from checkpoint in K8S HA setup >

[GitHub] [flink] flinkbot commented on pull request #15122: [FLINK-21684] Fix typo in StreamExecDeduplicate

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

[GitHub] [flink] flinkbot commented on pull request #15121: The method $(String) is undefined for the type TableExample

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

[jira] [Commented] (FLINK-21684) Fix typo in StreamExecDeduplicate

[ https://issues.apache.org/jira/browse/FLINK-21684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297885#comment-17297885 ] wangpeibin commented on FLINK-21684: I have create this pr [https://github.com/apach

[GitHub] [flink] shouweikun commented on a change in pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

shouweikun commented on a change in pull request #15060: URL: https://github.com/apache/flink/pull/15060#discussion_r590010182 ## File path: docs/content/docs/connectors/table/hive/hive_read_write.md ## @@ -409,6 +409,28 @@ This configuration is set in the `TableConfig` and wil

[jira] [Commented] (FLINK-19670) Create view error

[ https://issues.apache.org/jira/browse/FLINK-19670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297880#comment-17297880 ] jibiyr commented on FLINK-19670: absolutely   > Create view error > - >

[jira] [Updated] (FLINK-21684) Fix typo in StreamExecDeduplicate

[ https://issues.apache.org/jira/browse/FLINK-21684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21684: --- Labels: pull-request-available (was: ) > Fix typo in StreamExecDeduplicate > --

[GitHub] [flink] wangpeibin713 opened a new pull request #15122: [FLINK-21684] Fix typo in StreamExecDeduplicate

wangpeibin713 opened a new pull request #15122: URL: https://github.com/apache/flink/pull/15122 ## What is the purpose of the change Fix a typo in the comment for RowtimeDeduplicateOperatorTranslator in StreamExecDeduplicate.java: "process time " => "row time"

[jira] [Commented] (FLINK-19670) Create view error

[ https://issues.apache.org/jira/browse/FLINK-19670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297877#comment-17297877 ] Jark Wu commented on FLINK-19670: - I think you may right [~yr]. If this is the case, the

[jira] [Closed] (FLINK-21641) Support 'useModules' and 'listFullModules' in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-21641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-21641. --- Resolution: Fixed Merged to master via 77f7db7f1c0e6f4249b78abc7c96c6a66752c9b4 > Support 'useModules' and

[GitHub] [flink] wuchong commented on pull request #15089: [FLINK-21614][sql-client] Introduce a new integration test framework for SQL Client

wuchong commented on pull request #15089: URL: https://github.com/apache/flink/pull/15089#issuecomment-793471321 Build is passed in my private Azure: https://dev.azure.com/imjark/Flink/_build/results?buildId=428&view=results

[GitHub] [flink] dianfu merged pull request #15101: [FLINK-21641][python] Support 'useModules' and 'listFullModules' in PyFlink

dianfu merged pull request #15101: URL: https://github.com/apache/flink/pull/15101 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 t

[jira] [Commented] (FLINK-19670) Create view error

[ https://issues.apache.org/jira/browse/FLINK-19670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297868#comment-17297868 ] jibiyr commented on FLINK-19670: [~jark] hi wu,I test and reproduce the problem.I debug

[GitHub] [flink] 65725738 opened a new pull request #15121: The method $(String) is undefined for the type TableExample

65725738 opened a new pull request #15121: URL: https://github.com/apache/flink/pull/15121  why? This is an autom

[GitHub] [flink] lirui-apache commented on a change in pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

lirui-apache commented on a change in pull request #15060: URL: https://github.com/apache/flink/pull/15060#discussion_r589991960 ## File path: docs/content/docs/connectors/table/hive/hive_read_write.md ## @@ -409,6 +409,28 @@ This configuration is set in the `TableConfig` and w

[GitHub] [flink] lirui-apache commented on a change in pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

lirui-apache commented on a change in pull request #15060: URL: https://github.com/apache/flink/pull/15060#discussion_r589991960 ## File path: docs/content/docs/connectors/table/hive/hive_read_write.md ## @@ -409,6 +409,28 @@ This configuration is set in the `TableConfig` and w

[GitHub] [flink] flinkbot edited a comment on pull request #15120: [FLINK-21679][table] Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

flinkbot edited a comment on pull request #15120: URL: https://github.com/apache/flink/pull/15120#issuecomment-793379581 ## CI report: * aba4ee6ebb01d9c326c575d0c9e64b8d2e74c019 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15116: [FLINK-21656][hive] Add antlr parser for hive dialect

flinkbot edited a comment on pull request #15116: URL: https://github.com/apache/flink/pull/15116#issuecomment-792717669 ## CI report: * ac975834643c564ae10f738be8cd0be7f9659d59 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wuchong commented on a change in pull request #15120: [FLINK-21679][table] Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceS

wuchong commented on a change in pull request #15120: URL: https://github.com/apache/flink/pull/15120#discussion_r589983139 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ##

[GitHub] [flink] rmetzger commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

rmetzger commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-793459808 My commit needs to be included into the PR so that it ends up in master. If this environment variable is not available (for example here during CI verification, or with perso

[GitHub] [flink] flinkbot edited a comment on pull request #15120: [FLINK-21679][table] Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

flinkbot edited a comment on pull request #15120: URL: https://github.com/apache/flink/pull/15120#issuecomment-793379581 ## CI report: * aba4ee6ebb01d9c326c575d0c9e64b8d2e74c019 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-21684) Fix typo in StreamExecDeduplicate

wangpeibin created FLINK-21684: -- Summary: Fix typo in StreamExecDeduplicate Key: FLINK-21684 URL: https://issues.apache.org/jira/browse/FLINK-21684 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-21661) SHARD_GETRECORDS_INTERVAL_MILLIS wrong use?

[ https://issues.apache.org/jira/browse/FLINK-21661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiamo updated FLINK-21661: -- Priority: Critical (was: Major) > SHARD_GETRECORDS_INTERVAL_MILLIS wrong use? >

[jira] [Updated] (FLINK-21668) Fix typo in org.apache.flink.sql.parser.ddl.SqlCreateDatabase

[ https://issues.apache.org/jira/browse/FLINK-21668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21668: Summary: Fix typo in org.apache.flink.sql.parser.ddl.SqlCreateDatabase (was: A writing error in org.apach

[jira] [Closed] (FLINK-21668) A writing error in org.apache.flink.sql.parser.ddl.SqlCreateDatabase

[ https://issues.apache.org/jira/browse/FLINK-21668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21668. --- Fix Version/s: 1.13.0 Assignee: humengyu Resolution: Fixed Fixed in master: c4e058a042695bdc

[jira] [Commented] (FLINK-21661) SHARD_GETRECORDS_INTERVAL_MILLIS wrong use?

[ https://issues.apache.org/jira/browse/FLINK-21661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297854#comment-17297854 ] jiamo commented on FLINK-21661: --- In [https://ci.apache.org/projects/flink/flink-docs-stab

[GitHub] [flink] wuchong merged pull request #15114: [FLINK-21668][table] Change tableName to databaseName

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

[GitHub] [flink] wuchong commented on pull request #15114: [FLINK-21668][table] Change tableName to databaseName

wuchong commented on pull request #15114: URL: https://github.com/apache/flink/pull/15114#issuecomment-793454780 The failed test case is not related to this PR. Merging... This is an automated message from the Apache

[jira] [Commented] (FLINK-21667) Standby RM might remove resources from Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-21667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297851#comment-17297851 ] Xintong Song commented on FLINK-21667: -- I haven't check this in detail yet. But yes

[jira] [Closed] (FLINK-21682) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader

[ https://issues.apache.org/jira/browse/FLINK-21682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21682. --- Resolution: Duplicate > java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl > cannot

[jira] [Closed] (FLINK-21681) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader

[ https://issues.apache.org/jira/browse/FLINK-21681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21681. --- Resolution: Duplicate > java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl > cannot

[GitHub] [flink] flinkbot edited a comment on pull request #15101: [FLINK-21641][python] Support 'useModules' and 'listFullModules' in PyFlink

flinkbot edited a comment on pull request #15101: URL: https://github.com/apache/flink/pull/15101#issuecomment-791983297 ## CI report: * b31ad0cdf5f110594628b97376ef40220bd9af17 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-20387) Support column of TIMESTAMP WITH LOCAL ZONE TIME type as rowtime attribute

[ https://issues.apache.org/jira/browse/FLINK-20387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-20387: -- Assignee: Leonard Xu > Support column of TIMESTAMP WITH LOCAL ZONE TIME type as rowtime attri

[jira] [Assigned] (FLINK-21624) Correct FLOOR/CEIL (TIMESTAMP/TIMESTAMP_LTZ/DATE TO WEEK) functions

[ https://issues.apache.org/jira/browse/FLINK-21624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21624: -- Assignee: Leonard Xu > Correct FLOOR/CEIL (TIMESTAMP/TIMESTAMP_LTZ/DATE TO WEEK) functions >

[jira] [Assigned] (FLINK-21623) Introduce CURRENT_ROW_TIMESTAMP function

[ https://issues.apache.org/jira/browse/FLINK-21623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21623: -- Assignee: Leonard Xu > Introduce CURRENT_ROW_TIMESTAMP function > ---

[jira] [Assigned] (FLINK-21621) Support TIMESTAMP_LTZ arithmetic

[ https://issues.apache.org/jira/browse/FLINK-21621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21621: -- Assignee: Leonard Xu > Support TIMESTAMP_LTZ arithmetic > >

[jira] [Assigned] (FLINK-21622) Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

[ https://issues.apache.org/jira/browse/FLINK-21622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21622: -- Assignee: Leonard Xu > Introduce function TO_TIMESTAMP_LTZ(numeric [, precision]) >

[jira] [Assigned] (FLINK-21620) Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE

[ https://issues.apache.org/jira/browse/FLINK-21620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21620: -- Assignee: Leonard Xu > Support abbreviation TIMESTAMP_LTZ FOR TIMESTAMP WITH LOCAL TIME ZONE

[jira] [Closed] (FLINK-21683) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader

[ https://issues.apache.org/jira/browse/FLINK-21683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ying zhang closed FLINK-21683. -- Resolution: Not A Problem > java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl

[jira] [Created] (FLINK-21683) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader

ying zhang created FLINK-21683: -- Summary: java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader Key: FLINK-21683 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-21682) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader

ying zhang created FLINK-21682: -- Summary: java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader Key: FLINK-21682 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-21681) java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader

ying zhang created FLINK-21681: -- Summary: java.lang.ClassCastException: org.apache.hadoop.hive.ql.io.orc.ReaderImpl cannot be cast to org.apache.orc.Reader Key: FLINK-21681 URL: https://issues.apache.org/jira/browse

[jira] [Closed] (FLINK-21680) Table Created with LIKE clause may get unexpected options "is_generic"

[ https://issues.apache.org/jira/browse/FLINK-21680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21680. --- Resolution: Duplicate > Table Created with LIKE clause may get unexpected options "is_generic" > ---

[jira] [Updated] (FLINK-21660) CREATE TABLE LIKE doesn't work with Hive tables

[ https://issues.apache.org/jira/browse/FLINK-21660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21660: Summary: CREATE TABLE LIKE doesn't work with Hive tables (was: create table can not like with hive catalo

[jira] [Updated] (FLINK-21524) Improve the stability of scheduler benchmarks

[ https://issues.apache.org/jira/browse/FLINK-21524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-21524: Labels: (was: pull-request-available) > Improve the stability of scheduler benchmarks >

[jira] [Closed] (FLINK-21524) Improve the stability of scheduler benchmarks

[ https://issues.apache.org/jira/browse/FLINK-21524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-21524. --- Resolution: Fixed > Improve the stability of scheduler benchmarks >

[jira] [Comment Edited] (FLINK-21526) Replace scheduler benchmarks with wrapper classes

[ https://issues.apache.org/jira/browse/FLINK-21526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297839#comment-17297839 ] Zhu Zhu edited comment on FLINK-21526 at 3/9/21, 5:46 AM: -- done

[jira] [Closed] (FLINK-21526) Replace scheduler benchmarks with wrapper classes

[ https://issues.apache.org/jira/browse/FLINK-21526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-21526. --- Resolution: Fixed > Replace scheduler benchmarks with wrapper classes >

[jira] [Reopened] (FLINK-21526) Replace scheduler benchmarks with wrapper classes

[ https://issues.apache.org/jira/browse/FLINK-21526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reopened FLINK-21526: - > Replace scheduler benchmarks with wrapper classes > - > >

[jira] [Closed] (FLINK-21526) Replace scheduler benchmarks with wrapper classes

[ https://issues.apache.org/jira/browse/FLINK-21526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-21526. --- Resolution: Fixed done via mainThreadExecutor.getMainThreadExecutor() > Replace scheduler benchmarks with w

[GitHub] [flink-benchmarks] zhuzhurk merged pull request #8: [FLINK-21526][runtime] Replace scheduler benchmarks with wrapper classes

zhuzhurk merged pull request #8: URL: https://github.com/apache/flink-benchmarks/pull/8 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

[jira] [Resolved] (FLINK-21289) Application mode ignores the pipeline.classpaths configuration

[ https://issues.apache.org/jira/browse/FLINK-21289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhou Parker resolved FLINK-21289. - Resolution: Fixed > Application mode ignores the pipeline.classpaths configuration > ---

[jira] [Created] (FLINK-21680) Table Created with LIKE clause may get unexpected options "is_generic"

Xiaodong Chen created FLINK-21680: - Summary: Table Created with LIKE clause may get unexpected options "is_generic" Key: FLINK-21680 URL: https://issues.apache.org/jira/browse/FLINK-21680 Project: Fli

[GitHub] [flink] flinkbot edited a comment on pull request #15120: [FLINK-21679][table] Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

flinkbot edited a comment on pull request #15120: URL: https://github.com/apache/flink/pull/15120#issuecomment-793379581 ## CI report: * aba4ee6ebb01d9c326c575d0c9e64b8d2e74c019 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #15120: [FLINK-21679][table] Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

flinkbot commented on pull request #15120: URL: https://github.com/apache/flink/pull/15120#issuecomment-793379581 ## CI report: * aba4ee6ebb01d9c326c575d0c9e64b8d2e74c019 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

flinkbot edited a comment on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-788795982 ## CI report: * f5e5565cd42d6600a421961e5a2cec3b560ea250 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-21617) FLIP-162: Consistent Flink SQL time function behavior

[ https://issues.apache.org/jira/browse/FLINK-21617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21617: -- Assignee: Leonard Xu > FLIP-162: Consistent Flink SQL time function behavior > --

[GitHub] [flink] flinkbot edited a comment on pull request #15060: [FLINK-19944][Connectors / Hive]Support sink parallelism configuratio…

flinkbot edited a comment on pull request #15060: URL: https://github.com/apache/flink/pull/15060#issuecomment-788795982 ## CI report: * f5e5565cd42d6600a421961e5a2cec3b560ea250 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15019: [FLINK-21400] Store attempt numbers outside ExecutionGraph

flinkbot edited a comment on pull request #15019: URL: https://github.com/apache/flink/pull/15019#issuecomment-785740829 ## CI report: * efdf97be6b04d0bd96fa39684872bddd5dbeaf18 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20387) Support column of TIMESTAMP WITH LOCAL ZONE TIME type as rowtime attribute

[ https://issues.apache.org/jira/browse/FLINK-20387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20387: --- Parent: FLINK-21617 Issue Type: Sub-task (was: New Feature) > Support column of TIMESTAMP W

[GitHub] [flink] flinkbot commented on pull request #15120: [FLINK-21679][table] Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

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

[jira] [Updated] (FLINK-21679) Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

[ https://issues.apache.org/jira/browse/FLINK-21679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21679: --- Labels: pull-request-available (was: ) > Set output type for transformations from SourcePro

[GitHub] [flink] WeiZhong94 opened a new pull request #15120: [FLINK-21679][table] Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

WeiZhong94 opened a new pull request #15120: URL: https://github.com/apache/flink/pull/15120 ## What is the purpose of the change *This pull request set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan.* ## Verifying t

[jira] [Created] (FLINK-21679) Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

Wei Zhong created FLINK-21679: - Summary: Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan Key: FLINK-21679 URL: https://issues.apache.org/jira/browse/FLIN

[GitHub] [flink-statefun] tzulitai opened a new pull request #209: [Java SDK] Miscellaneous Java SDK improvements

tzulitai opened a new pull request #209: URL: https://github.com/apache/flink-statefun/pull/209 This PR contains several minor improvements to the new Java SDK. Please see the respective JIRA descriptions for motivations of each change. cc @igalshilman --

[GitHub] [flink] zhuzhurk commented on a change in pull request #15088: [FLINK-21328] Optimize the initialization of DefaultExecutionTopology

zhuzhurk commented on a change in pull request #15088: URL: https://github.com/apache/flink/pull/15088#discussion_r589913446 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -130,7 +131,8 @@ public EdgeMan

[GitHub] [flink] flinkbot edited a comment on pull request #15101: [FLINK-21641][python] Support 'useModules' and 'listFullModules' in PyFlink

flinkbot edited a comment on pull request #15101: URL: https://github.com/apache/flink/pull/15101#issuecomment-791983297 ## CI report: * ea6df37a831ec171cf0c235be2e49cd6d263597f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Thesharing commented on a change in pull request #15088: [FLINK-21328] Optimize the initialization of DefaultExecutionTopology

Thesharing commented on a change in pull request #15088: URL: https://github.com/apache/flink/pull/15088#discussion_r589909597 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -130,7 +131,8 @@ public EdgeM

[GitHub] [flink] leonardBang commented on a change in pull request #14684: [FLINK-20460][Connector-HBase] Support async lookup for HBase connector

leonardBang commented on a change in pull request #14684: URL: https://github.com/apache/flink/pull/14684#discussion_r589909417 ## File path: flink-connectors/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunctionTest.java

[jira] [Created] (FLINK-21678) Rename Expiration.expiresAfterReadOrWrite to Expiration.expiresAfterCall in StateFun

Tzu-Li (Gordon) Tai created FLINK-21678: --- Summary: Rename Expiration.expiresAfterReadOrWrite to Expiration.expiresAfterCall in StateFun Key: FLINK-21678 URL: https://issues.apache.org/jira/browse/FLINK-21678

[GitHub] [flink] zhuzhurk commented on a change in pull request #15088: [FLINK-21328] Optimize the initialization of DefaultExecutionTopology

zhuzhurk commented on a change in pull request #15088: URL: https://github.com/apache/flink/pull/15088#discussion_r589908162 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adapter/DefaultExecutionTopology.java ## @@ -130,7 +131,8 @@ public EdgeMan

[jira] [Assigned] (FLINK-21027) Add isStateKeyValueSerialized() method to KeyedStateBackend interface

[ https://issues.apache.org/jira/browse/FLINK-21027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-21027: Assignee: Yun Tang > Add isStateKeyValueSerialized() method to KeyedStateBackend interface >

[jira] [Created] (FLINK-21676) Ensure that state names are valid identifiers in the StateFun Java SDK

Tzu-Li (Gordon) Tai created FLINK-21676: --- Summary: Ensure that state names are valid identifiers in the StateFun Java SDK Key: FLINK-21676 URL: https://issues.apache.org/jira/browse/FLINK-21676

[jira] [Created] (FLINK-21677) org.apache.flink.test.state.operator.restore.unkeyed.ChainBreakTest hangs

Guowei Ma created FLINK-21677: - Summary: org.apache.flink.test.state.operator.restore.unkeyed.ChainBreakTest hangs Key: FLINK-21677 URL: https://issues.apache.org/jira/browse/FLINK-21677 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15101: [FLINK-21641][python] Support 'useModules' and 'listFullModules' in PyFlink

flinkbot edited a comment on pull request #15101: URL: https://github.com/apache/flink/pull/15101#issuecomment-791983297 ## CI report: * ea6df37a831ec171cf0c235be2e49cd6d263597f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21644) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failed

[ https://issues.apache.org/jira/browse/FLINK-21644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17297798#comment-17297798 ] Guowei Ma commented on FLINK-21644: --- another case https://dev.azure.com/apache-flink/

  1   2   3   4   >