[jira] [Comment Edited] (FLINK-18068) Job scheduling stops but not exits after throwing non-fatal exception

[ https://issues.apache.org/jira/browse/FLINK-18068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124685#comment-17124685 ] Till Rohrmann edited comment on FLINK-18068 at 6/3/20, 7:31 AM: I think

[GitHub] [flink] leonardBang commented on pull request #12436: [FLINK-17847][table sql / planner] ArrayIndexOutOfBoundsException happens in StreamExecCalc operator

leonardBang commented on pull request #12436: URL: https://github.com/apache/flink/pull/12436#issuecomment-638018884 I updated the PR @libenchao @wuchong ,could you take a look? This is an automated message from the Apache

[jira] [Updated] (FLINK-18085) Manually test application mode for standalone, Yarn, K8s

[ https://issues.apache.org/jira/browse/FLINK-18085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-18085: -- Fix Version/s: 1.11.0 > Manually test application mode for standalone, Yarn, K8s >

[GitHub] [flink] flinkbot commented on pull request #12456: [FLINK-17113][sql-cli] Refactor view support in SQL Client

flinkbot commented on pull request #12456: URL: https://github.com/apache/flink/pull/12456#issuecomment-638018167 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-17113) Refactor view support in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-17113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17113: --- Labels: pull-request-available (was: ) > Refactor view support in SQL Client >

[GitHub] [flink] flinkbot edited a comment on pull request #11397: [FLINK-16217] [sql-client] catch SqlExecutionException for all callXX methods

flinkbot edited a comment on pull request #11397: URL: https://github.com/apache/flink/pull/11397#issuecomment-598575354 ## CI report: * 209b426a5818e8a230bb63499a921398170281fc Azure:

[GitHub] [flink] leonardBang commented on a change in pull request #12436: [FLINK-17847][table sql / planner] ArrayIndexOutOfBoundsException happens in StreamExecCalc operator

leonardBang commented on a change in pull request #12436: URL: https://github.com/apache/flink/pull/12436#discussion_r434381251 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala ## @@

[GitHub] [flink] zhuzhurk commented on a change in pull request #12321: Add document for writing Avro files with StreamingFileSink

zhuzhurk commented on a change in pull request #12321: URL: https://github.com/apache/flink/pull/12321#discussion_r434380806 ## File path: docs/dev/connectors/streamfile_sink.md ## @@ -204,6 +205,65 @@ input.addSink(sink) + Avro format + +Flink also provides built-in

[jira] [Assigned] (FLINK-18026) E2E tests manually for new SQL connectors and formats

[ https://issues.apache.org/jira/browse/FLINK-18026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18026: -- Assignee: Shengkai Fang > E2E tests manually for new SQL connectors and formats >

[jira] [Assigned] (FLINK-18028) E2E tests manually for Kafka 2 all kinds of other connectors

[ https://issues.apache.org/jira/browse/FLINK-18028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18028: -- Assignee: Shengkai Fang > E2E tests manually for Kafka 2 all kinds of other connectors >

[jira] [Comment Edited] (FLINK-18033) Improve e2e test execution time

[ https://issues.apache.org/jira/browse/FLINK-18033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124737#comment-17124737 ] Robert Metzger edited comment on FLINK-18033 at 6/3/20, 8:13 AM: - Thanks

[GitHub] [flink] rmetzger opened a new pull request #12458: [FLINK-17404] Make sure netty 3.10.6 is used in flink-runtime

rmetzger opened a new pull request #12458: URL: https://github.com/apache/flink/pull/12458 Due to the recent changes in https://issues.apache.org/jira/browse/FLINK-11086 ("Add support for Hadoop 3"), the shaded netty dependency in flink-runtime changed depending on the Hadoop

[jira] [Updated] (FLINK-16175) Add config option to switch case sensitive for column names in SQL

[ https://issues.apache.org/jira/browse/FLINK-16175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16175: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Add config option to switch case

[jira] [Updated] (FLINK-17948) Sql client lost precision for Timestamp and Decimal Data type

[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17948: --- Fix Version/s: (was: 1.11.0) > Sql client lost precision for Timestamp and Decimal Data type >

[jira] [Updated] (FLINK-17895) Default value of rows-per-second in datagen can be limited

[ https://issues.apache.org/jira/browse/FLINK-17895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17895: --- Fix Version/s: (was: 1.11.0) > Default value of rows-per-second in datagen can be limited >

[jira] [Assigned] (FLINK-17959) Exception: "CANCELLED: call already cancelled" is thrown when run python udf

[ https://issues.apache.org/jira/browse/FLINK-17959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17959: --- Assignee: Dian Fu > Exception: "CANCELLED: call already cancelled" is thrown when run python udf >

[jira] [Assigned] (FLINK-18061) TableResult#collect should return closeable iterator to avoid resource leak

[ https://issues.apache.org/jira/browse/FLINK-18061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-18061: -- Assignee: godfrey he > TableResult#collect should return closeable iterator to avoid

[GitHub] [flink] zhijiangW commented on pull request #12461: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

zhijiangW commented on pull request #12461: URL: https://github.com/apache/flink/pull/12461#issuecomment-638089208 Just cherry-pick this fix to master from releasee-1.11, which has already been approved before in #12406 , will merge it after azure pass.

[jira] [Commented] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124822#comment-17124822 ] Piotr Nowojski commented on FLINK-15467: Thanks for coming back and providing a way to reproduce

[GitHub] [flink] wuchong closed pull request #12386: [FLINK-17995][docs][connectors] Redesign Table & SQL Connectors page and add HBase connector documentation

wuchong closed pull request #12386: URL: https://github.com/apache/flink/pull/12386 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

[GitHub] [flink-web] MarkSfik commented on a change in pull request #344: [blog] flink on zeppelin - part2

MarkSfik commented on a change in pull request #344: URL: https://github.com/apache/flink-web/pull/344#discussion_r434475743 ## File path: _posts/2020-05-25-flink-on-zeppelin-part2.md ## @@ -0,0 +1,107 @@ +--- +layout: post +title: "Flink on Zeppelin Notebooks for Interactive

[GitHub] [flink-web] MarkSfik commented on a change in pull request #344: [blog] flink on zeppelin - part2

MarkSfik commented on a change in pull request #344: URL: https://github.com/apache/flink-web/pull/344#discussion_r434475238 ## File path: _posts/2020-05-25-flink-on-zeppelin-part2.md ## @@ -0,0 +1,107 @@ +--- +layout: post +title: "Flink on Zeppelin Notebooks for Interactive

[jira] [Assigned] (FLINK-18087) Uploading user artifact for Yarn job cluster could not work

[ https://issues.apache.org/jira/browse/FLINK-18087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-18087: -- Assignee: Yang Wang > Uploading user artifact for Yarn job cluster could not work >

[GitHub] [flink] zentol commented on pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

zentol commented on pull request #12447: URL: https://github.com/apache/flink/pull/12447#issuecomment-638130993 Time-wise this seems fine; virtually no change for the javadocs, and scaladoc only takes 20 seconds. It would be nice if we could write the scaladoc warnings into a file

[GitHub] [flink] AHeise commented on pull request #12441: [FLINK-17918][table-blink] Fix AppendOnlyTopNFunction shouldn't mutate list value of MapState

AHeise commented on pull request #12441: URL: https://github.com/apache/flink/pull/12441#issuecomment-638137845 Okay I investigated `org.apache.flink.table.planner.runtime.stream.sql.OverWindowITCase#testRowTimeUnBoundedPartitionedRowsOver2`. The issue in general is that the

[GitHub] [flink] flinkbot edited a comment on pull request #12459: [FLINK-17959][python] Fix the 'call already cancelled' exception when executing Python UDF

flinkbot edited a comment on pull request #12459: URL: https://github.com/apache/flink/pull/12459#issuecomment-638086087 ## CI report: * 819a3d585cce9c827212ea3cd33eb05ad84ce006 Azure:

[jira] [Updated] (FLINK-17974) Test new Flink Docker image

[ https://issues.apache.org/jira/browse/FLINK-17974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17974: -- Parent: FLINK-18088 Issue Type: Sub-task (was: Task) > Test new Flink Docker image >

[jira] [Updated] (FLINK-17978) Test Hadoop dependency change

[ https://issues.apache.org/jira/browse/FLINK-17978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17978: -- Parent: FLINK-18088 Issue Type: Sub-task (was: Task) > Test Hadoop dependency change

[jira] [Updated] (FLINK-17976) Test native K8s integration

[ https://issues.apache.org/jira/browse/FLINK-17976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17976: -- Parent: FLINK-18088 Issue Type: Sub-task (was: Task) > Test native K8s integration >

[jira] [Updated] (FLINK-17977) Check log sanity

[ https://issues.apache.org/jira/browse/FLINK-17977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17977: -- Parent: FLINK-18088 Issue Type: Sub-task (was: Task) > Check log sanity >

[jira] [Updated] (FLINK-17975) Test ZooKeeper 3.5 support

[ https://issues.apache.org/jira/browse/FLINK-17975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17975: -- Parent: FLINK-18088 Issue Type: Sub-task (was: Task) > Test ZooKeeper 3.5 support >

[jira] [Comment Edited] (FLINK-18068) Job scheduling stops but not exits after throwing non-fatal exception

[ https://issues.apache.org/jira/browse/FLINK-18068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124685#comment-17124685 ] Till Rohrmann edited comment on FLINK-18068 at 6/3/20, 7:25 AM: I think

[GitHub] [flink] wuchong commented on a change in pull request #12427: [FLINK-16681][jdbc] Fix the bug that jdbc lost connection after a lon…

wuchong commented on a change in pull request #12427: URL: https://github.com/apache/flink/pull/12427#discussion_r434371368 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/executor/InsertOrUpdateJdbcExecutor.java ##

[GitHub] [flink] AHeise commented on pull request #12441: [FLINK-17918][table-blink] Fix AppendOnlyTopNFunction shouldn't mutate list value of MapState

AHeise commented on pull request #12441: URL: https://github.com/apache/flink/pull/12441#issuecomment-638038993 The actual changes LGTM. However, Azure showed an error that was probably found by the different test setup. I'll investigate what's going on (I have a good test setup for

[GitHub] [flink] danny0405 commented on a change in pull request #12355: [FLINK-17893] [sql-client] SQL CLI should print the root cause if the statement is invalid

danny0405 commented on a change in pull request #12355: URL: https://github.com/apache/flink/pull/12355#discussion_r434415772 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java ## @@ -253,8 +247,10 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

flinkbot edited a comment on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-635090403 ## CI report: * 08539af1e82e9ef40d9814fc4c787c9f66d3f33e Azure:

[GitHub] [flink] danny0405 commented on a change in pull request #12355: [FLINK-17893] [sql-client] SQL CLI should print the root cause if the statement is invalid

danny0405 commented on a change in pull request #12355: URL: https://github.com/apache/flink/pull/12355#discussion_r434415304 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java ## @@ -253,7 +253,13 @@ public boolean

[GitHub] [flink] zjuwangg commented on a change in pull request #12028: [FLINK-17553][table]fix plan error when constant exists in group window key

zjuwangg commented on a change in pull request #12028: URL: https://github.com/apache/flink/pull/12028#discussion_r434415210 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/WindowAggregateITCase.scala ## @@

[GitHub] [flink-web] klion26 commented on pull request #342: [FLINK-17926] Fix the build problem of docker image

klion26 commented on pull request #342: URL: https://github.com/apache/flink-web/pull/342#issuecomment-638081635 delete `.rubydeps` works for me, thanks for the fix. I'm fine to remove the `./docker` directory and using the command as the only official way to build the Flink

[GitHub] [flink] klion26 commented on a change in pull request #12143: [FLINK-17632][yarn] Support to specify a remote path for job jar

klion26 commented on a change in pull request #12143: URL: https://github.com/apache/flink/pull/12143#discussion_r434449857 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -733,67 +737,49 @@ private ApplicationReport

[GitHub] [flink] krasinski opened a new pull request #12462: [FLINK-18045] Fix Kerberos credentials checking

krasinski opened a new pull request #12462: URL: https://github.com/apache/flink/pull/12462 ## What is the purpose of the change This pull request brings back checking if the enabled security method is Kerberos, that's an old bug reintroduced during some refactoring. Code

[jira] [Created] (FLINK-18086) Migrate SQLClientKafkaITCase to use DDL and new options to create tables

Jark Wu created FLINK-18086: --- Summary: Migrate SQLClientKafkaITCase to use DDL and new options to create tables Key: FLINK-18086 URL: https://issues.apache.org/jira/browse/FLINK-18086 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #12462: [FLINK-18045] Fix Kerberos credentials checking

flinkbot edited a comment on pull request #12462: URL: https://github.com/apache/flink/pull/12462#issuecomment-638102486 ## CI report: * e5fa4096bd14b96de1cedffa35b74ac31a585f6e Azure:

[GitHub] [flink-web] MarkSfik commented on a change in pull request #344: [blog] flink on zeppelin - part2

MarkSfik commented on a change in pull request #344: URL: https://github.com/apache/flink-web/pull/344#discussion_r434473101 ## File path: _posts/2020-05-25-flink-on-zeppelin-part2.md ## @@ -0,0 +1,107 @@ +--- +layout: post +title: "Flink on Zeppelin Notebooks for Interactive

[GitHub] [flink] flinkbot edited a comment on pull request #12454: [FLINK-17091][Arvo] Adapt Avro record conversion to new timestamp bridged classes

flinkbot edited a comment on pull request #12454: URL: https://github.com/apache/flink/pull/12454#issuecomment-637997814 ## CI report: * 498d42db35e412ad834d8b0c70d6404d0de4c339 Azure:

[GitHub] [flink-web] MarkSfik commented on a change in pull request #344: [blog] flink on zeppelin - part2

MarkSfik commented on a change in pull request #344: URL: https://github.com/apache/flink-web/pull/344#discussion_r434473674 ## File path: _posts/2020-05-25-flink-on-zeppelin-part2.md ## @@ -0,0 +1,107 @@ +--- +layout: post +title: "Flink on Zeppelin Notebooks for Interactive

[GitHub] [flink] flinkbot edited a comment on pull request #12460: [FLINK-18063][checkpointing] Fix the race condition for aborting current checkpoint in CheckpointBarrierUnaligner

flinkbot edited a comment on pull request #12460: URL: https://github.com/apache/flink/pull/12460#issuecomment-638102290 ## CI report: * c3f3aca669da2619d58190e684479c3fadd7026f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12461: [FLINK-17994][checkpointing] Fix the race condition between CheckpointBarrierUnaligner#processBarrier and #notifyBarrierReceived

flinkbot edited a comment on pull request #12461: URL: https://github.com/apache/flink/pull/12461#issuecomment-638102391 ## CI report: * 471535fc849c7dbf5bb9b532b5848a43ccdedafb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12456: [FLINK-17113][sql-cli] Refactor view support in SQL Client

flinkbot edited a comment on pull request #12456: URL: https://github.com/apache/flink/pull/12456#issuecomment-638032908 ## CI report: * b5b8172d4ccddf197a084d38e6dcef13ee27da8e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12455: [FLINK-17935] Move setting yarn.log-config-file to YarnClusterClientFactory

flinkbot edited a comment on pull request #12455: URL: https://github.com/apache/flink/pull/12455#issuecomment-638007072 ## CI report: * bc3ca72ad94196d72570aa7a58e9aa5c411e2733 Azure:

[GitHub] [flink] zentol commented on a change in pull request #12447: [FLINK-18069][CI] Test if Java/Scaladocs builds are passing in the compile stage

zentol commented on a change in pull request #12447: URL: https://github.com/apache/flink/pull/12447#discussion_r434491456 ## File path: tools/ci/compile.sh ## @@ -43,39 +43,39 @@ echo "== EXIT_CODE=0

[jira] [Updated] (FLINK-18087) Uploading user artifact for Yarn job cluster could not work

[ https://issues.apache.org/jira/browse/FLINK-18087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-18087: -- Description: In FLINK-17632, we add the support remote user jar. However, uploading user artifact

[GitHub] [flink] twalthr opened a new pull request #12464: [FLINK-13784][table] Implement type inference for basic math functions

twalthr opened a new pull request #12464: URL: https://github.com/apache/flink/pull/12464 ## What is the purpose of the change This adds the new type inference to PLUS, MINUS, TIMES, DIVIDE, UNARY_MINUS, MOD, ROUND, FLOOR, CEIL. It fixes issues at different locations. We

[GitHub] [flink] dawidwys closed pull request #12434: [FLINK-18052] Increase timeout for ES Search API in IT Cases

dawidwys closed pull request #12434: URL: https://github.com/apache/flink/pull/12434 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

[jira] [Updated] (FLINK-18050) Fix the bug of recycling buffer twice once exception in ChannelStateWriteRequestDispatcher#dispatch

[ https://issues.apache.org/jira/browse/FLINK-18050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18050: --- Labels: pull-request-available (was: ) > Fix the bug of recycling buffer twice once

[GitHub] [flink] flinkbot edited a comment on pull request #11397: [FLINK-16217] [sql-client] catch SqlExecutionException for all callXX methods

flinkbot edited a comment on pull request #11397: URL: https://github.com/apache/flink/pull/11397#issuecomment-598575354 ## CI report: * cfb1c83e34488d65854df603907e72b7de784564 Azure:

[GitHub] [flink] rkhachatryan opened a new pull request #12457: [FLINK-18050][task][checkpointing] Fix double buffer recycling

rkhachatryan opened a new pull request #12457: URL: https://github.com/apache/flink/pull/12457 ## What is the purpose of the change Fix double buffer recycling in `ChannelStateWriteRequest.execute` and then in `cancel`. ## Verifying this change Added unit test

[GitHub] [flink] azagrebin commented on a change in pull request #12446: [FLINK-16225] Implement user class loading exception handler

azagrebin commented on a change in pull request #12446: URL: https://github.com/apache/flink/pull/12446#discussion_r434377343 ## File path: azure-pipelines.yml ## @@ -61,7 +61,107 @@ variables: jobs: - template: tools/azure-pipelines/jobs-template.yml parameters: #

[jira] [Comment Edited] (FLINK-18033) Improve e2e test execution time

[ https://issues.apache.org/jira/browse/FLINK-18033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124737#comment-17124737 ] Robert Metzger edited comment on FLINK-18033 at 6/3/20, 8:14 AM: - Thanks

[jira] [Commented] (FLINK-18033) Improve e2e test execution time

[ https://issues.apache.org/jira/browse/FLINK-18033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124737#comment-17124737 ] Robert Metzger commented on FLINK-18033: Thanks a lot for opening this ticket. I agree that the

[jira] [Updated] (FLINK-16627) Support only generate non-null values when serializing into JSON

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16627: --- Issue Type: New Feature (was: Improvement) > Support only generate non-null values when

[jira] [Updated] (FLINK-7151) Support function DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-7151: -- Fix Version/s: (was: 1.11.0) > Support function DDL > > >

[jira] [Updated] (FLINK-17774) supports all kinds of changes for select result

[ https://issues.apache.org/jira/browse/FLINK-17774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-17774: --- Fix Version/s: (was: 1.11.0) 1.12.0 > supports all kinds of changes for

[jira] [Updated] (FLINK-15585) Improve function identifier string in plan digest

[ https://issues.apache.org/jira/browse/FLINK-15585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15585: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Improve function identifier string in

[jira] [Updated] (FLINK-16175) Add config option to switch case sensitive for column names in SQL

[ https://issues.apache.org/jira/browse/FLINK-16175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16175: --- Issue Type: New Feature (was: Improvement) > Add config option to switch case sensitive for column

[jira] [Updated] (FLINK-16627) Support only generate non-null values when serializing into JSON

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16627: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Support only generate non-null values

[jira] [Updated] (FLINK-18079) KafkaShuffle Manual Tests

[ https://issues.apache.org/jira/browse/FLINK-18079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-18079: - Labels: release-testing (was: ) > KafkaShuffle Manual Tests > - > >

[GitHub] [flink] flinkbot commented on pull request #12459: [FLINK-17959][python] Fix the 'call already cancelled' exception when executing Python UDF

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

[GitHub] [flink] flinkbot edited a comment on pull request #12435: [FLINK-18059] [sql-client] Fix create/drop catalog statement can not be executed in sql client

flinkbot edited a comment on pull request #12435: URL: https://github.com/apache/flink/pull/12435#issuecomment-637372360 ## CI report: * 93c39c72dea164002f43ad015b55aa200b3c8d7d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12436: [FLINK-17847][table sql / planner] ArrayIndexOutOfBoundsException happens in StreamExecCalc operator

flinkbot edited a comment on pull request #12436: URL: https://github.com/apache/flink/pull/12436#issuecomment-637399261 ## CI report: * e98155d0d16e4c8aff16f018a349587cdadadede Azure:

[jira] [Closed] (FLINK-17830) Add documentation for the new HBase connector

[ https://issues.apache.org/jira/browse/FLINK-17830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17830. --- Resolution: Fixed - master (1.12.0): 42c0837fab961fe2c8ed9ab2da7b78cbda66b811 - 1.11.0:

[jira] [Comment Edited] (FLINK-15467) Should wait for the end of the source thread during the Task cancellation

[ https://issues.apache.org/jira/browse/FLINK-15467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124822#comment-17124822 ] Piotr Nowojski edited comment on FLINK-15467 at 6/3/20, 10:15 AM: --

[jira] [Closed] (FLINK-17995) Redesign Table & SQL Connectors pages

[ https://issues.apache.org/jira/browse/FLINK-17995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17995. --- Resolution: Fixed - master (1.12.0): ae8e0f5b370190df2058a8d5cd85e9aa47da1eeb - 1.11.0:

[GitHub] [flink-web] MarkSfik commented on a change in pull request #344: [blog] flink on zeppelin - part2

MarkSfik commented on a change in pull request #344: URL: https://github.com/apache/flink-web/pull/344#discussion_r434476802 ## File path: _posts/2020-05-25-flink-on-zeppelin-part2.md ## @@ -0,0 +1,107 @@ +--- +layout: post +title: "Flink on Zeppelin Notebooks for Interactive

[GitHub] [flink-web] MarkSfik commented on a change in pull request #344: [blog] flink on zeppelin - part2

MarkSfik commented on a change in pull request #344: URL: https://github.com/apache/flink-web/pull/344#discussion_r434476268 ## File path: _posts/2020-05-25-flink-on-zeppelin-part2.md ## @@ -0,0 +1,107 @@ +--- +layout: post +title: "Flink on Zeppelin Notebooks for Interactive

[GitHub] [flink-web] MarkSfik commented on a change in pull request #344: [blog] flink on zeppelin - part2

MarkSfik commented on a change in pull request #344: URL: https://github.com/apache/flink-web/pull/344#discussion_r434476009 ## File path: _posts/2020-05-25-flink-on-zeppelin-part2.md ## @@ -0,0 +1,107 @@ +--- +layout: post +title: "Flink on Zeppelin Notebooks for Interactive

[jira] [Assigned] (FLINK-18079) KafkaShuffle Manual Tests

[ https://issues.apache.org/jira/browse/FLINK-18079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18079: Assignee: Yuan Mei > KafkaShuffle Manual Tests > - > >

[jira] [Updated] (FLINK-18079) KafkaShuffle Manual Tests

[ https://issues.apache.org/jira/browse/FLINK-18079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18079: - Parent: FLINK-18088 Issue Type: Sub-task (was: Improvement) > KafkaShuffle Manual Tests >

[jira] [Updated] (FLINK-17813) Manually test unaligned checkpoints on a cluster

[ https://issues.apache.org/jira/browse/FLINK-17813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-17813: - Labels: release-testing (was: ) > Manually test unaligned checkpoints on a cluster >

[jira] [Updated] (FLINK-18089) Add the zero-copy test into the azure E2E pipeline

[ https://issues.apache.org/jira/browse/FLINK-18089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18089: - Parent: FLINK-18088 Issue Type: Sub-task (was: Test) > Add the zero-copy test into the azure

[jira] [Commented] (FLINK-16998) Add a changeflag to Row type

[ https://issues.apache.org/jira/browse/FLINK-16998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124885#comment-17124885 ] Timo Walther commented on FLINK-16998: -- Updating the `Row.toString` method will be postponed to

[jira] [Updated] (FLINK-18088) Umbrella for testing features in release-1.11.0

[ https://issues.apache.org/jira/browse/FLINK-18088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18088: - Labels: release-testing (was: ) > Umbrella for testing features in release-1.11.0 >

[jira] [Assigned] (FLINK-18089) Add the zero-copy test into the azure E2E pipeline

[ https://issues.apache.org/jira/browse/FLINK-18089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-18089: Assignee: Yun Gao > Add the zero-copy test into the azure E2E pipeline >

[jira] [Updated] (FLINK-18089) Add the zero-copy test into the azure E2E pipeline

[ https://issues.apache.org/jira/browse/FLINK-18089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18089: - Labels: release-testing (was: ) > Add the zero-copy test into the azure E2E pipeline >

[jira] [Updated] (FLINK-18087) Uploading user artifact for Yarn job cluster could not work

[ https://issues.apache.org/jira/browse/FLINK-18087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18087: --- Labels: pull-request-available (was: ) > Uploading user artifact for Yarn job cluster

[jira] [Updated] (FLINK-18089) Add the zero-copy test into the azure E2E pipeline

[ https://issues.apache.org/jira/browse/FLINK-18089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18089: - Priority: Blocker (was: Major) > Add the zero-copy test into the azure E2E pipeline >

[jira] [Updated] (FLINK-18089) Add the network zero-copy test into the azure E2E pipeline

[ https://issues.apache.org/jira/browse/FLINK-18089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-18089: - Summary: Add the network zero-copy test into the azure E2E pipeline (was: Add the zero-copy test into

[GitHub] [flink] dawidwys commented on a change in pull request #12411: [FLINK-18005][table] Implement type inference for CAST

dawidwys commented on a change in pull request #12411: URL: https://github.com/apache/flink/pull/12411#discussion_r434513273 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java ## @@ -919,7 +920,8 @@

[GitHub] [flink] wuchong commented on a change in pull request #12445: [FLINK-18006] Always overwrite RestClientFactory in ElasticsearchXDynamicSink

wuchong commented on a change in pull request #12445: URL: https://github.com/apache/flink/pull/12445#discussion_r434364854 ## File path:

[jira] [Comment Edited] (FLINK-18068) Job scheduling stops but not exits after throwing non-fatal exception

[ https://issues.apache.org/jira/browse/FLINK-18068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124685#comment-17124685 ] Till Rohrmann edited comment on FLINK-18068 at 6/3/20, 7:27 AM: I think

[GitHub] [flink] flinkbot edited a comment on pull request #12455: [FLINK-17935] Move setting yarn.log-config-file to YarnClusterClientFactory

flinkbot edited a comment on pull request #12455: URL: https://github.com/apache/flink/pull/12455#issuecomment-638007072 ## CI report: * bc3ca72ad94196d72570aa7a58e9aa5c411e2733 Azure:

[GitHub] [flink] zjffdu commented on a change in pull request #12346: [FLINK-17944][sql-client] Wrong output in sql client's table mode

zjffdu commented on a change in pull request #12346: URL: https://github.com/apache/flink/pull/12346#discussion_r434371197 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/result/MaterializedCollectStreamResult.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #12199: [FLINK-17774] [table] supports all kinds of changes for select result

flinkbot edited a comment on pull request #12199: URL: https://github.com/apache/flink/pull/12199#issuecomment-629793563 ## CI report: * 5b62118449cdf8d0de8d5b98781fdff9c2d0c571 Azure:

[jira] [Updated] (FLINK-15849) Update SQL-CLIENT document from type to data-type

[ https://issues.apache.org/jira/browse/FLINK-15849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-15849: --- Priority: Blocker (was: Major) > Update SQL-CLIENT document from type to data-type >

[jira] [Updated] (FLINK-16375) Remove references to registerTableSource/Sink methods from documentation

[ https://issues.apache.org/jira/browse/FLINK-16375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-16375: --- Priority: Blocker (was: Major) > Remove references to registerTableSource/Sink methods from

[jira] [Commented] (FLINK-18070) Time attribute been materialized after sub graph optimize

[ https://issues.apache.org/jira/browse/FLINK-18070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124735#comment-17124735 ] Jark Wu commented on FLINK-18070: - Yes, I think this is a bug in CommonSubGraphBasedOptimizer. > Time

[jira] [Closed] (FLINK-17908) Vague document about Kafka config in SQL-CLI

[ https://issues.apache.org/jira/browse/FLINK-17908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17908. -- Resolution: Duplicate will be taken care by FLINK-17831 > Vague document about Kafka config in

[jira] [Comment Edited] (FLINK-18074) Confirm checkpoint completed on task side would not fail the task if exception thrown out

[ https://issues.apache.org/jira/browse/FLINK-18074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124759#comment-17124759 ] Piotr Nowojski edited comment on FLINK-18074 at 6/3/20, 8:37 AM: - Yes, I

[jira] [Updated] (FLINK-17101) [Umbrella] Supports dynamic table options for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-17101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-17101: --- Summary: [Umbrella] Supports dynamic table options for Flink SQL (was: Supports dynamic table

[jira] [Assigned] (FLINK-18074) Confirm checkpoint completed on task side would not fail the task if exception thrown out

[ https://issues.apache.org/jira/browse/FLINK-18074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-18074: -- Assignee: Yun Tang > Confirm checkpoint completed on task side would not fail the

  1   2   3   4   5   6   7   8   >