[jira] [Assigned] (FLINK-22175) some mistakes in common.md

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-22175: -- Assignee: wym_maozi > some mistakes in common.md > --- > >

[jira] [Commented] (FLINK-22115) JobManager dies with IllegalStateException SharedSlot (physical request SlotRequestId{%}) has been released

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319960#comment-17319960 ] Robert Metzger commented on FLINK-22115: Thanks a lot for your bug report and th

[jira] [Updated] (FLINK-21968) Calcite parser doesn't support to parse "-- test"

2021-04-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21968: Component/s: (was: Table SQL / Planner) Table SQL / API > Calcite parser doesn't supp

[jira] [Comment Edited] (FLINK-22141) Manually test exactly-once JDBC sink

2021-04-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319900#comment-17319900 ] Yuan Mei edited comment on FLINK-22141 at 4/13/21, 6:56 AM:

[jira] [Updated] (FLINK-22249) JobMasterStopWithSavepointITCase failed due to status is FAILING

2021-04-12 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22249: -- Fix Version/s: 1.13.0 > JobMasterStopWithSavepointITCase failed due to status is FAILING > ---

[jira] [Updated] (FLINK-21907) Support watermark syntax for Hive DDL dialect

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21907: --- Component/s: Table SQL / Ecosystem > Support watermark syntax for Hive DDL dialect > ---

[jira] [Updated] (FLINK-22013) Add Github Actions to flink-ml for every push and pull request

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22013: --- Component/s: Build System / CI > Add Github Actions to flink-ml for every push and pull requ

[jira] [Updated] (FLINK-22115) JobManager dies with IllegalStateException SharedSlot (physical request SlotRequestId{%}) has been released

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22115: --- Component/s: Runtime / Coordination > JobManager dies with IllegalStateException SharedSlot

[jira] [Updated] (FLINK-21448) Test Changelog State backend (Wrapper)

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21448: --- Component/s: Runtime / State Backends > Test Changelog State backend (Wrapper) > ---

[jira] [Updated] (FLINK-22012) Add nightly-build pipeline to test flink-ml repo with the latest flink repo snapshot

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-22012: --- Component/s: Build System > Add nightly-build pipeline to test flink-ml repo with the latest

[jira] [Updated] (FLINK-21921) Unreasonable ADDED event ignoring in callback handler in KubernetesLeaderRetrievalDriver

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21921: --- Component/s: Deployment / Kubernetes > Unreasonable ADDED event ignoring in callback handler

[jira] [Updated] (FLINK-21520) ParquetInputFormat#setfilterPredicate() does not work

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21520: --- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > ParquetInputFormat#setfilter

[jira] [Updated] (FLINK-21468) ParquetTableSource: where clause on integer does not work

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21468: --- Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > ParquetTableSource: where cl

[jira] [Updated] (FLINK-21968) Calcite parser doesn't support to parse "-- test"

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21968: --- Component/s: Table SQL / Planner > Calcite parser doesn't support to parse "-- test" > -

[jira] [Updated] (FLINK-21863) SortPartition should allow chaining of KeySelectors to support different sorting orders for the fields

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21863: --- Component/s: API / DataSet > SortPartition should allow chaining of KeySelectors to support

[jira] [Updated] (FLINK-21607) Twitter table source connector

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21607: --- Component/s: Table SQL / Ecosystem > Twitter table source connector > --

[jira] [Assigned] (FLINK-22248) JobMasterStopWithSavepointITCase.suspendWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished fail because of TestTimedOutException

2021-04-12 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-22248: Assignee: Dawid Wysakowicz > JobMasterStopWithSavepointITCase.suspendWithSavepoin

[jira] [Created] (FLINK-22252) Backquotes are not rendered correctly in config option descriptions

2021-04-12 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-22252: -- Summary: Backquotes are not rendered correctly in config option descriptions Key: FLINK-22252 URL: https://issues.apache.org/jira/browse/FLINK-22252 Project: Flin

[GitHub] [flink] flinkbot commented on pull request #15585: [FLINK-22065] [sql-client]Beautify the parse error exception

2021-04-12 Thread GitBox
flinkbot commented on pull request #15585: URL: https://github.com/apache/flink/pull/15585#issuecomment-818483533 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 #15584: [FLINK-21743] Document limitation of JdbcXaSinkFunction for MySQL support

2021-04-12 Thread GitBox
flinkbot commented on pull request #15584: URL: https://github.com/apache/flink/pull/15584#issuecomment-818483549 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-22252) Backquotes are not rendered correctly in config option descriptions

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319953#comment-17319953 ] Robert Metzger commented on FLINK-22252: [~sjwiesman] Could you take a look at t

[GitHub] [flink] flinkbot commented on pull request #15583: [FLINK-21012][format-avro] Replace lambda with anonymous class to prevent serialization issue

2021-04-12 Thread GitBox
flinkbot commented on pull request #15583: URL: https://github.com/apache/flink/pull/15583#issuecomment-818483566 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-21012) AvroFileFormatFactory uses non-deserializable lambda function

2021-04-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319948#comment-17319948 ] Jingsong Lee commented on FLINK-21012: -- Thanks [~airblader], I'll take a look~ > A

[jira] [Updated] (FLINK-22247) can not pass AddressList when connecting to rabbitmq

2021-04-12 Thread Spongebob (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Spongebob updated FLINK-22247: -- Environment: flink: 1.12.2 rabbitmq: 3.8.4 was: flink: 2.12.2 rabbitmq: 3.8.4 > can not pass Ad

[jira] [Updated] (FLINK-22065) Beautify the parse error exception when input invalid command in the sql client

2021-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22065: --- Labels: pull-request-available (was: ) > Beautify the parse error exception when input inva

[jira] [Updated] (FLINK-21743) JdbcXaSinkFunction throws XAER_RMFAIL when calling snapshotState and beginTx

2021-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21743: --- Labels: pull-request-available (was: ) > JdbcXaSinkFunction throws XAER_RMFAIL when calling

[GitHub] [flink] curcur commented on pull request #15584: [FLINK-21743] Document limitation of JdbcXaSinkFunction for MySQL support

2021-04-12 Thread GitBox
curcur commented on pull request #15584: URL: https://github.com/apache/flink/pull/15584#issuecomment-818478532 rebult doc with mvn package -Dgenerate-config-docs -pl flink-docs -am -nsu -DskipTests -- This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] chaozwn opened a new pull request #15585: [FLINK-22065] [sql-client]Beautify the parse error exception

2021-04-12 Thread GitBox
chaozwn opened a new pull request #15585: URL: https://github.com/apache/flink/pull/15585 …ommand in the sql client ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way

[GitHub] [flink] curcur opened a new pull request #15584: [FLINK-21743] Document limitation of JdbcXaSinkFunction for MySQL support

2021-04-12 Thread GitBox
curcur opened a new pull request #15584: URL: https://github.com/apache/flink/pull/15584 MySQL supports XA transaction as global trans, and allows one xa trans open per connection. For JDBC exactly once sink, it needs at least two xa trans per connection (snapshot -> prepare trans; and the

[jira] [Commented] (FLINK-22134) Test the reactive mode

2021-04-12 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319944#comment-17319944 ] Robert Metzger commented on FLINK-22134: Thanks for the log. The behavior is as

[GitHub] [flink] wuchong commented on a change in pull request #15578: [FLINK-21431][upsert-kafka] Use testcontainers for UpsertKafkaTableITCase

2021-04-12 Thread GitBox
wuchong commented on a change in pull request #15578: URL: https://github.com/apache/flink/pull/15578#discussion_r612160162 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/UpsertKafkaTableITCase.java ## @@ -5

[jira] [Updated] (FLINK-21012) AvroFileFormatFactory uses non-deserializable lambda function

2021-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21012: --- Labels: pull-request-available (was: ) > AvroFileFormatFactory uses non-deserializable lamb

[GitHub] [flink] Airblader opened a new pull request #15583: [FLINK-21012][format-avro] Replace lambda with anonymous class to prevent serialization issue

2021-04-12 Thread GitBox
Airblader opened a new pull request #15583: URL: https://github.com/apache/flink/pull/15583 ## What is the purpose of the change This replaces a lambda implementation with an explicit anonymous class as otherwise serialization issues can occur. See also FLINK-20147 or FLINK-18006 fo

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319931#comment-17319931 ] Guowei Ma commented on FLINK-18634: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-22251) PrometheusReporterEndToEndITCase.testReporter fail because Dispatcher REST endpoint did not start in time.

2021-04-12 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22251: - Summary: PrometheusReporterEndToEndITCase.testReporter fail because Dispatcher REST endpoint did not start in time. Key: FLINK-22251 URL: https://issues.apache.org/jira/browse/FLINK-222

[GitHub] [flink] flinkbot edited a comment on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-817625124 ## CI report: * cd5ab564ce3aa46edd059bf1113f5053debc7418 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15548: [FLINK-22082][planner] Nested projection push down doesn't work for d…

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15548: URL: https://github.com/apache/flink/pull/15548#issuecomment-816538966 ## CI report: * 64160f09da52e0b873d1fbf1482bb7b6d7c7499e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-22239) Improve support for JdbcXaSinkFunction

2021-04-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319920#comment-17319920 ] Yuan Mei commented on FLINK-22239: -- Possible solution: Maintain a pool of connections

[GitHub] [flink] KurtYoung commented on a change in pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

2021-04-12 Thread GitBox
KurtYoung commented on a change in pull request #15564: URL: https://github.com/apache/flink/pull/15564#discussion_r612150467 ## File path: flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/catalog/hive/HiveCatalogTest.java ## @@ -78,4 +80,17 @@ public

[jira] [Closed] (FLINK-21748) LocalExecutorITCase.testBatchQueryExecutionMultipleTimes[Planner: old] fails

2021-04-12 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-21748. -- Resolution: Fixed fixed: b78ce3b9713c7b2792629d509a3951a96829012d > LocalExecutorITCase.testBatchQuer

[GitHub] [flink] KurtYoung merged pull request #15563: [FLINK-21748][sql-client] Fix unstable LocalExecutorITCase.testBatchQ…

2021-04-12 Thread GitBox
KurtYoung merged pull request #15563: URL: https://github.com/apache/flink/pull/15563 -- 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. For queries about this service, plea

[jira] [Reopened] (FLINK-21879) ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime fails on AZP

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reopened FLINK-21879: --- https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=16357&view=logs&j=34f41360-6c0d-5

[jira] [Issue Comment Deleted] (FLINK-21879) ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime fails on AZP

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21879: -- Comment: was deleted (was: another case https://dev.azure.com/apache-flink/apache-flink/_build/results

[jira] [Closed] (FLINK-22166) Empty values with sort willl fail

2021-04-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-22166. Resolution: Fixed master (1.13): 0e82a998afbb1d4be4fbf1a48c2a232ccc53fb9c > Empty values with so

[jira] [Commented] (FLINK-22190) no guarantee on Flink exactly_once sink to Kafka

2021-04-12 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319910#comment-17319910 ] Arvid Heise commented on FLINK-22190: - 1. You get byZeroException because you are di

[GitHub] [flink] JingsongLi merged pull request #15571: [FLINK-22166][table] Empty values with sort willl fail

2021-04-12 Thread GitBox
JingsongLi merged pull request #15571: URL: https://github.com/apache/flink/pull/15571 -- 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. For queries about this service, ple

[jira] [Commented] (FLINK-21879) ActiveResourceManagerTest.testWorkerRegistrationTimeoutNotCountingAllocationTime fails on AZP

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319909#comment-17319909 ] Guowei Ma commented on FLINK-21879: --- another case https://dev.azure.com/apache-flink/a

[GitHub] [flink] chaozwn commented on pull request #15582: [FLINK-22250] flink sql parser module ParserResource.properties lack createSystemFunctionOnlySupportTemporary describe message.

2021-04-12 Thread GitBox
chaozwn commented on pull request #15582: URL: https://github.com/apache/flink/pull/15582#issuecomment-818457368 > What's the problem if we don't add it? There are two descriptions on the original file that have been added to the ParserResource.properties, and the calcite official al

[jira] [Commented] (FLINK-22100) BatchFileSystemITCaseBase.testPartialDynamicPartition fail because of no output for 900 seconds

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319906#comment-17319906 ] Guowei Ma commented on FLINK-22100: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-20747) ClassCastException when using MAX aggregate function

2021-04-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319905#comment-17319905 ] Jingsong Lee commented on FLINK-20747: -- I think this is caused by FLINK-13191, and

[jira] [Closed] (FLINK-20747) ClassCastException when using MAX aggregate function

2021-04-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-20747. Resolution: Duplicate > ClassCastException when using MAX aggregate function > ---

[GitHub] [flink] flinkbot edited a comment on pull request #15582: [FLINK-22250] flink sql parser module ParserResource.properties lack createSystemFunctionOnlySupportTemporary describe message.

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15582: URL: https://github.com/apache/flink/pull/15582#issuecomment-818444729 ## CI report: * a1730e1eca63cb5ae0ef0468a5ff76c9efdb5ccc Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21025) SQLClientHBaseITCase fails when untarring HBase

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319904#comment-17319904 ] Guowei Ma commented on FLINK-21025: --- https://dev.azure.com/apache-flink/apache-flink/_

[GitHub] [flink] flinkbot edited a comment on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-817625124 ## CI report: * cd5ab564ce3aa46edd059bf1113f5053debc7418 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21025) SQLClientHBaseITCase fails when untarring HBase

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21025: -- Affects Version/s: 1.12.2 > SQLClientHBaseITCase fails when untarring HBase >

[GitHub] [flink] leonardBang commented on pull request #15578: [FLINK-21431][upsert-kafka] Use testcontainers for UpsertKafkaTableITCase

2021-04-12 Thread GitBox
leonardBang commented on pull request #15578: URL: https://github.com/apache/flink/pull/15578#issuecomment-818454928 cc @wuchong could you help review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[GitHub] [flink] wuchong commented on pull request #15582: [FLINK-22250] flink sql parser module ParserResource.properties lack createSystemFunctionOnlySupportTemporary describe message.

2021-04-12 Thread GitBox
wuchong commented on pull request #15582: URL: https://github.com/apache/flink/pull/15582#issuecomment-818453831 What's the problem if we don't add it? -- 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

[jira] [Commented] (FLINK-22141) Manually test exactly-once JDBC sink

2021-04-12 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319900#comment-17319900 ] Yuan Mei commented on FLINK-22141: -- TODO List: 1. Document limitation for support mysq

[GitHub] [flink] flinkbot commented on pull request #15582: [FLINK-22250] flink sql parser module ParserResource.properties lack createSystemFunctionOnlySupportTemporary describe message.

2021-04-12 Thread GitBox
flinkbot commented on pull request #15582: URL: https://github.com/apache/flink/pull/15582#issuecomment-818444729 ## CI report: * a1730e1eca63cb5ae0ef0468a5ff76c9efdb5ccc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15582: [FLINK-22250] flink sql parser module ParserResource.properties lack createSystemFunctionOnlySupportTemporary describe message.

2021-04-12 Thread GitBox
flinkbot commented on pull request #15582: URL: https://github.com/apache/flink/pull/15582#issuecomment-818439853 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-22250) flink-sql-parser model Class ParserResource lack ParserResource.properties

2021-04-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22250: --- Labels: pull-request-available (was: ) > flink-sql-parser model Class ParserResource lack P

[GitHub] [flink] chaozwn opened a new pull request #15582: [FLINK-22250] flink sql parser module ParserResource.properties lack createSystemFunctionOnlySupportTemporary describe message.

2021-04-12 Thread GitBox
chaozwn opened a new pull request #15582: URL: https://github.com/apache/flink/pull/15582 …createSystemFunctionOnlySupportTemporary describe message. ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server,

[GitHub] [flink] flinkbot edited a comment on pull request #15581: [Hotfix][python] Fix variable typo.

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15581: URL: https://github.com/apache/flink/pull/15581#issuecomment-818431544 ## CI report: * 7e80f21e80bb9d5663d31cb19cd2811cb19037ec Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-817625124 ## CI report: * ad833779d272f0f35cb82b26f559131e2192cfee Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-22250) flink-sql-parser model Class ParserResource lack ParserResource.properties

2021-04-12 Thread WeiNan Zhao (Jira)
WeiNan Zhao created FLINK-22250: --- Summary: flink-sql-parser model Class ParserResource lack ParserResource.properties Key: FLINK-22250 URL: https://issues.apache.org/jira/browse/FLINK-22250 Project: Fli

[GitHub] [flink] leonardBang commented on a change in pull request #15495: [FLINK-21305][table-planner-blink] Fix Cumulative and Hopping window should accumulate late events belonging to the cleaned s

2021-04-12 Thread GitBox
leonardBang commented on a change in pull request #15495: URL: https://github.com/apache/flink/pull/15495#discussion_r612122508 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/processors/SliceSharedWindowAggPr

[GitHub] [flink] godfreyhe commented on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-12 Thread GitBox
godfreyhe commented on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-818431839 @YuvalItzchakov , you can create a new pr to cherry pick this pr to 1.12 once this one is merged. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot commented on pull request #15581: [Hotfix][python] Fix variable typo.

2021-04-12 Thread GitBox
flinkbot commented on pull request #15581: URL: https://github.com/apache/flink/pull/15581#issuecomment-818431544 ## CI report: * 7e80f21e80bb9d5663d31cb19cd2811cb19037ec UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-817625124 ## CI report: * ad833779d272f0f35cb82b26f559131e2192cfee Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-22249) JobMasterStopWithSavepointITCase failed due to status is FAILING

2021-04-12 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22249: - Summary: JobMasterStopWithSavepointITCase failed due to status is FAILING Key: FLINK-22249 URL: https://issues.apache.org/jira/browse/FLINK-22249 Project: Flink I

[jira] [Commented] (FLINK-22100) BatchFileSystemITCaseBase.testPartialDynamicPartition fail because of no output for 900 seconds

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319884#comment-17319884 ] Guowei Ma commented on FLINK-22100: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22248) JobMasterStopWithSavepointITCase.suspendWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished fail because of TestTimedOutException

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319883#comment-17319883 ] Guowei Ma commented on FLINK-22248: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22100) BatchFileSystemITCaseBase.testPartialDynamicPartition fail because of no output for 900 seconds

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319881#comment-17319881 ] Guowei Ma commented on FLINK-22100: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-22248) JobMasterStopWithSavepointITCase.suspendWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished fail because of TestTimedOutException

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319880#comment-17319880 ] Guowei Ma commented on FLINK-22248: --- https://dev.azure.com/apache-flink/apache-flink/_

[GitHub] [flink] YuvalItzchakov commented on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-12 Thread GitBox
YuvalItzchakov commented on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-818426492 @godfreyhe It maybe better for me as well as my source is currently built on top of 1.12 and still not entirely sure what changes go into 1.13. -- This is an automated

[jira] [Assigned] (FLINK-22245) Reuse PrintUtils.MAX_COLUMN_WIDTH in CliChangelogResultView and CliTableResultView

2021-04-12 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22245: --- Assignee: Shengkai Fang > Reuse PrintUtils.MAX_COLUMN_WIDTH in CliChangelogResultView and > CliTab

[jira] [Commented] (FLINK-22248) JobMasterStopWithSavepointITCase.suspendWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished fail because of TestTimedOutException

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319879#comment-17319879 ] Guowei Ma commented on FLINK-22248: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Updated] (FLINK-22248) JobMasterStopWithSavepointITCase.suspendWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished fail because of TestTimedOutException

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22248: -- Priority: Critical (was: Major) > JobMasterStopWithSavepointITCase.suspendWithSavepointWithoutComplic

[jira] [Created] (FLINK-22248) JobMasterStopWithSavepointITCase.suspendWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished fail because of TestTimedOutException

2021-04-12 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22248: - Summary: JobMasterStopWithSavepointITCase.suspendWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished fail because of TestTimedOutException Key: FLINK-22248 URL: https://

[jira] [Commented] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown.

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319877#comment-17319877 ] Guowei Ma commented on FLINK-21995: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Updated] (FLINK-21995) YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogContents: File channel manager has shutdown.

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21995: -- Affects Version/s: 1.11.3 > YARNSessionFIFOSecuredITCase>YARNSessionFIFOITCase.checkForProhibitedLogCo

[GitHub] [flink] godfreyhe commented on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-12 Thread GitBox
godfreyhe commented on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-818423595 AFAK, very few connectors implement filter push down. If any one needs this fix in 1.12, we can cherry pick it to 1.12. -- This is an automated message from the Apache Git S

[jira] [Created] (FLINK-22247) can not pass AddressList when connecting to rabbitmq

2021-04-12 Thread Spongebob (Jira)
Spongebob created FLINK-22247: - Summary: can not pass AddressList when connecting to rabbitmq Key: FLINK-22247 URL: https://issues.apache.org/jira/browse/FLINK-22247 Project: Flink Issue Type: Im

[jira] [Comment Edited] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319875#comment-17319875 ] Guowei Ma edited comment on FLINK-17510 at 4/13/21, 4:12 AM: -

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319875#comment-17319875 ] Guowei Ma commented on FLINK-17510: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

2021-04-12 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17319872#comment-17319872 ] Guowei Ma commented on FLINK-17510: --- https://dev.azure.com/apache-flink/apache-flink/_

[GitHub] [flink] flinkbot commented on pull request #15581: [Hotfix][python] Fix variable typo.

2021-04-12 Thread GitBox
flinkbot commented on pull request #15581: URL: https://github.com/apache/flink/pull/15581#issuecomment-818414998 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 edited a comment on pull request #15580: [FLINK-22245][sql-client] Reuse PrintUtils.MAX_COLUMN_WIDTH in CliCha…

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15580: URL: https://github.com/apache/flink/pull/15580#issuecomment-818409161 ## CI report: * a5613bd98763175b59d5d2a3ecbf8a1cb047299a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15568: [FLINK-17371][table-runtime] Add cases for decimal casting

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15568: URL: https://github.com/apache/flink/pull/15568#issuecomment-817675780 ## CI report: * 0fadc09a8fa301dc7a46c5893d16390f76379853 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-817625124 ## CI report: * a793f435a93300e271013c875f098f30568c9b19 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] RocMarshal opened a new pull request #15581: [Hotfix][python] Fix variable typo.

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

[GitHub] [flink] YuvalItzchakov commented on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-12 Thread GitBox
YuvalItzchakov commented on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-818413801 @godfreyhe I just want to make sure since this is a critical fix on my end. I can also backport to 1.12 if it helps. -- This is an automated message from the Apache Git

[GitHub] [flink] godfreyhe commented on pull request #15307: [FLINK-21675][table-planner-blink] Allow Predicate Pushdown with Watermark Assigner Between Filter and Scan

2021-04-12 Thread GitBox
godfreyhe commented on pull request #15307: URL: https://github.com/apache/flink/pull/15307#issuecomment-818413113 @YuvalItzchakov master (1.13 now) is enough, do do you think ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Closed] (FLINK-22121) FlinkLogicalRankRuleBase should check if name of rankNumberType already exists in the input

2021-04-12 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22121. -- Resolution: Fixed Fixed in 1.13.0: a2c429d9a626d5f4ea47aa58a3e9f2da7ce1f47e > FlinkLogicalRankRuleBas

[GitHub] [flink] godfreyhe closed pull request #15498: [FLINK-22121][table-planner-blink] FlinkLogicalRankRuleBase now check if name of rankNumberType already exists in the input

2021-04-12 Thread GitBox
godfreyhe closed pull request #15498: URL: https://github.com/apache/flink/pull/15498 -- 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. For queries about this service, plea

[GitHub] [flink] flinkbot commented on pull request #15580: [FLINK-22245][sql-client] Reuse PrintUtils.MAX_COLUMN_WIDTH in CliCha…

2021-04-12 Thread GitBox
flinkbot commented on pull request #15580: URL: https://github.com/apache/flink/pull/15580#issuecomment-818409161 ## CI report: * a5613bd98763175b59d5d2a3ecbf8a1cb047299a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15568: [FLINK-17371][table-runtime] Add cases for decimal casting

2021-04-12 Thread GitBox
flinkbot edited a comment on pull request #15568: URL: https://github.com/apache/flink/pull/15568#issuecomment-817675780 ## CI report: * 0fadc09a8fa301dc7a46c5893d16390f76379853 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Resolved] (FLINK-22152) Fix the bug of same timers are registered multiple times

2021-04-12 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-22152. -- Resolution: Fixed Merged into master via 2d2a6876681b34e46fd7c090a3c98272626828ba > Fix the b

[GitHub] [flink] HuangXingBo closed pull request #15575: [FLINK-22152][python] Fix the bug of same timers are registered multiple times

2021-04-12 Thread GitBox
HuangXingBo closed pull request #15575: URL: https://github.com/apache/flink/pull/15575 -- 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. For queries about this service, pl

[GitHub] [flink] hameizi commented on pull request #15564: [FLINK-22207][connectors/hive]Hive Catalog retrieve Flink Properties …

2021-04-12 Thread GitBox
hameizi commented on pull request #15564: URL: https://github.com/apache/flink/pull/15564#issuecomment-818406172 @KurtYoung I add test case in new commit. Please review. Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

  1   2   3   4   5   6   7   8   >