[GitHub] [flink] gyfora commented on pull request #12250: [FLINK-17619] Backport to 1.11

gyfora commented on pull request #12250: URL: https://github.com/apache/flink/pull/12250#issuecomment-631279205 merged This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[jira] [Created] (FLINK-17826) Add missing custom query support on new jdbc connector

Jark Wu created FLINK-17826: --- Summary: Add missing custom query support on new jdbc connector Key: FLINK-17826 URL: https://issues.apache.org/jira/browse/FLINK-17826 Project: Flink Issue Type: Sub-

[GitHub] [flink] gyfora closed pull request #12250: [FLINK-17619] Backport to 1.11

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

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111837#comment-17111837 ] Jark Wu commented on FLINK-17826: - Would you like to take this? [~f.pompermaier] > Add

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111840#comment-17111840 ] Jark Wu commented on FLINK-17826: - Hi [~zjwang], I would like to treat this one as a bug

[GitHub] [flink] TsReaper commented on pull request #12262: [FLINK-17817][hotfix] Fix serializer thread safe problem in CollectSinkFunction

TsReaper commented on pull request #12262: URL: https://github.com/apache/flink/pull/12262#issuecomment-631280841 Closing because #12199 also solves this problem. This is an automated message from the Apache Git Service. To r

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * 265fa7767926382824b2894b2662d3a93a76b176 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-17541) Support inline structured types

[ https://issues.apache.org/jira/browse/FLINK-17541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-17541. Fix Version/s: 1.11.0 Resolution: Fixed Fixed in 1.12.0: 11b5330563b59e085ad4755c9f9a3da6f2

[GitHub] [flink] flinkbot edited a comment on pull request #12090: [FLINK-17622][connectors / jdbc] Remove useless switch for decimal in PostgresCatalog

flinkbot edited a comment on pull request #12090: URL: https://github.com/apache/flink/pull/12090#issuecomment-626999634 ## CI report: * c6f506b50b8728300915c3353e606a807ac1c0c5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-16986) Enhance the OperatorEvent handling guarantee during checkpointing.

[ https://issues.apache.org/jira/browse/FLINK-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-16986: - Priority: Blocker (was: Major) > Enhance the OperatorEvent handling guarantee during checkpoint

[jira] [Updated] (FLINK-16986) Enhance the OperatorEvent handling guarantee during checkpointing.

[ https://issues.apache.org/jira/browse/FLINK-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-16986: - Fix Version/s: 1.11.0 > Enhance the OperatorEvent handling guarantee during checkpointing. > ---

[jira] [Assigned] (FLINK-17822) Nightly Flink CLI end-to-end test failed with "JavaGcCleanerWrapper$PendingCleanersRunner cannot access class jdk.internal.misc.SharedSecrets" in Java 11

[ https://issues.apache.org/jira/browse/FLINK-17822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-17822: --- Assignee: Andrey Zagrebin > Nightly Flink CLI end-to-end test failed with > "JavaG

[jira] [Comment Edited] (FLINK-17817) CollectResultFetcher fails with EOFException in AggregateReduceGroupingITCase

[ https://issues.apache.org/jira/browse/FLINK-17817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111829#comment-17111829 ] Caizhi Weng edited comment on FLINK-17817 at 5/20/20, 7:17 AM: ---

[GitHub] [flink] zhuzhurk commented on a change in pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

zhuzhurk commented on a change in pull request #12181: URL: https://github.com/apache/flink/pull/12181#discussion_r427792440 ## File path: flink-core/src/test/java/org/apache/flink/core/fs/SafetyNetCloseableRegistryTest.java ## @@ -198,4 +198,29 @@ public void testReaperThread

[jira] [Assigned] (FLINK-16986) Enhance the OperatorEvent handling guarantee during checkpointing.

[ https://issues.apache.org/jira/browse/FLINK-16986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-16986: Assignee: Stephan Ewen (was: Jiangjie Qin) > Enhance the OperatorEvent handling guarante

[GitHub] [flink] zhuzhurk commented on a change in pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

zhuzhurk commented on a change in pull request #12181: URL: https://github.com/apache/flink/pull/12181#discussion_r427794339 ## File path: flink-core/src/test/java/org/apache/flink/core/fs/SafetyNetCloseableRegistryTest.java ## @@ -198,4 +198,29 @@ public void testReaperThread

[GitHub] [flink] flinkbot edited a comment on pull request #12090: [FLINK-17622][connectors / jdbc] Remove useless switch for decimal in PostgresCatalog

flinkbot edited a comment on pull request #12090: URL: https://github.com/apache/flink/pull/12090#issuecomment-626999634 ## CI report: * c6f506b50b8728300915c3353e606a807ac1c0c5 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12230: [FLINK-17504][docs] Update Chinese translation of Getting Started / O…

flinkbot edited a comment on pull request #12230: URL: https://github.com/apache/flink/pull/12230#issuecomment-630205457 ## CI report: * 2f0ca570ff878cd12f999570590a08fa75efcc6b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * 265fa7767926382824b2894b2662d3a93a76b176 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12258: [FLINK-17820][task][checkpointing] Don't flush channel state to disk explicitly

flinkbot edited a comment on pull request #12258: URL: https://github.com/apache/flink/pull/12258#issuecomment-631108764 ## CI report: * cf629e225bc323888017be5d5a86c7c89a2b76bd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12263: [FLINK-16998][core] Support backwards compatibility for upgraded RowSerializer

flinkbot edited a comment on pull request #12263: URL: https://github.com/apache/flink/pull/12263#issuecomment-631274882 ## CI report: * 5e0f9df0a404a5d88b8762238ec37b903b9f0e4b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics

[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-10241: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Reduce performance/stability im

[jira] [Commented] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111864#comment-17111864 ] Yordan Pavlov commented on FLINK-17800: --- [~yunta] Yes the attachment reproduces t

[GitHub] [flink] tzulitai commented on a change in pull request #12263: [FLINK-16998][core] Support backwards compatibility for upgraded RowSerializer

tzulitai commented on a change in pull request #12263: URL: https://github.com/apache/flink/pull/12263#discussion_r427782378 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java ## @@ -367,36 +367,42 @@ public int getVersion() {

[jira] [Commented] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111865#comment-17111865 ] Zakelly Lan commented on FLINK-15507: - I would like to take this ticket. > Activate

[jira] [Assigned] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-15507: - Assignee: Zakelly Lan > Activate local recovery for RocksDB backends by default > -

[jira] [Assigned] (FLINK-16165) NestedLoopJoin fallback to HashJoin when build records number is very large

[ https://issues.apache.org/jira/browse/FLINK-16165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-16165: -- Assignee: Jingsong Lee > NestedLoopJoin fallback to HashJoin when build records numbe

[jira] [Commented] (FLINK-15507) Activate local recovery for RocksDB backends by default

[ https://issues.apache.org/jira/browse/FLINK-15507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111869#comment-17111869 ] Yu Li commented on FLINK-15507: --- Thanks for volunteering [~Zakelly], just assigned to you.

[jira] [Updated] (FLINK-16975) Add docs for FileSystem connector

[ https://issues.apache.org/jira/browse/FLINK-16975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-16975: - Fix Version/s: 1.11.0 > Add docs for FileSystem connector > - >

[jira] [Updated] (FLINK-16245) Use a delegating classloader as the user code classloader to prevent class leaks.

[ https://issues.apache.org/jira/browse/FLINK-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16245: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Use a delegating classloader as

[jira] [Updated] (FLINK-16931) Large _metadata file lead to JobManager not responding when restart

[ https://issues.apache.org/jira/browse/FLINK-16931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16931: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Large _metadata file lead to Jo

[jira] [Updated] (FLINK-17096) Minibatch Group Agg support state ttl

[ https://issues.apache.org/jira/browse/FLINK-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17096: --- Affects Version/s: 1.11.0 > Minibatch Group Agg support state ttl >

[jira] [Updated] (FLINK-17096) Minibatch Group Agg support state ttl

[ https://issues.apache.org/jira/browse/FLINK-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17096: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Minibatch Group Agg support sta

[jira] [Updated] (FLINK-17827) scala-shell.sh should fail early if no mode is specified, or have default logging settings

[ https://issues.apache.org/jira/browse/FLINK-17827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17827: - Priority: Critical (was: Major) > scala-shell.sh should fail early if no mode is specif

[jira] [Created] (FLINK-17827) scala-shell.sh should fail early if no mode is specified, or have default logging settings

Chesnay Schepler created FLINK-17827: Summary: scala-shell.sh should fail early if no mode is specified, or have default logging settings Key: FLINK-17827 URL: https://issues.apache.org/jira/browse/FLINK-17827

[jira] [Assigned] (FLINK-17351) CheckpointCoordinator and CheckpointFailureManager ignores checkpoint timeouts

[ https://issues.apache.org/jira/browse/FLINK-17351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-17351: -- Assignee: Yuan Mei > CheckpointCoordinator and CheckpointFailureManager ignores check

[GitHub] [flink] kl0u closed pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

kl0u closed pull request #12233: URL: https://github.com/apache/flink/pull/12233 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] kl0u commented on pull request #12233: [FLINK-17745] Remove nested jar handling from PackagedProgram

kl0u commented on pull request #12233: URL: https://github.com/apache/flink/pull/12233#issuecomment-631300927 This PR is closed unmerged. For details see the discussion on the JIRA issue. This is an automated message from the

[jira] [Assigned] (FLINK-17721) AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry fails with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-17721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-17721: -- Assignee: Xintong Song > AbstractHadoopFileSystemITTest .cleanupDirectoryWithRetry fa

[GitHub] [flink] twalthr commented on a change in pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

twalthr commented on a change in pull request #12232: URL: https://github.com/apache/flink/pull/12232#discussion_r427791839 ## File path: flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/package.scala ## @@ -39,7 +37,7 @@ import org.apache.flink.tab

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111881#comment-17111881 ] Kostas Kloudas commented on FLINK-17745: [~Echo Lee] I also think that we can cl

[jira] [Assigned] (FLINK-17018) DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing

[ https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-17018: --- Assignee: Zhu Zhu > DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing >

[GitHub] [flink] dawidwys commented on a change in pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

dawidwys commented on a change in pull request #12232: URL: https://github.com/apache/flink/pull/12232#discussion_r427812311 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/package.scala ## @@ -21,8 +21,8 @@ package

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111889#comment-17111889 ] Flavio Pompermaier commented on FLINK-17826: I hope to find the time within

[jira] [Assigned] (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 ] Jark Wu reassigned FLINK-17774: --- Assignee: godfrey he > supports all kinds of changes for select result > --

[jira] [Commented] (FLINK-17470) Flink task executor process permanently hangs on `flink-daemon.sh stop`, deletes PID file

[ https://issues.apache.org/jira/browse/FLINK-17470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111891#comment-17111891 ] Stephan Ewen commented on FLINK-17470: -- What JVM version are you using? Maybe there

[jira] [Updated] (FLINK-17795) Add an example to show how to leverage GPU resources

[ https://issues.apache.org/jira/browse/FLINK-17795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-17795: --- Priority: Critical (was: Major) > Add an example to show how to leverage GPU resources > --

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111894#comment-17111894 ] Jark Wu commented on FLINK-17826: - Hi [~f.pompermaier], the options and validation shoul

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111895#comment-17111895 ] Flavio Pompermaier commented on FLINK-17826: Ok, it should not be too compli

[jira] [Assigned] (FLINK-17819) Yarn error unhelpful when forgetting HADOOP_CLASSPATH

[ https://issues.apache.org/jira/browse/FLINK-17819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-17819: -- Assignee: Kostas Kloudas > Yarn error unhelpful when forgetting HADOOP_CLASSPATH > --

[jira] [Assigned] (FLINK-17826) Add missing custom query support on new jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17826: --- Assignee: Flavio Pompermaier > Add missing custom query support on new jdbc connector > ---

[GitHub] [flink] flinkbot edited a comment on pull request #12261: [FLINK-17823][network] Resolve the race condition while releasing RemoteInputChannel

flinkbot edited a comment on pull request #12261: URL: https://github.com/apache/flink/pull/12261#issuecomment-631229356 ## CI report: * 26afeb03aa30f84994a8aa85ca2d223d44672067 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12258: [FLINK-17820][task][checkpointing] Don't flush channel state to disk explicitly

flinkbot edited a comment on pull request #12258: URL: https://github.com/apache/flink/pull/12258#issuecomment-631108764 ## CI report: * 8d01ba80d36c07517d7493cef13d6ab634c01e18 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] fpompermaier commented on a change in pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

fpompermaier commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427823029 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31 +12

[jira] [Commented] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111903#comment-17111903 ] Kostas Kloudas commented on FLINK-17745: [~Echo Lee] Is it ok if we open a discu

[jira] [Updated] (FLINK-17820) Memory threshold is ignored for channel state

[ https://issues.apache.org/jira/browse/FLINK-17820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17820: --- Priority: Critical (was: Major) > Memory threshold is ignored for channel state > -

[jira] [Commented] (FLINK-17174) Conversion to relational algebra failed to preserve datatypes when using Table API but succeed when using SQL query

[ https://issues.apache.org/jira/browse/FLINK-17174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111907#comment-17111907 ] Danny Chen commented on FLINK-17174: This is an duplicate issue of FLINK-16160, so i

[jira] [Closed] (FLINK-17174) Conversion to relational algebra failed to preserve datatypes when using Table API but succeed when using SQL query

[ https://issues.apache.org/jira/browse/FLINK-17174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-17174. -- Resolution: Duplicate > Conversion to relational algebra failed to preserve datatypes when using > Ta

[GitHub] [flink] fpompermaier commented on a change in pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

fpompermaier commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427825676 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31 +12

[GitHub] [flink] fpompermaier commented on a change in pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

fpompermaier commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427825676 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31 +12

[GitHub] [flink] fpompermaier commented on a change in pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

fpompermaier commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427826635 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31 +12

[jira] [Commented] (FLINK-17651) DecomposeGroupingSetsRule generates wrong plan when there exist distinct agg and simple agg with same filter

[ https://issues.apache.org/jira/browse/FLINK-17651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111913#comment-17111913 ] Danny Chen commented on FLINK-17651: cc [~godfreyhe], can you help to review this PR

[jira] [Commented] (FLINK-17756) Drop table/view shouldn't take effect on each other

[ https://issues.apache.org/jira/browse/FLINK-17756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111916#comment-17111916 ] Danny Chen commented on FLINK-17756: Hi, [~ykt836], i would like to take this issue

[jira] [Commented] (FLINK-17657) jdbc not support read BIGINT UNSIGNED field

[ https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111920#comment-17111920 ] Danny Chen commented on FLINK-17657: Hi [~zhanglun], would you plan to fix this in r

[GitHub] [flink] flinkbot edited a comment on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

flinkbot edited a comment on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-619214462 ## CI report: * 2e339ca93fcf4461ddb3502b49ab34083fc96cf6 UNKNOWN * 0e1a42d1f6f38f2e1e92db036b55a5f54a49402f Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

flinkbot edited a comment on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630355116 ## CI report: * 5925ef19171dea0dd42cd7f13875b7b05598f4b0 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #12256: [FLINK-17018][runtime] DefaultExecutionSlotAllocator allocates slots in bulks

flinkbot edited a comment on pull request #12256: URL: https://github.com/apache/flink/pull/12256#issuecomment-631025695 ## CI report: * edab8aef00bcac9a530501fa64165f344d7c74e7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #12096: [FLINK-16074][docs-zh] Translate the Overview page for State & Fault Tolerance into Chinese

flinkbot edited a comment on pull request #12096: URL: https://github.com/apache/flink/pull/12096#issuecomment-627237312 ## CI report: * b414987409b6b4e072ac41798e53ab30d326675a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #12263: [FLINK-16998][core] Support backwards compatibility for upgraded RowSerializer

flinkbot edited a comment on pull request #12263: URL: https://github.com/apache/flink/pull/12263#issuecomment-631274882 ## CI report: * 5e0f9df0a404a5d88b8762238ec37b903b9f0e4b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17073: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Slow checkpoint cleanup causing

[GitHub] [flink] wanglijie95 commented on a change in pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

wanglijie95 commented on a change in pull request #12181: URL: https://github.com/apache/flink/pull/12181#discussion_r427831205 ## File path: flink-core/src/test/java/org/apache/flink/core/fs/SafetyNetCloseableRegistryTest.java ## @@ -198,4 +198,29 @@ public void testReaperThr

[jira] [Commented] (FLINK-17625) Fix ArrayIndexOutOfBoundsException in AppendOnlyTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-17625?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111922#comment-17111922 ] Danny Chen commented on FLINK-17625: Hi, [~lsy], are you working on this ? > Fix Ar

[jira] [Assigned] (FLINK-17800) RocksDB optimizeForPointLookup results in missing time windows

[ https://issues.apache.org/jira/browse/FLINK-17800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-17800: - Fix Version/s: 1.11.0 Assignee: Yun Tang Priority: Critical (was: Major) > RocksDB o

[GitHub] [flink] dawidwys commented on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

dawidwys commented on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-631324483 Thank you all for joining the discussion! Thanks @twalthr for the review. I'll run the tests and after that I will merge that change. --

[GitHub] [flink] wuchong commented on a change in pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

wuchong commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427833904 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31 +124,33

[GitHub] [flink] wuchong commented on a change in pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

wuchong commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427834480 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31 +124,33

[GitHub] [flink] wuchong commented on a change in pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

wuchong commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427835703 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31 +124,33

[GitHub] [flink] wuchong commented on a change in pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

wuchong commented on a change in pull request #11906: URL: https://github.com/apache/flink/pull/11906#discussion_r427835703 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java ## @@ -126,31 +124,33

[jira] [Closed] (FLINK-17183) the 'create table [if not exists]' syntax is not supported

[ https://issues.apache.org/jira/browse/FLINK-17183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-17183. -- Resolution: Not A Problem Close because it is a feature on the road-map. > the 'create table [if not

[GitHub] [flink] wanglijie95 commented on a change in pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

wanglijie95 commented on a change in pull request #12181: URL: https://github.com/apache/flink/pull/12181#discussion_r427838651 ## File path: flink-core/src/test/java/org/apache/flink/core/fs/SafetyNetCloseableRegistryTest.java ## @@ -198,4 +198,29 @@ public void testReaperThr

[jira] [Updated] (FLINK-14982) YARN IT Test Case log config is mistakenly disabled

[ https://issues.apache.org/jira/browse/FLINK-14982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14982: -- Fix Version/s: (was: 1.11.0) > YARN IT Test Case log config is mistakenly disabled > -

[jira] [Comment Edited] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111903#comment-17111903 ] Kostas Kloudas edited comment on FLINK-17745 at 5/20/20, 8:44 AM:

[jira] [Comment Edited] (FLINK-17745) PackagedProgram' extractedTempLibraries and jarfiles may be duplicate

[ https://issues.apache.org/jira/browse/FLINK-17745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111903#comment-17111903 ] Kostas Kloudas edited comment on FLINK-17745 at 5/20/20, 8:44 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15289: --- Fix Version/s: (was: 1.11.0) > Run sql appear error of "Zero-length character strings have no se

[GitHub] [flink] cshuo commented on pull request #12208: [FLINK-17651][table-planner-blink] DecomposeGroupingSetsRule generat…

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

[jira] [Updated] (FLINK-15397) Streaming and batch has different value in the case of count function

[ https://issues.apache.org/jira/browse/FLINK-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-15397: --- Fix Version/s: (was: 1.11.0) > Streaming and batch has different value in the case of count func

[jira] [Updated] (FLINK-17819) Yarn error unhelpful when forgetting HADOOP_CLASSPATH

[ https://issues.apache.org/jira/browse/FLINK-17819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17819: -- Priority: Critical (was: Major) > Yarn error unhelpful when forgetting HADOOP_CLASSPATH > ---

[jira] [Updated] (FLINK-17819) Yarn error unhelpful when forgetting HADOOP_CLASSPATH

[ https://issues.apache.org/jira/browse/FLINK-17819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-17819: -- Fix Version/s: 1.11.0 > Yarn error unhelpful when forgetting HADOOP_CLASSPATH > --

[jira] [Commented] (FLINK-15503) FileUploadHandlerTest.testMixedMultipart and FileUploadHandlerTest. testUploadCleanupOnUnknownAttribute failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-15503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111939#comment-17111939 ] Till Rohrmann commented on FLINK-15503: --- [~rmetzger] could you re-run the tests wi

[jira] [Closed] (FLINK-15613) execute sql appear "java.lang.IndexOutOfBoundsException"

[ https://issues.apache.org/jira/browse/FLINK-15613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-15613. -- Resolution: Duplicate > execute sql appear "java.lang.IndexOutOfBoundsException" > ---

[jira] [Commented] (FLINK-17819) Yarn error unhelpful when forgetting HADOOP_CLASSPATH

[ https://issues.apache.org/jira/browse/FLINK-17819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111941#comment-17111941 ] Till Rohrmann commented on FLINK-17819: --- Thanks for looking into the issue [~kkl0u

[jira] [Closed] (FLINK-15399) Join with a LookupableTableSource：java.lang.RuntimeException: while converting XXXX Caused by: java.lang.AssertionError: Field ordinal 26 is invalid for type

[ https://issues.apache.org/jira/browse/FLINK-15399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-15399. -- Resolution: Fixed > Join with a LookupableTableSource：java.lang.RuntimeException: while > converting

[jira] [Closed] (FLINK-15066) Cannot run multiple `insert into csvTable values ()`

[ https://issues.apache.org/jira/browse/FLINK-15066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-15066. -- Resolution: Won't Fix > Cannot run multiple `insert into csvTable values ()` > ---

[GitHub] [flink] flinkbot edited a comment on pull request #12181: [FLINK-17645][runtime] Fix SafetyNetCloseableRegistry constructor bug.

flinkbot edited a comment on pull request #12181: URL: https://github.com/apache/flink/pull/12181#issuecomment-629344595 ## CI report: * bd9add8e480455265ca95b863601f6608918b334 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #11906: [FLINK-17356][jdbc][postgres] Support PK and Unique constraints

flinkbot edited a comment on pull request #11906: URL: https://github.com/apache/flink/pull/11906#issuecomment-619214462 ## CI report: * 2e339ca93fcf4461ddb3502b49ab34083fc96cf6 UNKNOWN * 0e1a42d1f6f38f2e1e92db036b55a5f54a49402f Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #12096: [FLINK-16074][docs-zh] Translate the Overview page for State & Fault Tolerance into Chinese

flinkbot edited a comment on pull request #12096: URL: https://github.com/apache/flink/pull/12096#issuecomment-627237312 ## CI report: * b414987409b6b4e072ac41798e53ab30d326675a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #12232: [FLINK-15947] Finish moving scala expression DSL to flink-table-api-scala

flinkbot edited a comment on pull request #12232: URL: https://github.com/apache/flink/pull/12232#issuecomment-630355116 ## CI report: * 5925ef19171dea0dd42cd7f13875b7b05598f4b0 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Closed] (FLINK-15333) Using FlinkCostFactory rather than RelOptCostImpl in blink planner

[ https://issues.apache.org/jira/browse/FLINK-15333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen closed FLINK-15333. -- Resolution: Not A Problem > Using FlinkCostFactory rather than RelOptCostImpl in blink planner >

[GitHub] [flink] zentol opened a new pull request #12264: [FLINK-17668][netty] Release partitions asynchronously

zentol opened a new pull request #12264: URL: https://github.com/apache/flink/pull/12264 With this PR the local release of partitions in the `NettyShuffleEnvironment` is executed asynchronously. This primarily includes the deletion of files. We have seen instances where this operation was

[jira] [Updated] (FLINK-14875) Blink planner should pass the right ExecutionConfig to the creation of serializer

[ https://issues.apache.org/jira/browse/FLINK-14875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Chen updated FLINK-14875: --- Fix Version/s: (was: 1.11.0) 1.12.0 > Blink planner should pass the right Exe

  1   2   3   4   5   6   >