[GitHub] [flink] sv3ndk commented on pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

2021-06-25 Thread GitBox
sv3ndk commented on pull request #16060: URL: https://github.com/apache/flink/pull/16060#issuecomment-868958957 > I think we have two ways to improve this: > > 1. not display full syntax, but the most common used syntax or example, e.g. `CREATE FUNCTION AS ''`. > > 2.

[GitHub] [flink] flinkbot edited a comment on pull request #16245: [FLINK-22940][SQL-CLIENT] Make sql client column max width configurable

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16245: URL: https://github.com/apache/flink/pull/16245#issuecomment-866278518 ## CI report: * 03f385a7170f0923a72793ac52db3245dace5090 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] sv3ndk commented on a change in pull request #16060: [FLINK-22860][table sql-client] Supplement 'HELP' command prompt message for SQL-Cli.

2021-06-25 Thread GitBox
sv3ndk commented on a change in pull request #16060: URL: https://github.com/apache/flink/pull/16060#discussion_r659128719 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStrings.java ## @@ -39,82 +39,171 @@ private CliStrings() {

[GitHub] [flink] flinkbot edited a comment on pull request #16245: [FLINK-22940][SQL-CLIENT] Make sql client column max width configurable

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16245: URL: https://github.com/apache/flink/pull/16245#issuecomment-866278518 ## CI report: * 03f385a7170f0923a72793ac52db3245dace5090 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] sv3ndk commented on pull request #16245: [FLINK-22940][SQL-CLIENT] Make sql client column max width configurable

2021-06-25 Thread GitBox
sv3ndk commented on pull request #16245: URL: https://github.com/apache/flink/pull/16245#issuecomment-868954280 I added one last commit clarifying the documentation of the new option as you suggested and decorated it with `@Documentation.TableOption(execMode = Documentation.ExecMode.STREAM

[jira] [Resolved] (FLINK-22492) KinesisTableApiITCase with wrong results

2021-06-25 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22492. - Fix Version/s: 1.13.2 1.14.0 Resolution: Fixed > KinesisTableApiITCase

[jira] [Commented] (FLINK-22492) KinesisTableApiITCase with wrong results

2021-06-25 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369816#comment-17369816 ] Arvid Heise commented on FLINK-22492: - See for FLINK-23009 for different issue with

[jira] [Commented] (FLINK-22492) KinesisTableApiITCase with wrong results

2021-06-25 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369815#comment-17369815 ] Arvid Heise commented on FLINK-22492: - Merged into 1.13 as b06862333119359afba6a8f43

[GitHub] [flink] AHeise merged pull request #16278: [FLINK-22492][test] Use order-agnostic check in KinesisTableApiITCase. [1.13]

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

[GitHub] [flink] sv3ndk commented on a change in pull request #16245: [FLINK-22940][SQL-CLIENT] Make sql client column max width configurable

2021-06-25 Thread GitBox
sv3ndk commented on a change in pull request #16245: URL: https://github.com/apache/flink/pull/16245#discussion_r659123441 ## File path: docs/content/docs/dev/table/sqlClient.md ## @@ -60,106 +59,72 @@ or explicitly use `embedded` mode: ./bin/sql-client.sh embedded ``` +See

[GitHub] [flink] flinkbot edited a comment on pull request #16278: [FLINK-22492][test] Use order-agnostic check in KinesisTableApiITCase. [1.13]

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16278: URL: https://github.com/apache/flink/pull/16278#issuecomment-867519346 ## CI report: * e5d8485a17a3f3c4bb2ca62e291a5c0d55d0a72e Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16297: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16297: URL: https://github.com/apache/flink/pull/16297#issuecomment-868854612 ## CI report: * a39fe2a5e662f86708dbc2b728270b01c3b4335c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Assigned] (FLINK-23017) HELP in sql-client still shows the removed SOURCE functionality

2021-06-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-23017: --- Assignee: Nicholas Jiang > HELP in sql-client still shows the removed SOURCE functionality > --

[jira] [Commented] (FLINK-23017) HELP in sql-client still shows the removed SOURCE functionality

2021-06-25 Thread Nicholas Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369798#comment-17369798 ] Nicholas Jiang commented on FLINK-23017: [~jark], I would like to take this tick

[GitHub] [flink] wuchong commented on pull request #16245: [FLINK-22940][SQL-CLIENT] Make sql client column max width configurable

2021-06-25 Thread GitBox
wuchong commented on pull request #16245: URL: https://github.com/apache/flink/pull/16245#issuecomment-868945390 Besides, a side note, please do not use "git merge" to update branches, otherwise it's hard to track the commit changes. Please use "git rebase" instead. IntelliJ IDEA provide a

[GitHub] [flink] wuchong commented on pull request #16245: [FLINK-22940][SQL-CLIENT] Make sql client column max width configurable

2021-06-25 Thread GitBox
wuchong commented on pull request #16245: URL: https://github.com/apache/flink/pull/16245#issuecomment-868945087 @sv3ndk , this is as expected. This config option should only affect variable-length types in streaming mode to control the displayed characters. Fixed-length types and all type

[GitHub] [flink] wuchong commented on a change in pull request #16245: [FLINK-22940][SQL-CLIENT] Make sql client column max width configurable

2021-06-25 Thread GitBox
wuchong commented on a change in pull request #16245: URL: https://github.com/apache/flink/pull/16245#discussion_r659116339 ## File path: docs/content/docs/dev/table/sqlClient.md ## @@ -60,106 +59,72 @@ or explicitly use `embedded` mode: ./bin/sql-client.sh embedded ``` +Se

[GitHub] [flink] wuchong commented on a change in pull request #16245: [FLINK-22940][SQL-CLIENT] Make sql client column max width configurable

2021-06-25 Thread GitBox
wuchong commented on a change in pull request #16245: URL: https://github.com/apache/flink/pull/16245#discussion_r659116064 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliChangelogResultView.java ## @@ -85,16 +94,6 @@ public CliCh

[jira] [Commented] (FLINK-23146) Data cannot be consumed when upsert Kafka is used as the source

2021-06-25 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369787#comment-17369787 ] JasonLee commented on FLINK-23146: -- Thank you for your reply, I will try to find the an

[jira] [Assigned] (FLINK-11622) Translate the "Command-Line Interface" page into Chinese

2021-06-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11622: --- Assignee: wuguihu > Translate the "Command-Line Interface" page into Chinese >

[jira] [Updated] (FLINK-20988) Various resource allocation improvements for active resource managers

2021-06-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20988: - Labels: Umbrella (was: Umbrella stale-assigned) > Various resource allocation improvements for

[jira] [Commented] (FLINK-23009) Bump up Guava in Kinesis Connector

2021-06-25 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369778#comment-17369778 ] Xintong Song commented on FLINK-23009: -- Thank you both for looking into this. I ha

[GitHub] [flink] zjffdu commented on pull request #15813: [FLINK-22519][flink-python] support tar python archives

2021-06-25 Thread GitBox
zjffdu commented on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-86505 Thanks @YikSanChan I am trying to make a workaround via `yarn.ship-archives`, but it would still be helpful if this PR is merged. -- This is an automated message from the Apac

[GitHub] [flink] YikSanChan commented on pull request #15813: [FLINK-22519][flink-python] support tar python archives

2021-06-25 Thread GitBox
YikSanChan commented on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-868882017 > Any update on this PR ? Supporting tar is definitely necessary. Hi Jeff, I haven't worked on this for a while. Though if you see the need being urgent, I am happy to

[jira] [Commented] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

2021-06-25 Thread Xinhao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369752#comment-17369752 ] Xinhao Li commented on FLINK-22014: --- Can Flink provides such config option that Flink

[GitHub] [flink] flinkbot edited a comment on pull request #16296: [FLINK-23088] Add flink-rpc-core module

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16296: URL: https://github.com/apache/flink/pull/16296#issuecomment-868781471 ## CI report: * 845139a9cd3b8e8f8da66ca04ea5e90ca7a642b2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16278: [FLINK-22492][test] Use order-agnostic check in KinesisTableApiITCase. [1.13]

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16278: URL: https://github.com/apache/flink/pull/16278#issuecomment-867519346 ## CI report: * f27a2f32d2c2479f512eeed4dc589e89944dffa8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-4942) Improve processing performance of HeapInternalTimerService with key groups

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

[jira] [Updated] (FLINK-22933) Upgrade the Flink Fabric8io/kubernetes-client version to >=5.4.0 to be FIPS compliant

2021-06-25 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22933: --- Labels: stale-critical (was: ) I am the [Flink Jira Bot|https://github.com/apache/flink-jir

[jira] [Updated] (FLINK-22949) java.io.InvalidClassException With Flink Kafka Beam

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

[jira] [Updated] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

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

[jira] [Updated] (FLINK-4855) Add partitionedKeyBy to DataStream

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

[jira] [Updated] (FLINK-20182) Add JDK 11 build to StateFun's CI

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

[jira] [Updated] (FLINK-5047) Add sliding group-windows for batch tables

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

[jira] [Updated] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

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

[jira] [Updated] (FLINK-5080) Cassandra connector ignores saveAsync result onSuccess

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

[jira] [Updated] (FLINK-22775) CassandraConnectorITCase.testCassandraTableSink Fail

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

[jira] [Updated] (FLINK-5105) Improve ReduceState: value put into ReducingState should always be a copy

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

[jira] [Updated] (FLINK-4815) Automatic fallback to earlier checkpoints when checkpoint restore fails

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

[jira] [Updated] (FLINK-4808) Allow skipping failed checkpoints

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

[jira] [Updated] (FLINK-4965) AllPairsShortestPaths

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

[jira] [Updated] (FLINK-5127) Reduce the amount of intermediate data in vertex-centric iterations

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

[jira] [Updated] (FLINK-4854) Efficient Batch Operator in Streaming

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

[jira] [Updated] (FLINK-5078) Introduce annotations for classes copied from Calcite

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

[jira] [Updated] (FLINK-5089) Introduce Loop functions and Enforce Nesting on Data Streams

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

[jira] [Updated] (FLINK-22516) ResourceManager cannot establish leadership

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

[jira] [Updated] (FLINK-22627) Remove SlotManagerImpl

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

[jira] [Updated] (FLINK-4966) BetweennessCentrality

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

[jira] [Updated] (FLINK-20988) Various resource allocation improvements for active resource managers

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

[GitHub] [flink] flinkbot edited a comment on pull request #16297: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16297: URL: https://github.com/apache/flink/pull/16297#issuecomment-868854612 ## CI report: * a39fe2a5e662f86708dbc2b728270b01c3b4335c Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16278: [FLINK-22492][test] Use order-agnostic check in KinesisTableApiITCase. [1.13]

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16278: URL: https://github.com/apache/flink/pull/16278#issuecomment-867519346 ## CI report: * f27a2f32d2c2479f512eeed4dc589e89944dffa8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16297: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-25 Thread GitBox
flinkbot commented on pull request #16297: URL: https://github.com/apache/flink/pull/16297#issuecomment-868854612 ## CI report: * a39fe2a5e662f86708dbc2b728270b01c3b4335c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-22492) KinesisTableApiITCase with wrong results

2021-06-25 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369717#comment-17369717 ] Arvid Heise commented on FLINK-22492: - Merged into master as 66120f98066c690d10bcca4

[GitHub] [flink] flinkbot commented on pull request #16297: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-25 Thread GitBox
flinkbot commented on pull request #16297: URL: https://github.com/apache/flink/pull/16297#issuecomment-868847019 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 pro

[jira] [Commented] (FLINK-23009) Bump up Guava in Kinesis Connector

2021-06-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369716#comment-17369716 ] Danny Cranmer commented on FLINK-23009: --- Agree with [~iemre] that the issue is the

[jira] [Comment Edited] (FLINK-23009) Bump up Guava in Kinesis Connector

2021-06-25 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369716#comment-17369716 ] Danny Cranmer edited comment on FLINK-23009 at 6/25/21, 9:37 PM: -

[GitHub] [flink] dannycranmer opened a new pull request #16297: [FLINK-23009][kinesis] Upgrade Guava for Flink Connector Kinesis

2021-06-25 Thread GitBox
dannycranmer opened a new pull request #16297: URL: https://github.com/apache/flink/pull/16297 ## What is the purpose of the change Upgrade Guava dependency for Flink Connector Kinesis. The connector was using Guava 18.0 which is quite old and has been flagged by some security tools

[GitHub] [flink] flinkbot edited a comment on pull request #16295: [FLINK-11622][chinese-translation,Documentation]Translate the "Command-Line Interface" page into Chinese

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16295: URL: https://github.com/apache/flink/pull/16295#issuecomment-868781381 ## CI report: * cc21081fe26190bb32ebd023aecb194e33262ff0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] iemre closed pull request #16292: Revert "[FLINK-23009][kinesis] Upgrade Guava for flink connector kine…

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

[GitHub] [flink] zjffdu removed a comment on pull request #15813: [FLINK-22519][flink-python] support tar python archives

2021-06-25 Thread GitBox
zjffdu removed a comment on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-868810271 Any update on -- 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

[GitHub] [flink] zjffdu commented on pull request #15813: [FLINK-22519][flink-python] support tar python archives

2021-06-25 Thread GitBox
zjffdu commented on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-868810510 Any update on this PR ? Supporting tar is definitely necessary. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] zjffdu commented on pull request #15813: [FLINK-22519][flink-python] support tar python archives

2021-06-25 Thread GitBox
zjffdu commented on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-868810271 Any update on -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #16296: [FLINK-23088] Add flink-rpc-core module

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16296: URL: https://github.com/apache/flink/pull/16296#issuecomment-868781471 ## CI report: * 845139a9cd3b8e8f8da66ca04ea5e90ca7a642b2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16295: [FLINK-11622][chinese-translation,Documentation]Translate the "Command-Line Interface" page into Chinese

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16295: URL: https://github.com/apache/flink/pull/16295#issuecomment-868781381 ## CI report: * cc21081fe26190bb32ebd023aecb194e33262ff0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16294: [FLINK-22593][tests] Waiting all tasks running before triggerSavepoint

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16294: URL: https://github.com/apache/flink/pull/16294#issuecomment-868666894 ## CI report: * c092b08ba1f7a093599f075326d671a1d9e2bb62 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16296: [FLINK-23088] Add flink-rpc-core module

2021-06-25 Thread GitBox
flinkbot commented on pull request #16296: URL: https://github.com/apache/flink/pull/16296#issuecomment-868781471 ## CI report: * 845139a9cd3b8e8f8da66ca04ea5e90ca7a642b2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #16295: [FLINK-11622][chinese-translation,Documentation]Translate the "Command-Line Interface" page into Chinese

2021-06-25 Thread GitBox
flinkbot commented on pull request #16295: URL: https://github.com/apache/flink/pull/16295#issuecomment-868781381 ## CI report: * cc21081fe26190bb32ebd023aecb194e33262ff0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #16296: [FLINK-23088] Add flink-rpc-core module

2021-06-25 Thread GitBox
flinkbot commented on pull request #16296: URL: https://github.com/apache/flink/pull/16296#issuecomment-868776311 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 pro

[GitHub] [flink] zentol opened a new pull request #16296: [FLINK-23088] Add flink-rpc-core module

2021-06-25 Thread GitBox
zentol opened a new pull request #16296: URL: https://github.com/apache/flink/pull/16296 Based on #16265. Adds a new flink-rpc-core module, acting as an interface between flink-runtime and the future flink-rpc-akka module. Essentially we're just moving the core rpc interface (like R

[GitHub] [flink] flinkbot commented on pull request #16295: [FLINK-11622][chinese-translation,Documentation]Translate the "Command-Line Interface" page into Chinese

2021-06-25 Thread GitBox
flinkbot commented on pull request #16295: URL: https://github.com/apache/flink/pull/16295#issuecomment-868767185 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 pro

[jira] [Commented] (FLINK-11622) Translate the "Command-Line Interface" page into Chinese

2021-06-25 Thread wuguihu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369655#comment-17369655 ] wuguihu commented on FLINK-11622: - Hi Jark Wu, can you assign this issue to me? I'd like

[jira] [Updated] (FLINK-11622) Translate the "Command-Line Interface" page into Chinese

2021-06-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11622: --- Labels: auto-unassigned pull-request-available (was: auto-unassigned) > Translate the "Comm

[GitHub] [flink] hapihu opened a new pull request #16295: [FLINK-11622][chinese-translation,Documentation]Translate the "Command-Line Interface" page into Chinese

2021-06-25 Thread GitBox
hapihu opened a new pull request #16295: URL: https://github.com/apache/flink/pull/16295 [chinese-translation,Documentation]Translate the "Command-Line Interface" page into Chinese https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/deployment/cli/ -- This is an au

[GitHub] [flink] flinkbot edited a comment on pull request #16293: [FLINK-23052][ci] Fetch maven artifacts from local mirror before deploying Flink

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16293: URL: https://github.com/apache/flink/pull/16293#issuecomment-868531393 ## CI report: * cee63aa7ae6204fa09067b198357f4d99a1c9d1d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16292: Revert "[FLINK-23009][kinesis] Upgrade Guava for flink connector kine…

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16292: URL: https://github.com/apache/flink/pull/16292#issuecomment-868531267 ## CI report: * 296ee7795b8911931b1f2c6c2e1a03dd64812091 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16286: [FLINK-21445] Refactors the PackagedProgramRetriever implementation and adds configuration to PackagedProgram

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16286: URL: https://github.com/apache/flink/pull/16286#issuecomment-868270639 ## CI report: * 4cbaee738f213985ae8d6850b36005e0ebafd5bf UNKNOWN * 1ef57a0f7a4530accbe4817a9f931e1c6467bd92 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] holdenk commented on pull request #14929: [FLINK-21364][connector] piggyback finishedSplitIds in RequestSplitEv…

2021-06-25 Thread GitBox
holdenk commented on pull request #14929: URL: https://github.com/apache/flink/pull/14929#issuecomment-868729109 For additional context you can see the workaround being done in Iceberg at https://github.com/apache/iceberg/pull/2305/files#diff-947f99483f34e6bdf912e54c0a15317a7281bf3815261f52

[GitHub] [flink] holdenk commented on pull request #14929: [FLINK-21364][connector] piggyback finishedSplitIds in RequestSplitEv…

2021-06-25 Thread GitBox
holdenk commented on pull request #14929: URL: https://github.com/apache/flink/pull/14929#issuecomment-868728511 cc @tweise -- 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.

[GitHub] [flink] flinkbot edited a comment on pull request #16245: [FLINK-22940][SQL-CLIENT] Make sql client column max width configurable

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16245: URL: https://github.com/apache/flink/pull/16245#issuecomment-866278518 ## CI report: * 03f385a7170f0923a72793ac52db3245dace5090 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16287: [FLINK-23066] Introduce TableEnvironment#from(TableDescriptor)

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16287: URL: https://github.com/apache/flink/pull/16287#issuecomment-868270704 ## CI report: * 396b474eb00876ed536ff8f99f72e0bbbe3eb53c Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16294: [FLINK-22593][tests] Waiting all tasks running before triggerSavepoint

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16294: URL: https://github.com/apache/flink/pull/16294#issuecomment-868666894 ## CI report: * c092b08ba1f7a093599f075326d671a1d9e2bb62 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16290: [FLINK-23067][table-api-java] Introduce Table#executeInsert(TableDescriptor)

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16290: URL: https://github.com/apache/flink/pull/16290#issuecomment-868395028 ## CI report: * f7d3d618d7f73fceabe136cefeda2cb210f1d463 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16291: [FLINK-23071][table-api-java] Introduce StatementSet#addInsert(TableDescriptor, Table)

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16291: URL: https://github.com/apache/flink/pull/16291#issuecomment-868457160 ## CI report: * 6be24ed4de7e8dc16370333e509556de1309dd9a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #16294: [FLINK-22593][tests] Waiting all tasks running before triggerSavepoint

2021-06-25 Thread GitBox
flinkbot commented on pull request #16294: URL: https://github.com/apache/flink/pull/16294#issuecomment-868666894 ## CI report: * c092b08ba1f7a093599f075326d671a1d9e2bb62 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16285: [FLINK-23070][table-api-java] Introduce TableEnvironment#createTable

2021-06-25 Thread GitBox
flinkbot edited a comment on pull request #16285: URL: https://github.com/apache/flink/pull/16285#issuecomment-868253867 ## CI report: * 3a7708ead7c69816ae9debe89df06f06abed3381 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-23157) Fix missing comma in SQL example in "Versioned View" page

2021-06-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-23157: Fix Version/s: 1.14.0 > Fix missing comma in SQL example in "Versioned View" page > --

[jira] [Closed] (FLINK-23157) Fix missing comma in SQL example in "Versioned View" page

2021-06-25 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23157. --- Assignee: HanWei Resolution: Fixed Fixed in - master: c6cd4923ca519c261fb7b0dfc9442642b5ba9867 - rele

[GitHub] [flink] echauchot commented on pull request #16186: [hotfix][docs] Fix groupBy() javadocs

2021-06-25 Thread GitBox
echauchot commented on pull request #16186: URL: https://github.com/apache/flink/pull/16186#issuecomment-868661809 Forgot to say thank you for merging -- 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 g

[jira] [Closed] (FLINK-23045) RunnablesTest.testExecutorService_uncaughtExceptionHandler fails on azure

2021-06-25 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-23045. - Resolution: Fixed Fixed via 1.14.0: 4d5f4df5361294197cf2b48e000550b0c54adbb0 1.13.2: d9121d701d

[GitHub] [flink] tillrohrmann merged pull request #16263: [BP-1.12][FLINK-23045][tests] Harden RunnablesTest by not relying on timeout

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

[GitHub] [flink] tillrohrmann commented on pull request #16263: [BP-1.12][FLINK-23045][tests] Harden RunnablesTest by not relying on timeout

2021-06-25 Thread GitBox
tillrohrmann commented on pull request #16263: URL: https://github.com/apache/flink/pull/16263#issuecomment-868659421 Thanks for reviewing this PR @rmetzger. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] echauchot commented on pull request #16201: [hotfix][docs] Merge the two Flink POJO definitions to make the definition uniform

2021-06-25 Thread GitBox
echauchot commented on pull request #16201: URL: https://github.com/apache/flink/pull/16201#issuecomment-868654451 Thanks Piotr for review / merge ! -- 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

[GitHub] [flink] infoverload commented on a change in pull request #16177: [FLINK-22528][docs] Document latency tracking metrics for state accesses

2021-06-25 Thread GitBox
infoverload commented on a change in pull request #16177: URL: https://github.com/apache/flink/pull/16177#discussion_r658853868 ## File path: docs/content.zh/docs/dev/datastream/fault-tolerance/state.md ## @@ -561,6 +561,17 @@ val counts: DataStream[(String, Int)] = stream

[GitHub] [flink] tillrohrmann merged pull request #16262: [BP-1.13][FLINK-23045][tests] Harden RunnablesTest by not relying on timeout

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

[GitHub] [flink] infoverload commented on a change in pull request #16177: [FLINK-22528][docs] Document latency tracking metrics for state accesses

2021-06-25 Thread GitBox
infoverload commented on a change in pull request #16177: URL: https://github.com/apache/flink/pull/16177#discussion_r658856234 ## File path: docs/content.zh/docs/dev/datastream/fault-tolerance/state.md ## @@ -561,6 +561,17 @@ val counts: DataStream[(String, Int)] = stream

[GitHub] [flink] infoverload commented on a change in pull request #16177: [FLINK-22528][docs] Document latency tracking metrics for state accesses

2021-06-25 Thread GitBox
infoverload commented on a change in pull request #16177: URL: https://github.com/apache/flink/pull/16177#discussion_r658857488 ## File path: docs/content.zh/docs/ops/metrics.md ## @@ -1642,7 +1642,7 @@ logged by `SystemResourcesMetricsInitializer` during the startup.

[GitHub] [flink] infoverload commented on a change in pull request #16177: [FLINK-22528][docs] Document latency tracking metrics for state accesses

2021-06-25 Thread GitBox
infoverload commented on a change in pull request #16177: URL: https://github.com/apache/flink/pull/16177#discussion_r658864082 ## File path: docs/content.zh/docs/dev/datastream/fault-tolerance/state.md ## @@ -561,6 +561,17 @@ val counts: DataStream[(String, Int)] = stream

[GitHub] [flink] infoverload commented on a change in pull request #16177: [FLINK-22528][docs] Document latency tracking metrics for state accesses

2021-06-25 Thread GitBox
infoverload commented on a change in pull request #16177: URL: https://github.com/apache/flink/pull/16177#discussion_r658863811 ## File path: docs/content.zh/docs/dev/datastream/fault-tolerance/state.md ## @@ -561,6 +561,17 @@ val counts: DataStream[(String, Int)] = stream

[GitHub] [flink] wuchong merged pull request #16289: [FLINK-23157][docs] Versioned View's SQL Script was missing a "," at Line 3 which yields Could not execute SQL statement ERROR

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

[GitHub] [flink] tillrohrmann commented on pull request #16262: [BP-1.13][FLINK-23045][tests] Harden RunnablesTest by not relying on timeout

2021-06-25 Thread GitBox
tillrohrmann commented on pull request #16262: URL: https://github.com/apache/flink/pull/16262#issuecomment-868638302 Thanks for the review @rmetzger. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

  1   2   3   4   >