[jira] [Updated] (FLINK-22757) Update GCS documentation

2021-05-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22757: - Priority: Major (was: Minor) > Update GCS documentation > > >

[jira] [Assigned] (FLINK-22757) Update GCS documentation

2021-05-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-22757: Assignee: Ankush Khanna > Update GCS documentation > > >

[GitHub] [flink] wuchong merged pull request #15949: [FLINK-22319][table][sql-client] Support RESET table option for ALTER TABLE statement

2021-05-25 Thread GitBox
wuchong merged pull request #15949: URL: https://github.com/apache/flink/pull/15949 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[jira] [Updated] (FLINK-22757) Update GCS documentation

2021-05-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22757: - Affects Version/s: 1.13.0 1.12.4 > Update GCS documentation >

[jira] [Commented] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

2021-05-25 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351443#comment-17351443 ] Guowei Ma commented on FLINK-22593: ---

[jira] [Issue Comment Deleted] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

2021-05-25 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22593: -- Comment: was deleted (was:

[jira] [Created] (FLINK-22779) KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due to ConcurrentModificationException

2021-05-25 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22779: - Summary: KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due to ConcurrentModificationException Key: FLINK-22779 URL: https://issues.apache.org/jira/browse/FLINK-22779

[jira] [Commented] (FLINK-22779) KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due to ConcurrentModificationException

2021-05-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351475#comment-17351475 ] Jark Wu commented on FLINK-22779: - I will cherry-pick FLINK-22203 to release-1.13. >

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-25 Thread GitBox
stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r639409914 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -0,0 +1,216 @@

[jira] [Updated] (FLINK-22777) Restore lost parts of Datastream API Try Flink example

2021-05-25 Thread Stefan Gloutnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Gloutnikov updated FLINK-22777: -- Summary: Restore lost parts of Datastream API Try Flink example (was: Recover lost

[jira] [Commented] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

2021-05-25 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351455#comment-17351455 ] Guowei Ma commented on FLINK-22545: ---

[jira] [Updated] (FLINK-22777) Recover lost parts of Datastream API Try Flink example

2021-05-25 Thread Stefan Gloutnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Gloutnikov updated FLINK-22777: -- Labels: pull-request-available (was: pull) > Recover lost parts of Datastream API

[GitHub] [flink] flinkbot edited a comment on pull request #15925: [FLINK-21464][sql-client] Support ADD JAR in SQL Client

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15925: URL: https://github.com/apache/flink/pull/15925#issuecomment-841952583 ## CI report: * 8119d476fa59a7aa35f09c84e285226ff9b3e238 UNKNOWN * 11ad41f163563ed6ff73d0ba081106173c807158 Azure:

[GitHub] [flink] flinkbot commented on pull request #16003: [FLINK-22777][docs] Restore full DataStream API fraud detection example in Try Flink section

2021-05-25 Thread GitBox
flinkbot commented on pull request #16003: URL: https://github.com/apache/flink/pull/16003#issuecomment-848423852 ## CI report: * 1004456375a0dce7944de312c6002b92c391656e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-22778) Upgrade to JUnit 4.13

2021-05-25 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-22778: Summary: Upgrade to JUnit 4.13 Key: FLINK-22778 URL: https://issues.apache.org/jira/browse/FLINK-22778 Project: Flink Issue Type: Improvement

[GitHub] [flink] Samuel-Fiddis commented on pull request #15808: [FLINK-21229] add confluent schema registry ssl support

2021-05-25 Thread GitBox
Samuel-Fiddis commented on pull request #15808: URL: https://github.com/apache/flink/pull/15808#issuecomment-848452599 Will this change allow for the basic auth credentials to be passed to the confluent schema registry? i.e. will this PR solve the problem detailed here:

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-25 Thread GitBox
stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r639410926 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -0,0 +1,216 @@

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-25 Thread GitBox
stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r639419719 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -0,0 +1,216 @@

[jira] [Commented] (FLINK-22776) Delete casting to byte[]

2021-05-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351449#comment-17351449 ] Ada Wong commented on FLINK-22776: -- [~Leonard Xu] > Delete casting to byte[] >

[jira] [Comment Edited] (FLINK-22776) Delete casting to byte[]

2021-05-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351449#comment-17351449 ] Ada Wong edited comment on FLINK-22776 at 5/26/21, 2:43 AM: cc [~Leonard Xu]

[jira] [Created] (FLINK-22776) Delete casting to byte[]

2021-05-25 Thread Ada Wong (Jira)
Ada Wong created FLINK-22776: Summary: Delete casting to byte[] Key: FLINK-22776 URL: https://issues.apache.org/jira/browse/FLINK-22776 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-22748) Allow dynamic target topic selection in SQL Kafka sinks

2021-05-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351458#comment-17351458 ] Jark Wu commented on FLINK-22748: - I think [~twalthr] means means the "topic" metadata column [1] to

[GitHub] [flink] beyond1920 commented on pull request #15997: [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

2021-05-25 Thread GitBox
beyond1920 commented on pull request #15997: URL: https://github.com/apache/flink/pull/15997#issuecomment-848429827 @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 #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 1685626df39ea331106f6b3f7d4f63f506a17f41 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16003: [FLINK-22777][docs] Restore full DataStream API fraud detection example in Try Flink section

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #16003: URL: https://github.com/apache/flink/pull/16003#issuecomment-848423852 ## CI report: * 1004456375a0dce7944de312c6002b92c391656e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15997: [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15997: URL: https://github.com/apache/flink/pull/15997#issuecomment-847752911 ## CI report: * 6582c68a14a6121adfd602be9f47f35f72ae0b3e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16004: [FLINK-22778] Upgrade to JUnit 4.13

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #16004: URL: https://github.com/apache/flink/pull/16004#issuecomment-848440913 ## CI report: * 781b8a67014a8b2748d196c3efb369bb767853c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16003: [FLINK-22777][docs] Restore full DataStream API fraud detection example in Try Flink section

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #16003: URL: https://github.com/apache/flink/pull/16003#issuecomment-848423852 ## CI report: * 1004456375a0dce7944de312c6002b92c391656e Azure:

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-25 Thread GitBox
stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r639411705 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -0,0 +1,216 @@

[jira] [Comment Edited] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

2021-05-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351424#comment-17351424 ] Nicholas Jiang edited comment on FLINK-22698 at 5/26/21, 1:51 AM: --

[jira] [Closed] (FLINK-22319) Support RESET table option for ALTER TABLE statement

2021-05-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22319. --- Fix Version/s: 1.14.0 Assignee: Jane Chan Resolution: Fixed Fixed in master:

[jira] [Created] (FLINK-22777) Recover lost parts of Datastream API Try Flink example

2021-05-25 Thread Stefan Gloutnikov (Jira)
Stefan Gloutnikov created FLINK-22777: - Summary: Recover lost parts of Datastream API Try Flink example Key: FLINK-22777 URL: https://issues.apache.org/jira/browse/FLINK-22777 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15925: [FLINK-21464][sql-client] Support ADD JAR in SQL Client

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15925: URL: https://github.com/apache/flink/pull/15925#issuecomment-841952583 ## CI report: * 8119d476fa59a7aa35f09c84e285226ff9b3e238 UNKNOWN * 11ad41f163563ed6ff73d0ba081106173c807158 Azure:

[GitHub] [flink] flinkbot commented on pull request #16003: [FLINK-22777][docs] Restore full DataStream API fraud detection example in Try Flink section

2021-05-25 Thread GitBox
flinkbot commented on pull request #16003: URL: https://github.com/apache/flink/pull/16003#issuecomment-848418532 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-22777) Recover lost parts of Datastream API Try Flink example

2021-05-25 Thread Stefan Gloutnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Gloutnikov updated FLINK-22777: -- Description: During the migration of the docs from Jekyll to Hugo (FLINK-21193) in

[jira] [Updated] (FLINK-22776) Delete casting to byte[] in AbstractJdbcRowConverter class

2021-05-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-22776: - Description: Casting to 'byte[]' is redundant. Could we delete it? {code:java} case

[GitHub] [flink] wuchong commented on a change in pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with -

2021-05-25 Thread GitBox
wuchong commented on a change in pull request #15980: URL: https://github.com/apache/flink/pull/15980#discussion_r639386756 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStatementSplitter.java ## @@ -49,18 +51,25 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * 1685626df39ea331106f6b3f7d4f63f506a17f41 Azure:

[jira] [Closed] (FLINK-22779) KafkaChangelogTableITCase.testKafkaDebeziumChangelogSource fail due to ConcurrentModificationException

2021-05-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22779. --- Fix Version/s: 1.13.2 Assignee: Jark Wu Resolution: Fixed Fixed in release-1.13:

[GitHub] [flink] flinkbot edited a comment on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-845673686 ## CI report: * 26d7d8b9c71a8ca8303fd0ee190f399c126c14db UNKNOWN * 9343dea2b8920eb1a96ae4b56ea1d8c7cde6fec0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15997: [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15997: URL: https://github.com/apache/flink/pull/15997#issuecomment-847752911 ## CI report: * 6582c68a14a6121adfd602be9f47f35f72ae0b3e Azure:

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-25 Thread GitBox
stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r639419030 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceEnumState.java ## @@ -0,0

[jira] [Updated] (FLINK-22770) Expose SET/RESET from the parser

2021-05-25 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-22770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-22770: -- Description: The SET/RESET statements are currently implemented using regular expressions in the

[GitHub] [flink] flinkbot commented on pull request #16004: [FLINK-22778] Upgrade to JUnit 4.13

2021-05-25 Thread GitBox
flinkbot commented on pull request #16004: URL: https://github.com/apache/flink/pull/16004#issuecomment-848433269 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 #16004: [FLINK-22778] Upgrade to JUnit 4.13

2021-05-25 Thread GitBox
flinkbot commented on pull request #16004: URL: https://github.com/apache/flink/pull/16004#issuecomment-848440913 ## CI report: * 781b8a67014a8b2748d196c3efb369bb767853c7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Comment Edited] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

2021-05-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351424#comment-17351424 ] Nicholas Jiang edited comment on FLINK-22698 at 5/26/21, 1:52 AM: --

[jira] [Comment Edited] (FLINK-22698) RabbitMQ source does not stop unless message arrives in queue

2021-05-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351424#comment-17351424 ] Nicholas Jiang edited comment on FLINK-22698 at 5/26/21, 1:52 AM: --

[GitHub] [flink] sgloutnikov opened a new pull request #16003: [FLINK-22777][docs] Restore full DataStream API fraud detection example in Try Flink section

2021-05-25 Thread GitBox
sgloutnikov opened a new pull request #16003: URL: https://github.com/apache/flink/pull/16003 ## What is the purpose of the change During the migration of the docs from Jekyll to Hugo (FLINK-21193) in 1.13 large parts of the fraud detection DataStream API example in the "Try Flink"

[jira] [Updated] (FLINK-22777) Recover lost parts of Datastream API Try Flink example

2021-05-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22777: --- Labels: pull-request-available (was: ) > Recover lost parts of Datastream API Try Flink

[jira] [Updated] (FLINK-22777) Recover lost parts of Datastream API Try Flink example

2021-05-25 Thread Stefan Gloutnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Gloutnikov updated FLINK-22777: -- Labels: pull (was: pull-request-available) > Recover lost parts of Datastream API

[GitHub] [flink] flinkbot edited a comment on pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15980: URL: https://github.com/apache/flink/pull/15980#issuecomment-845673686 ## CI report: * 26d7d8b9c71a8ca8303fd0ee190f399c126c14db UNKNOWN * 9343dea2b8920eb1a96ae4b56ea1d8c7cde6fec0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15997: [FLINK-22680][table-planner-blink] Fix IndexOutOfBoundsException when apply WatermarkAssignerChangelogNormalizeTransposeRule

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15997: URL: https://github.com/apache/flink/pull/15997#issuecomment-847752911 ## CI report: * 6582c68a14a6121adfd602be9f47f35f72ae0b3e Azure:

[GitHub] [flink] Jiayi-Liao edited a comment on pull request #8751: [FLINK-11937][StateBackend]Resolve small file problem in RocksDB incremental checkpoint

2021-05-25 Thread GitBox
Jiayi-Liao edited a comment on pull request #8751: URL: https://github.com/apache/flink/pull/8751#issuecomment-848429735 Hi @StephanEwen @carp84 , our team also implements the feature at [Bytedance](https://www.bytedance.com/en/) (Tiktok is one of our popular products)recently, but in a

[GitHub] [flink] flinkbot edited a comment on pull request #15823: [FLINK-22462][tests] Stabilize JdbcExactlyOnceSinkE2eTest

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15823: URL: https://github.com/apache/flink/pull/15823#issuecomment-831107274 ## CI report: * 6efe62d7fe9f2708bd32f3fb2be5ee0d31f34740 Azure:

[jira] [Commented] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

2021-05-25 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351441#comment-17351441 ] Guowei Ma commented on FLINK-20420: ---

[jira] [Updated] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

2021-05-25 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-20420: -- Affects Version/s: 1.14.0 > ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds >

[jira] [Commented] (FLINK-22593) SavepointITCase.testShouldAddEntropyToSavepointPath unstable

2021-05-25 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351442#comment-17351442 ] Guowei Ma commented on FLINK-22593: ---

[GitHub] [flink] tweise opened a new pull request #16004: [FLINK-22778] Upgrade to JUnit 4.13

2021-05-25 Thread GitBox
tweise opened a new pull request #16004: URL: https://github.com/apache/flink/pull/16004 ## What is the purpose of the change * Upgrade to latest JUnit4 version ## Verifying this change * Verify by running all tests ## Does this pull request potentially affect

[GitHub] [flink] tweise commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-25 Thread GitBox
tweise commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r639377458 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -0,0 +1,213 @@

[jira] [Updated] (FLINK-22778) Upgrade to JUnit 4.13

2021-05-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22778: --- Labels: pull-request-available (was: ) > Upgrade to JUnit 4.13 > - > >

[GitHub] [flink] fsk119 commented on a change in pull request #15980: [FLINK-22655]When using -i option to initialize SQL Client session It should be possible to annotate the script with --

2021-05-25 Thread GitBox
fsk119 commented on a change in pull request #15980: URL: https://github.com/apache/flink/pull/15980#discussion_r639381477 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStatementSplitter.java ## @@ -49,18 +51,25 @@ public static

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-25 Thread GitBox
stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r639403318 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-25 Thread GitBox
stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r639413522 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -0,0 +1,209 @@

[jira] [Updated] (FLINK-22776) Delete casting to byte[] in AbstractJdbcRowConverter class

2021-05-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ada Wong updated FLINK-22776: - Summary: Delete casting to byte[] in AbstractJdbcRowConverter class (was: Delete casting to byte[]) >

[jira] [Commented] (FLINK-22776) Delete casting to byte[] in AbstractJdbcRowConverter class

2021-05-25 Thread Ada Wong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351451#comment-17351451 ] Ada Wong commented on FLINK-22776: -- If we can do it, please assign to me. > Delete casting to byte[]

[jira] [Commented] (FLINK-22756) DispatcherTest.testJobStatusIsShownDuringTermination fail

2021-05-25 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351453#comment-17351453 ] Guowei Ma commented on FLINK-22756: ---

[jira] [Updated] (FLINK-22776) Delete casting to byte[] in AbstractJdbcRowConverter class

2021-05-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22776: Component/s: Table SQL / Ecosystem > Delete casting to byte[] in AbstractJdbcRowConverter class >

[jira] [Commented] (FLINK-22613) FlinkKinesisITCase.testStopWithSavepoint fails

2021-05-25 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351476#comment-17351476 ] Guowei Ma commented on FLINK-22613: ---

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-25 Thread GitBox
stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r639405298 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -0,0 +1,213 @@

[GitHub] [flink] stevenzwu commented on a change in pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-05-25 Thread GitBox
stevenzwu commented on a change in pull request #15924: URL: https://github.com/apache/flink/pull/15924#discussion_r639411705 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java ## @@ -0,0 +1,216 @@

[GitHub] [flink] alec-brooks commented on pull request #15994: [hotfix] [docs] Fix typo in JDBC Execution Options Documentation

2021-05-25 Thread GitBox
alec-brooks commented on pull request #15994: URL: https://github.com/apache/flink/pull/15994#issuecomment-847574318 Adjusted the title to match convention. Looking to rerun @flinkbot -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Updated] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

2021-05-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-22472: - Attachment: image-2021-05-25-14-27-40-563.png > The real partition data produced time is behind

[GitHub] [flink] dawidwys merged pull request #15771: [FLINK-18934] Idle stream does not advance watermark in connected stream

2021-05-25 Thread GitBox
dawidwys merged pull request #15771: URL: https://github.com/apache/flink/pull/15771 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[jira] [Commented] (FLINK-21420) Add path templating to the DataStream API

2021-05-25 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350828#comment-17350828 ] Tzu-Li (Gordon) Tai commented on FLINK-21420: - Hi [~maraujo] what you suggested looks like a

[jira] [Assigned] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering

2021-05-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-22088: -- Assignee: Yun Gao > CheckpointCoordinator might not be able to abort triggering

[GitHub] [flink] flinkbot edited a comment on pull request #15877: [FLINK-22612][python] Restructure the coders in PyFlink

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15877: URL: https://github.com/apache/flink/pull/15877#issuecomment-836433504 ## CI report: * be2f68b4cd7086048d5a16c1ab5ee1661908a0c0 Azure:

[jira] [Closed] (FLINK-18934) Idle stream does not advance watermark in connected stream

2021-05-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-18934. Resolution: Fixed Fixed in

[jira] [Updated] (FLINK-18934) Idle stream does not advance watermark in connected stream

2021-05-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-18934: - Affects Version/s: 1.13.0 > Idle stream does not advance watermark in connected stream

[jira] [Commented] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

2021-05-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350816#comment-17350816 ] luoyuxia commented on FLINK-22472: -- I think this problem can be caused by two reasons: 1:  Although

[jira] [Issue Comment Deleted] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

2021-05-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-22472: - Comment: was deleted (was: I think this problem can be caused by two reasons: 1:  Although the

[jira] [Commented] (FLINK-22472) The real partition data produced time is behind meta(_SUCCESS) file produced

2021-05-25 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350817#comment-17350817 ] luoyuxia commented on FLINK-22472: -- I think this problem can be caused by two reasons: 1:  Although

[jira] [Commented] (FLINK-22088) CheckpointCoordinator might not be able to abort triggering checkpoint if failover happens during triggering

2021-05-25 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350805#comment-17350805 ] Piotr Nowojski commented on FLINK-22088: As I wrote, if you open the PR we can help with

[jira] [Closed] (FLINK-22763) avro-confluent format does not allow for authorization credentials to be supplied to Confluent Schema Registry

2021-05-25 Thread Samuel Fiddis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samuel Fiddis closed FLINK-22763. - Resolution: Duplicate > avro-confluent format does not allow for authorization credentials to

[jira] [Created] (FLINK-22764) Disable Values Source node in streaming plan optimization

2021-05-25 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-22764: -- Summary: Disable Values Source node in streaming plan optimization Key: FLINK-22764 URL: https://issues.apache.org/jira/browse/FLINK-22764 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #15885: [FLINK-22376][runtime] RecoveredChannelStateHandler recycles the buffer if it was created inside and doesn't recycle if it was passed

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15885: URL: https://github.com/apache/flink/pull/15885#issuecomment-837001445 ## CI report: * 5a64f54467bca6bb7a5044bbcd2c654df5c978db Azure:

[jira] [Closed] (FLINK-15289) Run sql appear error of "Zero-length character strings have no serializable string representation".

2021-05-25 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-15289. Resolution: Fixed Should have been fixed as part of FLIP-163. > Run sql appear error of

[GitHub] [flink] flinkbot edited a comment on pull request #15729: [FLINK-22234][runtime] Read savepoint before creating ExecutionGraph

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15729: URL: https://github.com/apache/flink/pull/15729#issuecomment-825360063 ## CI report: * 4bb1185d7bbe8c7719ea4de375c3dc4cbd8810ba Azure:

[GitHub] [flink-web] dawidwys commented on pull request #438: Release blog post (update)

2021-05-25 Thread GitBox
dawidwys commented on pull request #438: URL: https://github.com/apache/flink-web/pull/438#issuecomment-847872386 Closing as the changes were already incorporated. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink-web] dawidwys closed pull request #438: Release blog post (update)

2021-05-25 Thread GitBox
dawidwys closed pull request #438: URL: https://github.com/apache/flink-web/pull/438 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15959: [FLINK-22684][runtime] Added ability to ignore in-flight data during …

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15959: URL: https://github.com/apache/flink/pull/15959#issuecomment-844265660 ## CI report: * a0b3af8f3d5503bbd3cb16c208521ce515ef6c67 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15975: [FLINK-22725][coordination] SlotManagers unregister metrics in suspend()

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15975: URL: https://github.com/apache/flink/pull/15975#issuecomment-845084760 ## CI report: * 54d2002e4ce89e914492d5c16c16b89368d7c1e5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15998: [FLINK-22765][runtime][tests] Improve logging for debugging rare test failure

2021-05-25 Thread GitBox
flinkbot edited a comment on pull request #15998: URL: https://github.com/apache/flink/pull/15998#issuecomment-847840896 ## CI report: * c5ce88706ce5b340a675ec3b1899bf1a32c00321 UNKNOWN * d49ea87e07df55125f1803ab53b2b36ada2d9338 Azure:

[GitHub] [flink-web] knaufk commented on pull request #448: Announce 1.13.1

2021-05-25 Thread GitBox
knaufk commented on pull request #448: URL: https://github.com/apache/flink-web/pull/448#issuecomment-847906003 Is it expected that the list of issues still contains OPEN issues? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Updated] (FLINK-20975) HiveTableSourceITCase.testPartitionFilter fails on AZP

2021-05-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20975: - Fix Version/s: (was: 1.13.1) 1.13.2 >

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

2021-05-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20431: - Fix Version/s: 1.13.2 >

[jira] [Updated] (FLINK-21317) Downstream keyed state not work after FlinkKafkaShuffle

2021-05-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-21317: - Fix Version/s: (was: 1.13.1) > Downstream keyed state not work after

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

2021-05-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-20431: - Fix Version/s: (was: 1.13.1) >

[jira] [Updated] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

2021-05-25 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-15493: - Fix Version/s: (was: 1.13.1) 1.13.2 >

[jira] [Commented] (FLINK-22770) Expose SET/RESET from the parser

2021-05-25 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351023#comment-17351023 ] Timo Walther commented on FLINK-22770: -- I agree with [~airblader]. Maintaining two parsers is not a

[jira] [Comment Edited] (FLINK-22770) Expose SET/RESET from the parser

2021-05-25 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351023#comment-17351023 ] Timo Walther edited comment on FLINK-22770 at 5/25/21, 12:16 PM: - I

  1   2   3   4   >