[jira] [Updated] (FLINK-20147) "Invalid lambda deserialization" when trying to read metadata from Kafka in SQL

[ https://issues.apache.org/jira/browse/FLINK-20147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20147: --- Labels: pull-request-available (was: ) > "Invalid lambda deserialization" when trying to

[jira] [Updated] (FLINK-20161) Consider switching from Travis CI to Github Actions for flink-statefun's CI workflows

[ https://issues.apache.org/jira/browse/FLINK-20161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20161: --- Labels: pull-request-available (was: ) > Consider switching from Travis CI to Github

[GitHub] [flink] twalthr opened a new pull request #14081: [FLINK-20147][connector-kafka] Replace lambdas with classes to prevent serialization issues

twalthr opened a new pull request #14081: URL: https://github.com/apache/flink/pull/14081 ## What is the purpose of the change Replaces lambdas with anonymous classes to prevent deserialization issues during runtime after shading. ## Brief change log - Fix the Kafka

[GitHub] [flink-statefun] tzulitai opened a new pull request #174: [FLINK-20161] Switch from Travis to Github Actions for CI

tzulitai opened a new pull request #174: URL: https://github.com/apache/flink-statefun/pull/174 Travis-CI.com recently announced a new pricing model on Nov. 2, which affects public open source projects: https://blog.travis-ci.com/2020-11-02-travis-ci-new-billing It seems like the

[GitHub] [flink] wangyang0918 commented on a change in pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

wangyang0918 commented on a change in pull request #14006: URL: https://github.com/apache/flink/pull/14006#discussion_r524077381 ## File path: docs/ops/jobmanager_high_availability.md ## @@ -215,6 +215,76 @@ Starting zookeeper daemon on host localhost. $

[jira] [Updated] (FLINK-19996) Add end-to-end IT case for Debezium + Kafka + temporal join

[ https://issues.apache.org/jira/browse/FLINK-19996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19996: --- Labels: pull-request-available (was: ) > Add end-to-end IT case for Debezium + Kafka +

[GitHub] [flink] flinkbot commented on pull request #14080: [FLINK-19996][e2e] Add end-to-end IT case for Debezium + Kafka + temporal join

flinkbot commented on pull request #14080: URL: https://github.com/apache/flink/pull/14080#issuecomment-727880453 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] [Assigned] (FLINK-20073) Add kerberos setup documentation for native k8s integration

[ https://issues.apache.org/jira/browse/FLINK-20073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20073: Assignee: Yangze Guo > Add kerberos setup documentation for native k8s integration >

[GitHub] [flink] flinkbot commented on pull request #14079: [FLINK-19182][doc] Update documents for intra-slot managed memory sharing.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

flinkbot edited a comment on pull request #14076: URL: https://github.com/apache/flink/pull/14076#issuecomment-727741544 ## CI report: * 6082a1d0c0f4274e553de47fae1285537c38ace8 Azure:

[GitHub] [flink] leonardBang opened a new pull request #14080: [FLINK-1996][e2e] Add end-to-end IT case for Debezium + Kafka + temporal join

leonardBang opened a new pull request #14080: URL: https://github.com/apache/flink/pull/14080 ## What is the purpose of the change * Debezium + Kafka + temporal join is the most important use case when we propose FLIP-132. The blocker FLINK-19276 ha been finished, so this PR add a

[jira] [Updated] (FLINK-1996) Add output methods to Table API

[ https://issues.apache.org/jira/browse/FLINK-1996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-1996: -- Labels: pull-request-available (was: ) > Add output methods to Table API >

[GitHub] [flink] flinkbot edited a comment on pull request #14078: [FLINK-20169] Move emitting MAX_WATERMARK out of the SourceOperator processing loop

flinkbot edited a comment on pull request #14078: URL: https://github.com/apache/flink/pull/14078#issuecomment-727863911 ## CI report: * 2b82b9448e3bb43d3e7da50bce557f50c07ae19b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14032: [FLINK-19863][tests] check hbase has been ready before use it

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

[GitHub] [flink] flinkbot edited a comment on pull request #14017: [FLINK-19859][document] Add document for the upsert-kafka connector

flinkbot edited a comment on pull request #14017: URL: https://github.com/apache/flink/pull/14017#issuecomment-724665676 ## CI report: * 7dff1e172e3b99d819cfc1cbc1eedf71bea94626 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13865: [FLINK-19906][table-planner] Fix incorrect result when compare two binary fields

flinkbot edited a comment on pull request #13865: URL: https://github.com/apache/flink/pull/13865#issuecomment-719958332 ## CI report: * 88be9c211877f0ad5778efdd35359f8e138b9e8b Azure:

[jira] [Created] (FLINK-20170) json deserialize loses precision

Mulan created FLINK-20170: - Summary: json deserialize loses precision Key: FLINK-20170 URL: https://issues.apache.org/jira/browse/FLINK-20170 Project: Flink Issue Type: Improvement

[GitHub] [flink] fsk119 commented on a change in pull request #14017: [FLINK-19859][document] Add document for the upsert-kafka connector

fsk119 commented on a change in pull request #14017: URL: https://github.com/apache/flink/pull/14017#discussion_r524060554 ## File path: docs/dev/table/connectors/upsert-kafka.md ## @@ -0,0 +1,204 @@ +--- +title: "Upsert Kafka SQL Connector" +nav-title: Upsert Kafka

[jira] [Commented] (FLINK-20149) SQLClientKafkaITCase.testKafka failed with "Did not get expected results before timeout."

[ https://issues.apache.org/jira/browse/FLINK-20149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232662#comment-17232662 ] Aljoscha Krettek commented on FLINK-20149: -- Sorry about this one, I saw the "test instability"

[jira] [Commented] (FLINK-19687) Support to get execution plan in `StatementSet`

[ https://issues.apache.org/jira/browse/FLINK-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232660#comment-17232660 ] xiaozilong commented on FLINK-19687: Hi [~jark], Could you talk about your thoughts about this

[GitHub] [flink] flinkbot commented on pull request #14079: [FLINK-19182][doc] Update documents for intra-slot managed memory sharing.

flinkbot commented on pull request #14079: URL: https://github.com/apache/flink/pull/14079#issuecomment-727870457 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] tillrohrmann commented on a change in pull request #14076: [FLINK-19775][test] SystemProcessingTimeServiceTest.testImmediateShutdown is instable

tillrohrmann commented on a change in pull request #14076: URL: https://github.com/apache/flink/pull/14076#discussion_r524052550 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/OneShotLatch.java ## @@ -61,7 +61,11 @@

[GitHub] [flink] kl0u commented on pull request #14070: [FLINK-20152] Document supported execution.target values

kl0u commented on pull request #14070: URL: https://github.com/apache/flink/pull/14070#issuecomment-727869410 Yes, I agree that this must happen and maybe even have a verification somewhere. I will merge this for now and then open an umbrella issue about documenting the relevant options

[GitHub] [flink] xintongsong commented on pull request #14079: [FLINK-19182][doc] Update documents for intra-slot managed memory sharing.

xintongsong commented on pull request #14079: URL: https://github.com/apache/flink/pull/14079#issuecomment-727869540 cc @KarmaGYZ This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] xintongsong opened a new pull request #14079: [FLINK-19182][doc] Update documents for intra-slot managed memory sharing.

xintongsong opened a new pull request #14079: URL: https://github.com/apache/flink/pull/14079 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Updated] (FLINK-19182) Update document for intra-slot managed memory sharing

[ https://issues.apache.org/jira/browse/FLINK-19182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19182: --- Labels: pull-request-available (was: ) > Update document for intra-slot managed memory

[GitHub] [flink] tillrohrmann commented on a change in pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

tillrohrmann commented on a change in pull request #14006: URL: https://github.com/apache/flink/pull/14006#discussion_r524048796 ## File path: docs/ops/jobmanager_high_availability.md ## @@ -215,6 +215,76 @@ Starting zookeeper daemon on host localhost. $

[GitHub] [flink] tzulitai commented on a change in pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

tzulitai commented on a change in pull request #14042: URL: https://github.com/apache/flink/pull/14042#discussion_r524049020 ## File path: flink-core/src/main/java/org/apache/flink/util/IOUtils.java ## @@ -143,6 +143,30 @@ public static void readFully(final InputStream in,

[GitHub] [flink] tillrohrmann commented on a change in pull request #14006: [FLINK-19546][doc] Add documentation for native Kubernetes HA

tillrohrmann commented on a change in pull request #14006: URL: https://github.com/apache/flink/pull/14006#discussion_r524047117 ## File path: docs/ops/jobmanager_high_availability.md ## @@ -215,6 +215,76 @@ Starting zookeeper daemon on host localhost. $

[jira] [Updated] (FLINK-20167) Rework the high availability documentation

[ https://issues.apache.org/jira/browse/FLINK-20167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20167: -- Fix Version/s: 1.12.0 > Rework the high availability documentation >

[jira] [Updated] (FLINK-20167) Rework the high availability documentation

[ https://issues.apache.org/jira/browse/FLINK-20167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20167: -- Labels: usability (was: ) > Rework the high availability documentation >

[jira] [Updated] (FLINK-20167) Rework the high availability documentation

[ https://issues.apache.org/jira/browse/FLINK-20167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20167: -- Affects Version/s: 1.12.0 > Rework the high availability documentation >

[jira] [Updated] (FLINK-20167) Rework the high availability documentation

[ https://issues.apache.org/jira/browse/FLINK-20167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20167: -- Component/s: Runtime / Coordination > Rework the high availability documentation >

[GitHub] [flink] tillrohrmann commented on a change in pull request #14070: [FLINK-20152] Document supported execution.target values

tillrohrmann commented on a change in pull request #14070: URL: https://github.com/apache/flink/pull/14070#discussion_r524041071 ## File path: flink-core/src/main/java/org/apache/flink/configuration/DeploymentOptions.java ## @@ -34,7 +36,16 @@

[jira] [Updated] (FLINK-20167) Rework the high availability documentation

[ https://issues.apache.org/jira/browse/FLINK-20167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20167: -- Priority: Major (was: Minor) > Rework the high availability documentation >

[GitHub] [flink] flinkbot commented on pull request #14078: [FLINK-20169] Move emitting MAX_WATERMARK out of the SourceOperator processing loop

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

[GitHub] [flink] flinkbot edited a comment on pull request #14070: [FLINK-20152] Document supported execution.target values

flinkbot edited a comment on pull request #14070: URL: https://github.com/apache/flink/pull/14070#issuecomment-726978459 ## CI report: * cbf96e7bb990402b6e591d1f829d55d1e3b2cd01 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13865: [FLINK-19906][table-planner] Fix incorrect result when compare two binary fields

flinkbot edited a comment on pull request #13865: URL: https://github.com/apache/flink/pull/13865#issuecomment-719958332 ## CI report: * 88be9c211877f0ad5778efdd35359f8e138b9e8b Azure:

[GitHub] [flink] aljoscha commented on a change in pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

aljoscha commented on a change in pull request #14061: URL: https://github.com/apache/flink/pull/14061#discussion_r524038494 ## File path: docs/dev/connectors/file_sink.md ## @@ -768,7 +768,12 @@ and Flink will throw an exception. normal job termination (*e.g.* finite input

[GitHub] [flink] tillrohrmann commented on a change in pull request #14070: [FLINK-20152] Document supported execution.target values

tillrohrmann commented on a change in pull request #14070: URL: https://github.com/apache/flink/pull/14070#discussion_r524037208 ## File path: flink-core/src/main/java/org/apache/flink/configuration/DeploymentOptions.java ## @@ -34,7 +34,13 @@

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

[ https://issues.apache.org/jira/browse/FLINK-20162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232656#comment-17232656 ] Timo Walther commented on FLINK-20162: -- [~jark] I'm about to open a PR to make adding built-in

[GitHub] [flink] azagrebin commented on a change in pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

azagrebin commented on a change in pull request #14061: URL: https://github.com/apache/flink/pull/14061#discussion_r524035582 ## File path: docs/dev/connectors/index.zh.md ## @@ -43,6 +43,7 @@ under the License. * [Amazon Kinesis Streams](kinesis.html) (source/sink) *

[GitHub] [flink] azagrebin commented on a change in pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

azagrebin commented on a change in pull request #14061: URL: https://github.com/apache/flink/pull/14061#discussion_r524035582 ## File path: docs/dev/connectors/index.zh.md ## @@ -43,6 +43,7 @@ under the License. * [Amazon Kinesis Streams](kinesis.html) (source/sink) *

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232653#comment-17232653 ] Till Rohrmann commented on FLINK-17726: --- I think we first need a design because there were still

[jira] [Commented] (FLINK-20118) Test New File Source API - Continuous Streaming Execution

[ https://issues.apache.org/jira/browse/FLINK-20118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232648#comment-17232648 ] Andrey Zagrebin commented on FLINK-20118: - I suggest to write an e2e test which generates random

[GitHub] [flink] kl0u commented on a change in pull request #14070: [FLINK-20152] Document supported execution.target values

kl0u commented on a change in pull request #14070: URL: https://github.com/apache/flink/pull/14070#discussion_r523984081 ## File path: flink-core/src/main/java/org/apache/flink/configuration/DeploymentOptions.java ## @@ -34,7 +34,13 @@

[GitHub] [flink] flinkbot commented on pull request #14078: [FLINK-20169] Move emitting MAX_WATERMARK out of the SourceOperator processing loop

flinkbot commented on pull request #14078: URL: https://github.com/apache/flink/pull/14078#issuecomment-727856308 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-16753) Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException

[ https://issues.apache.org/jira/browse/FLINK-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232649#comment-17232649 ] Nico Kruber commented on FLINK-16753: - Merged in * release-1.11:

[GitHub] [flink] NicoK merged pull request #14071: [FLINK-16753] Use CheckpointException to wrap exceptions thrown from AsyncCheckpointRnnable

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

[jira] [Updated] (FLINK-16753) Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException

[ https://issues.apache.org/jira/browse/FLINK-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-16753: Fix Version/s: 1.11.3 1.10.3 > Exception from AsyncCheckpointRunnable should

[jira] [Commented] (FLINK-20145) Streaming job fails with IllegalStateException: Should only poll priority events

[ https://issues.apache.org/jira/browse/FLINK-20145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232647#comment-17232647 ] Robert Metzger commented on FLINK-20145: Running on this commit:

[jira] [Updated] (FLINK-20169) Move emitting MAX_WATERMARK out of SourceOperator processing loop

[ https://issues.apache.org/jira/browse/FLINK-20169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20169: --- Labels: pull-request-available (was: ) > Move emitting MAX_WATERMARK out of SourceOperator

[GitHub] [flink] dawidwys opened a new pull request #14078: [FLINK-20169] Move emitting MAX_WATERMARK out of the SourceOperator processing loop

dawidwys opened a new pull request #14078: URL: https://github.com/apache/flink/pull/14078 ## What is the purpose of the change This commit reverts some of the changes introduced in fada6fb6ac9fd7f6510f1f2d77b6baa06563e222. Instead of checking for END_OF_INPUT in the

[GitHub] [flink] flinkbot edited a comment on pull request #14075: [FLINK-20163][docs-zh] Translate page "raw format" into Chinese

flinkbot edited a comment on pull request #14075: URL: https://github.com/apache/flink/pull/14075#issuecomment-727598953 ## CI report: * 08214d0608cf8a45395d003dc136a3e51eb1db68 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14070: [FLINK-20152] Document supported execution.target values

flinkbot edited a comment on pull request #14070: URL: https://github.com/apache/flink/pull/14070#issuecomment-726978459 ## CI report: * cbf96e7bb990402b6e591d1f829d55d1e3b2cd01 Azure:

[GitHub] [flink] NicoK merged pull request #14072: [FLINK-16753][checkpointing] Use CheckpointException to wrap exceptio…

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

[jira] [Commented] (FLINK-19161) Port File Sources to FLIP-27 API

[ https://issues.apache.org/jira/browse/FLINK-19161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232640#comment-17232640 ] Andrey Zagrebin commented on FLINK-19161: - Is there a plan to also add some dedicated chapter(s)

[jira] [Commented] (FLINK-20165) YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred during initialization of boot layer java.lang.IllegalStateException: Module system already initiali

[ https://issues.apache.org/jira/browse/FLINK-20165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232636#comment-17232636 ] Robert Metzger commented on FLINK-20165: Yes >

[jira] [Created] (FLINK-20169) Move emitting MAX_WATERMARK out of SourceOperator processing loop

Dawid Wysakowicz created FLINK-20169: Summary: Move emitting MAX_WATERMARK out of SourceOperator processing loop Key: FLINK-20169 URL: https://issues.apache.org/jira/browse/FLINK-20169 Project:

[jira] [Assigned] (FLINK-20165) YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred during initialization of boot layer java.lang.IllegalStateException: Module system already initializ

[ https://issues.apache.org/jira/browse/FLINK-20165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-20165: -- Assignee: Robert Metzger > YARNSessionFIFOITCase.checkForProhibitedLogContents:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

gaoyunhaii commented on a change in pull request #14061: URL: https://github.com/apache/flink/pull/14061#discussion_r524006896 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -765,6 +765,7 @@ and Flink will throw an exception. normal job termination (*e.g.* finite

[jira] [Commented] (FLINK-16753) Exception from AsyncCheckpointRunnable should be wrapped in CheckpointException

[ https://issues.apache.org/jira/browse/FLINK-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232632#comment-17232632 ] Nico Kruber commented on FLINK-16753: - You can actually also consider this a bug that the wrong

[jira] [Updated] (FLINK-20166) FlinkKafkaProducerITCase.testRunOutOfProducersInThePool failed with "CheckpointException: Could not complete snapshot 1 for operator MockTask (1/1)#0. Failure reason: Ch

[ https://issues.apache.org/jira/browse/FLINK-20166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20166: -- Priority: Critical (was: Major) > FlinkKafkaProducerITCase.testRunOutOfProducersInThePool

[jira] [Commented] (FLINK-20165) YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred during initialization of boot layer java.lang.IllegalStateException: Module system already initiali

[ https://issues.apache.org/jira/browse/FLINK-20165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232624#comment-17232624 ] Till Rohrmann commented on FLINK-20165: --- cc [~rmetzger] could you take a look at this problem? >

[jira] [Updated] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-16908: -- Priority: Critical (was: Major) > FlinkKafkaProducerITCase testScaleUpAfterScalingDown

[jira] [Updated] (FLINK-20165) YARNSessionFIFOITCase.checkForProhibitedLogContents: Error occurred during initialization of boot layer java.lang.IllegalStateException: Module system already initialize

[ https://issues.apache.org/jira/browse/FLINK-20165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20165: -- Priority: Critical (was: Major) > YARNSessionFIFOITCase.checkForProhibitedLogContents: Error

[GitHub] [flink] dianfu commented on a change in pull request #14068: [FLINK-200137][python] Emit timestamps of current records to downstream in PythonFunctionOperator.

dianfu commented on a change in pull request #14068: URL: https://github.com/apache/flink/pull/14068#discussion_r523956531 ## File path: flink-python/pyflink/datastream/functions.py ## @@ -637,6 +639,32 @@ def time_domain(self) -> TimeDomain: pass +class

[GitHub] [flink] flinkbot edited a comment on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

flinkbot edited a comment on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-726585261 ## CI report: * 6fe31d3968af835ed0ce694d2ed6193c11173f5f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

flinkbot edited a comment on pull request #14042: URL: https://github.com/apache/flink/pull/14042#issuecomment-725744439 ## CI report: * e3b7dd66064055ba3fac57199e8a5acc7f00a38b Azure:

[GitHub] [flink] wuchong commented on a change in pull request #14017: [FLINK-19859][document] Add document for the upsert-kafka connector

wuchong commented on a change in pull request #14017: URL: https://github.com/apache/flink/pull/14017#discussion_r521988727 ## File path: docs/dev/table/connectors/upsert-kafka.md ## @@ -43,7 +43,7 @@ To use the connector, add the following Maven dependency to your project:

[GitHub] [flink] kl0u commented on a change in pull request #14070: [FLINK-20152] Document supported execution.target values

kl0u commented on a change in pull request #14070: URL: https://github.com/apache/flink/pull/14070#discussion_r523984081 ## File path: flink-core/src/main/java/org/apache/flink/configuration/DeploymentOptions.java ## @@ -34,7 +34,13 @@

[GitHub] [flink] kl0u commented on pull request #14070: [FLINK-20152] Document supported execution.target values

kl0u commented on pull request #14070: URL: https://github.com/apache/flink/pull/14070#issuecomment-727835205 I integrated your comments @tillrohrmann , let me know what you think. This is an automated message from the

[GitHub] [flink] kl0u commented on a change in pull request #14070: [FLINK-20152] Document supported execution.target values

kl0u commented on a change in pull request #14070: URL: https://github.com/apache/flink/pull/14070#discussion_r523984081 ## File path: flink-core/src/main/java/org/apache/flink/configuration/DeploymentOptions.java ## @@ -34,7 +34,13 @@

[GitHub] [flink] wuchong commented on a change in pull request #14017: [FLINK-19859][document] Add document for the upsert-kafka connector

wuchong commented on a change in pull request #14017: URL: https://github.com/apache/flink/pull/14017#discussion_r523979437 ## File path: docs/dev/table/connectors/upsert-kafka.md ## @@ -0,0 +1,204 @@ +--- +title: "Upsert Kafka SQL Connector" +nav-title: Upsert Kafka

[GitHub] [flink] flinkbot edited a comment on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

flinkbot edited a comment on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-726585261 ## CI report: * 6fe31d3968af835ed0ce694d2ed6193c11173f5f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

flinkbot edited a comment on pull request #14042: URL: https://github.com/apache/flink/pull/14042#issuecomment-725744439 ## CI report: * e3b7dd66064055ba3fac57199e8a5acc7f00a38b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14020: [FLINK-20078][coordination] Factor out an ExecutionGraph factory method for DefaultExecutionTopology

flinkbot edited a comment on pull request #14020: URL: https://github.com/apache/flink/pull/14020#issuecomment-724735089 ## CI report: * bb25d7f6325759f7400ae0b5728d41d478784659 UNKNOWN * c7df499afee4829fd30823f277597e04de20a8f2 Azure:

[GitHub] [flink] wuchong commented on a change in pull request #14075: [FLINK-20163][docs-zh] Translate page "raw format" into Chinese

wuchong commented on a change in pull request #14075: URL: https://github.com/apache/flink/pull/14075#discussion_r523971408 ## File path: docs/dev/table/connectors/formats/raw.zh.md ## @@ -78,105 +78,105 @@ FROM( -In contrast, you can also write a single column of STRING

[GitHub] [flink] tzulitai commented on pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

tzulitai commented on pull request #14042: URL: https://github.com/apache/flink/pull/14042#issuecomment-727824916 LGTM, giving another CI run before merging. This is an automated message from the Apache Git Service. To

[GitHub] [flink] tzulitai commented on pull request #14042: [FLINK-19300][flink-core] Fix input stream read to prevent heap based timer loss

tzulitai commented on pull request #14042: URL: https://github.com/apache/flink/pull/14042#issuecomment-727824057 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-20145) Streaming job fails with IllegalStateException: Should only poll priority events

[ https://issues.apache.org/jira/browse/FLINK-20145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17232605#comment-17232605 ] Roman Khachatryan commented on FLINK-20145: --- Sure, I just wanted to see whether it indeed

[GitHub] [flink] flinkbot edited a comment on pull request #13991: [FLINK-19983][network] Remove wrong state checking in SortMergeSubpartitionReader

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

[GitHub] [flink] flinkbot edited a comment on pull request #13998: [FLINK-20062][hive] ContinuousHiveSplitEnumerator should be lock-free

flinkbot edited a comment on pull request #13998: URL: https://github.com/apache/flink/pull/13998#issuecomment-724001789 ## CI report: * 530e65e61ae94f952ffb682f0573071724da27d6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13900: [FLINK-19949][csv] Unescape CSV format line delimiter character

flinkbot edited a comment on pull request #13900: URL: https://github.com/apache/flink/pull/13900#issuecomment-720989833 ## CI report: * d9e47451664a976692e4e6110bbffa2842f2ae7a UNKNOWN * c9a24a3ac861addff4a26ffa47cffd38db7427ae Azure:

[GitHub] [flink] kl0u commented on pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

kl0u commented on pull request #14061: URL: https://github.com/apache/flink/pull/14061#issuecomment-727812701 Thanks for the comments @gaoyunhaii ! I integrated them and I think that also the chinese translation has to be updated. Let me know what you think.

[GitHub] [flink] kl0u commented on a change in pull request #14061: [FLINK-20141][fs-connector] Add FileSink documentation

kl0u commented on a change in pull request #14061: URL: https://github.com/apache/flink/pull/14061#discussion_r523956778 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -765,6 +765,7 @@ and Flink will throw an exception. normal job termination (*e.g.* finite input

<    2   3   4   5   6   7