[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

[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_r639420915 ## 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_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] [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] 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

[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:

[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 @@

[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] 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] 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_r639409914 ## 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] 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] 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_r639403318 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java ## @@ -0,0

[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] 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 #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 #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 #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 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

[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 #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 #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:

[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:

[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: ---

[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] 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

[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

[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 #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 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] 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] 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] Jiayi-Liao commented on pull request #8751: [FLINK-11937][StateBackend]Resolve small file problem in RocksDB incremental checkpoint

2021-05-25 Thread GitBox
Jiayi-Liao commented 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 recently, but in a different way without complex changes on JobMaster's side. The core idea is,

[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] 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

[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

[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] 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

[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:

[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

[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] [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

[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: -- Labels: pull-request-available (was: pull) > Recover lost parts of Datastream API

[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 (was: pull-request-available) > Recover lost parts of Datastream API

[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

[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] [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: ---

[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:

[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

[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] [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[]

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] [Created] (FLINK-22775) CassandraConnectorITCase.testCassandraTableSink Fail

2021-05-25 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-22775: - Summary: CassandraConnectorITCase.testCassandraTableSink Fail Key: FLINK-22775 URL: https://issues.apache.org/jira/browse/FLINK-22775 Project: Flink Issue Type:

[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] [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] [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: ---

[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-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] [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:

[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] [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: --

[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] [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] [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 > > >

[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] [Commented] (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 commented on FLINK-22698: Thanks for [~cmick]'s investigation. The solution which

[jira] [Updated] (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 updated FLINK-22763: -- Priority: Major (was: Minor) > avro-confluent format does not allow for authorization

[jira] [Reopened] (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 reopened FLINK-22763: --- May be related to https://issues.apache.org/jira/browse/FLINK-21229 > avro-confluent format

[jira] [Updated] (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 updated FLINK-22763: -- Issue Type: Improvement (was: Bug) > avro-confluent format does not allow for authorization

[GitHub] [flink] flinkbot edited a comment on pull request #16000: [FLINK-22613][tests] Fix FlinkKinesisITCase.testStopWithSavepoint. [1.12]

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

[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: * 323d87e5394e8968856741d0bfd48463e38ddc8a Azure:

[jira] [Updated] (FLINK-11793) Make KafkaProducer more resilient to Kafka Broker Failures

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11793: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-13719) Update Yarn E2E test docker image to run on Java 11

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13719: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22443) can not be execute an extreme long sql under batch mode

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22443: --- I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help the community

[jira] [Updated] (FLINK-11831) Separate CodeGeneratorContext for different generation targets

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11831: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-17714) Support custom RestartBackoffTimeStrategy

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17714: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-11983) Refactor resolved aggregation reference expressions in blink

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11983: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-11797) Implement empty unit tests in CheckpointCoordinatorMasterHooksTest

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

[jira] [Updated] (FLINK-12097) Flink SQL hangs in StreamTableEnvironment.sqlUpdate, keeps executing and seems never stop, finally lead to java.lang.OutOfMemoryError: GC overhead limit exceeded

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12097: --- Labels: auto-deprioritized-major performance (was: performance stale-major)

[jira] [Updated] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17785: --- Labels: stale-major (was: ) I am the [Flink Jira

[jira] [Updated] (FLINK-12116) Args autocast will cause exception for plan transformation in TableAPI

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12116: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-13692) Make CompletedCheckpointStore backwards compatible?

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13692: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-12193) Send TM "can be released status" with RM heartbeat

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12193: --- Labels: auto-deprioritized-major starter (was: stale-major starter) Priority: Minor

[jira] [Updated] (FLINK-19647) Support the limit push down for the hbase connector

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19647: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-13443) Support/Map Hive INTERVAL type in Hive connector

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13443: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-15040) Open function is not called in UDF AggregateFunction

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15040: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-13418) Avoid InfluxdbReporter to report unnecessary tags

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13418: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-13149) improve flink ui to make it easier to be used by other projects

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

[jira] [Updated] (FLINK-22519) Have python-archives also take tar.gz

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22519: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-12206) cannot query nested fields using Flink SQL

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12206: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-12701) Column name alias causes exception when used with where and group-by

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12701: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-16504) Add a AWS DynamoDB sink

2021-05-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16504: --- Labels: auto-unassigned stale-assigned (was: auto-unassigned) I am the [Flink Jira

  1   2   3   4   >