[jira] [Comment Edited] (FLINK-20368) Supports custom operator name for Flink SQL

2020-11-26 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239452#comment-17239452 ] Kevin Kwon edited comment on FLINK-20368 at 11/26/20, 11:28 PM: Thanks

[GitHub] [flink] godfreyhe commented on pull request #14103: [FLINK-18545] Introduce `pipeline.name` to allow users to specify job name by configuration

2020-11-26 Thread GitBox
godfreyhe commented on pull request #14103: URL: https://github.com/apache/flink/pull/14103#issuecomment-734531462 I will merge this pr This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API

2020-11-26 Thread GaryGao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GaryGao updated FLINK-20190: External issue URL: (was: https://github.com/apache/flink/pull/14099) > A New Window Trigger that can

[jira] [Updated] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API

2020-11-26 Thread GaryGao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] GaryGao updated FLINK-20190: External issue URL: https://github.com/apache/flink/pull/14099 > A New Window Trigger that can trigger

[jira] [Comment Edited] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API

2020-11-26 Thread GaryGao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239475#comment-17239475 ] GaryGao edited comment on FLINK-20190 at 11/27/20, 1:59 AM: Hi, [~aljoscha]

[jira] [Commented] (FLINK-18545) Sql api cannot specify flink job name

2020-11-26 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239476#comment-17239476 ] godfrey he commented on FLINK-18545: master: 78d6ef6f..88d0ee00 release-1.12: 84b6631eee..1aa1b8c6e6

[GitHub] [flink] flinkbot edited a comment on pull request #14240: [FLINK-20383][runtime] Fix race condition in notification.

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14240: URL: https://github.com/apache/flink/pull/14240#issuecomment-734499029 ## CI report: * bb6fc14107467373c1422cb23a06ddda8bb585ec Azure:

[jira] [Created] (FLINK-20385) Allow to read metadata for Canal-json format

2020-11-26 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-20385: -- Summary: Allow to read metadata for Canal-json format Key: FLINK-20385 URL: https://issues.apache.org/jira/browse/FLINK-20385 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-20385) Allow to read metadata for Canal-json format

2020-11-26 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20385: --- Description: In FLIP-107, we support read meta from CDC format Debezium, Canal-json is also

[GitHub] [flink] flinkbot edited a comment on pull request #14244: [FLINK-20299][docs-zh] Update Chinese table overview

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14244: URL: https://github.com/apache/flink/pull/14244#issuecomment-734665945 ## CI report: * e2d25f123282470094c6ebe4122e04921304cc57 Azure:

[GitHub] [flink] fsk119 opened a new pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

2020-11-26 Thread GitBox
fsk119 opened a new pull request #14245: URL: https://github.com/apache/flink/pull/14245 ## What is the purpose of the change *Add document for maxwell format* ## Brief change log

[jira] [Updated] (FLINK-18545) Sql api cannot specify flink job name

2020-11-26 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-18545: --- Fix Version/s: (was: 1.11.4) 1.11.3 > Sql api cannot specify flink job name

[GitHub] [flink] rmetzger commented on a change in pull request #14222: [FLINK-20343] Add new Deployment overview documentation page

2020-11-26 Thread GitBox
rmetzger commented on a change in pull request #14222: URL: https://github.com/apache/flink/pull/14222#discussion_r531416434 ## File path: docs/ops/deployment/overview.md ## @@ -0,0 +1,358 @@ +--- +title: "Clusters & Deployment" +nav-id: deployment +nav-parent_id: ops

[jira] [Commented] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column

2020-11-26 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239548#comment-17239548 ] hailong wang commented on FLINK-20386: -- Yes, currently we just validate between the QUERY Schema

[jira] [Commented] (FLINK-18262) PyFlink end-to-end test stalls

2020-11-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239557#comment-17239557 ] Dian Fu commented on FLINK-18262: -

[jira] [Commented] (FLINK-19369) BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob hangs

2020-11-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239465#comment-17239465 ] Dian Fu commented on FLINK-19369: - Another instance on master:

[jira] [Reopened] (FLINK-19369) BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob hangs

2020-11-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reopened FLINK-19369: - > BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob hangs >

[jira] [Updated] (FLINK-19369) BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob hangs

2020-11-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19369: Affects Version/s: 1.12.0 > BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob hangs >

[GitHub] [flink] leonardBang commented on a change in pull request #14152: [FLINK-19082][doc] Add docs for temporal table and temporal table join

2020-11-26 Thread GitBox
leonardBang commented on a change in pull request #14152: URL: https://github.com/apache/flink/pull/14152#discussion_r531342302 ## File path: docs/dev/table/streaming/joins.md ## @@ -65,174 +65,147 @@ WHERE o.id = s.orderId AND Compared to a regular join operation, this

[GitHub] [flink] KarmaGYZ opened a new pull request #14241: [FLINK-20073][doc] Add native k8s integration to kerberos setup documentation

2020-11-26 Thread GitBox
KarmaGYZ opened a new pull request #14241: URL: https://github.com/apache/flink/pull/14241 ## What is the purpose of the change Add native k8s integration to kerberos setup documentation This is an

[GitHub] [flink] KarmaGYZ commented on pull request #14241: [FLINK-20073][doc] Add native k8s integration to kerberos setup documentation

2020-11-26 Thread GitBox
KarmaGYZ commented on pull request #14241: URL: https://github.com/apache/flink/pull/14241#issuecomment-734543108 cc @xintongsong This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-20073) Add kerberos setup documentation for native k8s integration

2020-11-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20073: --- Labels: pull-request-available (was: ) > Add kerberos setup documentation for native k8s

[jira] [Commented] (FLINK-20259) Add explanation that "configured values" for JM/TM memory sizes include automatically derived values

2020-11-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239491#comment-17239491 ] Xintong Song commented on FLINK-20259: -- Thanks [~vthinkxie]. I've assigned you. Please go ahead. >

[jira] [Assigned] (FLINK-20259) Add explanation that "configured values" for JM/TM memory sizes include automatically derived values

2020-11-26 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20259: Assignee: Yadong Xie > Add explanation that "configured values" for JM/TM memory sizes

[jira] [Commented] (FLINK-20380) Problems with creating iceberg Catalog (Catalog -type=hive) using flink-SQL shell

2020-11-26 Thread tianyu guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239496#comment-17239496 ] tianyu guo commented on FLINK-20380: Hello, do you know the reason for my problem? I am quite urgent

[GitHub] [flink] flinkbot edited a comment on pull request #14241: [FLINK-20073][doc] Add native k8s integration to kerberos setup documentation

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14241: URL: https://github.com/apache/flink/pull/14241#issuecomment-734564072 ## CI report: * 3b3d1e5f945d5e8951d80d314668a986b6000d78 Azure:

[GitHub] [flink] flinkbot commented on pull request #14242: [FLINK-20384][doc] Fix Wrong Links in Some Chinese Docs

2020-11-26 Thread GitBox
flinkbot commented on pull request #14242: URL: https://github.com/apache/flink/pull/14242#issuecomment-734591430 ## CI report: * 64189c2e0b4c4069fc46c0f2fd79f2cacc491c89 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] becketqin commented on a change in pull request #14239: [FLINK-20114][connector/kafka,common] Fix a few issues reported in Kafka Source release testing.

2020-11-26 Thread GitBox
becketqin commented on a change in pull request #14239: URL: https://github.com/apache/flink/pull/14239#discussion_r531331794 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContextTest.java ## @@ -170,6 +178,70 @@ public

[GitHub] [flink] HuangXingBo commented on pull request #14204: [FLINK-20325][build] Move docs_404_check to CI stage

2020-11-26 Thread GitBox
HuangXingBo commented on pull request #14204: URL: https://github.com/apache/flink/pull/14204#issuecomment-734633566 Many Chinese docs newly added recently have links to English documents that cause `build_doc.sh` to fail. But the existing logic of `check_docs.sh` is to test whether there

[GitHub] [flink] flinkbot edited a comment on pull request #14239: [FLINK-20114][connector/kafka,common] Fix a few issues reported in Kafka Source release testing.

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14239: URL: https://github.com/apache/flink/pull/14239#issuecomment-734365513 ## CI report: * 93e06a32ad83c81adcec2b71e6d1e61358fb8b88 UNKNOWN * 4c0bcde650774d1afacb024f1045441269f04af3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14235: [FLINK-20298][docs] Replace usage of {{ site.baseurl }} in documentation

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14235: URL: https://github.com/apache/flink/pull/14235#issuecomment-734255724 ## CI report: * 49108f9990bc2844f793113e6a624c5aa3368ccb Azure:

[jira] [Updated] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column

2020-11-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20386: Description: The primary key of the MySQL is an INT UNSIGNED column, but declared INT in Flink. I know

[jira] [Created] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column

2020-11-26 Thread Jark Wu (Jira)
Jark Wu created FLINK-20386: --- Summary: ClassCastException when lookup join a JDBC table on INT UNSIGNED column Key: FLINK-20386 URL: https://issues.apache.org/jira/browse/FLINK-20386 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14235: [FLINK-20298][docs] Replace usage of {{ site.baseurl }} in documentation

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14235: URL: https://github.com/apache/flink/pull/14235#issuecomment-734255724 ## CI report: * ae0222a92490ad8d345f14866cb31564434044f6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14241: [FLINK-20073][doc] Add native k8s integration to kerberos setup documentation

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14241: URL: https://github.com/apache/flink/pull/14241#issuecomment-734564072 ## CI report: * 3b3d1e5f945d5e8951d80d314668a986b6000d78 Azure:

[jira] [Closed] (FLINK-18545) Sql api cannot specify flink job name

2020-11-26 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-18545. -- Release Note: Introduce `pipeline.name` to allow users to specify job name by configuration. This

[jira] [Updated] (FLINK-20382) Exception thrown from JobMaster.startScheduling() may be ignored.

2020-11-26 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-20382: --- Priority: Critical (was: Major) > Exception thrown from JobMaster.startScheduling() may be

[GitHub] [flink] rmetzger commented on pull request #14239: [FLINK-20114][connector/kafka,common] Fix a few issues reported in Kafka Source release testing.

2020-11-26 Thread GitBox
rmetzger commented on pull request #14239: URL: https://github.com/apache/flink/pull/14239#issuecomment-734696972 I've rebuild Flink using the latest version of this PR + I added myself some logging into the JobMaster / Scheduler to find out the issue: ``` Caused by:

[jira] [Assigned] (FLINK-20114) Test Kafka Source based on the new Source API 

2020-11-26 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20114: -- Assignee: (was: Robert Metzger) > Test Kafka Source based on the new Source API 

[jira] [Assigned] (FLINK-20114) Test Kafka Source based on the new Source API 

2020-11-26 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20114: -- Assignee: Robert Metzger > Test Kafka Source based on the new Source API  >

[jira] [Assigned] (FLINK-20114) Test Kafka Source based on the new Source API 

2020-11-26 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20114: -- Assignee: (was: Robert Metzger) > Test Kafka Source based on the new Source API 

[GitHub] [flink] flinkbot commented on pull request #14240: [FLINK-20383][runtime] Fix race condition in notification.

2020-11-26 Thread GitBox
flinkbot commented on pull request #14240: URL: https://github.com/apache/flink/pull/14240#issuecomment-734499029 ## CI report: * bb6fc14107467373c1422cb23a06ddda8bb585ec UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14177: [FLINK-16443][checkpointing] Make sure that CheckpointException are also serialized in DeclineCheckpoint.

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14177: URL: https://github.com/apache/flink/pull/14177#issuecomment-732207895 ## CI report: * 81187637662cac241774f53951af4eba82da3484 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14240: [FLINK-20383][runtime] Fix race condition in notification.

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14240: URL: https://github.com/apache/flink/pull/14240#issuecomment-734499029 ## CI report: * bb6fc14107467373c1422cb23a06ddda8bb585ec Azure:

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

2020-11-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239463#comment-17239463 ] Dian Fu commented on FLINK-20329: - Another instance:

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

2020-11-26 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239483#comment-17239483 ] Leonard Xu commented on FLINK-19863: I will continue work for this ticket. >

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

2020-11-26 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239490#comment-17239490 ] Yun Tang commented on FLINK-20376: -- I think the reported message has given enough hint: {{Cannot map

[GitHub] [flink] zlzhang0122 commented on pull request #13580: [hotfix][flink-runtime-web] modify checkpoint time format

2020-11-26 Thread GitBox
zlzhang0122 commented on pull request #13580: URL: https://github.com/apache/flink/pull/13580#issuecomment-734631818 > Thanks for looking into that @zizhang0122. Unfortunately, you change was already merged as part of [FLINK-19553](https://issues.apache.org/jira/browse/FLINK-19553).

[jira] [Comment Edited] (FLINK-20368) Supports custom operator name for Flink SQL

2020-11-26 Thread Danny Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239503#comment-17239503 ] Danny Chen edited comment on FLINK-20368 at 11/27/20, 4:22 AM: --- Hi

[GitHub] [flink] flinkbot commented on pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

2020-11-26 Thread GitBox
flinkbot commented on pull request #14245: URL: https://github.com/apache/flink/pull/14245#issuecomment-734680404 ## CI report: * 4cc62d164e11aa827f6de269c8945667a6fc8461 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2020-11-26 Thread Jark Wu (Jira)
Jark Wu created FLINK-20387: --- Summary: Support column of TIMESTAMP WITH LOCAL ZONE TIME type as rowtime attribute Key: FLINK-20387 URL: https://issues.apache.org/jira/browse/FLINK-20387 Project: Flink

[jira] [Updated] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

2020-11-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20389: Fix Version/s: 1.12.0 > UnalignedCheckpointITCase failure caused by NullPointerException >

[jira] [Commented] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

2020-11-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239556#comment-17239556 ] Dian Fu commented on FLINK-20389: - cc [~AHeise] > UnalignedCheckpointITCase failure caused by

[GitHub] [flink] SteNicholas commented on pull request #14120: [FLINK-19984][core] Add TypeSerializerTestCoverageTest to check whether tests based on SerializerTestBase and TypeSerializerUpgradeTestBa

2020-11-26 Thread GitBox
SteNicholas commented on pull request #14120: URL: https://github.com/apache/flink/pull/14120#issuecomment-734534667 @aljoscha , could you please take a look at this pull request? @guoweiM has already completed the review.

[GitHub] [flink] flinkbot edited a comment on pull request #14177: [FLINK-16443][checkpointing] Make sure that CheckpointException are also serialized in DeclineCheckpoint.

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14177: URL: https://github.com/apache/flink/pull/14177#issuecomment-732207895 ## CI report: * ce283f64f17cadd3f4ab80534343dbfe917867fa Azure:

[GitHub] [flink-statefun] tzulitai commented on a change in pull request #179: [FLINK-20268] [python] Support new invocation protocol in the Python SDK

2020-11-26 Thread GitBox
tzulitai commented on a change in pull request #179: URL: https://github.com/apache/flink-statefun/pull/179#discussion_r531363954 ## File path: statefun-examples/statefun-python-walkthrough-example/walkthrough.py ## @@ -111,12 +115,29 @@ def state2(context, message):

[GitHub] [flink] flinkbot edited a comment on pull request #14243: [FLINK-20366][table-planner-blink] ColumnIntervalUtil#getColumnIntervalWithFilter should consider constant predicate

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14243: URL: https://github.com/apache/flink/pull/14243#issuecomment-734643602 ## CI report: * 99365bd5ed999a9f19e1678a89ca1289a507d467 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14239: [FLINK-20114][connector/kafka,common] Fix a few issues reported in Kafka Source release testing.

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14239: URL: https://github.com/apache/flink/pull/14239#issuecomment-734365513 ## CI report: * 93e06a32ad83c81adcec2b71e6d1e61358fb8b88 UNKNOWN * a56c3a56de6254bca14410b923cd9c4dce69dc98 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14235: [FLINK-20298][docs] Replace usage of {{ site.baseurl }} in documentation

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14235: URL: https://github.com/apache/flink/pull/14235#issuecomment-734255724 ## CI report: * 49108f9990bc2844f793113e6a624c5aa3368ccb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14204: [FLINK-20325][build] Move docs_404_check to CI stage

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14204: URL: https://github.com/apache/flink/pull/14204#issuecomment-733048767 ## CI report: * 6550d3e1b01af94d4f652f993834b75272da1020 UNKNOWN * 595ab82c651f8c225193eeeba90d6366fdff341d Azure:

[GitHub] [flink] flinkbot commented on pull request #14244: [FLINK-20299][docs-zh] Update Chinese table overview

2020-11-26 Thread GitBox
flinkbot commented on pull request #14244: URL: https://github.com/apache/flink/pull/14244#issuecomment-734665945 ## CI report: * e2d25f123282470094c6ebe4122e04921304cc57 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] godfreyhe commented on a change in pull request #14228: [FLINK-20349][table-planner-blink] Fix checking for deadlock caused by exchange

2020-11-26 Thread GitBox
godfreyhe commented on a change in pull request #14228: URL: https://github.com/apache/flink/pull/14228#discussion_r531410506 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/processors/utils/InputOrderCalculator.java ## @@

[GitHub] [flink] flinkbot commented on pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

2020-11-26 Thread GitBox
flinkbot commented on pull request #14245: URL: https://github.com/apache/flink/pull/14245#issuecomment-734675458 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

[GitHub] [flink] godfreyhe merged pull request #14233: [FLINK-18545] Introduce `pipeline.name` to allow users to specify job name by configuration

2020-11-26 Thread GitBox
godfreyhe merged pull request #14233: URL: https://github.com/apache/flink/pull/14233 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] [Comment Edited] (FLINK-18545) Sql api cannot specify flink job name

2020-11-26 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239476#comment-17239476 ] godfrey he edited comment on FLINK-18545 at 11/27/20, 6:52 AM: --- master:

[jira] [Commented] (FLINK-20378) Watermark generation check TIMESTAMP_WITHOUT_TIME_ZONE

2020-11-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239529#comment-17239529 ] Jark Wu commented on FLINK-20378: - Supporting TIMESTAMP WITH LOCAL TIME ZONE is on the roadmap (v1.13).

[jira] [Commented] (FLINK-20380) Problems with creating iceberg Catalog (Catalog -type=hive) using flink-SQL shell

2020-11-26 Thread Zheng Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239553#comment-17239553 ] Zheng Hu commented on FLINK-20380: -- Would you mind to check your jars ? Pls extract the jar and find

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

2020-11-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239466#comment-17239466 ] Dian Fu commented on FLINK-19863: -

[jira] [Commented] (FLINK-20378) Watermark generation check TIMESTAMP_WITHOUT_TIME_ZONE

2020-11-26 Thread wxmimperio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239504#comment-17239504 ] wxmimperio commented on FLINK-20378: [~jark] Thank you for your answer. However, I always feel that

[jira] [Updated] (FLINK-20366) ColumnIntervalUtil#getColumnIntervalWithFilter does not consider the case when the predicate is a false constant

2020-11-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20366: --- Labels: pull-request-available (was: ) > ColumnIntervalUtil#getColumnIntervalWithFilter

[GitHub] [flink] flinkbot commented on pull request #14243: [FLINK-20366][table-planner-blink] ColumnIntervalUtil#getColumnIntervalWithFilter should consider constant predicate

2020-11-26 Thread GitBox
flinkbot commented on pull request #14243: URL: https://github.com/apache/flink/pull/14243#issuecomment-734638648 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

[GitHub] [flink] rmetzger commented on pull request #14204: [FLINK-20325][build] Move docs_404_check to CI stage

2020-11-26 Thread GitBox
rmetzger commented on pull request #14204: URL: https://github.com/apache/flink/pull/14204#issuecomment-734672656 @dianfu can you take a look as well? Afaik you've recently fixed the link check script. This is an automated

[jira] [Commented] (FLINK-20375) Add a switch to control the operator name in SQL

2020-11-26 Thread YufeiLiu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239547#comment-17239547 ] YufeiLiu commented on FLINK-20375: -- +1 for this. I think it's necessary to provide a way to report

[jira] [Commented] (FLINK-20380) Problems with creating iceberg Catalog (Catalog -type=hive) using flink-SQL shell

2020-11-26 Thread Zheng Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239551#comment-17239551 ] Zheng Hu commented on FLINK-20380: -- I guess you have included a hive-metastore jar which is older than

[jira] [Commented] (FLINK-20368) Supports custom operator name for Flink SQL

2020-11-26 Thread Kevin Kwon (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239452#comment-17239452 ] Kevin Kwon commented on FLINK-20368: Are the DDLs also using DataStreams API? Will it break like

[GitHub] [flink] becketqin commented on pull request #14239: [FLINK-20114][connector/kafka,common] Fix a few issues reported in Kafka Source release testing.

2020-11-26 Thread GitBox
becketqin commented on pull request #14239: URL: https://github.com/apache/flink/pull/14239#issuecomment-734530063 Hey @rmetzger , can you check if you are using the latest update of the PR? Some earlier commit I had for this PR had a problem of using `Integer.parseInt()` to parse a long

[GitHub] [flink] godfreyhe merged pull request #14103: [FLINK-18545] Introduce `pipeline.name` to allow users to specify job name by configuration

2020-11-26 Thread GitBox
godfreyhe merged pull request #14103: URL: https://github.com/apache/flink/pull/14103 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] [Created] (FLINK-20384) Broken Link in deployment/ha/kubernetes_ha.zh.md

2020-11-26 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20384: Summary: Broken Link in deployment/ha/kubernetes_ha.zh.md Key: FLINK-20384 URL: https://issues.apache.org/jira/browse/FLINK-20384 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #14241: [FLINK-20073][doc] Add native k8s integration to kerberos setup documentation

2020-11-26 Thread GitBox
flinkbot commented on pull request #14241: URL: https://github.com/apache/flink/pull/14241#issuecomment-734564072 ## CI report: * 3b3d1e5f945d5e8951d80d314668a986b6000d78 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] wangyang0918 commented on pull request #14237: [FLINK-20381][yarn] Replace -id by -yid

2020-11-26 Thread GitBox
wangyang0918 commented on pull request #14237: URL: https://github.com/apache/flink/pull/14237#issuecomment-734623706 Another concern is that the following command has the same semantic but it could not work too. Because we only check the cli option

[GitHub] [flink] becketqin commented on a change in pull request #14239: [FLINK-20114][connector/kafka,common] Fix a few issues reported in Kafka Source release testing.

2020-11-26 Thread GitBox
becketqin commented on a change in pull request #14239: URL: https://github.com/apache/flink/pull/14239#discussion_r531331794 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/source/coordinator/SourceCoordinatorContextTest.java ## @@ -170,6 +178,70 @@ public

[GitHub] [flink] wuchong commented on pull request #14204: [FLINK-20325][build] Move docs_404_check to CI stage

2020-11-26 Thread GitBox
wuchong commented on pull request #14204: URL: https://github.com/apache/flink/pull/14204#issuecomment-734653626 Hi @HuangXingBo , `./tools/ci/docs.sh` will run `build_doc.sh` first, so I think this can cover the problem you mentioned of linking Chinese documents to English documents?

[GitHub] [flink] flinkbot commented on pull request #14244: [FLINK-20299][docs-zh] Update Chinese table overview

2020-11-26 Thread GitBox
flinkbot commented on pull request #14244: URL: https://github.com/apache/flink/pull/14244#issuecomment-734662128 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

[jira] [Updated] (FLINK-20299) Update Chinese table overview

2020-11-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20299: --- Labels: pull-request-available (was: ) > Update Chinese table overview >

[GitHub] [flink] flinkbot edited a comment on pull request #14204: [FLINK-20325][build] Move docs_404_check to CI stage

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14204: URL: https://github.com/apache/flink/pull/14204#issuecomment-733048767 ## CI report: * 6550d3e1b01af94d4f652f993834b75272da1020 UNKNOWN * 595ab82c651f8c225193eeeba90d6366fdff341d Azure:

[jira] [Updated] (FLINK-18897) Add documentation for the maxwell-json format

2020-11-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18897: --- Labels: pull-request-available (was: ) > Add documentation for the maxwell-json format >

[GitHub] [flink] uglymagic commented on a change in pull request #11830: [FLINK-17096] [table] Mini-batch group aggregation doesn't expire state even if state ttl is enabled

2020-11-26 Thread GitBox
uglymagic commented on a change in pull request #11830: URL: https://github.com/apache/flink/pull/11830#discussion_r531363295 ## File path: flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/aggregate/GroupAggFunctionTestBase.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #14239: [FLINK-20114][connector/kafka,common] Fix a few issues reported in Kafka Source release testing.

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14239: URL: https://github.com/apache/flink/pull/14239#issuecomment-734365513 ## CI report: * 93e06a32ad83c81adcec2b71e6d1e61358fb8b88 UNKNOWN * 4c0bcde650774d1afacb024f1045441269f04af3 Azure:

[jira] [Comment Edited] (FLINK-20378) Watermark generation check TIMESTAMP_WITHOUT_TIME_ZONE

2020-11-26 Thread wxmimperio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239504#comment-17239504 ] wxmimperio edited comment on FLINK-20378 at 11/27/20, 4:10 AM: --- [~jark]

[GitHub] [flink] flinkbot commented on pull request #14243: [FLINK-20366][table-planner-blink] ColumnIntervalUtil#getColumnIntervalWithFilter should consider constant predicate

2020-11-26 Thread GitBox
flinkbot commented on pull request #14243: URL: https://github.com/apache/flink/pull/14243#issuecomment-734643602 ## CI report: * 99365bd5ed999a9f19e1678a89ca1289a507d467 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Assigned] (FLINK-20162) Fix time zone problems for some time related functions

2020-11-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20162: --- Assignee: Leonard Xu > Fix time zone problems for some time related functions >

[jira] [Created] (FLINK-20388) Supports users setting operators' metrics name

2020-11-26 Thread hailong wang (Jira)
hailong wang created FLINK-20388: Summary: Supports users setting operators' metrics name Key: FLINK-20388 URL: https://issues.apache.org/jira/browse/FLINK-20388 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #14245: [FLINK-18897][doc] Add document for Maxwell format

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14245: URL: https://github.com/apache/flink/pull/14245#issuecomment-734680404 ## CI report: * 4cc62d164e11aa827f6de269c8945667a6fc8461 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14244: [FLINK-20299][docs-zh] Update Chinese table overview

2020-11-26 Thread GitBox
flinkbot edited a comment on pull request #14244: URL: https://github.com/apache/flink/pull/14244#issuecomment-734665945 ## CI report: * e2d25f123282470094c6ebe4122e04921304cc57 Azure:

[jira] [Updated] (FLINK-20281) Window aggregation supports changelog stream input

2020-11-26 Thread silence (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] silence updated FLINK-20281: Attachment: screenshot-1.png > Window aggregation supports changelog stream input >

[GitHub] [flink] rmetzger commented on pull request #14239: [FLINK-20114][connector/kafka,common] Fix a few issues reported in Kafka Source release testing.

2020-11-26 Thread GitBox
rmetzger commented on pull request #14239: URL: https://github.com/apache/flink/pull/14239#issuecomment-734697959 Note: CI is failing because of checkstyle. This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-20281) Window aggregation supports changelog stream input

2020-11-26 Thread silence (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239561#comment-17239561 ] silence commented on FLINK-20281: - [~jark] Over window is also not supported !screenshot-1.png! >

[jira] [Commented] (FLINK-20190) A New Window Trigger that can trigger window operation both by event time interval、event count for DataStream API

2020-11-26 Thread GaryGao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239475#comment-17239475 ] GaryGao commented on FLINK-20190: - Hi, [~aljoscha] EventTimeTrigger only supports triggering by

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

2020-11-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17239484#comment-17239484 ] Dian Fu commented on FLINK-19863: - [~Leonard Xu] Thanks a lot~ > SQLClientHBaseITCase.testHBase failed

[GitHub] [flink] flinkbot commented on pull request #14241: [FLINK-20073][doc] Add native k8s integration to kerberos setup documentation

2020-11-26 Thread GitBox
flinkbot commented on pull request #14241: URL: https://github.com/apache/flink/pull/14241#issuecomment-734546268 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

  1   2   3   4   5   >