[GitHub] [flink] flinkbot edited a comment on pull request #13195: [FLINK-18994][doc-zh] Fix typo in setup taskmanager memory page

flinkbot edited a comment on pull request #13195: URL: https://github.com/apache/flink/pull/13195#issuecomment-675844035 ## CI report: * caa599bea8dc09145e62ca2edbbaa3238e5449f6 Azure:

[jira] [Closed] (FLINK-18994) There is one typo in "Set up TaskManager Memory"

[ https://issues.apache.org/jira/browse/FLINK-18994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-18994. Resolution: Fixed Fixed via * master: e39ede95134aeccb441141d0db68e32be2da209b * release-1.11:

[GitHub] [flink] flinkbot edited a comment on pull request #13186: [FLINK-18720][k8s] Migrate KubernetesResourceManager to the new KubernetesResourceManagerDriver

flinkbot edited a comment on pull request #13186: URL: https://github.com/apache/flink/pull/13186#issuecomment-675299227 ## CI report: * 523cf170fe07e4b32e47653af46bf2290935d87a Azure:

[jira] [Created] (FLINK-18997) Rename type_info to result_type to make it more clear

Hequn Cheng created FLINK-18997: --- Summary: Rename type_info to result_type to make it more clear Key: FLINK-18997 URL: https://issues.apache.org/jira/browse/FLINK-18997 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #13196: [FLINK-18997][python] Rename type_info to result_type to make it more clear

flinkbot commented on pull request #13196: URL: https://github.com/apache/flink/pull/13196#issuecomment-675891549 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] wuchong commented on a change in pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

wuchong commented on a change in pull request #12880: URL: https://github.com/apache/flink/pull/12880#discussion_r472743692 ## File path: flink-table/flink-table-api-java-bridge/src/test/java/org/apache/flink/table/api/bridge/java/internal/StreamTableEnvironmentImplTest.java

[GitHub] [flink] xintongsong closed pull request #13195: [FLINK-18994][doc-zh] Fix typo in setup taskmanager memory page

xintongsong closed pull request #13195: URL: https://github.com/apache/flink/pull/13195 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-18931) Translate "Hive Streaming" page of "Hive Integration" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180293#comment-17180293 ] Xu Ronghao commented on FLINK-18931: Hi , Rui Li, There are many similarities between this issue

[jira] [Updated] (FLINK-18997) Rename type_info to result_type to make it more clear

[ https://issues.apache.org/jira/browse/FLINK-18997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18997: Description: Currently, the name of result type parameter for Python DataStream.map() and

[jira] [Updated] (FLINK-18959) Fail to archiveExecutionGraph because job is not finished when dispatcher close

[ https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18959: -- Priority: Critical (was: Major) > Fail to archiveExecutionGraph because job is not finished

[jira] [Updated] (FLINK-18986) KubernetesSessionCli creates RestClusterClient for detached deployments

[ https://issues.apache.org/jira/browse/FLINK-18986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18986: -- Labels: pull-request-available usability (was: pull-request-available) >

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180304#comment-17180304 ] Till Rohrmann commented on FLINK-12351: --- Thanks for reporting this issue [~wenlong.lwl]. Pulling

[jira] [Updated] (FLINK-18974) Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-18974: Component/s: chinese-translation > Translate the 'User-Defined Functions' page of "Application

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180290#comment-17180290 ] Timo Walther commented on FLINK-17793: -- Yes, this is planned for 1.12. But I'm waiting for the

[jira] [Commented] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180300#comment-17180300 ] Till Rohrmann commented on FLINK-16408: --- A growing metaspace size is not per se a proof that Flink

[jira] [Commented] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180311#comment-17180311 ] Echo Lee commented on FLINK-16408: -- [~trohrmann]  Yes, The problem I currently encounter is that

[GitHub] [flink] wbgentleman commented on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

wbgentleman commented on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675890942 @TisonKun I have do the typesetting according the materials you offered. Please check. Thank you. This is

[jira] [Updated] (FLINK-18997) Rename type_info to result_type to make it more clear

[ https://issues.apache.org/jira/browse/FLINK-18997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18997: --- Labels: pull-request-available (was: ) > Rename type_info to result_type to make it more

[GitHub] [flink] hequn8128 opened a new pull request #13196: [FLINK-18997][python] Rename type_info to result_type to make it more clear

hequn8128 opened a new pull request #13196: URL: https://github.com/apache/flink/pull/13196 ## What is the purpose of the change This pull request renames type_info to result_type to make it more clear. ## Brief change log - Rename parameter name type_info to

[GitHub] [flink] tillrohrmann commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

tillrohrmann commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472783027 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int

[GitHub] [flink] tillrohrmann commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

tillrohrmann commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472866577 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18998: -- Component/s: Runtime / Web Frontend Runtime / Task > No watermark is shown

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18998: -- Affects Version/s: 1.12.0 1.11.1 > No watermark is shown on Flink UI

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18998: -- Fix Version/s: 1.12.0 > No watermark is shown on Flink UI when ProcessingTime is used >

[jira] [Commented] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180366#comment-17180366 ] Robert Metzger commented on FLINK-18998: I agree, this is a good improvement. > No watermark is

[GitHub] [flink] flinkbot edited a comment on pull request #12908: [FLINK-18449][table sql/api]Kafka topic discovery & partition discove…

flinkbot edited a comment on pull request #12908: URL: https://github.com/apache/flink/pull/12908#issuecomment-658771971 ## CI report: * 2769a8edbd4a4e28ca6b75f39e69d95007b5c4b2 Azure:

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18998: -- Issue Type: Improvement (was: Bug) > No watermark is shown on Flink UI when ProcessingTime

[GitHub] [flink] flinkbot edited a comment on pull request #13157: [FLINK-18900][hive] HiveCatalog should error out when listing partitions with an invalid spec

flinkbot edited a comment on pull request #13157: URL: https://github.com/apache/flink/pull/13157#issuecomment-674410767 ## CI report: * b64a33a3e57e4af2522aeaf274c4711ddb2b00ef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13197: [FLINK-18995][hive] Some Hive functions fail because they need to acc…

flinkbot edited a comment on pull request #13197: URL: https://github.com/apache/flink/pull/13197#issuecomment-675953571 ## CI report: * 66f8b6582b131697cccebbf4e2ef9f90a7f43825 Azure:

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18998: -- Labels: starter usability (was: usability) > No watermark is shown on Flink UI when

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18998: -- Component/s: (was: Runtime / Task) > No watermark is shown on Flink UI when

[GitHub] [flink] flinkbot edited a comment on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

flinkbot edited a comment on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675323573 ## CI report: * 5c37469ec372c4660283677e4984a8c87f5254a9 Azure:

[jira] [Commented] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180374#comment-17180374 ] Chesnay Schepler commented on FLINK-18998: -- [~trohrmann] How is this related to FLINK-8949? >

[jira] [Commented] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180380#comment-17180380 ] Nico Kruber commented on FLINK-18998: - Maybe also add a line how to enable EventTime or point to the

[jira] [Commented] (FLINK-16258) Update test utilities to FLIP-65

[ https://issues.apache.org/jira/browse/FLINK-16258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180377#comment-17180377 ] CaoZhen commented on FLINK-16258: - Hi  [~twalthr] ,Can this task be assigned to me? > Update test

[jira] [Assigned] (FLINK-16258) Update test utilities to FLIP-65

[ https://issues.apache.org/jira/browse/FLINK-16258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-16258: Assignee: CaoZhen (was: Timo Walther) > Update test utilities to FLIP-65 >

[jira] [Assigned] (FLINK-16258) Update test utilities to FLIP-65

[ https://issues.apache.org/jira/browse/FLINK-16258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-16258: Assignee: Timo Walther > Update test utilities to FLIP-65 >

[jira] [Commented] (FLINK-16258) Update test utilities to FLIP-65

[ https://issues.apache.org/jira/browse/FLINK-16258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180381#comment-17180381 ] Timo Walther commented on FLINK-16258: -- This issue is not as straight forward as it seems. The

[GitHub] [flink] flinkbot edited a comment on pull request #13157: [FLINK-18900][hive] HiveCatalog should error out when listing partitions with an invalid spec

flinkbot edited a comment on pull request #13157: URL: https://github.com/apache/flink/pull/13157#issuecomment-674410767 ## CI report: * b64a33a3e57e4af2522aeaf274c4711ddb2b00ef Azure:

[jira] [Commented] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180388#comment-17180388 ] Yun Gao commented on FLINK-18695: - Hi, I have finished the tests with the current master branch, and the

[GitHub] [flink] wooplevip opened a new pull request #13198: [FLINK-18993][Runtime]Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

wooplevip opened a new pull request #13198: URL: https://github.com/apache/flink/pull/13198 ## What is the purpose of the change This pull request fixes checking jobmanager off-heap memory size incorrectly when off-heap memory is explicitly set by user. ## Brief change

[jira] [Updated] (FLINK-18993) Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

[ https://issues.apache.org/jira/browse/FLINK-18993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18993: --- Labels: pull-request-available (was: ) > Invoke sanityCheckTotalFlinkMemory method

[GitHub] [flink] flinkbot commented on pull request #13198: [FLINK-18993][Runtime]Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

flinkbot commented on pull request #13198: URL: https://github.com/apache/flink/pull/13198#issuecomment-676015059 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] flinkbot commented on pull request #13198: [FLINK-18993][Runtime]Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

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

[jira] [Commented] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180405#comment-17180405 ] Chesnay Schepler commented on FLINK-18695: -- [~gaoyunhaii] Thanks for keeping us updated, these

[jira] [Updated] (FLINK-18999) Temporary generic table doesn't work with HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-18999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-18999: --- Description: Suppose current catalog is a {{HiveCatalog}}. If user creates a temporary generic table, this

[GitHub] [flink] flinkbot edited a comment on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

flinkbot edited a comment on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675323573 ## CI report: * 664986884e6e9e1930d48568a4e33b2f36cefe6c Azure:

[GitHub] [flink] flinkbot commented on pull request #13196: [FLINK-18997][python] Rename type_info to result_type to make it more clear

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

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 1f213639e4e38e9e25506c20d7eff660cadbb6b1 Azure:

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180322#comment-17180322 ] Jark Wu commented on FLINK-17793: - Maybe. Not sure. The {{Schema}} descriptor will hold Expression as

[jira] [Commented] (FLINK-18988) Continuous query with LATERAL and LIMIT produces wrong result

[ https://issues.apache.org/jira/browse/FLINK-18988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180331#comment-17180331 ] Fabian Hueske commented on FLINK-18988: --- [~danny0405] Yes, I used the Blink planner for this.

[GitHub] [flink] dawidwys commented on a change in pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

dawidwys commented on a change in pull request #13050: URL: https://github.com/apache/flink/pull/13050#discussion_r472815116 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/Expander.java ## @@ -0,0 +1,126 @@ +/* + *

[jira] [Updated] (FLINK-15299) Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

[ https://issues.apache.org/jira/browse/FLINK-15299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-15299: - Fix Version/s: 1.12.0 > Move ClientUtils#submitJob &

[GitHub] [flink] zentol commented on a change in pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

zentol commented on a change in pull request #11469: URL: https://github.com/apache/flink/pull/11469#discussion_r472826235 ## File path: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java ## @@ -306,94 +257,6 @@ private

[jira] [Updated] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

[ https://issues.apache.org/jira/browse/FLINK-18998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Qin updated FLINK-18998: Description: As stated in the subject, no watermark is shown on Flink UI when ProcessingTime is used,

[jira] [Commented] (FLINK-18931) Translate "Hive Streaming" page of "Hive Integration" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180352#comment-17180352 ] Rui Li commented on FLINK-18931: [~lzljs3620320] Could you help assign this ticket? > Translate "Hive

[GitHub] [flink] flinkbot commented on pull request #13197: [FLINK-18995][hive] Some Hive functions fail because they need to acc…

flinkbot commented on pull request #13197: URL: https://github.com/apache/flink/pull/13197#issuecomment-675933780 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] TisonKun commented on a change in pull request #11469: [FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope

TisonKun commented on a change in pull request #11469: URL: https://github.com/apache/flink/pull/11469#discussion_r472859214 ## File path: flink-clients/src/test/java/org/apache/flink/client/program/rest/RestClusterClientTest.java ## @@ -595,35 +458,6 @@ public void

[jira] [Commented] (FLINK-17793) Replace TableSchema with dedicated CatalogSchema

[ https://issues.apache.org/jira/browse/FLINK-17793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180359#comment-17180359 ] Timo Walther commented on FLINK-17793: -- I'm also not sure yet. But it would be good to avoid too

[GitHub] [flink] flinkbot edited a comment on pull request #12770: [FLINK-18200][python] Replace the deprecated interfaces with the new interfaces in the tests and examples

flinkbot edited a comment on pull request #12770: URL: https://github.com/apache/flink/pull/12770#issuecomment-649764859 ## CI report: * 14838ccc8ac1e759449b5c392e05e2deeb0e005c Azure:

[GitHub] [flink] wbgentleman edited a comment on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

wbgentleman edited a comment on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675890942 @TisonKun I have done the typesetting according the materials you offered. Please check. Thank you.

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 1f213639e4e38e9e25506c20d7eff660cadbb6b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12770: [FLINK-18200][python] Replace the deprecated interfaces with the new interfaces in the tests and examples

flinkbot edited a comment on pull request #12770: URL: https://github.com/apache/flink/pull/12770#issuecomment-649764859 ## CI report: * 14838ccc8ac1e759449b5c392e05e2deeb0e005c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13196: [FLINK-18997][python] Rename type_info to result_type to make it more clear

flinkbot edited a comment on pull request #13196: URL: https://github.com/apache/flink/pull/13196#issuecomment-675895709 ## CI report: * ef1e3aff4509d7dbabed7cb333b1d75851b3e502 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13188: [hotfix][docs] Translate building.md to building.zh.md

flinkbot edited a comment on pull request #13188: URL: https://github.com/apache/flink/pull/13188#issuecomment-675323573 ## CI report: * 664986884e6e9e1930d48568a4e33b2f36cefe6c Azure:

[jira] [Created] (FLINK-18998) No watermark is shown on Flink UI when ProcessingTime is used

Jun Qin created FLINK-18998: --- Summary: No watermark is shown on Flink UI when ProcessingTime is used Key: FLINK-18998 URL: https://issues.apache.org/jira/browse/FLINK-18998 Project: Flink Issue

[GitHub] [flink] rkhachatryan commented on a change in pull request #13180: [FLINK-18962][checkpointing] Improve logging when checkpoint declined

rkhachatryan commented on a change in pull request #13180: URL: https://github.com/apache/flink/pull/13180#discussion_r472818246 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java ## @@ -129,12 +129,10 @@

[GitHub] [flink] wuchong commented on a change in pull request #13122: [FLINK-18824][format][canal] Support serialization for canal-json format

wuchong commented on a change in pull request #13122: URL: https://github.com/apache/flink/pull/13122#discussion_r472805841 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonFormatFactory.java ## @@ -56,16 +57,16 @@

[GitHub] [flink] zentol commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

zentol commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472817962 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String[]

[jira] [Commented] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180345#comment-17180345 ] Piotr Nowojski commented on FLINK-12351: I think this is a valid concern. I'm not sure how much

[jira] [Updated] (FLINK-18983) Job doesn't changed to failed if close function has blocked

[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YufeiLiu updated FLINK-18983: - Description: If a operator throw a exception, it will break process loop and dispose all operator. But

[GitHub] [flink] lirui-apache opened a new pull request #13197: [FLINK-18995][hive] Some Hive functions fail because they need to acc…

lirui-apache opened a new pull request #13197: URL: https://github.com/apache/flink/pull/13197 …ess SessionState ## What is the purpose of the change Fix/ban some hive functions that need to access SessionState. ## Brief change log - Ban

[jira] [Updated] (FLINK-18995) Some Hive functions fail because they need to access SessionState

[ https://issues.apache.org/jira/browse/FLINK-18995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18995: --- Labels: pull-request-available (was: ) > Some Hive functions fail because they need to

[jira] [Assigned] (FLINK-18995) Some Hive functions fail because they need to access SessionState

[ https://issues.apache.org/jira/browse/FLINK-18995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-18995: Assignee: Rui Li > Some Hive functions fail because they need to access SessionState >

[jira] [Assigned] (FLINK-18931) Translate "Hive Streaming" page of "Hive Integration" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-18931: Assignee: Xu Ronghao > Translate "Hive Streaming" page of "Hive Integration" into

[GitHub] [flink] flinkbot commented on pull request #13197: [FLINK-18995][hive] Some Hive functions fail because they need to acc…

flinkbot commented on pull request #13197: URL: https://github.com/apache/flink/pull/13197#issuecomment-675953571 ## CI report: * 66f8b6582b131697cccebbf4e2ef9f90a7f43825 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

flinkbot edited a comment on pull request #12880: URL: https://github.com/apache/flink/pull/12880#issuecomment-657437173 ## CI report: * 94e8eb39032665f77e897cb572cd4320b66635f9 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

tillrohrmann commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472863712 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int

[jira] [Commented] (FLINK-16408) Bind user code class loader to lifetime of a slot

[ https://issues.apache.org/jira/browse/FLINK-16408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180363#comment-17180363 ] Till Rohrmann commented on FLINK-16408: --- How many concurrent {{WordCount}} jobs do you have

[GitHub] [flink] flinkbot commented on pull request #13199: [FLINK-18953][python][docs] Add documentation for DataTypes in Python DataStream API

flinkbot commented on pull request #13199: URL: https://github.com/apache/flink/pull/13199#issuecomment-676387876 ## CI report: * 9a5329b994ede3de3bc97855a2dc6b302d92bd7b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-18643) Migrate Jenkins jobs to ci-builds.apache.org

[ https://issues.apache.org/jira/browse/FLINK-18643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180565#comment-17180565 ] Robert Metzger commented on FLINK-18643: I haven't considered this. We should be able to

[jira] [Commented] (FLINK-15156) Warn user if System.exit() is called in user code

[ https://issues.apache.org/jira/browse/FLINK-15156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17180573#comment-17180573 ] Stephan Ewen commented on FLINK-15156: -- I assume we only have the Security Manager on the Task

[GitHub] [flink] twalthr opened a new pull request #13200: [FLINK-18553][table-api-java] Update set operations to new type system

twalthr opened a new pull request #13200: URL: https://github.com/apache/flink/pull/13200 ## What is the purpose of the change Updates set operations to the new type system. The result table schema is the common type for each pairwise column types. ## Brief change log

[GitHub] [flink-training] alpinegizmo commented on a change in pull request #13: [FLINK-18630] Redo the LongRideAlerts solutions to cover a corner case

alpinegizmo commented on a change in pull request #13: URL: https://github.com/apache/flink-training/pull/13#discussion_r473075894 ## File path: long-ride-alerts/README.md ## @@ -62,13 +62,11 @@ The resulting stream should be printed to standard out. Overall approach

[GitHub] [flink] flinkbot edited a comment on pull request #13199: [FLINK-18953][python][docs] Add documentation for DataTypes in Python DataStream API

flinkbot edited a comment on pull request #13199: URL: https://github.com/apache/flink/pull/13199#issuecomment-676387876 ## CI report: * 9a5329b994ede3de3bc97855a2dc6b302d92bd7b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

flinkbot edited a comment on pull request #13190: URL: https://github.com/apache/flink/pull/13190#issuecomment-675384858 ## CI report: * 3c4c7fd79fc8e84bcf9afd078e3ec5e6c8629025 Azure:

[GitHub] [flink] zentol commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

zentol commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472941009 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String[]

[GitHub] [flink] NicoK commented on a change in pull request #13180: [FLINK-18962][checkpointing] Improve logging when checkpoint declined

NicoK commented on a change in pull request #13180: URL: https://github.com/apache/flink/pull/13180#discussion_r473012801 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java ## @@ -129,12 +129,10 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #13198: [FLINK-18993][Runtime]Invoke sanityCheckTotalFlinkMemory method incorrectly in JobManagerFlinkMemoryUtils.java

flinkbot edited a comment on pull request #13198: URL: https://github.com/apache/flink/pull/13198#issuecomment-676027592 ## CI report: * f7e89b9ebadf0c8373c09817f327558363fe2751 Azure:

[GitHub] [flink] kl0u commented on a change in pull request #13024: [FLINK-18742][flink-clients] Some configuration args do not take effect at client

kl0u commented on a change in pull request #13024: URL: https://github.com/apache/flink/pull/13024#discussion_r473046293 ## File path: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java ## @@ -219,34 +219,49 @@ protected void run(String[] args) throws

[GitHub] [flink] zentol commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

zentol commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472936802 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,51 @@ private int run(String[]

[jira] [Updated] (FLINK-19001) Add data-stream integration for stateful functions

[ https://issues.apache.org/jira/browse/FLINK-19001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19001: --- Labels: pull-request-available (was: ) > Add data-stream integration for stateful

[jira] [Created] (FLINK-19003) Add micro-benchmark for unaligned checkpoints

Zhijiang created FLINK-19003: Summary: Add micro-benchmark for unaligned checkpoints Key: FLINK-19003 URL: https://issues.apache.org/jira/browse/FLINK-19003 Project: Flink Issue Type: Task

[GitHub] [flink] hequn8128 commented on pull request #13199: [FLINK-18953][python][docs] Add documentation for DataTypes in Python DataStream API

hequn8128 commented on pull request #13199: URL: https://github.com/apache/flink/pull/13199#issuecomment-676369504 CC @sjwiesman @shuiqiangchen This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] zentol commented on a change in pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

zentol commented on a change in pull request #13190: URL: https://github.com/apache/flink/pull/13190#discussion_r472942385 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java ## @@ -96,40 +97,42 @@ private int run(String[]

[GitHub] [flink] wangyang0918 commented on pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

wangyang0918 commented on pull request #13121: URL: https://github.com/apache/flink/pull/13121#issuecomment-676142615 @rmetzger Thanks for your suggestions. I have added two more commits to address your comments. * de1e3d29fe97e5daecddebf4c8c705aba41f10db to update the documentation to

[GitHub] [flink] flinkbot edited a comment on pull request #13190: [FLINK-18986][kubernetes] Create ClusterClient only for attached deployments

flinkbot edited a comment on pull request #13190: URL: https://github.com/apache/flink/pull/13190#issuecomment-675384858 ## CI report: * 3d0ec8202d20e69a2e0f76598566378a28152dd6 Azure:

[GitHub] [flink] rmetzger commented on a change in pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

rmetzger commented on a change in pull request #13121: URL: https://github.com/apache/flink/pull/13121#discussion_r472956028 ## File path: docs/ops/deployment/native_kubernetes.md ## @@ -195,6 +188,28 @@ As always, Jobs may stop when manually canceled or, in the case of

[GitHub] [flink] flinkbot edited a comment on pull request #13121: [FLINK-15793][k8s] Replace kubernetes-entry.sh with unified docker-entrypoint.sh

flinkbot edited a comment on pull request #13121: URL: https://github.com/apache/flink/pull/13121#issuecomment-672466655 ## CI report: * a572964939815f96ee78d0ff1939bf444812b7da Azure:

[GitHub] [flink] dianfu closed pull request #12770: [FLINK-18200][python] Replace the deprecated interfaces with the new interfaces in the tests and examples

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

  1   2   3   >