[jira] [Resolved] (FLINK-24106) Remove notice that python does not support state TTL

2021-09-01 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24106. -- Resolution: Fixed merged master: aa2dddcf1cf9fb6241c4840f9c907530b76dc02a release-1.14:

[GitHub] [flink] flinkbot edited a comment on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-908359102 ## CI report: * da1ab056d42b37d5e36a3121a4827fc7200a6164 UNKNOWN * 16aaadcdc7fa31f94cca6e2f0874ef6b76c57a83 Azure:

[jira] [Commented] (FLINK-24063) Reconsider the behavior of ClusterEntrypoint#startCluster failure handler

2021-09-01 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408551#comment-17408551 ] Yang Wang commented on FLINK-24063: --- Now I think I understand the job in step 4 means the Flink

[GitHub] [flink] Myasuka merged pull request #17099: [FLINK-24106][docs] Remove notice that pyflink does not support state TTL

2021-09-01 Thread GitBox
Myasuka merged pull request #17099: URL: https://github.com/apache/flink/pull/17099 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] Aitozi commented on pull request #17053: [FLINK-24021][HA]Handle curator framework start error by register UnhandledErrorListener before start zk client

2021-09-01 Thread GitBox
Aitozi commented on pull request #17053: URL: https://github.com/apache/flink/pull/17053#issuecomment-911213265 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-09-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408549#comment-17408549 ] Xintong Song commented on FLINK-23493: --

[jira] [Commented] (FLINK-24123) test_dependency.py fails due to 'Failed to close remote bundle'

2021-09-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408548#comment-17408548 ] Xintong Song commented on FLINK-24123: -- cc [~dianfu] [~hxbks2ks] > test_dependency.py fails due to

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #265: [FLINK-24109] Correct egress string serialization

2021-09-01 Thread GitBox
igalshilman commented on a change in pull request #265: URL: https://github.com/apache/flink-statefun/pull/265#discussion_r700754940 ## File path: statefun-sdk-go/v3/pkg/statefun/egress.go ## @@ -78,7 +78,7 @@ func (k KafkaEgressBuilder) toEgressMessage()

[jira] [Created] (FLINK-24123) test_dependency.py fails due to 'Failed to close remote bundle'

2021-09-01 Thread Xintong Song (Jira)
Xintong Song created FLINK-24123: Summary: test_dependency.py fails due to 'Failed to close remote bundle' Key: FLINK-24123 URL: https://issues.apache.org/jira/browse/FLINK-24123 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * Unknown: [CANCELED](TBD) * 4e081b085af12590ca411f2be9f32bfcc32d03f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17099: [FLINK-24106][docs] Remove notice that pyflink does not support state TTL

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17099: URL: https://github.com/apache/flink/pull/17099#issuecomment-910306209 ## CI report: * b3c264fa4dd0f7b2e585ba9d1b8a00d7b4db67c6 Azure:

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #265: [FLINK-24109] Correct egress string serialization

2021-09-01 Thread GitBox
igalshilman commented on a change in pull request #265: URL: https://github.com/apache/flink-statefun/pull/265#discussion_r700751431 ## File path: statefun-sdk-go/v3/pkg/statefun/egress.go ## @@ -78,7 +78,7 @@ func (k KafkaEgressBuilder) toEgressMessage()

[GitHub] [flink] hapihu commented on pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

2021-09-01 Thread GitBox
hapihu commented on pull request #16865: URL: https://github.com/apache/flink/pull/16865#issuecomment-911190205 Sorry, I will resubmit it through rebase later. Thank you for your guidances. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] RocMarshal commented on pull request #16865: [FLINK-23836][doc-zh]Translate "/dev/datastream/execution/execution_c…

2021-09-01 Thread GitBox
RocMarshal commented on pull request #16865: URL: https://github.com/apache/flink/pull/16865#issuecomment-911180419 Hi, @hapihu, Thanks for the contribution. Please do not use "git merge" to rebase branches, otherwise the changes is hard to track. And maybe you could visit the

[jira] [Issue Comment Deleted] (FLINK-15352) develop MySQLCatalog to connect Flink with MySQL tables and ecosystem

2021-09-01 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-15352: Comment: was deleted (was: Could someone help me to advance it ? Thank you.:)) > develop

[GitHub] [flink] flinkbot edited a comment on pull request #17109: [BP-1.14][FLINK-22002][tests] Let taskmanager.slot.timeout fall back to akka.ask.timeout

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17109: URL: https://github.com/apache/flink/pull/17109#issuecomment-910742039 ## CI report: * 1a4b3ce67415e0bda473601a38d481f769d0c7c2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17108: [BP-1.14][FLINK-24091][tests] Harden TaskManagerProcessFailureBatchRecoveryITCase

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17108: URL: https://github.com/apache/flink/pull/17108#issuecomment-910741880 ## CI report: * 85bd6a1ca098223852d3a2929ebcafeb0b469f97 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * Unknown: [CANCELED](TBD) * 4e081b085af12590ca411f2be9f32bfcc32d03f5 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on pull request #17107: [FLINK-24091][tests] Harden TaskManagerProcessFailureBatchRecoveryITCase

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17107: URL: https://github.com/apache/flink/pull/17107#issuecomment-910741663 ## CI report: * ebbfc2ba878235f66c86187181164464e6646e4e Azure:

[jira] [Commented] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-09-01 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408534#comment-17408534 ] liwei li commented on FLINK-20443: -- this is happening in our environment when using the continuous

[GitHub] [flink] hililiwei commented on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-09-01 Thread GitBox
hililiwei commented on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-911162783 @flinkbot run azure -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-911126675 ## CI report: * 8b30569b39cab81ad02bf35d6c6064e8c3cc18b3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17110: [FLINK-24121][flink-python] There are spelling mistakes in the notes.

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17110: URL: https://github.com/apache/flink/pull/17110#issuecomment-911126511 ## CI report: * 0a8f8918be9dd3920c076ada957fbba94bf3aaa5 Azure:

[jira] [Comment Edited] (FLINK-23905) Reduce the load on JobManager when submitting large-scale job with a big user jar

2021-09-01 Thread huntercc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408518#comment-17408518 ] huntercc edited comment on FLINK-23905 at 9/2/21, 3:58 AM: --- Hi [~trohrmann].

[jira] [Comment Edited] (FLINK-23905) Reduce the load on JobManager when submitting large-scale job with a big user jar

2021-09-01 Thread huntercc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408518#comment-17408518 ] huntercc edited comment on FLINK-23905 at 9/2/21, 3:57 AM: --- hi [~trohrmann].

[jira] [Commented] (FLINK-23905) Reduce the load on JobManager when submitting large-scale job with a big user jar

2021-09-01 Thread huntercc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408518#comment-17408518 ] huntercc commented on FLINK-23905: -- Recently, we tried to transform

[GitHub] [flink] flinkbot commented on pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-01 Thread GitBox
flinkbot commented on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-911126675 ## CI report: * 8b30569b39cab81ad02bf35d6c6064e8c3cc18b3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17110: [FLINK-24121][flink-python] There are spelling mistakes in the notes.

2021-09-01 Thread GitBox
flinkbot commented on pull request #17110: URL: https://github.com/apache/flink/pull/17110#issuecomment-911126511 ## CI report: * 0a8f8918be9dd3920c076ada957fbba94bf3aaa5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * a94170622c594ff99903ea583dafe5655bf1e29b Azure:

[GitHub] [flink] tweise commented on pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-01 Thread GitBox
tweise commented on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-94921 @AHeise @stevenzwu please take a look at the deserialization change in general. I'm planning for some more cleanup work on this PR tomorrow but would also like for this to go

[GitHub] [flink] flinkbot commented on pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-01 Thread GitBox
flinkbot commented on pull request #17111: URL: https://github.com/apache/flink/pull/17111#issuecomment-92239 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] [Commented] (FLINK-23836) [doc-zh]Translate "/dev/datastream/execution/execution_configuration.md" into Chinese

2021-09-01 Thread wuguihu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408508#comment-17408508 ] wuguihu commented on FLINK-23836: - Hello, [~jark] , Excuse me for taking up your time. I have finished

[jira] [Commented] (FLINK-23847) [Kafka] Error msg are obscure when KafkaConsumer init, valueDeserializer is null

2021-09-01 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408507#comment-17408507 ] Hang Ruan commented on FLINK-23847: --- The _checkNotNull_ method will throw a _NullPointerException_

[jira] [Commented] (FLINK-23749) Testing Window Join

2021-09-01 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408506#comment-17408506 ] lixiaobao commented on FLINK-23749: --- ok, if i need any help,I will email you. > Testing Window Join >

[GitHub] [flink] tweise opened a new pull request #17111: [FLINK-24064][connector/common] HybridSource restore from savepoint

2021-09-01 Thread GitBox
tweise opened a new pull request #17111: URL: https://github.com/apache/flink/pull/17111 ## What is the purpose of the change Restore from savepoint fails due to deserialization of underlying splits before the underlying enumerator has been restored (details in JIRA). With this

[jira] [Updated] (FLINK-24064) HybridSource recovery from savepoint fails

2021-09-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24064: --- Labels: pull-request-available (was: ) > HybridSource recovery from savepoint fails >

[GitHub] [flink] flinkbot commented on pull request #17110: [FLINK-24121][flink-python] There are spelling mistakes in the notes.

2021-09-01 Thread GitBox
flinkbot commented on pull request #17110: URL: https://github.com/apache/flink/pull/17110#issuecomment-911105763 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] [Comment Edited] (FLINK-24121) There are spelling mistakes in the notes.

2021-09-01 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408502#comment-17408502 ] lixiaobao edited comment on FLINK-24121 at 9/2/21, 3:27 AM: I have corrected

[GitHub] [flink] flinkbot edited a comment on pull request #17099: [FLINK-24106][docs] Remove notice that pyflink does not support state TTL

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17099: URL: https://github.com/apache/flink/pull/17099#issuecomment-910306209 ## CI report: * 895ca9d447a31e81880fdb85039b4d466900804e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17090: [FLINK-24082][python] Fix Python UDTF to handle properly when the result is a generator of Row

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17090: URL: https://github.com/apache/flink/pull/17090#issuecomment-909842676 ## CI report: * fbf565cf0173162a227bafad913398138d02af23 Azure:

[jira] [Comment Edited] (FLINK-24121) There are spelling mistakes in the notes.

2021-09-01 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408502#comment-17408502 ] lixiaobao edited comment on FLINK-24121 at 9/2/21, 3:25 AM: I have corrected

[jira] [Updated] (FLINK-24121) There are spelling mistakes in the notes.

2021-09-01 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lixiaobao updated FLINK-24121: -- Description: There are spelling mistakes in the notes, which have been corrected. {code:java}

[jira] [Commented] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

2021-09-01 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408503#comment-17408503 ] Yang Wang commented on FLINK-22262: --- [~rmetzger] Thanks for reviving this discussion and sharing your

[jira] [Created] (FLINK-24122) Add support to do clean in history server

2021-09-01 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-24122: --- Summary: Add support to do clean in history server Key: FLINK-24122 URL: https://issues.apache.org/jira/browse/FLINK-24122 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24121) There are spelling mistakes in the notes.

2021-09-01 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408502#comment-17408502 ] lixiaobao commented on FLINK-24121: --- I have corrected spelling mistakes. Please assign them to me. >

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

2021-09-01 Thread GitBox
ruanhang1993 commented on a change in pull request #17105: URL: https://github.com/apache/flink/pull/17105#discussion_r700713939 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -281,6 +290,21 @@ public void

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

2021-09-01 Thread GitBox
ruanhang1993 commented on a change in pull request #17105: URL: https://github.com/apache/flink/pull/17105#discussion_r700713939 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -281,6 +290,21 @@ public void

[jira] [Updated] (FLINK-24121) There are spelling mistakes in the notes.

2021-09-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24121: --- Labels: pull-request-available (was: ) > There are spelling mistakes in the notes. >

[GitHub] [flink] q977734161 opened a new pull request #17110: [FLINK-24121][flink-python] There are spelling mistakes in the notes.

2021-09-01 Thread GitBox
q977734161 opened a new pull request #17110: URL: https://github.com/apache/flink/pull/17110 ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): no - The public API, i.e., is any changed class

[jira] [Updated] (FLINK-24121) There are spelling mistakes in the notes.

2021-09-01 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lixiaobao updated FLINK-24121: -- Summary: There are spelling mistakes in the notes. (was: There are spelling mistakes in the notes。)

[jira] [Commented] (FLINK-24113) Introduce option in Application Mode to request cluster shutdown

2021-09-01 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408498#comment-17408498 ] Yang Wang commented on FLINK-24113: --- Maybe we could add an optional argument to the

[jira] [Created] (FLINK-24121) There are spelling mistakes in the notes。

2021-09-01 Thread lixiaobao (Jira)
lixiaobao created FLINK-24121: - Summary: There are spelling mistakes in the notes。 Key: FLINK-24121 URL: https://issues.apache.org/jira/browse/FLINK-24121 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-24120) The memory will rise a little after each savepoint ends

2021-09-01 Thread Jiayi Liao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408497#comment-17408497 ] Jiayi Liao commented on FLINK-24120: Try add an environment variable for taskmanagers:

[jira] [Closed] (FLINK-22850) org.apache.flink.configuration.ConfigOptions.defaultValue() and noDefaultValue() is Deprecated.

2021-09-01 Thread lixiaobao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lixiaobao closed FLINK-22850. - Resolution: Staged > org.apache.flink.configuration.ConfigOptions.defaultValue() and >

[GitHub] [flink] flinkbot edited a comment on pull request #17099: [FLINK-24106][docs] Remove notice that pyflink does not support state TTL

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17099: URL: https://github.com/apache/flink/pull/17099#issuecomment-910306209 ## CI report: * 895ca9d447a31e81880fdb85039b4d466900804e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17090: [FLINK-24082][python] Fix Python UDTF to handle properly when the result is a generator of Row

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17090: URL: https://github.com/apache/flink/pull/17090#issuecomment-909842676 ## CI report: * fbf565cf0173162a227bafad913398138d02af23 Azure:

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

2021-09-01 Thread Hang Ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408491#comment-17408491 ] Hang Ruan commented on FLINK-23828: --- This should have been fixed by 

[GitHub] [flink] flinkbot edited a comment on pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #16598: URL: https://github.com/apache/flink/pull/16598#issuecomment-886655820 ## CI report: * 779cfe076236f909749dad31b5f16e5e17a8a29b Azure:

[jira] [Created] (FLINK-24120) The memory will rise a little after each savepoint ends

2021-09-01 Thread no nO (Jira)
no nO created FLINK-24120: - Summary: The memory will rise a little after each savepoint ends Key: FLINK-24120 URL: https://issues.apache.org/jira/browse/FLINK-24120 Project: Flink Issue Type: Bug

[GitHub] [flink] q977734161 closed pull request #16054: [FLINK-22850][flink-core] Define the type explicitly first with one of the intType(), stringType(), etc

2021-09-01 Thread GitBox
q977734161 closed pull request #16054: URL: https://github.com/apache/flink/pull/16054 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] Myasuka commented on a change in pull request #16969: [FLINK-23949][runtime][checkpoint] fix first incremental checkpoint degenerate into full checkpoint after savepont

2021-09-01 Thread GitBox
Myasuka commented on a change in pull request #16969: URL: https://github.com/apache/flink/pull/16969#discussion_r700697901 ## File path:

[jira] [Assigned] (FLINK-24094) Support DROP PARTITION by partial partition specification

2021-09-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24094: --- Assignee: luoyuxia > Support DROP PARTITION by partial partition specification >

[jira] [Commented] (FLINK-24094) Support DROP PARTITION by partial partition specification

2021-09-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408486#comment-17408486 ] Jark Wu commented on FLINK-24094: - Sure [~luoyuxia] > Support DROP PARTITION by partial partition

[jira] [Closed] (FLINK-23768) Test StreamTableEnvironment batch mode in Python

2021-09-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23768. --- Resolution: Done Test it with the following job: {code} import logging import sys from pyflink.common

[GitHub] [flink] flinkbot edited a comment on pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17105: URL: https://github.com/apache/flink/pull/17105#issuecomment-910456773 ## CI report: * 743397b89cb74407fd00b784c30ffc855a9bfcf2 Azure:

[jira] [Commented] (FLINK-23816) Test new (Kafka) metrics in cluster

2021-09-01 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408476#comment-17408476 ] Huang Xingbo commented on FLINK-23816: -- Ok. I will start testing in these two days. > Test new

[jira] [Closed] (FLINK-24083) The result isn't as expected when the result type is generator of string for Python UDTF

2021-09-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-24083. --- Assignee: Dian Fu Resolution: Fixed Fixed in - master via da1912d546f24349ee687457b3bf8149051212d7 -

[GitHub] [flink] dianfu closed pull request #17091: [FLINK-24083][python] Fix Python UDTF to handle properly when the result is str

2021-09-01 Thread GitBox
dianfu closed pull request #17091: URL: https://github.com/apache/flink/pull/17091 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * fcfa7e6f398fdcc73317c2cbf5f6124e87d2a89c Azure:

[jira] [Closed] (FLINK-24097) Remove the streaming check in StreamTableEnvironment in PyFlink

2021-09-01 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-24097. --- Resolution: Fixed Fixed in - master via f2982cafa1f478ef702d30e4fdbb51bad1968676 - release-1.14 via

[jira] [Commented] (FLINK-12793) Add localKeyBy API to DataStream

2021-09-01 Thread vinoyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408472#comment-17408472 ] vinoyang commented on FLINK-12793: -- Sorry, I no longer follow the Flink project. > Add localKeyBy API

[jira] [Commented] (FLINK-24042) DataStream printToErr doc indicates that it writes to standard output

2021-09-01 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408471#comment-17408471 ] Zili Chen commented on FLINK-24042: --- master via 94d7952a5e80a987e0ee06b57d2d4098d53a4ebc   >

[jira] [Closed] (FLINK-24042) DataStream printToErr doc indicates that it writes to standard output

2021-09-01 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-24042. - Resolution: Fixed > DataStream printToErr doc indicates that it writes to standard output >

[GitHub] [flink] dianfu closed pull request #17094: [FLINK-24097][python] Remove is_streaming_mode checks in StreamTableEnvironment

2021-09-01 Thread GitBox
dianfu closed pull request #17094: URL: https://github.com/apache/flink/pull/17094 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] tisonkun merged pull request #17042: [FLINK-24042] Corrected the description of stderr in DataStream java doc

2021-09-01 Thread GitBox
tisonkun merged pull request #17042: URL: https://github.com/apache/flink/pull/17042 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-12793) Add localKeyBy API to DataStream

2021-09-01 Thread zhengyu.lou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408469#comment-17408469 ] zhengyu.lou commented on FLINK-12793: - Could you please provide some more details and assign this

[GitHub] [flink] zuoniduimian commented on pull request #16949: [FLINK-23242][docs-zh] Translate the page of "Handling Application Parameters" into Chinese

2021-09-01 Thread GitBox
zuoniduimian commented on pull request #16949: URL: https://github.com/apache/flink/pull/16949#issuecomment-911021256 @PatrickRen @wuchong hello,Thank you for your review and comments. Do you think there is anything else that can be modified in my PR? -- This is an automated message

[jira] [Commented] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

2021-09-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408466#comment-17408466 ] Xintong Song commented on FLINK-23047: -- CassandraConnectorITCase.testScalingDown

[jira] [Commented] (FLINK-16346) BlobsCleanupITCase.testBlobServerCleanupCancelledJob fails on Travis

2021-09-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408465#comment-17408465 ] Xintong Song commented on FLINK-16346: -- 1.12:

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-09-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408464#comment-17408464 ] Xintong Song commented on FLINK-23493: --

[jira] [Created] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

2021-09-01 Thread Xintong Song (Jira)
Xintong Song created FLINK-24119: Summary: KafkaITCase.testTimestamps fails due to "Topic xxx already exist" Key: FLINK-24119 URL: https://issues.apache.org/jira/browse/FLINK-24119 Project: Flink

[jira] [Assigned] (FLINK-24105) state TTL might not take effect for pyflink

2021-09-01 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-24105: Assignee: Huang Xingbo > state TTL might not take effect for pyflink >

[GitHub] [flink] flinkbot edited a comment on pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17105: URL: https://github.com/apache/flink/pull/17105#issuecomment-910456773 ## CI report: * 743397b89cb74407fd00b784c30ffc855a9bfcf2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-907189537 ## CI report: * fcfa7e6f398fdcc73317c2cbf5f6124e87d2a89c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16996: [BP-1.13][FLINK-22002][tests] Let taskmanager.slot.timeout fall back to akka.ask.timeout

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #16996: URL: https://github.com/apache/flink/pull/16996#issuecomment-906282952 ## CI report: * 15ee66b04651cad385eebc0049ede4fca7a34e48 Azure:

[jira] [Closed] (FLINK-23814) Test FLIP-143 KafkaSink

2021-09-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-23814. Resolution: Done > Test FLIP-143 KafkaSink > --- > > Key:

[jira] [Commented] (FLINK-23814) Test FLIP-143 KafkaSink

2021-09-01 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408461#comment-17408461 ] Xintong Song commented on FLINK-23814: -- Thanks [~ruanhang1993], closing this ticket. > Test

[GitHub] [flink] mans2singh commented on pull request #17042: [FLINK-24042] Updated javadoc to indicate printToErr writes to standard error stream

2021-09-01 Thread GitBox
mans2singh commented on pull request #17042: URL: https://github.com/apache/flink/pull/17042#issuecomment-910999594 @leonardBang @tisonkun - I've updated the javadoc of DataStream.scala as you had recommended. Please let me know if you have any additional advice for me. Thanks again for

[GitHub] [flink] flinkbot edited a comment on pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #16598: URL: https://github.com/apache/flink/pull/16598#issuecomment-886655820 ## CI report: * 7f5e2749090dbdccf18a6a3ae4c899ac432808bb Azure:

[GitHub] [flink] lometheus commented on pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

2021-09-01 Thread GitBox
lometheus commented on pull request #17024: URL: https://github.com/apache/flink/pull/17024#issuecomment-910969955 I squash all my commits into one , thinks for your review and patiently answer again > P.S. Please, squash your commits into one(and you can rebase onto the fresh

[GitHub] [flink] lometheus commented on a change in pull request #17024: [FLINK-23457][network] The upstream sends the buffer of the right size for broadcast case

2021-09-01 Thread GitBox
lometheus commented on a change in pull request #17024: URL: https://github.com/apache/flink/pull/17024#discussion_r700666840 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -330,8 +330,16 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17042: [FLINK-24042] Updated javadoc to indicate printToErr writes to standard error stream

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17042: URL: https://github.com/apache/flink/pull/17042#issuecomment-907889674 ## CI report: * 7766b5c615d93fc89dc9727850c5b105ff76ae48 Azure:

[jira] [Comment Edited] (FLINK-24094) Support DROP PARTITION by partial partition specification

2021-09-01 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408443#comment-17408443 ] luoyuxia edited comment on FLINK-24094 at 9/2/21, 12:08 AM: [~leexu] Thanks

[jira] [Commented] (FLINK-24094) Support DROP PARTITION by partial partition specification

2021-09-01 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17408443#comment-17408443 ] luoyuxia commented on FLINK-24094: -- Yeah, hive supoorts it. But I can't figure out why it shouldn't be

[GitHub] [flink] flinkbot edited a comment on pull request #17042: [FLINK-24042] Updated javadoc to indicate printToErr writes to standard error stream

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17042: URL: https://github.com/apache/flink/pull/17042#issuecomment-907889674 ## CI report: * 7766b5c615d93fc89dc9727850c5b105ff76ae48 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-09-01 Thread GitBox
flinkbot edited a comment on pull request #17106: URL: https://github.com/apache/flink/pull/17106#issuecomment-910662440 ## CI report: * bc06f66402036c872851c92a4d64a27a7bef918b UNKNOWN * b28a0ecfa7d97a27b4ba806f23c301c27e32d1bb Azure:

[jira] [Updated] (FLINK-23016) Job client must be a Coordination Request Gateway when submit a job on web ui

2021-09-01 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23016: --- Labels: auto-deprioritized-critical stale-major (was: auto-deprioritized-critical) I am

[jira] [Updated] (FLINK-22234) Read savepoint before creating ExecutionGraph

2021-09-01 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22234: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available

[jira] [Updated] (FLINK-24118) enable TaxiFareGenerator to produce a bounded stream

2021-09-01 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24118: --- Labels: pull-request-available (was: ) > enable TaxiFareGenerator to produce a bounded

[GitHub] [flink-training] alpinegizmo opened a new pull request #40: [FLINK-24118] Allow TaxiFareGenerator to produce bounded streams

2021-09-01 Thread GitBox
alpinegizmo opened a new pull request #40: URL: https://github.com/apache/flink-training/pull/40 I want to leverage this in a new exercise (or two). -- 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

  1   2   3   4   5   6   7   8   >